Gecko [ dataharbor.africa ]

Name	Size	Permission
?;medusa	[ DIR ]	drwxr-xr-x
?;scripts	[ DIR ]	drwxr-xr-x
?;skel	[ DIR ]	drwxr-xr-x
?;tests	[ DIR ]	drwxr-xr-x
?;ui	[ DIR ]	drwxr-xr-x
childutils.py	2.38 KB	-rw-r--r--
childutils.pyc	4.26 KB	-rw-r--r--
childutils.pyo	4.26 KB	-rw-r--r--
confecho.py	154 B	-rw-r--r--
confecho.pyc	485 B	-rw-r--r--
confecho.pyo	485 B	-rw-r--r--
datatypes.py	12.89 KB	-rw-r--r--
datatypes.pyc	17.6 KB	-rw-r--r--
datatypes.pyo	17.55 KB	-rw-r--r--
dispatchers.py	17.5 KB	-rw-r--r--
dispatchers.pyc	15.7 KB	-rw-r--r--
dispatchers.pyo	15.7 KB	-rw-r--r--
events.py	6.58 KB	-rw-r--r--
events.pyc	13 KB	-rw-r--r--
events.pyo	13 KB	-rw-r--r--
http.py	30.28 KB	-rw-r--r--
http.pyc	26.31 KB	-rw-r--r--
http.pyo	26.31 KB	-rw-r--r--
http_client.py	5.95 KB	-rw-r--r--
http_client.pyc	8.42 KB	-rw-r--r--
http_client.pyo	8.42 KB	-rw-r--r--
loggers.py	10.28 KB	-rw-r--r--
loggers.pyc	15.04 KB	-rw-r--r--
loggers.pyo	14.95 KB	-rw-r--r--
options.py	82.66 KB	-rw-r--r--
options.pyc	69.29 KB	-rw-r--r--
options.pyo	69.29 KB	-rw-r--r--
pidproxy.py	1.84 KB	-rw-r--r--
pidproxy.pyc	2.92 KB	-rw-r--r--
pidproxy.pyo	2.92 KB	-rw-r--r--
poller.py	6.54 KB	-rw-r--r--
poller.pyc	10.18 KB	-rw-r--r--
poller.pyo	10.18 KB	-rw-r--r--
process.py	35.4 KB	-rw-r--r--
process.pyc	28.68 KB	-rw-r--r--
process.pyo	28.68 KB	-rw-r--r--
rpcinterface.py	34.71 KB	-rw-r--r--
rpcinterface.pyc	29.7 KB	-rw-r--r--
rpcinterface.pyo	29.7 KB	-rw-r--r--
socket_manager.py	3.04 KB	-rw-r--r--
socket_manager.pyc	5.35 KB	-rw-r--r--
socket_manager.pyo	5.35 KB	-rw-r--r--
states.py	1.62 KB	-rw-r--r--
states.pyc	2.23 KB	-rw-r--r--
states.pyo	2.23 KB	-rw-r--r--
supervisorctl.py	47.77 KB	-rw-r--r--
supervisorctl.pyc	43.63 KB	-rw-r--r--
supervisorctl.pyo	43.63 KB	-rw-r--r--
supervisord.py	14.04 KB	-rw-r--r--
supervisord.pyc	12.43 KB	-rw-r--r--
supervisord.pyo	12.32 KB	-rw-r--r--
version.txt	5 B	-rw-r--r--
web.py	22.99 KB	-rw-r--r--
web.pyc	18.87 KB	-rw-r--r--
web.pyo	18.87 KB	-rw-r--r--
xmlrpc.py	21.63 KB	-rw-r--r--
xmlrpc.pyc	20.9 KB	-rw-r--r--
xmlrpc.pyo	20.9 KB	-rw-r--r--

Code Editor : http_client.py

# this code based on Daniel Krech's RDFLib HTTP client code (see rdflib.net)

import sys
import socket
import base64
from urlparse import urlparse

from supervisor.medusa import asynchat_25 as asynchat

CR="\x0d"
LF="\x0a"
CRLF=CR+LF

class Listener(object):

def status(self, url, status):
        pass

def error(self, url, error):
        sys.stderr.write("%s %s\n" % (url, error))

def response_header(self, url, name, value):
        pass

def done(self, url):
        pass

def feed(self, url, data):
        sys.stdout.write(data)
        sys.stdout.flush()

def close(self, url):
        pass

