mirror of
https://github.com/kennethreitz/requests3.git
synced 2026-06-05 23:10:16 +00:00
Kenneth Reitz
149 lines
2.9 KiB
Python
149 lines
2.9 KiB
Python
# -*- coding: utf-8 -*-
|
|
|
|
"""
|
|
requests.core
|
|
~~~~~~~~~~~~~
|
|
|
|
This module implements the main Requests system.
|
|
|
|
:copyright: (c) 2011 by Kenneth Reitz.
|
|
:license: ISC, see LICENSE for more details.
|
|
"""
|
|
|
|
import httplib
|
|
import urllib
|
|
import urllib2
|
|
|
|
import requests.handler
|
|
|
|
__title__ = 'requests'
|
|
__version__ = '0.0.1'
|
|
__build__ = 0x000001
|
|
__author__ = 'Kenneth Reitz'
|
|
__license__ = 'ISC'
|
|
__copyright__ = 'Copyright 2011 Kenneth Reitz'
|
|
|
|
|
|
AUTHOAUTHS = []
|
|
|
|
|
|
class Request(object):
|
|
"""The :class:`Request` object. It's awesome.
|
|
"""
|
|
|
|
_METHODS = ('get', 'head', 'put', 'post', 'delete')
|
|
|
|
def __init__(self):
|
|
self.headers = dict()
|
|
self.method = None
|
|
self.response = None
|
|
self.auth = None
|
|
|
|
def __setattr__(self, key, val):
|
|
if key == 'method':
|
|
if not val.lower() in _METHODS:
|
|
raise InvalidMethod()
|
|
|
|
def send(self):
|
|
"""Sends the request. """
|
|
#set self.response
|
|
# return True / False
|
|
|
|
|
|
class Response(object):
|
|
"""The :class:`Request` object. It's awesome.
|
|
"""
|
|
|
|
def __init__(self):
|
|
self.content = None
|
|
self.status_code = None
|
|
self.headers = dict()
|
|
|
|
|
|
class AuthObject(object):
|
|
"""The :class:`AuthObject` is a simple HTTP Authentication token.
|
|
|
|
:param username: Username to authenticate with.
|
|
:param password: Password for given username.
|
|
"""
|
|
|
|
def __init__(self, username, password):
|
|
self.username = username
|
|
self.password = password
|
|
|
|
|
|
|
|
def get(url, params={}, headers={}, auth=None):
|
|
"""Sends a GET request. Returns :class:`Response` object.
|
|
"""
|
|
r = Request()
|
|
|
|
r.url = url
|
|
r.headers = headers
|
|
r.auth = _detect_auth(url, auth)
|
|
r.method = 'GET'
|
|
r.send()
|
|
|
|
return r.response
|
|
|
|
# return response object
|
|
|
|
|
|
def head(url, params={}, headers={}, auth=None):
|
|
"""Sends a HEAD request. Returns :class:`Response` object.
|
|
"""
|
|
pass
|
|
# return response object
|
|
|
|
|
|
def post(url, params={}, headers={}, auth=None):
|
|
"""Sends a POST request. Returns :class:`Response` object.
|
|
"""
|
|
pass
|
|
# return response object
|
|
|
|
|
|
def put(url, data='', headers={}, auth=None):
|
|
"""Sends a PUT request. Returns :class:`Response` object.
|
|
"""
|
|
pass
|
|
# return response object
|
|
|
|
|
|
def delete(url, params={}, headers={}, auth=None):
|
|
"""Sends a DELETE request. Returns :class:`Response` object.
|
|
"""
|
|
pass
|
|
# return response object
|
|
|
|
|
|
def add_autoauth(url, authobject):
|
|
global AUTOAUTHS
|
|
|
|
AUTOAUTHS.append((url, authobject))
|
|
|
|
|
|
def _detect_auth(url, auth):
|
|
|
|
return _get_autoauth(url) if not auth else auth
|
|
|
|
|
|
def _get_autoauth(url):
|
|
for (authauth_url, auth) in AUTOAUTHS:
|
|
if autoauth_url in url:
|
|
return auth
|
|
|
|
return None
|
|
|
|
class RequestException(Exception):
|
|
"""There was an ambiguous exception that occured while handling your request."""
|
|
|
|
class AuthenticationError(RequestException):
|
|
"""The authentication credentials provided were invalid."""
|
|
|
|
class URLRequired(RequestException):
|
|
"""A valid URL is required to make a request."""
|
|
|
|
class InvalidMethod(RequestException):
|
|
"""An inappropriate method was attempted."""
|
|
|