home *** CD-ROM | disk | FTP | other *** search
- # Source Generated with Decompyle++
- # File: in.pyc (Python 1.5)
-
- import os
- import rfc822
- import string
- import tempfile
-
- class Message(rfc822.Message):
-
- def __init__(self, fp, seekable = 1):
- rfc822.Message.__init__(self, fp, seekable)
- self.encodingheader = self.getheader('content-transfer-encoding')
- self.typeheader = self.getheader('content-type')
- self.parsetype()
- self.parseplist()
-
-
- def parsetype(self):
- str = self.typeheader
- if str == None:
- str = 'text/plain'
-
- if ';' in str:
- i = string.index(str, ';')
- self.plisttext = str[i:]
- str = str[:i]
- else:
- self.plisttext = ''
- fields = string.splitfields(str, '/')
- for i in range(len(fields)):
- fields[i] = string.lower(string.strip(fields[i]))
-
- self.type = string.joinfields(fields, '/')
- self.maintype = fields[0]
- self.subtype = string.joinfields(fields[1:], '/')
-
-
- def parseplist(self):
- str = self.plisttext
- self.plist = []
- while str[:1] == ';':
- str = str[1:]
- if ';' in str:
- end = string.index(str, ';')
- else:
- end = len(str)
- f = str[:end]
- if '=' in f:
- i = string.index(f, '=')
- f = string.lower(string.strip(f[:i])) + '=' + string.strip(f[i + 1:])
-
- self.plist.append(string.strip(f))
- str = str[end:]
-
-
- def getplist(self):
- return self.plist
-
-
- def getparam(self, name):
- name = string.lower(name) + '='
- n = len(name)
- for p in self.plist:
- pass
-
- return None
-
-
- def getparamnames(self):
- result = []
- for p in self.plist:
- i = string.find(p, '=')
-
- return result
-
-
- def getencoding(self):
- if self.encodingheader == None:
- return '7bit'
-
- return string.lower(self.encodingheader)
-
-
- def gettype(self):
- return self.type
-
-
- def getmaintype(self):
- return self.maintype
-
-
- def getsubtype(self):
- return self.subtype
-
-
- _prefix = None
-
- def choose_boundary():
- global _prefix
- import time
- import random
- if _prefix == None:
- import socket
- import os
- hostid = socket.gethostbyname(socket.gethostname())
-
- try:
- uid = `os.getuid()`
- except:
- uid = '1'
-
-
- try:
- pid = `os.getpid()`
- except:
- pid = '1'
-
- _prefix = hostid + '.' + uid + '.' + pid
-
- timestamp = '%.3f' % time.time()
- seed = `random.randint(0, 32767)`
- return _prefix + '.' + timestamp + '.' + seed
-
-
- def decode(input, output, encoding):
- if encoding == 'base64':
- import base64
- return base64.decode(input, output)
-
- if encoding == 'quoted-printable':
- import quopri
- return quopri.decode(input, output)
-
- if encoding in ('uuencode', 'x-uuencode', 'uue', 'x-uue'):
- import uu
- return uu.decode(input, output)
-
- if decodetab.has_key(encoding):
- pipethrough(input, decodetab[encoding], output)
- else:
- raise ValueError, 'unknown Content-Transfer-Encoding: %s' % encoding
-
-
- def encode(input, output, encoding):
- if encoding == 'base64':
- import base64
- return base64.encode(input, output)
-
- if encoding == 'quoted-printable':
- import quopri
- return quopri.encode(input, output, 0)
-
- if encoding in ('uuencode', 'x-uuencode', 'uue', 'x-uue'):
- import uu
- return uu.encode(input, output)
-
- if encodetab.has_key(encoding):
- pipethrough(input, encodetab[encoding], output)
- else:
- raise ValueError, 'unknown Content-Transfer-Encoding: %s' % encoding
-
- uudecode_pipe = '(\nTEMP=/tmp/@uu.$$\nsed "s%^begin [0-7][0-7]* .*%begin 600 $TEMP%" | uudecode\ncat $TEMP\nrm $TEMP\n)'
- decodetab = {
- 'uuencode': uudecode_pipe,
- 'x-uuencode': uudecode_pipe,
- 'uue': uudecode_pipe,
- 'x-uue': uudecode_pipe,
- 'quoted-printable': 'mmencode -u -q',
- 'base64': 'mmencode -u -b' }
- encodetab = {
- 'x-uuencode': 'uuencode tempfile',
- 'uuencode': 'uuencode tempfile',
- 'x-uue': 'uuencode tempfile',
- 'uue': 'uuencode tempfile',
- 'quoted-printable': 'mmencode -q',
- 'base64': 'mmencode -b' }
-
- def pipeto(input, command):
- pipe = os.popen(command, 'w')
- copyliteral(input, pipe)
- pipe.close()
-
-
- def pipethrough(input, command, output):
- tempname = tempfile.mktemp()
-
- try:
- temp = open(tempname, 'w')
- except IOError:
- print '*** Cannot create temp file', `tempname`
- return None
-
- copyliteral(input, temp)
- temp.close()
- pipe = os.popen(command + ' <' + tempname, 'r')
- copybinary(pipe, output)
- pipe.close()
- os.unlink(tempname)
-
-
- def copyliteral(input, output):
- while 1:
- line = input.readline()
- if not line:
- break
-
- output.write(line)
-
-
- def copybinary(input, output):
- BUFSIZE = 8192
- while 1:
- line = input.read(BUFSIZE)
- if not line:
- break
-
- output.write(line)
-
-