activityClient = new \GuzzleHttp\Client([ 'headers' => [ 'Accept' => 'application/activity+json, application/ld+json; profile="https://www.w3.org/ns/activitystreams"' ] ]); } public function resolve(string $url): Metadata { $res = $this->activityClient->get($url); if ($res->getStatusCode() === 200) { return $this->parse($res->getBody()); } else { throw new \RuntimeException("{$res->getStatusCode()}: $url"); } } public function parse(string $json): Metadata { $activityOrObject = json_decode($json, true); $object = $activityOrObject['object'] ?? $activityOrObject; $metadata = new Metadata(); $metadata->title = isset($object['attributedTo']) ? $this->getTitleFromActor($object['attributedTo']) : ''; $metadata->description .= isset($object['summary']) ? $object['summary'] . " | " : ''; $metadata->description .= isset($object['content']) ? $this->html2text($object['content']) : ''; $metadata->image = $object['attachment'][0]['url'] ?? ''; return $metadata; } private function getTitleFromActor(string $url): string { try { $res = $this->activityClient->get($url); if ($res->getStatusCode() !== 200) { Log::info(self::class . ': Actorの取得に失敗 URL=' . $url); return ''; } $actor = json_decode($res->getBody(), true); $title = $actor['name'] ?? ''; if (isset($actor['preferredUsername'])) { $title .= ' (@' . $actor['preferredUsername'] . '@' . parse_url($actor['id'], PHP_URL_HOST) . ')'; } return $title; } catch (TransferException $e) { Log::info(self::class . ': Actorの取得に失敗 URL=' . $url); return ''; } } private function html2text(string $html): string { $html = mb_convert_encoding($html, 'HTML-ENTITIES', 'UTF-8'); $html = preg_replace('~|

\s*]*>~i', "\n", $html); $dom = new \DOMDocument(); $dom->loadHTML($html, LIBXML_HTML_NOIMPLIED | LIBXML_HTML_NODEFDTD); return $dom->textContent; } }