Differential D8930 Diff 21449 externals/twilio-php/Services/Twilio/HttpStream.php

Changeset View

Standalone View

externals/twilio-php/Services/Twilio/HttpStream.php

This file was added.

Property	Old Value	New Value
File Mode	null	100755

				<?php
				/**
				* HTTP Stream version of the TinyHttp Client used to connect to Twilio
				* services.
				*/

				class Services_Twilio_HttpStreamException extends ErrorException {}

				class Services_Twilio_HttpStream {

				private $auth_header = null;
				private $uri = null;
				private $debug = false;
				private static $default_options = array(
				"http" => array(
				"headers" => "",
				"timeout" => 60,
				"follow_location" => true,
				"ignore_errors" => true,
				),
				"ssl" => array(),
				);
				private $options = array();

				public function __construct($uri = '', $kwargs = array()) {
				$this->uri = $uri;
				if (isset($kwargs['debug'])) {
				$this->debug = true;
				}
				if (isset($kwargs['http_options'])) {
				$this->options = $kwargs['http_options'] + self::$default_options;
				} else {
				$this->options = self::$default_options;
				}
				}

				public function __call($name, $args) {
				list($res, $req_headers, $req_body) = $args + array(0, array(), '');

				$request_options = $this->options;
				$url = $this->uri . $res;

				if (isset($req_body) && strlen($req_body) > 0) {
				$request_options['http']['content'] = $req_body;
				}

				foreach($req_headers as $key => $value) {
				$request_options['http']['header'] .= sprintf("%s: %s\r\n", $key, $value);
				}

				if (isset($this->auth_header)) {
				$request_options['http']['header'] .= $this->auth_header;
				}

				$request_options['http']['method'] = strtoupper($name);
				$request_options['http']['ignore_errors'] = true;

				if ($this->debug) {
				error_log(var_export($request_options, true));
				}
				$ctx = stream_context_create($request_options);
				$result = file_get_contents($url, false, $ctx);

				if (false === $result) {
				throw new Services_Twilio_HttpStreamException(
				"Unable to connect to service");
				}

				$status_header = array_shift($http_response_header);
				if (1 !== preg_match('#HTTP/\d+\.\d+ (\d+)#', $status_header, $matches)) {
				throw new Services_Twilio_HttpStreamException(
				"Unable to detect the status code in the HTTP result.");
				}

				$status_code = intval($matches[1]);
				$response_headers = array();

				foreach($http_response_header as $header) {
				list($key, $val) = explode(":", $header);
				$response_headers[trim($key)] = trim($val);
				}

				return array($status_code, $response_headers, $result);
				}

				public function authenticate($user, $pass) {
				if (isset($user) && isset($pass)) {
				$this->auth_header = sprintf("Authorization: Basic %s",
				base64_encode(sprintf("%s:%s", $user, $pass)));
				} else {
				$this->auth_header = null;
				}
				}
				}