1

from twisted.application import internet, service

     2

from twisted.internet import reactor, protocol

     3

from twisted.python import log

     4

import sys

     5

     6

import irc, api

     7

     8

class Nexus (object) :

    15

    24

        self.modules = dict()

    25

    26

    def registerModule (self, module, transport) :

    27

        self.modules[module.name] = (module, transport)

    28

    29

        self.irc.connection.moduleConnected(module, transport.transport.getPeer())

    30

    31

    def unregisterModule (self, module, reason) :

    32

        del self.modules[module.name]

    33

    34

        self.irc.connection.moduleDisconnected(module, reason)

    35

    36

    def handleEvent (self, event) :

    37

        self.irc.connection.sendEvent(event)

    38

    39

    def getModules (self) :

    40

        return (module for (module, transport) in self.modules.itervalues())

    41

    42

    def getModuleInfo (self, name) :

    43

        module, connection = self.modules[name]

    44

    45

        return module, connection.transport.getPeer()

    46

    47

def makeService (config) :

    49

    s = service.MultiService()

    50

    51

    # the IRC side

    52

    n.irc = irc.Factory(n, 

    53

        config['irc-nickname'], 

    54

        config['irc-username'],

    55

        config['irc-channel']

    56

    )

    57

    58

    log.msg("Connecting to IRC server on [%s:%d]", config['irc-server'], config['irc-port'])

    59

    irc_client = internet.TCPClient(config['irc-server'], config['irc-port'], n.irc)

    60

    61

    irc_client.setServiceParent(s)

    62

    63

    # the API side

    65

    66

    log.msg("Starting API server on [%s:%d]", config['api-port'], config['api-listen'])

    67

    api_server = internet.TCPServer(config['api-port'], n.api, interface=config['api-listen'])

    68

    69

    api_server.setServiceParent(s)

    70

    71

    # return the service collection

    72

    return s

    73