Skip to content
Snippets Groups Projects
ActivityRequest.php 3.18 KiB
Newer Older
  • Learn to ignore specific revisions
  • <?php
    
    /**
     * @copyright  2021 Podlibre
     * @license    https://www.gnu.org/licenses/agpl-3.0.en.html AGPL3
     * @link       https://castopod.org/
     */
    
    namespace ActivityPub;
    
    use CodeIgniter\I18n\Time;
    use phpseclib\Crypt\RSA;
    
    class ActivityRequest
    {
        /**
         * @var \CodeIgniter\HTTP\CURLRequest
         */
        protected $request;
    
        /**
         * @var \CodeIgniter\HTTP\URI
         */
        protected $uri;
    
        /**
         * @var \ActivityPub\Core\Activity|null
         */
        protected $activity;
    
        /**
         * @var array
         */
        protected $options = [
            'headers' => [
                'Content-Type' => 'application/activity+json',
                'Accept' => 'application/activity+json', // TODO: outgoing and incoming requests
            ],
        ];
    
        /**
         * @param string $uri
         * @param string $activityPayload
         */
        public function __construct($uri, $activityPayload = null)
        {
            $this->request = \Config\Services::curlrequest();
    
            if ($activityPayload) {
                $this->request->setBody($activityPayload);
            }
    
            $this->uri = new \CodeIgniter\HTTP\URI($uri);
        }
    
        public function post()
        {
            // send Message to Fediverse instance
            $this->request->post($this->uri, $this->options);
        }
    
        public function get()
        {
            return $this->request->get($this->uri, $this->options);
        }
    
        public function getDomain()
        {
            return $this->uri->getHost() .
                ($this->uri->getPort() ? ':' . $this->uri->getPort() : '');
        }
    
        public function sign($keyId, $privateKey)
        {
            $rsa = new RSA();
            $rsa->loadKey($privateKey); // private key
            $rsa->setHash('sha256');
            $rsa->setSignatureMode(RSA::SIGNATURE_PKCS1);
    
            $path =
                $this->uri->getPath() .
                ($this->uri->getQuery() ? "?{$this->uri->getQuery()}" : '');
            $host = $this->uri->getHost();
            $date = Time::now('GMT')->format('D, d M Y H:i:s T');
            $digest = 'SHA-256=' . base64_encode($this->getBodyDigest());
            $contentType = $this->options['headers']['Content-Type'];
            $contentLength = strval(strlen($this->request->getBody()));
            $userAgent = 'Castopod';
    
            $plainText = "(request-target): post $path\nhost: $host\ndate: $date\ndigest: $digest\ncontent-type: $contentType\ncontent-length: $contentLength\nuser-agent: $userAgent";
    
            $signature = $rsa->sign($plainText);
    
            $signatureHeader =
                'keyId="' .
                $keyId .
                '",algorithm="rsa-sha256",headers="(request-target) host date digest content-type content-length user-agent",signature="' .
                base64_encode($signature) .
                '"';
    
            $this->options = [
                'headers' => [
                    'Content-Type' => $contentType,
                    'Content-Length' => $contentLength,
                    'Authorization' => "Signature $signatureHeader",
                    'Signature' => $signatureHeader,
                    'Host' => $host,
                    'Date' => $date,
                    'User-Agent' => $userAgent,
                    'Digest' => $digest,
                ],
            ];
        }
    
        protected function getBodyDigest()
        {
            return hash('sha256', $this->request->getBody(), true);
        }
    }