class HTTPHandler(object, asynchat.async_chat):
    def __init__(self, listener, username='', password=None):
        super(HTTPHandler, self).__init__()
        asynchat.async_chat.__init__(self)
        self.listener = listener
        self.user_agent = 'Supervisor HTTP Client'
        self.buffer = ''
        self.set_terminator(CRLF)
        self.connected = 0
        self.part = self.status_line
        self.chunk_size = 0
        self.chunk_read = 0
        self.length_read = 0
        self.length = 0
        self.encoding = None
        self.username = username
        self.password = password
        self.url = None
        self.error_handled = False

def get(self, serverurl, path):
        if self.url != None:
            raise AssertionError('Already doing a get')
        self.url = serverurl + path
        scheme, host, path_ignored, params, query, fragment = urlparse(self.url)
        if not scheme in ("http", "unix"):
            raise NotImplementedError
        self.host = host
        if ":" in host:
            hostname, port = host.split(":", 1)
            port = int(port)
        else:
            hostname = host
            port = 80

self.path = path
        self.port = port

if scheme == "http":
            ip = hostname
            self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
            self.connect((ip, self.port))
        elif scheme == "unix":
            socketname = serverurl[7:]
            self.create_socket(socket.AF_UNIX, socket.SOCK_STREAM)
            self.connect(socketname)

def close (self):
        self.listener.close(self.url)
        self.connected = 0
        self.del_channel()
        self.socket.close()
        self.url = "CLOSED"

def header(self, name, value):
        self.push('%s: %s' % (name, value))
        self.push(CRLF)

def handle_error (self):
        if self.error_handled == True:
            return
        if 1 or self.connected:
            t,v,tb = sys.exc_info()
            msg = 'Cannot connect, error: %s (%s)' % (t, v)
            self.listener.error(self.url, msg)
            self.part = self.ignore
            self.close()
            self.error_handled = True
            del t
            del v
            del tb

def handle_connect(self):
        self.connected = 1
        method = "GET"
        version = "HTTP/1.1"
        self.push("%s %s %s" % (method, self.path, version))
        self.push(CRLF)
        self.header("Host", self.host)

self.header('Accept-Encoding', 'chunked')
        self.header('Accept', '*/*')
        self.header('User-agent', self.user_agent)
        if self.password:
            unencoded = '%s:%s' % (self.username, self.password)
            encoded = base64.encodestring(unencoded).replace('\n', '')
            self.header('Authorization', 'Basic %s' % encoded)
        self.push(CRLF)
        self.push(CRLF)

def feed(self, data):
        self.listener.feed(self.url, data)

def collect_incoming_data(self, bytes):
        self.buffer = self.buffer + bytes
        if self.part==self.body:
            self.feed(self.buffer)
            self.buffer = ''

def found_terminator(self):
        self.part()
        self.buffer = ''

def ignore(self):
        self.buffer = ''

def status_line(self):
        line = self.buffer

version, status, reason = line.split(None, 2)
        status = int(status)
        if not version.startswith('HTTP/'):
            raise ValueError(line)

self.listener.status(self.url, status)

if status == 200:
            self.part = self.headers
        else:
            self.part = self.ignore
            msg = 'Cannot read, status code %s' % status
            self.listener.error(self.url, msg)
            self.close()
        return version, status, reason

def headers(self):
        line = self.buffer
        if not line:
            if self.encoding=="chunked":
                self.part = self.chunked_size
            else:
                self.part = self.body
                self.set_terminator(self.length)
        else:
            name, value = line.split(":", 1)
            if name and value:
                name = name.lower()
                value = value.strip()
                if name=="Transfer-Encoding".lower():
                    self.encoding = value
                elif name=="Content-Length".lower():
                    self.length = int(value)
                self.response_header(name, value)

def response_header(self, name, value):
        self.listener.response_header(self.url, name, value)

def body(self):
        self.done()
        self.close()

def done(self):
        self.listener.done(self.url)

def chunked_size(self):
        line = self.buffer
        if not line:
            return
        chunk_size = int(line.split()[0], 16)
        if chunk_size==0:
            self.part = self.trailer
        else:
            self.set_terminator(chunk_size)
            self.part = self.chunked_body
        self.length += chunk_size

def chunked_body(self):
        line = self.buffer
        self.set_terminator(CRLF)
        self.part = self.chunked_size
        self.feed(line)

def trailer(self):
        # http://www.w3.org/Protocols/rfc2616/rfc2616-sec3.html#sec3.6.1
        # trailer        = *(entity-header CRLF)
        line = self.buffer
        if line==CRLF:
            self.done()
            self.close()

${this.title}

Code Editor : http_client.py