Module: kamailio Branch: master Commit: 55b1c2cebc8ad7f18cebe805be3730c0a0736504 URL: https://github.com/kamailio/kamailio/commit/55b1c2cebc8ad7f18cebe805be3730c… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2016-04-27T16:36:26+02:00 examples/kemi: more comments in python script --- Modified: examples/kemi/kamailio-basic-kemi-python.py --- Diff: https://github.com/kamailio/kamailio/commit/55b1c2cebc8ad7f18cebe805be3730c… Patch: https://github.com/kamailio/kamailio/commit/55b1c2cebc8ad7f18cebe805be3730c… --- diff --git a/examples/kemi/kamailio-basic-kemi-python.py b/examples/kemi/kamailio-basic-kemi-python.py index ec18d78..ecd72eb 100644 --- a/examples/kemi/kamailio-basic-kemi-python.py +++ b/examples/kemi/kamailio-basic-kemi-python.py @@ -1,11 +1,14 @@ ## Kamailio - equivalent of routing blocks in Python +## ## KSR - the new dynamic object exporting Kamailio functions ## Router - the old object exporting Kamailio functions ## + import sys import Router.Logger as Logger import KSR as KSR +# global variables corresponding to defined values (e.g., flags) in kamailio.cfg FLT_ACC=1 FLT_ACCMISSED=2 FLT_ACCFAILED=3 @@ -14,26 +17,29 @@ FLB_NATB=6 FLB_NATSIPPING=7 -def dumpObj(obj): - for attr in dir(obj): - # KSR.info("obj.%s = %s\n" % (attr, getattr(obj, attr))); - Logger.LM_INFO("obj.%s = %s\n" % (attr, getattr(obj, attr))); +# global function to instantiate a kamailio class object +# -- executed when kamailio app_python module is initialized def mod_init(): KSR.info("===== from Python mod init\n"); # dumpObj(KSR); return kamailio(); + +# -- {start defining kamailio class} class kamailio: def __init__(self): KSR.info('===== kamailio.__init__\n'); + # executed when kamailio child processes are initialized def child_init(self, rank): KSR.info('===== kamailio.child_init(%d)\n' % rank); return 0; + # SIP request routing + # -- equivalent of request_route{} def ksr_request_route(self, msg): # KSR.info("===== request - from kamailio python script\n"); # KSR.info("===== method [%s] r-uri [%s]\n" % (KSR.pv.get("$rm"),KSR.pv.get("$ru"))); @@ -326,6 +332,7 @@ def ksr_route_sipout(self, msg): # Manage outgoing branches + # -- equivalent of branch_route[...]{} def ksr_branch_manage(self, msg): KSR.dbg("new branch ["+ str(KSR.pv.get("$T_branch_idx")) + " to "+ KSR.pv.get("$ru") + "\n"); @@ -334,6 +341,7 @@ def ksr_branch_manage(self, msg): # Manage incoming replies + # -- equivalent of onreply_route[...]{} def ksr_onreply_manage(self, msg): KSR.dbg("incoming reply\n"); scode = KSR.pv.get("$rs"); @@ -344,6 +352,7 @@ def ksr_onreply_manage(self, msg): # Manage failure routing cases + # -- equivalent of failure_route[...]{} def ksr_failure_manage(self, msg): if self.ksr_route_natmanage()==-255 : return 1; @@ -353,7 +362,19 @@ def ksr_failure_manage(self, msg): return 1; + # SIP response handling + # -- equivalent of reply_route{} def ksr_reply_route(self, msg): KSR.info("===== response - from kamailio python script\n"); return 1; + +# -- {end defining kamailio class} + + +# global helper function for debugging purposes +def dumpObj(obj): + for attr in dir(obj): + # KSR.info("obj.%s = %s\n" % (attr, getattr(obj, attr))); + Logger.LM_INFO("obj.%s = %s\n" % (attr, getattr(obj, attr))); +