main.py

import json
import sys
import thread
from base64 import b64encode

from twisted.internet import reactor

from pyipv8.controller import Controller
from pyipv8.gui import open_gui
from pyipv8.ipv8.REST.rest_manager import RESTManager
from pyipv8.ipv8.keyvault.crypto import ECCrypto
from pyipv8.ipv8_service import IPv8


import subprocess

try:
    import tkinter as tk
except ImportError:
    import Tkinter as tk


import socket 
def get_open_port(): 
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    s.bind(("",0)) 
    s.listen(1) 
    port = s.getsockname()[1] 
    s.close() 
    return port


config = {
    'address': '0.0.0.0',
    'port': 8090,
    'keys': [{
        'alias': "discovery",
        'generation': u"medium",
        'file': u"keys/discovery.pem"
    }],
    'logger': {
        'level': "INFO"
    },
    'walker_interval': 0.5,
    'overlays': [
        {
            'class': 'DiscoveryCommunity',
            'key': "discovery",
            'walkers': [
                {
                    'strategy': "RandomWalk",
                    'peers': 20,
                    'init': {
                        'timeout': 3.0
                    }
                },
                {
                    'strategy': "RandomChurn",
                    'peers': -1,
                    'init': {
                        'sample_size': 8,
                        'ping_interval': 10.0,
                        'inactive_time': 27.5,
                        'drop_time': 57.5
                    }
                }
            ],
            'initialize': {},
            'on_start': [
                ('resolve_dns_bootstrap_addresses',)
            ]
        }
    ]
}

try:
    with open('property_to_key_mappings.json', 'r') as file:
        json_file = json.load(file)
        for property in json_file:
            # with open("keys/" + property[1] + ".pem", 'r') as key:
            #     key_content = key.read()
            config['keys'].append({
                'alias': property[1],
                'generation': u"medium",
                'file': u"keys/" + property[1] + ".pem"
            })
            config['overlays'].append(
                {
                    'class': 'BOBChainCommunity',
                    'key': property[1],
                    'walkers': [{
                        'strategy': "EdgeWalk",
                        'peers': 20,
                        'init': {
                            'edge_length': 4,
                            'neighborhood_size': 6,
                            'edge_timeout': 3.0
                        }
                    }],
                    'initialize': property[0],
                    'on_start': [('started',)]
                }
            )
except IOError:
    with open('property_to_key_mappings.json', 'w') as file:
        json.dump([], file)

# Start the IPv8 service
ipv8 = IPv8.__new__(IPv8)
controller = Controller(ipv8)
ipv8.__init__(config)
rest_manager = RESTManager(ipv8)


if len(sys.argv) > 1:
    rest_manager.start(int(sys.argv[1]))
else:
    rest_manager.start(14410)


#rest_manager.start(get_open_port())

root = tk.Tk()
root.geometry("900x900")


thread.start_new_thread(open_gui, (controller,root))
#subprocess.call(["python2", "main.py", "14411"])
thread.start_new_thread(open_gui, (controller,root))
root.mainloop()
# Start the Twisted reactor: this is the engine scheduling all of the
# asynchronous calls.
reactor.run()