main.py

#!/usr/bin/python3  
# -*- coding: utf-8 -*- 

import asyncio
import sys
from P2PNode import *
import service


node =None;

async def dealCMD(line):
    line = line.split();
    global node
    if line[0]=="sendData":
        await node.sendData()
    elif line[0] == "showRoutTable":
        await node.printRoutTable()
    #TODO
    elif line[0] == "runCMDFromFile":
        pass
    elif line[0] == "createTX":
        pass
    elif line[0] == "CheckBalances":
        pass 
    else:
        print("pass cmd :",line[0]);
        pass 

async def monitorCommand():
    while True:
        loop = asyncio.get_event_loop()
        line = await loop.run_in_executor(None, sys.stdin.readline)
        line = line.strip()
        if not line:
           continue;
        print('Got line:', line)
        await dealCMD(line)
    
def setUpEvent(local_addr,peer_addr,mode):

    ser = service.Service(local_addr, peer_addr)
    

    
    ser.start()


    
    '''tasks = [
        asyncio.ensure_future(monitorCommand()),
    ]

    loop = asyncio.get_event_loop()
    loop.run_until_complete(asyncio.wait(tasks))'''
    
    
if __name__ == '__main__':
    local_addr=(sys.argv[1], int(sys.argv[2]))
    peer_addr=(sys.argv[3], int(sys.argv[4]))
    mode  = (sys.argv[5])
    print("local_addr:",local_addr)
    print("static_addr:",peer_addr)
    print("mode:",mode)
    setUpEvent(local_addr,peer_addr,mode);