Incoming adv
File: incoming_adv.py
# incoming_adv.py - advanced incoming script for capisuite # -------------------------------------------------------- # copyright : (c) 2007 by Neobiker # Version : $Revision: 1.8 $ # Date : $Date: 2007/09/10 20:37:00 $ # # original script : incoming.py # copyright : (C) 2002 by Gernot Hillier # email : gernot@hillier.de # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # general imports import locale,datetime,time,os,re,string,pwd,commands # CapiSuite imports import capisuite,cs_helpers # phonebook file (neobiker's _adv) configfile_phonebook="/etc/capisuite/phonebook.conf" configfile_fax="/etc/capisuite/fax.conf" configfile_voice="/etc/capisuite/answering_machine.conf" # read_Configfiles () # read configuration file and return a ConfigParser object # # The configfile is read from the path given above and the surrounding # quotation marks from the values are removed # # @return the constructed config file object def read_Configfiles(file=""): import ConfigParser config=ConfigParser.ConfigParser() if (file==""): config.readfp(open(configfile_fax)) config.readfp(open(configfile_voice)) try: config.readfp(open(configfile_phonebook)) except: pass else: config.readfp(open(file)) for s in config.sections(): for o in config.options(s): value=config.get(s,o) if (len(value)>1 and value[0]=='"'): config.set(s,o,value[1:-1]) if (not config.has_section('GLOBAL')): raise IOError("invalid config file, section GLOBAL missing") return config # read_phonebook () # check if number is listed in phonebook # # read_phonebook (number): # number: tel number # # return: name def read_phonebook (number): """read_phonebook () read name of number if listed in phonebook""" try: fd=open(configfile_phonebook) except: return number for line in fd: line=line.strip() if (not line) | line.startswith("#") | (not '=' in line): continue match=re.match(r'(.*?)\s*=\s*(.*)$', line) name=match.group(1) details=re.sub('[\s+()-]','',match.group(2)) if re.sub('[\s+()-]','',number) in details.split(','): fd.close() return name fd.close() return number # ---------------------------------------- # check_number_online () # online reverse lookup # # check_number_online (number): # number: tel number # # return: name, details def check_number_online (number,call): """check_number_online () check if number if listed in online phonebook""" name = details = "" cmd = "tbident.sh " + number + " 2>/dev/null" try: number, name, details = commands.getoutput(cmd).split("|") except: capisuite.log("Error: "+cmd+" failed",1,call) return name, details # ---------------------------------------- # check_date () # check if user program date fits actual date # # check_date (pdate, adate): # pdate: program date # adate: actual date # # return: True/False if 'pdate' fits 'adate' def check_date (pdate, adate): """check_date() check if actual date fits user program date""" # a '*' fits always... if pdate == '*': return True # initialise day.month.year from actual date if field is undefined # update pdate fields day.month.year as defined in user program idate=pdate.split('.') pdate=adate[:] for i in range(len(idate)): if idate[i] and idate[i] != '*': pdate[i] = int(idate[i]) return pdate == adate; # ---------------------------------------- # check_date_section () # check if date is listed in date section # # check_date_section (config, dsect, adate): # config: config file # dsect: date section list of dates # adate: actual date # # return: True/False if 'adate' is listed/not listed def check_date_section (config, dsect, adate): """check_date_section () check if date is listed in date section""" # check all entries in date section # every entry (item) can be a list of dates for i in range(len(config.items(dsect))): for pdate in config.items(dsect)[i][1].split(','): if check_date(pdate, adate): return True return False # ---------------------------------------- # prog_time () # check if actual time fits user program time interval # # prog_time (ptime, atime): # ptime: program time intervall # atime: actual time # # return: True/False if 'ptime' fit's actual time def prog_time (ptime, atime): """prog_time() check if actual time fits user program time interval""" # a '*' fits always... if ptime == '*': return True # From: time intervall start # From: minutes are optional, set default to :00 f0 = ptime.split('-')[0] + ':00' f = [int(f0.split(':')[0]), int(f0.split(':')[1])] # To: time intervall end # To: minutes are optional, set default to :00 t0 = ptime.split('-')[1] + ':00' t = [int(t0.split(':')[0]), int(t0.split(':')[1])] # test actual time interval: From < PTime < To? # 1.st test: f < t (means: t < 23:59) # 2.nd test: f > t (means: t >= 00:00 -> on next day!) if f < t: return f <= atime <= t else: return not (t <= atime <= f) # ---------------------------------------- # prog_wday() # check if weekday is listed in user program # # prog_wday (pwday, wday): # pwday program weekday # wday actual weekday # # return: True/False if 'wday' is listed/not listed def prog_wday (pwday, wday): """prog_wday() check if weekday is listed in user program""" # a '*' fits always... if pwday == '*': return True wd={'MO': 0, 'DI': 1, 'MI': 2, 'DO': 3, 'FR': 4, 'SA': 5, 'SO': 6, \ 'TU': 1, 'WE': 2, 'TH': 3, 'SU': 6} return wday == wd[pwday.upper()] # ---------------------------------------- # check_caller_section () # check if call_from is listed in user caller-section # # check_caller_section (config, csect, call_from): # config: config file # csect: caller-section # call_from: caller number # # return: True/False if 'call_from' is listed/not listed def check_caller_section (config, csect, call_from): """check_caller_section () check if call_from is listed in callers section""" # check all entries in caller section # every entry (item) can be a list of numbers # standardise numbers (delete blanks etc.) for i in range(len(config.items(csect))): for j in config.items(csect)[i][1].split(','): if call_from == re.sub('[\s+()-]','',j): return True return False # ---------------------------------------- # check_caller() # check if 'call_from' is listed in any callers list/section # # check_caller (config, callers, call_from): # config: config file # callers: list of numbers or sections # call_from: caller number # # return: True/False if 'call_from' is listed/not listed def check_caller (config, callers, call_from): """check_caller () check if caller_from matches group entries/section""" # a '*' fits always... if callers == '*': return True # check all entries in group entry (caller numbers) # every entry (item) can be a separate section # correct format of numbers (delete blanks etc.) for i in range(len(callers.split(','))): pcaller = re.sub('[\s+()-]', '', callers.split(',')[i]) if pcaller in config.sections(): if check_caller_section(config, pcaller, call_from): return True elif call_from == pcaller: return True return False # ---------------------------------------- # prog_active() # check if given user program is active # # Check if Date/Time/Weekday fits actual date/time # to see if user program is activ # # prog_active (config, dates, times, wdays): # config: config file # dates: program dates # times: program time intervals # wdays: program week days # # return: True/False if programm is active/not active def prog_active (config, dates, times, wdays): """prog_active() check if given user program is active""" # get actual date / time d = datetime.datetime.now() # check the dates in user program for i in range(len(dates.split(','))): pdate = dates.split(',')[i] if pdate in config.sections(): if check_date_section(config, pdate, [d.day, d.month, d.year]): break elif check_date(pdate, [d.day, d.month, d.year]): break # date didn't fit else: return False # check the times in user program for i in range(len(times.split(','))): ptime = times.split(',')[i] if prog_time(ptime, [d.hour, d.minute]): break # time intervals didn't fit else: return False # check the weekdays in user program for i in range(len(wdays.split(','))): pwday = wdays.split(',')[i] if prog_wday(pwday, d.weekday()): break # weekdays didn't fit else: return False # all tests OK til now return True # ---------------------------------------- # read_prog() # read prog[dates, times, weekdays, message, delay, length, callers] # # It will search for a valid user program ('prog#') in the user section # and reads coresponding definitions for # - delay the delay of vbox activation # - message the specific message to play # - length the max. record length # # read_prog (config, section, call_from) # config: config file # section: section in config file to read # call_from: caller number # # return: True/False if valid programm found or not # @user_prog['delay': xx, 'message': yy, 'length': zz] def read_prog (config, section, call_from): """read_prog(section) read user specific program for vbox""" user_prog = {} i = 1 prog = "prog" + str(i) while config.has_option(section, prog): # progX = [dates, times, weekdays, message, delay, length, callers] p = config.get(section, prog).split() if prog_active(config, p[0], p[1], p[2]): if check_caller(config, re.sub('[\s+()-]', '', p[6]), call_from): user_prog['message'] = p[3] user_prog['delay'] = p[4] user_prog['length'] = p[5] return user_prog i += 1 prog = "prog" + str(i) # empty user_prog = False return user_prog # ------------------------------------------------------------------- # main function called by CapiSuite when an incoming call is received # ------------------------------------------------------------------- # # It will decide if this call should be accepted, with which service and for # which user. The real call handling is done in faxIncoming and voiceIncoming. # # callIncoming(call,service,call_from,call_to) # call reference to the call. Needed by all capisuite functions # service one of SERVICE_FAXG3, SERVICE_VOICE, SERVICE_OTHER # call_from string containing the number of the calling party # call_to string containing the number of the called party def callIncoming(call,service,call_from,call_to): # read sections in config file try: locale.setlocale(locale.LC_ALL, 'de_DE') config=read_Configfiles() userlist=config.sections() userlist.remove('GLOBAL') # search for call_to in the user sections curr_user="" for u in userlist: if config.has_option(u,'voice_numbers'): numbers=config.get(u,'voice_numbers') if (call_to in numbers.split(',') or numbers=="*"): if (service==capisuite.SERVICE_VOICE): curr_user=u curr_service=capisuite.SERVICE_VOICE break if (service==capisuite.SERVICE_FAXG3): curr_user=u curr_service=capisuite.SERVICE_FAXG3 break if config.has_option(u,'fax_numbers'): numbers=config.get(u,'fax_numbers') if (call_to in numbers.split(',') or numbers=="*"): if (service in (capisuite.SERVICE_FAXG3,capisuite.SERVICE_VOICE)): curr_user=u curr_service=capisuite.SERVICE_FAXG3 break except IOError,e: capisuite.error("Error occured during config file reading: "+e+" Disconnecting...") capisuite.reject(call,0x34A9) return # answer the call with the right service if (curr_user==""): capisuite.log("call from "+call_from+" to "+call_to+" ignoring",1,call) capisuite.reject(call,1) return # XXX: neobiker's _adv try: phonebook=cs_helpers.readConfig(configfile_phonebook) except IOError,e: capisuite.error("Warning: Error occured during phonebook file reading: "+e) try: if (curr_service==capisuite.SERVICE_VOICE): # XXX: neobiker's _adv user_prog = read_prog(config, curr_user, call_from) if user_prog: delay = user_prog['delay'] else: delay=cs_helpers.getOption(config,curr_user,"voice_delay") caller_name = read_phonebook(call_from) called_name = read_phonebook(call_to) if (delay==None): capisuite.error("voice_delay not found for user "+curr_user+"! -> rejecting call") capisuite.reject(call,0x34A9) return capisuite.log("call from "+caller_name+" to "+called_name+" for "+curr_user+" connecting with voice",1,call) capisuite.connect_voice(call,int(delay)) voiceIncoming(call,call_from,caller_name,call_to,called_name,curr_user,config) elif (curr_service==capisuite.SERVICE_FAXG3): caller_name = read_phonebook(call_from) called_name = read_phonebook(call_to) faxIncoming(call,call_from,caller_name,call_to,called_name,curr_user,config,0) except capisuite.CallGoneError: # catch exceptions from connect_* (cause,causeB3)=capisuite.disconnect(call) capisuite.log("connection lost with cause 0x%x,0x%x" % (cause,causeB3),1,call) # ------------------------------------------------------------------- # @brief called by callIncoming when an incoming fax call is received # ------------------------------------------------------------------- # @param call reference to the call. Needed by all capisuite functions # @param call_from string containing the number of the calling party # @param call_to string containing the number of the called party # @param curr_user name of the user who is responsible for this # @param config ConfigParser instance holding the config data # @param already_connected 1 if we're already connected (that means we must switch to fax mode) def faxIncoming(call,call_from,caller_name,call_to,called_name,curr_user,config,already_connected): try: udir=cs_helpers.getOption(config,"","fax_user_dir") if (udir==None): capisuite.error("global option fax_user_dir not found! -> rejecting call") capisuite.reject(call,0x34A9) return udir=os.path.join(udir,curr_user)+"/" if (not os.access(udir,os.F_OK)): userdata=pwd.getpwnam(curr_user) os.mkdir(udir,0700) os.chown(udir,userdata[2],userdata[3]) if (not os.access(udir+"received/",os.F_OK)): userdata=pwd.getpwnam(curr_user) os.mkdir(udir+"received/",0700) os.chown(udir+"received/",userdata[2],userdata[3]) except KeyError: capisuite.error("user "+curr_user+" is not a valid system user. Disconnecting",call) capisuite.reject(call,0x34A9) return filename="" # assure the variable is defined... try: stationID=cs_helpers.getOption(config,curr_user,"fax_stationID") if (stationID==None): capisuite.error("Warning: fax_stationID not found for user "+curr_user+" -> using empty string") stationID="" headline=cs_helpers.getOption(config,curr_user,"fax_headline","") # empty string is no problem here capisuite.log("call from "+caller_name+" to "+called_name+" for "+curr_user+" connecting with fax",1,call) if (already_connected): faxInfo=capisuite.switch_to_faxG3(call,stationID,headline) else: faxInfo=capisuite.connect_faxG3(call,stationID,headline,0) if (faxInfo!=None and faxInfo[3]==1): faxFormat="cff" # color fax else: faxFormat="sff" # normal b&w fax filename=cs_helpers.uniqueName(udir+"received/","fax",faxFormat) capisuite.fax_receive(call,filename) (cause,causeB3)=capisuite.disconnect(call) capisuite.log("connection finished with cause 0x%x,0x%x" % (cause,causeB3),1,call) except capisuite.CallGoneError: # catch this here to get the cause info in the mail (cause,causeB3)=capisuite.disconnect(call) capisuite.log("connection lost with cause 0x%x,0x%x" % (cause,causeB3),1,call) if (os.access(filename,os.R_OK)): cs_helpers.writeDescription(filename, "call_from=\""+call_from+"\"\ncall_to=\""+call_to+"\"\ntime=\"" +time.ctime()+"\"\ncause=\"0x%x/0x%x\"\n" % (cause,causeB3)) userdata=pwd.getpwnam(curr_user) os.chmod(filename,0600) os.chown(filename,userdata[2],userdata[3]) os.chmod(filename[:-3]+"txt",0600) os.chown(filename[:-3]+"txt",userdata[2],userdata[3]) fromaddress=cs_helpers.getOption(config,curr_user,"fax_email_from","") if (fromaddress==""): fromaddress=curr_user mailaddress=cs_helpers.getOption(config,curr_user,"fax_email","") if (mailaddress==""): mailaddress=curr_user action=cs_helpers.getOption(config,curr_user,"fax_action","").lower() if (action not in ("mailandsave","saveonly")): capisuite.error("Warning: No valid fax_action definition found for user "+curr_user+" -> assuming SaveOnly") action="saveonly" if (action=="mailandsave"): # XXX: changed Mail text caller_details = "" if (caller_name == call_from): caller_name, caller_details = check_number_online (call_from,call) cs_helpers.sendMIMEMail(fromaddress, mailaddress, "Fax von "+caller_name+" an "+called_name, faxFormat, "Fax Sender: "+caller_name+" ("+call_from+")\n" +" "+caller_details+"\n" +"Datum: "+time.strftime("%c")+"\n\n" +"Siehe Anhang.\nDas Fax wurde gespeichert unter: "+filename+"\n", filename) # --------------------------------------------------------------------- # @brief called by callIncoming when an incoming voice call is received # --------------------------------------------------------------------- # @param call reference to the call. Needed by all capisuite functions # @param call_from string containing the number of the calling party # @param call_to string containing the number of the called party # @param curr_user name of the user who is responsible for this # @param config ConfigParser instance holding the config data def voiceIncoming(call,call_from,caller_name,call_to,called_name,curr_user,config): try: udir=cs_helpers.getOption(config,"","voice_user_dir") if (udir==None): capisuite.error("global option voice_user_dir not found! -> rejecting call") capisuite.reject(call,0x34A9) return udir=os.path.join(udir,curr_user)+"/" if (not os.access(udir,os.F_OK)): userdata=pwd.getpwnam(curr_user) os.mkdir(udir,0700) os.chown(udir,userdata[2],userdata[3]) if (not os.access(udir+"received/",os.F_OK)): userdata=pwd.getpwnam(curr_user) os.mkdir(udir+"received/",0700) os.chown(udir+"received/",userdata[2],userdata[3]) except KeyError: capisuite.error("user "+curr_user+" is not a valid system user. Disconnecting",call) capisuite.reject(call,0x34A9) return filename=cs_helpers.uniqueName(udir+"received/","voice","la") action=cs_helpers.getOption(config,curr_user,"voice_action","").lower() if (action not in ("mailandsave","saveonly","none")): capisuite.error("Warning: No valid voice_action definition found for user "+curr_user+" -> assuming SaveOnly") action="saveonly" try: capisuite.enable_DTMF(call) # XXX: neobiker's _adv user_prog = read_prog(config, curr_user, call_from) if user_prog: userannouncement = udir + user_prog['message'] else: userannouncement=udir+cs_helpers.getOption(config,curr_user,"announcement","announcement.la") pin=cs_helpers.getOption(config,curr_user,"pin","") if (os.access(userannouncement,os.R_OK)): capisuite.audio_send(call,userannouncement,1) else: if (call_to!="-"): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"anrufbeantworter-von.la"),1) cs_helpers.sayNumber(call,call_to,curr_user,config) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"bitte-nachricht.la"),1) if (action!="none"): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"beep.la"),1) # XXX: neobiker's _adv if user_prog: length = user_prog['length'] else: length=cs_helpers.getOption(config,curr_user,"record_length","60") silence_timeout=cs_helpers.getOption(config,curr_user,"record_silence_timeout","5") capisuite.audio_receive(call,filename,int(length), int(silence_timeout),1) dtmf_list=capisuite.read_DTMF(call,0) if (dtmf_list=="X"): if (os.access(filename,os.R_OK)): os.unlink(filename) faxIncoming(call,call_from,caller_name,call_to,called_name,curr_user,config,1) elif (dtmf_list!="" and pin!=""): dtmf_list+=capisuite.read_DTMF(call,3) # wait 5 seconds for input count=1 while (count<3 and pin!=dtmf_list): # try again if input was wrong capisuite.log("wrong PIN entered...",1,call) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"beep.la")) dtmf_list=capisuite.read_DTMF(call,3) count+=1 if (pin==dtmf_list): if (os.access(filename,os.R_OK)): os.unlink(filename) capisuite.log("Starting remote inquiry...",1,call) remoteInquiry(call,udir,curr_user,config) (cause,causeB3)=capisuite.disconnect(call) capisuite.log("connection finished with cause 0x%x,0x%x" % (cause,causeB3),1,call) except capisuite.CallGoneError: # catch this here to get the cause info in the mail (cause,causeB3)=capisuite.disconnect(call) capisuite.log("connection lost with cause 0x%x,0x%x" % (cause,causeB3),1,call) if (os.access(filename,os.R_OK)): cs_helpers.writeDescription(filename, "call_from=\""+call_from+"\"\ncall_to=\""+call_to+"\"\ntime=\"" +time.ctime()+"\"\ncause=\"0x%x/0x%x\"\n" % (cause,causeB3)) userdata=pwd.getpwnam(curr_user) os.chmod(filename,0600) os.chown(filename,userdata[2],userdata[3]) os.chmod(filename[:-2]+"txt",0600) os.chown(filename[:-2]+"txt",userdata[2],userdata[3]) fromaddress=cs_helpers.getOption(config,curr_user,"voice_email_from","") if (fromaddress==""): fromaddress=curr_user mailaddress=cs_helpers.getOption(config,curr_user,"voice_email","") if (mailaddress==""): mailaddress=curr_user if (action=="mailandsave"): # XXX: changed Mail text caller_details = "" if (caller_name == call_from): caller_name, caller_details = check_number_online (call_from,call) cs_helpers.sendMIMEMail(fromaddress, mailaddress, "Nachricht von "+caller_name+" fuer "+called_name, "la", "Anrufer: "+caller_name+" ("+call_from+")\n" +" "+caller_details+"\n" +"Laenge: "+str(os.stat(filename)[6]/8/1024)+" Sek.\n" +"Datum: "+time.strftime("%c")+"\n" +"Nummer: "+called_name+" ("+call_to+")\n\n" +"Siehe Anhang.\nDas File wurde gespeichert unter: "+filename+"\n", filename) # ----------------------------------------------------------- # @brief remote inquiry function (uses german wave snippets!) # ----------------------------------------------------------- # commands for remote inquiry # delete message - 1 # next message - 4 # last message - 5 # repeat current message - 6 # # @param call reference to the call. Needed by all capisuite functions # @param userdir spool_dir of the current_user # @param curr_user name of the user who is responsible for this # @param config ConfigParser instance holding the config data # def remoteInquiry(call,userdir,curr_user,config): import time,fcntl,errno,os # acquire lock lockfile=open(userdir+"received/inquiry_lock","w") try: fcntl.lockf(lockfile,fcntl.LOCK_EX | fcntl.LOCK_NB) # only one inquiry at a time! except IOError,err: # can't get the lock if (err.errno in (errno.EACCES,errno.EAGAIN)): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"fernabfrage-aktiv.la")) lockfile.close() return try: # read directory contents messages=os.listdir(userdir+"received/") messages=filter (lambda s: re.match("voice-.*\.la",s),messages) # only use voice-* files messages=map(lambda s: int(re.match("voice-([0-9]+)\.la",s).group(1)),messages) # filter out numbers messages.sort() # read the number of the message heard last at the last inquiry lastinquiry=-1 if (os.access(userdir+"received/last_inquiry",os.W_OK)): lastfile=open(userdir+"received/last_inquiry","r") lastinquiry=int(lastfile.readline()) lastfile.close() # sort out old messages oldmessages=[] i=0 while (i<len(messages)): if (messages[i]<=lastinquiry): oldmessages.append(messages[i]) del messages[i] else: i+=1 cs_helpers.sayNumber(call,str(len(messages)),curr_user,config) if (len(messages)==1): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"neue-nachricht.la"),1) else: capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"neue-nachrichten.la"),1) # menu for record new announcement cmd="" while (cmd not in ("1","9")): if (len(messages)+len(oldmessages)): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"zum-abhoeren-1.la"),1) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"fuer-neue-ansage-9.la"),1) cmd=capisuite.read_DTMF(call,0,1) if (cmd=="9"): newAnnouncement(call,userdir,curr_user,config) return # start inquiry for curr_msgs in (messages,oldmessages): cs_helpers.sayNumber(call,str(len(curr_msgs)),curr_user,config) if (curr_msgs==messages): if (len(curr_msgs)==1): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"neue-nachricht.la"),1) else: capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"neue-nachrichten.la"),1) else: if (len(curr_msgs)==1): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"nachricht.la"),1) else: capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"nachrichten.la"),1) i=0 while (i<len(curr_msgs)): filename=userdir+"received/voice-"+str(curr_msgs[i])+".la" descr=cs_helpers.readConfig(filename[:-2]+"txt") capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"nachricht.la"),1) cs_helpers.sayNumber(call,str(i+1),curr_user,config) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"von.la"),1) cs_helpers.sayNumber(call,descr.get('GLOBAL','call_from'),curr_user,config) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"fuer.la"),1) cs_helpers.sayNumber(call,descr.get('GLOBAL','call_to'),curr_user,config) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"am.la"),1) locale.setlocale(locale.LC_ALL, 'C') calltime=time.strptime(descr.get('GLOBAL','time')) cs_helpers.sayNumber(call,str(calltime[2]),curr_user,config) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"..la"),1) cs_helpers.sayNumber(call,str(calltime[1]),curr_user,config) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"..la"),1) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"um.la"),1) cs_helpers.sayNumber(call,str(calltime[3]),curr_user,config) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"uhr.la"),1) cs_helpers.sayNumber(call,str(calltime[4]),curr_user,config) capisuite.audio_send(call,filename,1) cmd="" while (cmd not in ("1","4","5","6")): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"erklaerung.la"),1) cmd=capisuite.read_DTMF(call,0,1) if (cmd=="1"): os.remove(filename) os.remove(filename[:-2]+"txt") del curr_msgs[i] capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"nachricht-geloescht.la")) elif (cmd=="4"): if (curr_msgs[i]>lastinquiry): lastinquiry=curr_msgs[i] lastfile=open(userdir+"received/last_inquiry","w") lastfile.write(str(curr_msgs[i])+"\n") lastfile.close() i+=1 elif (cmd=="5"): i-=1 capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"keine-weiteren-nachrichten.la")) finally: # unlock fcntl.lockf(lockfile,fcntl.LOCK_UN) lockfile.close() os.unlink(userdir+"received/inquiry_lock") # --------------------------------------------------------------------------- # @brief remote inquiry: record new announcement (uses german wave snippets!) # --------------------------------------------------------------------------- # @param call reference to the call. Needed by all capisuite functions # @param userdir spool_dir of the current_user # @param curr_user name of the user who is responsible for this # @param config ConfigParser instance holding the config data def newAnnouncement(call,userdir,curr_user,config): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"bitte-neue-ansage-komplett.la")) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"beep.la")) cmd="" while (cmd!="1"): capisuite.audio_receive(call,userdir+"announcement-tmp.la",60,3) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"neue-ansage-lautet.la")) capisuite.audio_send(call,userdir+"announcement-tmp.la") capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"wenn-einverstanden-1.la")) cmd=capisuite.read_DTMF(call,0,1) if (cmd!="1"): capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"bitte-neue-ansage-kurz.la")) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"beep.la")) userannouncement=userdir+cs_helpers.getOption(config,curr_user,"announcement","announcement.la") os.rename(userdir+"announcement-tmp.la",userannouncement) userdata=pwd.getpwnam(curr_user) os.chown(userannouncement,userdata[2],userdata[3]) capisuite.audio_send(call,cs_helpers.getAudio(config,curr_user,"ansage-gespeichert.la")) # # History: # # $Log: incoming_adv.py,v $ # Revision 1.8 2007/09/10 20:37:00 root # optimized read_phonebook() # # Revision 1.7 2007/09/09 19:24:47 root # Names now case sensitive # # Revision 1.6 2007/09/09 19:08:26 root # phonebook.conf optional # # Revision 1.5 2007/09/09 19:05:26 root # integrated phonebook sections in capisuite config # # Revision 1.4 2007/09/09 16:01:50 root # added errorhandling and logging in check_number_online () # # Revision 1.3 2007/09/09 15:29:16 root # added German date format and record length to Email # # Revision 1.2 2007/09/09 13:49:40 root # added phonebook function and reverse lookup online # # Revision 1.1 2007/09/09 13:22:42 root # Initial revision # # Revision 1.4 2007/01/23 14:42:11 root # changed mail text to german and beatified layout # # Revision 1.3 2007/01/03 23:27:36 root # none # # Revision 1.2 2007/01/03 23:23:27 root # First checkin # # Revision 1.1 2007/01/03 23:18:13 root # Initial revision # # Revision 1.9.2.1 2003/08/24 12:47:19 gernot # - faxIncoming tried to reconnect when it was called after a switch from # voice to fax mode, which lead to a call abort. Thx to Harald Jansen & # Andreas Scholz for reporting! # # ... dropped old RCS comments...