Gecko [ www.finalhopeacademy.com ]

Name	Size	Permission
folder	[ DIR ]	drwxr-xr-x
repository	[ DIR ]	drwxr-xr-x
ui	[ DIR ]	drwxr-xr-x
utils	[ DIR ]	drwxr-xr-x
CustomConfig.py	10.68 KB	-rw-r--r--
CustomConfig.pyc	11.28 KB	-rw-r--r--
CustomConfig.pyo	11.28 KB	-rw-r--r--
__init__.py	833 B	-rw-r--r--
__init__.pyc	966 B	-rw-r--r--
__init__.pyo	966 B	-rw-r--r--
accounts.py	23.23 KB	-rw-r--r--
accounts.pyc	18.19 KB	-rw-r--r--
accounts.pyo	18.19 KB	-rw-r--r--
emailutil.py	1.52 KB	-rw-r--r--
emailutil.pyc	827 B	-rw-r--r--
emailutil.pyo	827 B	-rw-r--r--
error.py	1.41 KB	-rw-r--r--
error.pyc	2.11 KB	-rw-r--r--
error.pyo	2.11 KB	-rw-r--r--
globals.py	299 B	-rw-r--r--
globals.pyc	488 B	-rw-r--r--
globals.pyo	488 B	-rw-r--r--
imaplib2.py	92 KB	-rw-r--r--
imaplib2.pyc	80.04 KB	-rw-r--r--
imaplib2.pyo	73.8 KB	-rw-r--r--
imaplibutil.py	8.7 KB	-rw-r--r--
imaplibutil.pyc	8.9 KB	-rw-r--r--
imaplibutil.pyo	8.9 KB	-rw-r--r--
imapserver.py	32.97 KB	-rw-r--r--
imapserver.pyc	24.66 KB	-rw-r--r--
imapserver.pyo	24.66 KB	-rw-r--r--
imaputil.py	11.99 KB	-rw-r--r--
imaputil.pyc	10.42 KB	-rw-r--r--
imaputil.pyo	10.42 KB	-rw-r--r--
init.py	18.36 KB	-rw-r--r--
init.pyc	13.53 KB	-rw-r--r--
init.pyo	13.53 KB	-rw-r--r--
localeval.py	1.65 KB	-rw-r--r--
localeval.pyc	1.28 KB	-rw-r--r--
localeval.pyo	1.28 KB	-rw-r--r--
mbnames.py	3.59 KB	-rw-r--r--
mbnames.pyc	2.87 KB	-rw-r--r--
mbnames.pyo	2.87 KB	-rw-r--r--
syncmaster.py	1.67 KB	-rw-r--r--
syncmaster.pyc	1.15 KB	-rw-r--r--
syncmaster.pyo	1.15 KB	-rw-r--r--
threadutil.py	8.21 KB	-rw-r--r--
threadutil.pyc	8.26 KB	-rw-r--r--
threadutil.pyo	8.26 KB	-rw-r--r--

Code Editor : imaplibutil.py

# imaplib utilities
# Copyright (C) 2002-2015 John Goerzen & contributors
#    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.
#
#    This program is distributed in the hope that it will be useful,
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#    GNU General Public License for more details.
#
#    You should have received a copy of the GNU General Public License
#    along with this program; if not, write to the Free Software
#    Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA

import os
import fcntl
import time
import subprocess
from sys import exc_info
import threading
from hashlib import sha1
import socket
import errno

from offlineimap.ui import getglobalui
from offlineimap import OfflineImapError
from offlineimap.imaplib2 import IMAP4, IMAP4_SSL, zlib, InternalDate, Mon2num

class UsefulIMAPMixIn(object):
    def __getselectedfolder(self):
        if self.state == 'SELECTED':
            return self.mailbox
        return None

def select(self, mailbox='INBOX', readonly=False, force=False):
        """Selects a mailbox on the IMAP server

:returns: 'OK' on success, nothing if the folder was already
        selected or raises an :exc:`OfflineImapError`."""

if self.__getselectedfolder() == mailbox and \
            self.is_readonly == readonly and \
            not force:
            # No change; return.
            return
        try:
            result = super(UsefulIMAPMixIn, self).select(mailbox, readonly)
        except self.readonly as e:
            # pass self.readonly to our callers
            raise
        except self.abort as e:
            # self.abort is raised when we are supposed to retry
            errstr = "Server '%s' closed connection, error on SELECT '%s'. Ser"\
                "ver said: %s" % (self.host, mailbox, e.args[0])
            severity = OfflineImapError.ERROR.FOLDER_RETRY
            raise OfflineImapError(errstr, severity), None, exc_info()[2]
        if result[0] != 'OK':
            #in case of error, bail out with OfflineImapError
            errstr = "Error SELECTing mailbox '%s', server reply:\n%s" %\
                (mailbox, result)
            severity = OfflineImapError.ERROR.FOLDER
            raise OfflineImapError(errstr, severity)
        return result

# Overrides private function from IMAP4 (@imaplib2)
    def _mesg(self, s, tn=None, secs=None):
        new_mesg(self, s, tn, secs)

