charun_tac.py

"""this is the twisted application configuration (tac)-file.

it holds the basic configuration for the charun app.
please specify urls and ports for the twisted UDP server and the CouchDB
instance you can also set the function that will be applied to incoming
messages on the UDP server.
"""

import logging

from twisted.application import internet, service
from twisted.python import log
from twisted.python.log import ILogObserver
from twisted.python.logfile import DailyLogFile

from charun import Charun


## configuration parameters
## Twisted configuration
port = 9999
host = 'localhost'
loglevel = logging.INFO
#loglevel = logging.DEBUG

# this is the initial forwarding function used in the UDP Server.
# It is applied to incoming dicts
initial = lambda x: x

## CouchDB configuration
couchdb_url = "http://localhost:5984"
db_name = "charun"
## Test DB
test_db_name = "test_charun"

## LOGGING
logfile = DailyLogFile("charun.log", "tmp")
logname = "charun"
logging.basicConfig(stream=logfile,
                    format="[%(asctime)s]:charun: %(levelname)s:%(message)s",
                    datefmt="%Y-%m-%d %H:%M:%S")
logger = logging.getLogger(logname)
logger.setLevel(loglevel)

# create the application service
application = service.Application("charun couchdb bridge")
application.setComponent(ILogObserver, log.PythonLoggingObserver(logname).emit)

#define the UDP server on the specified port and hand the handler-class in
udp_service = internet.UDPServer(port, Charun(couchdb_url, db_name, initial))

# this hooks the udp-service to the application
udp_service.setServiceParent(application)
# when started with twistd, the child services will be started automatically.


def test_initial(x):
    """this function serves testing purposes"""
    for it in x.items():
        x[it[0]] = it[1] * 2
    return x