From f84c0141a57030b9aff485f3fa5b17486c3e1b11 Mon Sep 17 00:00:00 2001
From: Raphael Coeffic <rco@iptel.org>
Date: Fri, 17 Mar 2006 14:47:01 +0000
Subject: [PATCH] corrected dependencies to non included files.

git-svn-id: http://svn.berlios.de/svnroot/repos/sems/trunk@6 8eb893ce-cfd4-0310-b710-fb5ebe64c474
---
 apps/ivr/py/log.patch                   |  83 ---------
 apps/ivr/py/log.py                      |  53 ++----
 apps/ivr/py/log.pyc                     | Bin 2780 -> 2310 bytes
 apps/mailbox/Makefile                   |   2 +-
 apps/mailbox/imap_mailbox/MailboxURL.py |  50 +++++
 apps/mailbox/imap_mailbox/__init__.py   |   0
 apps/mailbox/imap_mailbox/imap4ext.py   | 235 ++++++++++++++++++++++++
 apps/mailbox/mailbox.py                 |   3 +-
 apps/mailbox/mailbox_query.py           |   3 +-
 9 files changed, 304 insertions(+), 125 deletions(-)
 delete mode 100644 apps/ivr/py/log.patch
 create mode 100644 apps/mailbox/imap_mailbox/MailboxURL.py
 create mode 100644 apps/mailbox/imap_mailbox/__init__.py
 create mode 100644 apps/mailbox/imap_mailbox/imap4ext.py

diff --git a/apps/ivr/py/log.patch b/apps/ivr/py/log.patch
deleted file mode 100644
index 2729a735..00000000
--- a/apps/ivr/py/log.patch
+++ /dev/null
@@ -1,83 +0,0 @@
-Index: log.py
-===================================================================
---- log.py	(.../branches/inter_plugin_com/apps/ivr/py/log.py)	(revision 22559)
-+++ log.py	(.../trunk/apps/ivr/py/log.py)	(revision 21770)
-@@ -1,52 +1,35 @@
- import ivr
--import sys,logging
-+import sys
- 
--from com.iptel.log.Logger import *
--
- # These are the same as in log.h
- L_ERR  = 0
- L_WARN = 1
- L_INFO = 2
- L_DBG  = 3
- 
--def fromPyLogLevel(py_level):
-+def log(level, msg, args):
- 
--	level = 0
--	if py_level >= logging.ERROR:
--		level = L_ERR
--	elif py_level >= logging.WARN:
--		level = L_WARN
--	elif py_level >= logging.INFO:
--		level = L_INFO
-+	if args != None:
-+		tmp_msg = msg % args
- 	else:
--		level = L_DBG
-+		tmp_msg = msg
-+		
-+	ivr.log(level,"Ivr-Python: " + tmp_msg + "\n")
- 
--	return level
--	
- 
--def toPyLogLevel(level):
-+def error(msg, args=None):
-+	log(L_ERR, msg, args)
- 
--	py_level = 0
--	if level >= L_DBG:
--		py_level = logging.DEBUG
--	elif level >= L_INFO:
--		py_level = logging.INFO
--	elif level >= L_WARN:
--		py_level = logging.WARN
--	else:
--		py_level = logging.ERROR
-+def warn(msg, args=None):
-+	log(L_WARN, msg, args)
- 
--	return py_level
-+def info(msg, args=None):
-+	log(L_INFO, msg, args)
-+	
-+def debug(msg, args=None):
-+	log(L_DBG, msg, args)
- 
- 
--class SemsLogHandler(logging.Handler):
--
--	def emit(self, record):
--
--		msg = self.format(record)
--		ivr.log(fromPyLogLevel(record.levelno),msg + '\n')
--
--
- def stacktrace(tb):
- 
- 	if tb: last_file = stacktrace(tb.tb_next)
-@@ -72,9 +55,5 @@
- 
- 
- # init code
--if not hasattr(Logger,"logger"):
--	initLogger("sems",toPyLogLevel(ivr.SEMS_LOG_LEVEL))
--	getLogger().addLogHandler(SemsLogHandler())
--
- sys.excepthook = log_excepthook
- debug("Python-Ivr logging started")
diff --git a/apps/ivr/py/log.py b/apps/ivr/py/log.py
index 1dcac712..3c673178 100644
--- a/apps/ivr/py/log.py
+++ b/apps/ivr/py/log.py
@@ -1,7 +1,5 @@
 import ivr