# Overrides private function from IMAP4 (@imaplib2)
    def open_socket(self):
        """open_socket()
        Open socket choosing first address family available."""
        msg = (-1, 'could not open socket')
        for res in socket.getaddrinfo(self.host, self.port, self.af, socket.SOCK_STREAM):
            af, socktype, proto, canonname, sa = res
            try:
                # use socket of our own, possiblly socksified socket.
                s = self.socket(af, socktype, proto)
            except socket.error, msg:
                continue
            try:
                for i in (0, 1):
                    try:
                        s.connect(sa)
                        break
                    except socket.error, msg:
                        if len(msg.args) < 2 or msg.args[0] != errno.EINTR:
                            raise
                else:
                    raise socket.error(msg)
            except socket.error, msg:
                s.close()
                continue
            break
        else:
            raise socket.error(msg)

return s

class IMAP4_Tunnel(UsefulIMAPMixIn, IMAP4):
    """IMAP4 client class over a tunnel

Instantiate with: IMAP4_Tunnel(tunnelcmd)

tunnelcmd -- shell command to generate the tunnel.
    The result will be in PREAUTH stage."""

def __init__(self, tunnelcmd, **kwargs):
        if "use_socket" in kwargs:
            self.socket = kwargs['use_socket']
            del kwargs['use_socket']
        IMAP4.__init__(self, tunnelcmd, **kwargs)

def open(self, host, port):
        """The tunnelcmd comes in on host!"""

self.host = host
        self.process = subprocess.Popen(host, shell=True, close_fds=True,
                        stdin=subprocess.PIPE, stdout=subprocess.PIPE)
        (self.outfd, self.infd) = (self.process.stdin, self.process.stdout)
        # imaplib2 polls on this fd
        self.read_fd = self.infd.fileno()

self.set_nonblocking(self.read_fd)

def set_nonblocking(self, fd):
        """Mark fd as nonblocking"""

# get the file's current flag settings
        fl = fcntl.fcntl(fd, fcntl.F_GETFL)
        # clear non-blocking mode from flags
        fl = fl & ~os.O_NONBLOCK
        fcntl.fcntl(fd, fcntl.F_SETFL, fl)

def read(self, size):
        """data = read(size)
        Read at most 'size' bytes from remote."""

if self.decompressor is None:
            return os.read(self.read_fd, size)

if self.decompressor.unconsumed_tail:
            data = self.decompressor.unconsumed_tail
        else:
            data = os.read(self.read_fd, 8192)

return self.decompressor.decompress(data, size)

def send(self, data):
        if self.compressor is not None:
            data = self.compressor.compress(data)
            data += self.compressor.flush(zlib.Z_SYNC_FLUSH)
        self.outfd.write(data)

def shutdown(self):
        self.infd.close()
        self.outfd.close()
        self.process.wait()

def new_mesg(self, s, tn=None, secs=None):
            if secs is None:
                secs = time.time()
            if tn is None:
                tn = threading.currentThread().getName()
            tm = time.strftime('%M:%S', time.localtime(secs))
            getglobalui().debug('imap', '  %s.%02d %s %s' % (tm, (secs*100)%100, tn, s))

class WrappedIMAP4_SSL(UsefulIMAPMixIn, IMAP4_SSL):
    """Improved version of imaplib.IMAP4_SSL overriding select()."""

def __init__(self, *args, **kwargs):
        if "af" in kwargs:
            self.af = kwargs['af']
            del kwargs['af']
        if "use_socket" in kwargs:
            self.socket = kwargs['use_socket']
            del kwargs['use_socket']
        self._fingerprint = kwargs.get('fingerprint', None)
        if type(self._fingerprint) != type([]):
            self._fingerprint = [self._fingerprint]
        if 'fingerprint' in kwargs:
            del kwargs['fingerprint']
        super(WrappedIMAP4_SSL, self).__init__(*args, **kwargs)

def open(self, host=None, port=None):
        if not self.ca_certs and not self._fingerprint:
            raise OfflineImapError("No CA certificates "
              "and no server fingerprints configured.  "
              "You must configure at least something, otherwise "
              "having SSL helps nothing.", OfflineImapError.ERROR.REPO)
        super(WrappedIMAP4_SSL, self).open(host, port)
        if self._fingerprint:
            # compare fingerprints
            fingerprint = sha1(self.sock.getpeercert(True)).hexdigest()
            if fingerprint not in self._fingerprint:
                raise OfflineImapError("Server SSL fingerprint '%s' "
                      "for hostname '%s' "
                      "does not match configured fingerprint(s) %s.  "
                      "Please verify and set 'cert_fingerprint' accordingly "
                      "if not set yet."%
                      (fingerprint, host, self._fingerprint),
                      OfflineImapError.ERROR.REPO)

class WrappedIMAP4(UsefulIMAPMixIn, IMAP4):
    """Improved version of imaplib.IMAP4 overriding select()."""

def Internaldate2epoch(resp):
    """Convert IMAP4 INTERNALDATE to UT.

Returns seconds since the epoch."""

from calendar import timegm

mo = InternalDate.match(resp)
    if not mo:
        return None

mon = Mon2num[mo.group('mon')]
    zonen = mo.group('zonen')

day = int(mo.group('day'))
    year = int(mo.group('year'))
    hour = int(mo.group('hour'))
    min = int(mo.group('min'))
    sec = int(mo.group('sec'))
    zoneh = int(mo.group('zoneh'))
    zonem = int(mo.group('zonem'))

# INTERNALDATE timezone must be subtracted to get UT

zone = (zoneh*60 + zonem)*60
    if zonen == '-':
        zone = -zone

tt = (year, mon, day, hour, min, sec, -1, -1, -1)

return timegm(tt) - zone

${this.title}

Code Editor : imaplibutil.py