Source code for paradrop.main

Core module.
Contains the entry point into Paradrop and establishes all other modules.
Does not implement any behavior itself.

import argparse
from twisted.internet import reactor
from twisted.internet.defer import inlineCallbacks

from paradrop.base.output import out
from paradrop.base import nexus, settings
from paradrop.lib.misc.procmon import ProcessMonitor
from paradrop.core.agent import provisioning
from paradrop.core.agent.reporting import sendNodeIdentity, sendStateReport
from paradrop.core.agent.wamp_session import WampSession
from paradrop.core.update.update_fetcher import UpdateFetcher
from paradrop.core.update.update_manager import UpdateManager
from paradrop.airshark.airshark import AirsharkManager
from paradrop.backend.http_server import HttpServer, setup_http_server
from paradrop.backend.ssdp_responder import SsdpResponder
from paradrop import confd

[docs]class Nexus(nexus.NexusBase): def __init__(self, update_fetcher, update_manager): self.update_fetcher = update_fetcher self.update_manager = update_manager # Want to change logging functionality? See optional args on the base class and pass them here super(Nexus, self).__init__(stealStdio=True, printToConsole=True)
[docs] @inlineCallbacks def onStart(self): super(Nexus, self).onStart() # onStart is called when the reactor starts, not when the connection is made. # Check for provisioning keys and attempt to connect if not self.provisioned() and not provisioning.can_provision(): out.warn("The node is not provisioned and is not configured to self-provision.") return while not self.provisioned(): yield provisioning.provision_self(self.update_manager) try: # Set up communication with pdserver. # 1. Create a report of the current system state and send that. # 2. Send the node public key. # 3. Poll for a list of updates that should be applied. # 4. Open WAMP session. yield sendStateReport() yield sendNodeIdentity() yield self.update_fetcher.start_polling() yield self.connect(WampSession) except Exception: out.warn('The router ID or password is invalid!') else:'WAMP session is ready!')
[docs] def onStop(self): if self.session is not None: self.session.leave() else:'No WAMP session found!') super(Nexus, self).onStop()
[docs]def main(): p = argparse.ArgumentParser(description='Paradrop daemon running on client') p.add_argument('--mode', '-m', help='Set the mode to one of [production, local, unittest]', action='store', type=str, default='production') p.add_argument('--portal', '-p', help='Set the folder of files for local portal', action='store', type=str) p.add_argument('--no-exec', help='Skip execution of configuration commands', action='store_false', dest='execute') args = p.parse_args() # print args settings.loadSettings(args.mode, []) update_manager = UpdateManager(reactor) update_fetcher = UpdateFetcher(update_manager) WampSession.set_update_fetcher(update_fetcher) ProcessMonitor.allowedActions = set() # Start the configuration service as a thread confd.main.run_thread(execute=args.execute) airshark_manager = AirsharkManager() # Globally assign the nexus object so anyone else can access it. nexus.core = Nexus(update_fetcher, update_manager) http_server = HttpServer(update_manager, update_fetcher, airshark_manager, args.portal) setup_http_server(http_server, '', settings.PORTAL_SERVER_PORT) reactor.listenMulticast(1900, SsdpResponder(), listenMultiple=True)
if __name__ == "__main__": main()