-import sys,logging
-
-from com.iptel.log.Logger import *
+import sys
 
 # These are the same as in log.h
 L_ERR  = 0
@@ -9,42 +7,27 @@ L_WARN = 1
 L_INFO = 2
 L_DBG  = 3
 
-def fromPyLogLevel(py_level):
+def log(level, msg, args):
 
-	level = 0
-	if py_level >= logging.ERROR:
-		level = L_ERR
-	elif py_level >= logging.WARN:
-		level = L_WARN
-	elif py_level >= logging.INFO:
-		level = L_INFO
+	if args != None:
+		tmp_msg = msg % args
 	else:
-		level = L_DBG
-
-	return level
-	
+		tmp_msg = msg
+		
+	ivr.log(level,"Ivr-Python: " + tmp_msg + "\n")
 
-def toPyLogLevel(level):
-
-	py_level = 0
-	if level >= L_DBG:
-		py_level = logging.DEBUG
-	elif level >= L_INFO:
-		py_level = logging.INFO
-	elif level >= L_WARN:
-		py_level = logging.WARN
-	else:
-		py_level = logging.ERROR
 
-	return py_level
+def error(msg, args=None):
+	log(L_ERR, msg, args)
 
+def warn(msg, args=None):
+	log(L_WARN, msg, args)
 
-class SemsLogHandler(logging.Handler):
-
-	def emit(self, record):
-
-		msg = self.format(record)
-		ivr.log(fromPyLogLevel(record.levelno),msg + '\n')
+def info(msg, args=None):
+	log(L_INFO, msg, args)
+	
+def debug(msg, args=None):
+	log(L_DBG, msg, args)
 
 
 def stacktrace(tb):
@@ -72,9 +55,5 @@ def log_excepthook(exception, value, tb):
 
 
 # init code
-if not hasattr(Logger,"logger"):
-	initLogger("sems",toPyLogLevel(ivr.SEMS_LOG_LEVEL))
-	getLogger().addLogHandler(SemsLogHandler())
-
 sys.excepthook = log_excepthook
 debug("Python-Ivr logging started")
