StreamClient.php

<?php
 
namespace ceLTIc\LTI\Http;
 
use ceLTIc\LTI\Http\HttpMessage;
 
class StreamClient implements ClientInterface
{
 
    public function send(HttpMessage $message)
    {
        if (!is_array($message->requestHeaders)) {
            $message->requestHeaders = array();
        }
        if (count(preg_grep("/^Accept:/i", $message->requestHeaders)) === 0) {
            $message->requestHeaders[] = 'Accept: */*';
        }
        if (($message->getMethod() !== 'GET') && !is_null($message->request) &&
            (count(preg_grep("/^Content-Type:/i", $message->requestHeaders)) === 0)) {
            $message->requestHeaders[] = 'Content-Type: application/x-www-form-urlencoded; charset=UTF-8';
        }
        $opts = [
            'method' => $message->getMethod(),
            'content' => $message->request,
            'header' => $message->requestHeaders,
            'ignore_errors' => true,
        ];
 
        $message->requestHeaders = "{$message->getMethod()} {$message->getUrl()}\n" . implode("\n", $message->requestHeaders);
        try {
            $ctx = stream_context_create(['http' => $opts]);
            $fp = @fopen($message->getUrl(), 'rb', false, $ctx);
            if ($fp) {
                $resp = stream_get_contents($fp);
                $message->ok = $resp !== false;
                if ($message->ok) {
                    $message->response = $resp;
                    // see http://php.net/manual/en/reserved.variables.httpresponseheader.php
                    if (isset($http_response_header[0])) {
                        $message->responseHeaders = trim(implode("\n", $http_response_header));
                        if (preg_match("/HTTP\/\d.\d\s+(\d+)/", $http_response_header[0], $out)) {
                            $message->status = $out[1];
                        }
                        $message->ok = $message->status < 400;
                        if (!$message->ok) {
                            $message->error = $http_response_header[0];
                        }
                    }
                    return $message->ok;
                }
            }
        } catch (\Exception $e) {
            $message->error = $e->getMessage();
            $message->ok = false;
            return false;
        }
        $message->error = error_get_last()["message"];
        $message->ok = false;
        return false;
    }
 
}