Response.php

<?php
/**
 * @file    response.php
 * @brief   http response class
 *
 * @author  Frank Hellenkamp <jonas@depage.net>
 **/

namespace Depage\Http;

class Response {
    /**
     * @brief headers
     **/
    protected $headers = array();

    /**
     * @brief body
     **/
    protected $body = "";

    /**
     * @brief info
     **/
    protected $info = array();

    /**
     * @brief isRedirect
     **/
    protected $isRedirect = false;

    /**
     * @brief redirectUrl
     **/
    protected $redirectUrl = "";

    /**
     * @brief lastModified
     **/
    protected $lastModified;

    /**
     * @brief contentType
     **/
    protected $contentType = "";

    /**
     * @brief charset
     **/
    protected $charset = "";

    /**
     * @brief httpCode
     **/
    protected $httpCode = "";

    /**
     * @brief httpMessage
     **/
    protected $httpMessage = "";

    /**
     * @brief fiels
     **/
    protected static $fields = array(
        "headers",
        "body",
        "info",
        "contentType",
        "charset",
        "httpCode",
        "httpMessage",
        "isRedirect",
        "redirectUrl",
        "lastModified",
    );

    // {{{ __construct()
    public function __construct($body = "", $headers = [], $info = []) {
        $this->lastModified = new \DateTimeImmutable("now");
        $this->setBody($body);
        $this->info = $info;

        if (!is_array($headers)) {
            $headers = explode("\r\n", $headers);
        }

        foreach ($headers as $header) {
            $this->addHeader($header);
        }
    }
    // }}}
    // {{{ setBody()
    /**
     * @brief setBody
     *
     * @param mixed $$
     * @return void
     **/
    public function setBody($body = "")
    {
        if (is_array($body)) {
            $this->body = implode('', $body);
        } else {
            $this->body = (string) $body;
        }

        return $this;
    }
    // }}}
    // {{{ getJson()
    /**
     * @brief getJson
     *
     * @param mixed $param
     * @return void
     **/
    public function getJson()
    {
        $data = json_decode((string) $this->body, true);
        if (JSON_ERROR_NONE !== json_last_error()) {
            throw new \Exception('Unable to parse response body into JSON: ' . json_last_error());
        }

        return $data === null ? array() : $data;
    }
    // }}}
    // {{{ getXml()
    /**
     * @brief getXml
     *
     * @param mixed $param
     * @return void
     **/
    public function getXml()
    {
        $useErrors = libxml_use_internal_errors(true);

        $doc = new \DOMDocument("1.0", "UTF-8");
        if (!$doc->loadHtml($this->body)) {
            throw new \Exception('Unable to parse response body into XML: ' . libxml_get_last_error());
        }

        libxml_use_internal_errors($useErrors);

        return $doc;
    }
    // }}}
    // {{{ addHeader()
    /**
     * @brief addHeader
     *
     * @param mixed $
     * @return void
     **/
    public function addHeader($headerLine)
    {
        if (empty($headerLine)) {
            return;
        }
        $this->headers[] = $headerLine;

        list($key, $value) = array_replace(array("", ""), explode(": ", $headerLine));

        $key = strtolower($key);

        if (substr($key, 0, 4) == "http") {
            $data = explode(' ', $headerLine, 3);
            $this->httpCode = $data[1];
            $this->httpMessage = $data[2] ?? "";
        } else if ($key == "content-type") {
            preg_match('/([\w\/+]+)(;\s+charset=(\S+))?/i', $value, $matches );
            if (isset($matches[1])) {
                $this->contentType = $matches[1];
            }
            if (isset($matches[3])) {
                $this->charset = $matches[3];
            }
        } else if ($key == "location") {
            $this->isRedirect = true;
            $this->redirectUrl = $value;
        } else if ($key == "last-modified") {
            $this->lastModified = new \DateTimeImmutable($value);
        }

        return $this;
    }
    // }}}
    // {{{ sendHeaders()
    /**
     * @brief sendHeaders
     *
     * @param mixed
     * @return void
     **/
    public function sendHeaders()
    {
        foreach($this->headers as $header) {
            header($header);
        }
    }
    // }}}
    // {{{ getStatus()
    /**
     * @brief getStatus
     *
     * @param mixed
     * @return void
     **/
    public function getStatus()
    {
        $matches = [];
        preg_match('|HTTP/[\d\.]+\s+(\d+)(\s+.*)?|', $this->headers[0] ?? '', $matches);

        return (object) [
            'code' => $matches[1] ?? '',
            'message' => $matches[2] ?? ''
        ];
    }
    // }}}
    // {{{ getHeader()
    /**
     * @brief getHeader
     *
     * @param mixed $key
     * @return void
     **/
    public function getHeader($search)
    {
        foreach($this->headers as $header) {
            list($key, $value) = array_replace(array("", ""), explode(": ", $header));
            if (strtolower($key) == strtolower($search)) {
                return trim($value);
            }
        }

        return "";
    }
    // }}}

    // {{{ __get()
    /**
     * @brief __get
     *
     * @param mixed $
     * @return void
     **/
    public function __get($key)
    {
        if (in_array($key, static::$fields)) {
            return $this->$key;
        }
    }
    // }}}
    // {{{ __call()
    /**
     * @brief __get
     *
     * @param mixed $
     * @return void
     **/
    public function __call($name, $arguments)
    {
        $prefix = substr($name, 0, 3);
        $key = lcfirst(substr($name, 3));

        if ($prefix == "get" && in_array($key, static::$fields)) {
            return $this->$key;
        }
    }
    // }}}
    // {{{ isRedirect()
    /**
     * @brief isRedirect
     *
     * @param mixed
     * @return void
     **/
    public function isRedirect()
    {
        return $this->isRedirect;
    }
    // }}}

    // {{{ __toString()
    public function __toString() {
        return (string) $this->body;
    }
    // }}}
}

/* vim:set ft=php sw=4 sts=4 fdm=marker et : */