diff --git a/apps/ivr/py/log.pyc b/apps/ivr/py/log.pyc
index c0d42454624e921f9132b12ce1d9fa7bdd326612..ae75f73d77288e62a3e580acb28cfcb9f24a0898 100644
GIT binary patch
literal 2310
zcmb_d+iuf95S_JisokVS6j7-v$h=vI0&hqlM7b3qRROgRNO`fGcoR%hJMy}vk=m#7
z$fxl&d;xRDj*~X61fsc&XLo03&(7{Se(}5Q?*H0&*QfGh@pGI1<|mto=zyqOIEuQ8
zBDNMq7IkfkZ0go1s!_L2QJsEpWP@~*q6YoouqE-E;ydCmiSLT<h`&scD-&B3EsN78
z%|AuK3TYl~(YYeUIQIQE1M0+VC{{2)8ry98FtzgkmY?P&n^TK&Mc-^nS4f>IwC|qT
zlr*KqUS6ZPPN%#%9<*tlH?@9lm5U)|$F$gfJkGX0Px7y6^4v36*!7!i4HgWup%JH(
zCfZ=mp&1$s=ZE6}KKkP0OrE23XzJV^>0>?eF@M&qCRb_aviKZIVvNJyc=Ci(JswY{
zSzV-BLXg!~D^|nmqc->>n^fcuJ30S&t6UmI=XSYK?5I<K0oEzT-QfM+-U28eITw4m
z^GbNwtj@AD!|DceN&O$R2B+8!zP#S+ETZ@~Y^colFiY0?d4teCc6L791hhCAq#HK{
z4d<{MynFNEe~}?kq<crhdvnlmgHTOeAGvE2cKDX1Yov<%##Ch%pD9Y}#jWGfSlAag
z=*&VenoGp2WSa8z1Z_8Yx+~<gs4eVdmbTZS2g$8sjKim0Ja0dOOaMwph_w@sv?pwQ
z?v3K4^dA+zzszxR@OjS&f%33_kY{0E7X<DFi9X4NaHG)V!GN;~$?{$>$ihQya2W?d
zKaI3OvVJNt35HOUfkY1iES;nx6L1BZu%cict}R0Vv1jWP^RX37xt9MIaX;X2bDIrW
zO<GemYgM&a5H|TK5{UysN;#x$c32Qt`%utI8n^)+#JS0cl$({3%Ui~=>cg9>^)pWO
zu=;p2!SwV=Uyt)RO}tEx(=7L@sM3*bds!G89kIM#%A}LXO9y|K(8p=aYAZM0<e4l`
z!I1IeaCD?EA9-;KK1y`$lrn}xu2j1f?q~T7iq*cR>A_QED|Fda_m!&*C|$fvwzy0l
zhY#aq=$Smsavk}rm;emZSB9Aw!Cc7koca~6sLe%oL%@Xscq3H;EM1U0aUd=-CS1N;
zip70M#B5vgCY~k2YLXhjvHZnbDKsfH`-;?3@oJY-jl%wC;49f#s09jeEjvJ>S1@Li
WjiVg9q2y~hZp)T$%~^F^NBsfdYpgH;

literal 2780
zcma)8+ioL85Un2HVkgdZ*$7x6Bk^EGn}B#h+Ld58BpX&T&MM|2{4#Q;+s<t48EbkH
zt)=i3z6O4Uui*<gRXrYG;vgJ#Pjy#yRrRS$=jA{3+Mj=Io&=Qriuk_5uzzFHMAt-J
zM=0tl+3~3BkydnFpr14rMbZW8mPi+=TP9tiZiRH2{=msK(iI`9q}RxJ6xOH@EmhvU
zC;F|sPP!%%8>H8TsFT?wvqgG??mgOw4@sGA(%7z&AqscsUNJ|RT~-n9ky&Q~yDGvk
zkW}P9A@dRGP1(jhI?XLysNGb2H=YhcOcXL1dOQ^{1-#@HkMA+;B_`bUcSUzZDK1c;
z_a%yJq|zeqMlVTaoKnsy3+MBkQ^`4N!l~eNRdg!qh;wYOEgm&%Y_^1HXl~8Wu7Mg)
ze7C6Zc03q_(Lh8_FD}k6glhSqZ4vxmUthFs8AQt$lK0-W-<)TALbCdne{y`*WW$R#
za??$)NG4kaHJ*G4(?{cp-NdS&#G`kURy=62mmAozyO_u;t8G=A4zKJzgcLzsfRyp9
z1CauS4$^NOa1PIm;~@RQaU7l*$3e;gfr9@=bpgx#o*8~X!!F}{a(evp**tJdVCDb|
z!5SqZ4%L}~dApCI${42c4AW1s&M~d4{Lia;5`m5xS>XReFVaJk1dx^=XYetG-NBTi
z22pNG3d^I5j(FA%IO?45d>u*iuRtJ;Q4V(~F66sM$nUU3X_<Gz3UA&?+3$1hX|5<q
zS}CSlldmZ0XU(uLi1p)S)Jug-Ob{p9vc-`d$Tz%A<cpMAkxwoVoLN!a<YSAf7xg`g
zDBsSE!u0u60eM@>sbhD2KkAK)?^~`o-yg;LX2{Fwv6)_>RusWv2oBf`W0EC3>tWvo
z;0Xu-9Pc4drI(=TFwW>8B?l+NFOY}Gbx)#!C9=D~z#|Cn3lu-Y@frsdTlIZ(-~GD+
z2xwB#w&Ov3x&<NEUf7kk<oTO$Xc_|Vi^edFGWxlro9mF1E2Ni#icNdLb(-`7BS+Fp
zKQbRuL1Ngmso#e-=^o(p6QJoL?+39qmX!su$S}~7D1DLc`)oRj1!^Y6HIpQ9(qvbs
zE^ynK+2PFY=SODISqhBw&)n~?S)J=l71~opWWa`3SI_VbI5<4mqy*^|2$T%qWk5l>
zP+`GH^FlZRH_8L>W^#A{nbKSp4(o5A>LC9$-rgpM?<VP095u{`z>L!nRAR<)k~VUw
zjF9^@l3r+ye$lW?noOh{asU4*Z1OWO!&VB;rimEH-4On5Z+K&tL(aLJUb=$eP^>zV
z$$<OlQ-Koq-O;N!zJ3i!Ndod}>N7kQk}{APm?W$6k+q*d%Heeg=o-w%o7X@-CaKZQ
zr>ulSH*F(!Vi%hC6Yzp~bQF$LGd#laqn5M4P1(Jbb5Eor7hlFzU1_;Ri^;43ujt9k
zc=EdmSLVPF1y?=WOA!_E!g<L#97bW9In4(<r$2W5*7=#=I{oFeB_SM`sX!e9J*^==
z^@cUfK$jS6b9pmp%2T~qBMZnqeB4*vY!18?x8lffMCNdv2I~QYvw%2?|0%)omD$7{
i;5(jd15;J)dX++1$)8u<s&0L}hPk$*o~nJXs{RG)jVWCK

diff --git a/apps/mailbox/Makefile b/apps/mailbox/Makefile
index ed0c3024..63f03852 100644
--- a/apps/mailbox/Makefile
+++ b/apps/mailbox/Makefile
@@ -31,7 +31,7 @@ compile:
 	/usr/bin/python${PYTHON_VERSION} /usr/lib/python${PYTHON_VERSION}/compileall.py -q ${LIBDIR}
 
 install: all
-	install -d ${BASEDIR}/${LIB_INSTALLDIR} 
+	install -d ${BASEDIR}/${LIB_INSTALLDIR}
 	install -m ${LIB_PERMISSIONS} -o ${OWNER} -g ${GROUP} ${LIBDIR}/*.pyc ${BASEDIR}/${LIB_INSTALLDIR}
 
 uninstall: 
diff --git a/apps/mailbox/imap_mailbox/MailboxURL.py b/apps/mailbox/imap_mailbox/MailboxURL.py
new file mode 100644
index 00000000..95f67182
--- /dev/null
+++ b/apps/mailbox/imap_mailbox/MailboxURL.py
@@ -0,0 +1,50 @@
+
+import re
+
+class InvalidMailboxURL(Exception):
+
+	value = ""
+	
+	def __init__(self,value):
+		self.value = value
+		Exception.__init__(value)
+
+	def __str__(self):
+		return repr(self.value)
+
+
+class MailboxURL:
+
+
+	url    = ""
+	user   = ""
+	passwd = ""
+	host   = ""
+	port   = 0
+	path   = ""
+
+	def __init__(self,url):
+		self.url = url
+		self._parse()
+
+
+	def _parse(self):
+		m = re.match('imap://(.+):(.+)@(.+):([0-9]+)/(.+)',self.url)
+		if m is None:
+			raise InvalidMailboxURL('regex did not match')
+
+		self.user   = m.group(1)
+		self.passwd = m.group(2)
+		self.host   = m.group(3)
+		self.port   = int(m.group(4))
+		self.path   = m.group(5)
+
+	def __str__(self):
+		return ("url:\t%s\n" % self.url) + \
+		       ("user:\t%s\n" % self.user) + \
+		       ("passwd:\t%s\n" % self.passwd) + \
+		       ("host:\t%s\n" % self.host) + \
+		       ("port:\t%i\n" % self.port) + \
+		       ("path:\t%s\n" % self.path)
+		       
+		
diff --git a/apps/mailbox/imap_mailbox/__init__.py b/apps/mailbox/imap_mailbox/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/apps/mailbox/imap_mailbox/imap4ext.py b/apps/mailbox/imap_mailbox/imap4ext.py
new file mode 100644
index 00000000..cda7e19d
--- /dev/null
+++ b/apps/mailbox/imap_mailbox/imap4ext.py
@@ -0,0 +1,235 @@
+import os,base64,time
+from imaplib import IMAP4
+
+from MailboxURL import *
+
+
+READ_BUFSIZE = 4096
+
+
+def IMAPCALL(call_res):
+
+	(t,d) = call_res
+	if t != 'OK':
+		raise IMAP4.error(d[0])
+	return (t,d)
+
+
+class IMAP4_MsgBODY:
+
+	uid   = ''
+	parts = []
+	ct    = ''
+		
+	def __init__(self,imap,uid):
+
+		self.uid   = ''
+		self.parts = []
+		self.ct    = ''
+
+		(t,d) = imap.uid('FETCH',uid,'(BODY)')
+		if d[0] is None:
+			raise IMAP4.error('No message with UID "%s" has been found' % uid)
+		self._parse_body_desc(d[0])
+
+	def part_ct(self,part):
+
+		return '%s/%s' % (self.parts[part][0],self.parts[part][1])
+
+	def fetch2file(self,imap,part,filename=None):
+
+		(t,d) = imap.uid('fetch',self.uid,'(BODY.PEEK[%i])' % (part+1))
+		if (t != "OK") or (len(d[0]) != 2):
+			raise IMAP4.error("could not retrieve part %s/%i" \
+					  % (self.uid, part+1))
+			
+		msg = d[0][1]
+		msg = base64.decodestring(msg)
+		if filename is None:
+			out_file = os.tmpfile()
+		else:
+			out_file = open(filename,'w+')
+			
+		out_file.write(msg)
+		out_file.seek(0)
+
+		if filename is None:
+			return out_file
+		else:
+			out_file.close()
+			return None
+
+
+	def _parse_body_desc(self,desc):
+
+		(_dummy,s) = self._parenthesis2seq(desc)[1]
+		
+		self.uid = s[1]
+
+		if type(s[3][0]) is not str:
+
+			# Multipart message
+			for i in s[3]:
+				if type(i) is str:
+					self.ct = i
+					break
+				self.parts.append(i)
+		else:
+			self.parts.append(s[3])
+			self.ct = s[3][0]
+
+
+	def _parenthesis2seq(self,s,ibeg=0):
+
+		seq = []
+		i = elmt_beg = ibeg
+
+		while i < len(s):
+
+			if s[i] == '(':
+				(i,tmp_seq) = self._parenthesis2seq(s,i+1)
+				elmt_beg = i
+				seq.append(tmp_seq)
+			
+			elif s[i] == ')':
+				if elmt_beg < i:
+					seq.append(s[elmt_beg:i])
+				return (i+1,seq)
+
+			elif s[i] == ' ':
+				if elmt_beg < i:
+					if s[elmt_beg] == '"':
+						seq.append(s[elmt_beg+1:i-1])
+					else:
+						seq.append(s[elmt_beg:i])
+				i = i+1
+				elmt_beg = i
+			else:
+				i = i+1
+
+		return (i,seq)
+
+
+
+class IMAP4_Mailbox:
+
+	url  = None
+	imap = None
+
+	def __init__(self,url):
+
+		self.url = None
+		self.url = MailboxURL(url)
+
+	def __del__(self):
+
+		if self.imap != None:
+			self.imap.logout()
+			self.imap = None
+		
+
+	def createBox(self):
+
+		self._login()
+		debug("Creating account: " + \
+		      repr(IMAPCALL(self.imap.create(self.url.path))))
+
+
+	def deleteBox(self):
+
+		self._login()
+		debug("Deleting account: " + \
+		      repr(IMAPCALL(self.imap.delete(self.url.path))))
+
+
+	def uploadMsg(self,msg):
+
+		self._login()
+		IMAPCALL(self.imap.append(self.url.path,None,time.gmtime(),msg))
+
+	def deleteMsg(self,uid):
+
+		self._login()
+		IMAPCALL(self.imap.select(self.url.path))
+		IMAPCALL(self.imap.uid('STORE',uid,'+flags', '(\\Deleted)'))
+		IMAPCALL(self.imap.expunge())
+		IMAPCALL(self.imap.close())
+
+	def saveMsg(self,uid):
+
+		self._login()
+		IMAPCALL(self.imap.select(self.url.path))
+		IMAPCALL(self.imap.uid('STORE',uid,'+flags','(\\seen)'))
+		IMAPCALL(self.imap.close())
+
+	def getWavMsgList(self,search_criterion):
+
+		self._login()
+		IMAPCALL(self.imap.select(self.url.path))
+
+		(t,d) = self.imap.uid('SEARCH',search_criterion)
+		IMAPCALL((t,d))
+
+		msg_list = []
+		for i in d[0].split():
+			body = IMAP4_MsgBODY(self.imap,i)
+			for p in range(len(body.parts)):
+				if body.part_ct(p) == 'AUDIO/X-WAV':
+					msg_list.append(body.uid)
+
+		IMAPCALL(self.imap.close())
+		return msg_list
+
+
+	def downloadWAV(self,msg_uid):
+		
+		self._login()
+		IMAPCALL(self.imap.select(self.url.path))
+		body = IMAP4_MsgBODY(self.imap,msg_uid)
+
+		fp = None
+		for p in range(len(body.parts)):
+			if body.part_ct(p) == 'AUDIO/X-WAV':
+				fp = body.fetch2file(self.imap,p)
+				break
+
+		IMAPCALL(self.imap.close())
+		return fp
+		
+
+	def downloadWAVs(self,search_criterion,file_prefix):
+
+		self._login()
+		IMAPCALL(self.imap.select(self.url.path))
+		
+		(t,d) = self.imap.uid('SEARCH',search_criterion)
+		IMAPCALL((t,d))
+
+		msg_list = []
+		for i in d[0].split():
+
+			body = IMAP4_MsgBODY(self.imap,i)
+		
+			for p in range(len(body.parts)):
+			
+				if body.part_ct(p) == 'AUDIO/X-WAV':
+					
+					filename = file_prefix + '-' + body.uid + '.wav'
+					msg_list.append(filename)
+					body.fetch2file(self.imap,p,filename)
+					
+		IMAPCALL(self.imap.close())
+		return msg_list
+
+	def _login(self):
+
+		if self.imap != None:
+			return
+
+		self.imap = IMAP4(self.url.host,self.url.port)
+		try:
+			IMAPCALL(self.imap.login(self.url.user,self.url.passwd))
+		except:
+			self.imap = None
+			raise
+		
diff --git a/apps/mailbox/mailbox.py b/apps/mailbox/mailbox.py
index 1c05df6a..2d93f5fb 100644
--- a/apps/mailbox/mailbox.py
+++ b/apps/mailbox/mailbox.py
@@ -3,8 +3,7 @@ import base64,time
 from log import *
 from ivr import *
 
-from com.iptel.log.Logger    import *
-from com.iptel.imap.imap4ext import *
+from imap_mailbox.imap4ext import *
 
 
 class IvrDialog(IvrDialogBase):
diff --git a/apps/mailbox/mailbox_query.py b/apps/mailbox/mailbox_query.py
index 7560b3bf..9bb52836 100644
--- a/apps/mailbox/mailbox_query.py
+++ b/apps/mailbox/mailbox_query.py
@@ -3,8 +3,7 @@ import os,weakref
 from log import *
 from ivr import *
 
-from com.iptel.log.Logger    import *
-from com.iptel.imap.imap4ext import *
+from imap_mailbox.imap4ext import *
 
 
 class List(list):