View source for YAYPM:Simple IVR with Inline Callbacks


Same example as above, this time with Inline Callbacks. Notice how readablity has improved over bare deferreds version:
 
 #!/usr/bin/python
 from twisted.internet import defer
 from yaypm import AbandonedException
 import logging, yaypm.utils
 
 logger = logging.getLogger('yaypm.examples')
 
 @defer.inlineCallbacks
 def ivr(yate, callid):
     try:
         end = yate.onwatch("chan.hangup", lambda m : m["id"] == callid)
 
         execute = yield yate.onwatch("call.execute",
                                      lambda m : m["id"] == callid,
                                      until = end)
         targetid = execute["targetid"]
 
         yate.msg("call.answered",
                  {"id": targetid,
                   "targetid": callid}).enqueue()
 
         logger.debug("Call %s answered." % callid)
 
         while True:
             dtmf = yield yate.onmsg("chan.dtmf",
                                     lambda m : m["id"] == callid,
                                     end)
 
             logger.debug("Dtmf %s received." % dtmf["text"])
 
             yate.msg("chan.masquerade",
                 {"message" : "chan.attach",
                  "id": targetid,
                  "source": "wave/play/./sounds/digits/pl/%s.gsm" % \
                  dtmf["text"]}).enqueue()
 
             dtmf.ret(True)
 
     except AbandonedException, e:
         logger.debug("Call %s abandoned." % callid)
 
 @defer.inlineCallbacks
 def route(yate):
     while True:
         route = yield yate.onmsg("call.route", lambda m : m["called"] == "ivr")
         ivr(yate, route["id"])
         route.ret(True, "dumb/")
 
 if __name__ in ["__main__", "__embedded_yaypm_module__"]:
     logger.setLevel(logging.DEBUG)
     yaypm.utils.setup(lambda yate: route(yate))

'''See also'''

* [[YAYPM:Bridge and then unbridge]]
* [[YAYPM:Bridge and then redirect after a hangup]]

[[Category:IVR]] [[Category:YAYPM]] [[Category:Programmers]] [[Category:Scripting]]