"""
TCP server that receives config requests from freeswitch.
"""
- def __init__(self, parent=None):
+ def __init__(self, parent):
super(FreeswitchConfigServer, self).__init__(parent)
self.host = None
self.port = None
self.is_running = False
+ self.generators = [
+ GenClass(self.parent().model) for GenClass in (
+ SofiaConfGenerator,)]
- self.httpRequestParser = HttpRequestParser()
+ self.httpRequestParser = HttpRequestParser(self)
def setSocketData(self, host, port):
"""
Set host and port for socket to listen on.
+
+ If the settings differ from previous values, server gets restarted.
"""
+ # Check if restart is needed before new settings are applied.
+ needs_restart = (host, port) != (self.host, self.port)
+
+ # Save new settings.
self.host = host
self.port = port
+ # Restart server if necessary.
+ if needs_restart:
+ self.restartServer()
+
def startServer(self):
"""
Start listening on our socket.
"""
A simple state machine for parsing HTTP requests.
"""
- HTTP_NONE, HTTP_REQUEST, HTTP_HEADERS, HTTP_EMPTY, HTTP_MESSAGE = range(5)
- HTTP_STATES = ['NONE', 'REQUEST', 'HEADERS', 'EMPTY', 'MESSAGE']
+ HTTP_NONE, HTTP_REQUEST, HTTP_HEADERS, HTTP_EMPTY, HTTP_MESSAGE, \
+ HTTP_DONE = range(6)
+ HTTP_STATES = ['NONE', 'REQUEST', 'HEADERS', 'EMPTY', 'MESSAGE', 'DONE']
- def __init__(self):
- super(HttpRequestParser, self).__init__()
+ def __init__(self, parent):
+ self.parent = parent
self.reset()
def reset(self):
"""
for state in self.HTTP_STATES:
if getattr(self, 'HTTP_%s' % state) == self.state:
- print self.state, line
getattr(self, 'handle%s' % state.title())(line)
break
else:
print k, '=>', v
print
+ for generator in self.parent.generators:
+ if generator.canHandle(self.data):
+ self.state += 1
+ print generator.generateConfig(self.headers)
+ else:
+ print 'No generator found'
+
class FreeswitchConfigGenerator(object):
def __init__(self, model):
self.model = model
- def check_params(self, params):
+ def canHandle(self, params):
for key, value in self.param_match.iteritems():
+ print key, value, params.get(key, None)
if params.get(key, None) != value:
return False
else:
return True
- def base_elements(self):
+ def baseElements(self):
root_elt = etree.Element('document')
section_elt = etree.SubElement(
root_elt, 'section', name=self.section_name)
return root_elt, section_elt
- base_elements = property(base_elements)
+ baseElements = property(baseElements)
- def generate_config(self, params):
+ def generateConfig(self, params):
return NotImplemented
- def add_params(parent_elt, params):
+ def addParams(parent_elt, params):
for name, value in params:
etree.SubElement(parent_elt, 'param', name=name, value=value)
section_name = 'configuration'
config_name = 'sofia.conf'
- def generate_config(self, params):
+ def generateConfig(self, params):
# Get base elements.
- root_elt, section_elt = self.base_elements
+ root_elt, section_elt = self.baseElements
# Create configuration, settings and profiles elements.
configuration_elt = etree.SubElement(
('sip-ip', profile.sip_ip),
('rtp-ip', profile.rtp_ip),
('sip-port', profile.sip_port),
- ('nonce-ttl'. '60'),
+ ('nonce-ttl', '60'),
('rtp-timer-name', 'soft'),
('codec-prefs', 'PCMU@20i'),
('debug', '1'),