import networkwhisper, sync, sys, threading, time

# TODO: Consider moving sync state outside of log
# XXX: Assume {a,b}sync.log exists

# TODO: UX feedback, when recv it should show

# XXX: Ugly constants, should be elsewhere
SETTINGS = {
    'a': {
        'host': "http://localhost:8500",
        'keypair': "0x57083392b29bdf24512c93cfdf45d38c87d9d882da3918c59f4406445ea976a4",
        'pubkey': "0x04d94a1a01872b598c7cdc5aca2358d35eb91cd8a91eaea8da277451bb71d45c0d1eb87a31ea04e32f537e90165c870b3e115a12438c754d507ac75bddd6ecacd5",
        'friend' : "0x04ff921ddf78b5ed4537402f59a150caf9d96a83f2a345a1ddf9df12e99e7778f314c9ca72e8285eb213af84f5a7b01aabb62c67e46657976ded6658e1b9e83c73" #b
        },
    'b': {
        'host': "http://localhost:8501",
        'keypair': "0x7b5c5af9736d9f1773f2020dd0fef0bc3c8aeaf147d2bf41961e766588e086e7",
        'pubkey' : "0x04ff921ddf78b5ed4537402f59a150caf9d96a83f2a345a1ddf9df12e99e7778f314c9ca72e8285eb213af84f5a7b01aabb62c67e46657976ded6658e1b9e83c73",
        'friend': "0x04d94a1a01872b598c7cdc5aca2358d35eb91cd8a91eaea8da277451bb71d45c0d1eb87a31ea04e32f537e90165c870b3e115a12438c754d507ac75bddd6ecacd5" #a
    }
}

# XXX: Hardcoded for logging, hacky for now
#NODE = 'xxx'

def foo(x):
    return lambda y: print("I just ", x, "the", y)

# XXX: Add debug log level
def log(node, message):
    with open(node + 'sync.log', 'a') as f:
        f.write(message + '\n')

#    print("****NODE", node)
#    print(message)

def logger(node):
    return lambda message: log(node, message)

def tick_process(node, whisper_node):
    while True:
        #print("tick")
        # XXX: careful maybe
        whisper_node.tick()
        # This should be done in the sync
        #node.tick()
        time.sleep(0.1)

def main():

    assert len(sys.argv) > 1, "Missing node argument. Example: 'a' or 'b'"
    # Assume exists
    node_name = sys.argv[1]
    settings = SETTINGS[node_name]
    keypair = settings['keypair']
    identity_pk = settings['pubkey']
    host = settings['host']
    friend_pk = settings['friend']
    logfn = logger(node_name)

    # Init node
    whisper_node = networkwhisper.WhisperNodeHelper(keypair, host)
    # XXX: interactive mode with offer might not work?
    node = sync.Node(logfn, identity_pk, whisper_node, 'onlineDesktop', 'batch')

    #where?
    #whisper_node.tick()

    # XXX: A bit weird? Or very weird
    # XXX Thought we got rid of this
    node.nodes = [node]
    # XXX: Doesn't make sense, a doesn't have b info
    # XXX
    node.addPeer(friend_pk, friend_pk)
    # Clients should decide policy
    node.share(friend_pk)

    # Start background thread
    thread = threading.Thread(target=tick_process, args=[node, whisper_node])
    thread.daemon = True
    thread.start()

    while True:
        text = input("")
        #print("You: " + text)
        rec = sync.new_message_record(text)
        node.append_message(rec)

        # XXX: Dunno best way to showcase this
        #node.print_sync_state()

main()

# Ok, can send message
# Now share with these other
# And allow b to run as a proc too

# so it is sending but not recving. Why is this?
# Is it resending? 2fce e.g. for b
# Is it actually trying to receive? static peers etc
# Does burstyMobile impact things? fs

# Looking at naive print I DONT see it resending,sync state is updated! what does this mean?

#hm maybe
#ok, it IS resyncing, just abit slow. TICK? ok 100ms now
# what does bursty mobile mean? lets do onlineDesktop