PHPでBlueskyの埋め込み用HTMLを取得

Bluesky クライアントの機能として、ホームページやブログに投稿メッセージを埋め込むためのHTML取得機能がある。ところが、Twitter(現・X) と異なり、Bluesky API にこの機能が用意されていない。
そこで今回は、PHPでメッセージ取得用の Bluesky APIを利用し、Bluesky の埋め込み用HTMLを取得するプログラムを作ってみることにする。

サンプル・プログラムの実行例

サンプル・プログラム

ダウンロード（PHP8対応）

圧縮ファイルの内容
embedBlueskyPost.php	サンプル・プログラム本体
pahooBlueskyAPI.php	Bluesky APIに関わるクラス pahooBlueskyAPI。使い方は「PHPでPHPでBlueskyに投稿する」などを参照。include_path が通ったディレクトリに配置すること。
pahooScraping.php	スクレイピング処理に関わるクラス pahooScraping。スクレイピング処理に関わるクラスの使い方は「PHPでDOMDocumentを使ってスクレイピング」を参照。include_path が通ったディレクトリに配置すること。
pahooInputData.php	データ入力に関わる関数群。使い方は「数値入力とバリデーション」「文字入力とバリデーション」などを参照。include_path が通ったディレクトリに配置すること。

embedBlueskyPost.php 更新履歴
バージョン	更新日	内容
1.0.0	2025/01/18	初版

pahooBlueskyAPI.php 更新履歴
バージョン	更新日	内容
2.1.0	2025/03/20	getUserPosts() 追加
2.0.1	2025/01/24	getPostThread() -- 認証必要のエンドポイントに変更
2.0.0	2025/01/24	トークンを保持するよう改良
1.9.0	2025/01/16	getEmbedPosts() 追加
1.8.1	2024/12/11	getOGPInformation()--リダイレクト対応

pahooScraping.php 更新履歴
バージョン	更新日	内容
1.2.1	2024/10/31	__construct() 文字化け対策
1.2.0	2024/09/29	getValueFistrXPath() 属性値でない指定に対応
1.1.0	2023/10/15	getValueFistrXPath() 追加
1.0.1	2023/09/29	__construct() bug-fix
1.0.0	2023/09/18	初版

pahooInputData.php 更新履歴
バージョン	更新日	内容
1.8.1	2025/03/15	validRegexPattern() -- debug
1.8.0	2024/11/12	validRegexPattern() 追加
1.7.0	2024/10/09	validURL() validEmail() 追加
1.6.0	2024/10/07	isButton() -- buttonタグに対応
1.5.0	2024/01/28	exitIfExceedVersion() 追加

準備：PHP の https対応

Bluesky API の呼び出しはhttps通信で行うため、PHPにOpenSSLモジュールが組み込まれている必要がある。関数 phpinfo を使って、下図のように表示されればＯＫ。

そうでない場合は、次の手順に従ってOpenSSLを有効化し、PHPを再起動させる必要がある。

Windowsでは、"php.ini" の下記の行を有効化する。

extension=php_openssl.dll

Linuxでは --with-openssl=/usr オプションを付けて再ビルドする。→OpenSSLインストール手順

これで準備は完了だ。

解説：pahooBlueskyAPIクラス

Bluesky に投稿したりプログラムで操作するAPIについては、公式リファレンスが詳しい。APIを利用するには、事前に、あなたのアカウントから利用登録を行い、アプリパスワードを取得する必要がある。その手順は「Bluesky API - 各種クラウド連携サービス（WebAPI）の登録方法」をご覧いただきたい。
Bluesky APIを利用するメソッドはクラス "pahooBlueskyAPI.php" に分離している。また、このクラスからクラス "pahooScraping.php" を呼び出すので、2つのクラス・ファイルを include_path の通ったディレクトリに配置すること。

解説：セッション開始

BlueskyAPI を利用するには、まずセッションを開き、アクセストークン accessJwt を取得する。使用するエンドポイントは com.atproto.server.createSession だ。

com.atproto.server.createSession
ＵＲＬ
https://{PDSドメイン}/xrpc/com.atproto.server.createSession

アクセストークン accessJwt は、後述するメッセージや画像の投稿で使用する。寿命は1～2時間だ。
アクセストークン refreshJwt は、アクセストークンの再発行や、セッションの終了・破棄に用いることができ、寿命は数十日と長い。リフレッシュトークン refreshJwt をストレージに保存しておき、次回はアクセストークンを再発行するというのが BlueskyAPI の望ましい運用方法と思われるが、リフレッシュトークン refreshJwt だけでアクセストークン accessJwt を再発行できてしまうので、流出するとたいへん危険である。

今回つくるプログラムは、単発でメッセージや画像を投稿するものなので、リフレッシュトークン refreshJwt は使わず、プログラム起動時にアクセストークン accessJwt を取得するようにする。

pahooBlueskyAPI.php

  11: // スクレイピング処理に関わるクラス：include_pathが通ったディレクトリに配置
  12: require_once('pahooScraping.php');
  13:
  14: // Bluesky API クラス =======================================================
  15: class pahooBlueskyAPI {
  16:     var $pds;           // PDSドメイン
  17:     var $webapi;        // 直前に呼び出したWebAPI URL
  18:     var $errmsg;        // エラーメッセージ
  19:     var $accessJwt;     // accessJwt
  20:     var $refreshJwt;    // refreshJwt
  21:
  22:     const INTERNAL_ENCODING = 'UTF-8';  // 内部エンコーディング
  23:     const MAX_MESSAGE_LEN = 300;        // 投稿可能なメッセージ文字数
  24:     const URL_LEN = 23;                 // メッセージ中のURL文字数(相当)
  25:     const MAX_IMAGE_WIDTH  = 1200;      // 投稿可能な最大画像幅（ピクセル）
  26:     const MAX_IMAGE_HEIGHT = 630;       // 投稿可能な最大画像高さ（ピクセル）
  27:                                         // これより大きいときは自動縮小する
  28:     // トークンを保存するファイル名
  29:     // 秘匿性を保つことができ、かつ、PHPプログラムから読み書き可能であること
  30:     const FILENAME_TOKEN = './.token';
  31:
  32:     // Bluesky API アプリパスワード
  33:     // https://bsky.app/
  34:     var $BLUESKY_HANDLE   = '***************';      // ハンドル名
  35:     var $BLUESKY_PASSWORD = '***************';      // アプリケーション・パスワード

BlueskyAPI を利用するユーザー定義クラス pahooBlueskyAPIをつくる。
上述の手順で取得したアプリケーション・パスワードをプロパティ変数 $BLUESKY_PASSWORD に、あなたのハンドル名を $BLUESKY_HANDLE に代入する。
投稿可能な最大文字数は定数 MAX_MESSAGE_LEN として用意した。現在の仕様では300文字だ。

pahooBlueskyAPI.php

  37: /**
  38:  * コンストラクタ
  39:  * もしAPIエラーが出る場合には，新規セッションにしてみる．
  40:  * @param   string $pds PDSドメイン
  41:  * @param   bool $newSession 新規セッションにするかどうか（TRUE：新規，デフォルトはFALSE）
  42:  * @return  なし
  43: */
  44: function __construct($pds, $newSession=FALSE) {
  45:     $this->pds        = $pds;
  46:     $this->webapi     = '';
  47:     $this->errmsg     = '';
  48:     $this->accessJwt  = '';
  49:     $this->refreshJwt = '';
  50:
  51:     // 新規セッションを開始する．
  52:     if ($newSession) {
  53:         $this->createSession();
  54:     }
  55: }

コンストラクタの引数は PDSドメインで、変数 $pds に保管し、API呼び出し時に参照できるようにした。

pahooBlueskyAPI.php

347: /**
348:  * 新規セッションを開始する．
349:  * @param   なし
350:  * @return  bool TRUE：成功／FALSE：失敗
351: */
352: function createSession() {
353:     // エラーメッセージ・クリア
354:     $this->clearerror();
355:
356:     // リクエストURL
357:     $requestURL = 'https://' . $this->pds . '/xrpc/com.atproto.server.createSession';
358:     $this->webapi = $requestURL;
359:     $ch = curl_init($requestURL);
360:     // cURLを使ったリクエスト
361:     curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
362:     curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
363:     curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
364:     curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE); // サーバ証明書検証をスキップ
365:     curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE); //　　〃
366:     curl_setopt($ch, CURLOPT_POST, TRUE);
367:     curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode([
368:         'identifier' => $this->BLUESKY_HANDLE,
369:         'password'   => $this->BLUESKY_PASSWORD,
370:     ]));
371:
372:     // レスポンス処理
373:     $response = curl_exec($ch);
374: //  var_dump('*createSession');
375: //  var_dump($response);
376:     $httpStatusCode = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
377:     if ($httpStatusCode != 200) {
378:         $this->seterror('セッションを開始できません');
379:         return FALSE;
380:     }
381:     curl_close($ch);
382:     $items = json_decode($response, TRUE);
383:
384:     // エラーチェックとリターン
385:     if (isset($items['accessJwt']) && isset($items['refreshJwt'])) {
386:         $this->accessJwt = (string)$items['accessJwt'];
387:         $this->refreshJwt = (string)$items['refreshJwt'];
388:         // トークンをファイルに保存する
389:         $contents = $this->accessJwt . "\n" . $this->refreshJwt;
390:         file_put_contents(self::FILENAME_TOKEN, $contents);
391:         return TRUE;
392:     } else if (isset($items['error'])) {
393:         $this->seterror($items['message']);
394:         return FALSE;
395:     } else {
396:         $this->seterror('セッションを開始できません');
397:         return FALSE;
398:     }
399: }

セッション開始メソッド createSession は、引数はなく、セッション開始に成功したかどうかを戻り値にする。

メソッドの中身は、上述のAPI仕様の通りに作った。
POSTプロトコルとして、これまでのクラウドサービス利用でも使ってきた cURL関数を利用する。

解説：セッション終了

アクセストークン accessJwt のセッションを終了するには、エンドポイント com.atproto.server.deleteSession を呼び出す。

com.atproto.server.deleteSession
ＵＲＬ
https://{PDSドメイン}/xrpc/com.atproto.server.deleteSession

セッション開始時に取得したアクセストークン accessJwt を使い、このセッションをクローズする。以後、このアクセストークン accessJwt は使用できなくなる。
アクセストークン accessJwt の盗用を避ける意味で、セッションを開始したら、かならずセッション終了するようにしよう。

APIの戻り値は、httpステータスが200であれば成功、それ以外であればエラー情報が戻る。

pahooBlueskyAPI.php

455: /**
456:  * セッション終了する．
457:  * @param   なし
458:  * @return  bool TRUE：成功／FALSE：失敗
459: */
460: function deleteSession() {
461:     // リクエストURL
462:     $requestURL = 'https://' . $this->pds . '/xrpc/com.atproto.server.deleteSession';
463:     $this->webapi = $requestURL;
464:     $ch = curl_init($requestURL);
465:     // cURLを使ったリクエスト
466:     curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
467:     curl_setopt($ch, CURLOPT_HTTPHEADER, ['Authorization: Bearer ' . $this->accessJwt]);
468:     curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
469:     curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
470:     curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE); // サーバ証明書検証をスキップ
471:     curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE); //　　〃
472:
473:     // レスポンス処理
474:     $response = curl_exec($ch);
475:     if (curl_errno($ch)) {
476:         $this->seterror('セッション終了できません' . curl_error($ch));
477:         return FALSE;
478:     }
479:     curl_close($ch);
480:     $this->accessJwt = '';
481:     $this->refreshJwt = '';
482:
483:     return TRUE;
484: }

セッション終了メソッド deleteSession は、引数はなく、セッション開始に成功したかどうかを戻り値にする。

解説：メッセージ情報を取得

メッセージ情報を取得するエンドポイントは app.bsky.feed.getPosts だ。

app.bsky.feed.getPosts
ＵＲＬ
https://{PDSドメイン}/xrpc/app.bsky.feed.getPosts?uris={atURI(複数)}

取得したい複数のメッセージの atURI をGETで渡すことで、一度の呼び出しで複数のメッセージ情報を取得することができる。

APIの戻り値は、httpステータスが200であれば成功、それ以外であればエラー情報が戻る。

pahooBlueskyAPI.php

1136: /**
1137:  * メッセージURLからメッセージ情報を取得する
1138:  * @param   array $urls メッセージURL（複数）
1139:  * @return  array メッセージ情報 / FALSE:取得失敗
1140: */
1141: function getPosts($urls) {
1142:     $atURIs = [];
1143:     foreach ($urls as $url) {
1144:         // ユーザー名、投稿IDを取得する
1145:         if (preg_match('/\/profile\/([^\/]+)\/post\/([0-9a-zA-Z]+)/ui', $url, $arr) == 0) {
1146:             $this->seterror($url . 'は投稿URLではありません');
1147:             return FALSE;
1148:         }
1149:         if (count($arr) < 3) {
1150:             $this->seterror($url . '投稿URLではありません');
1151:             return FALSE;
1152:         }
1153:         $userName = $arr[1];
1154:         $postID   = $arr[2];
1155:
1156:         // ユーザーDIDを取得する
1157:         $userDID = $this->getDID($userName);
1158:         if ($userDID == FALSE) {
1159:             $this->seterror($url . 'はユーザーDIDを取得できません');
1160:             return FALSE;
1161:         }
1162:
1163:         // AT-URIを生成する
1164:         $atURIs[] = 'at://' . $userDID . '/app.bsky.feed.post/' . $postID;
1165:     }
1166:
1167:     // トークンを取得する．
1168:     $this->getValidToken();
1169:
1170:     // リクエストURL (認証必要)
1171:     $requestURL = 'https://' . $this->pds . '/xrpc/app.bsky.feed.getPosts';
1172:     $ch = curl_init($requestURL . '?' . http_build_query(['uris' => $atURIs]));
1173:     curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
1174:     curl_setopt($ch, CURLOPT_HTTPHEADER, [
1175:         'Content-Type: application/json',
1176:         'Authorization: Bearer ' . $this->accessJwt,
1177:     ]);
1178:     curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
1179:     curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE); // サーバ証明書検証をスキップ
1180:     curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE); //　　〃
1181:
1182:     // レスポンス処理
1183:     $response = curl_exec($ch);
1184:     $httpStatusCode = curl_getinfo($ch, CURLINFO_RESPONSE_CODE);
1185:
1186:     if ($httpStatusCode != 200) {
1187:         $this->seterror('メッセージ情報を取得できません(httpステータス異常)');
1188:         return FALSE;
1189:     }
1190:     curl_close($ch);
1191:     $items = json_decode($response, TRUE);
1192:
1193:     return $items;
1194: }

メッセージ情報を取得メソッド getPosts は、引数に atURI ではなく BlueskyメッセージのURLを配列で渡す。内部でURLを atURI に変換してから BlueskyAPI に渡すようにしている。

解説：埋め込み用HTMLを取得

pahooBlueskyAPI.php

1196: /**
1197:  * メッセージURLから埋め込みHTMLを取得する
1198:  * @param   array $url メッセージURL
1199:  * @return  string 埋め込みHTML / FALSE:取得失敗
1200: */
1201: function getEmbedPosts($url) {
1202:     $items = $this->getPosts([$url]);
1203:     if ($items == FALSE) {
1204:         return FALSE;
1205:     }
1206:
1207:     // 投稿日時を日本語に変換する
1208:     $createdDateTime = $items['posts'][0]['record']['createdAt'];
1209:     preg_match('/([0-9]{4})\-([0-9]{2})\-([0-9]{2})T([0-9]{2})\:([0-9]{2})/', $createdDateTime, $arr);
1210:     $dt = sprintf('%04d年%d月%d日 %02d:%02d', (int)$arr[1], (int)$arr[2], (int)$arr[3], (int)$arr[4], (int)$arr[5]);
1211:     // 埋め込みHTML生成（公式の出力に合わせる）
1212:     return <<< EOT
1213: <blockquote class="bluesky-embed" data-bluesky-uri="{$items['posts'][0]['uri']}" data-bluesky-cid="{$items['posts'][0]['cid']}"><p lang="">{$items['posts'][0]['record']['text']}<br><br><a href="https://bsky.app/profile/{$items['posts'][0]['uri']}?ref_src=embed">[image or embed]</a></p>— {$items['posts'][0]['author']['displayName']} (<a href="https://bsky.app/profile/{$items['posts'][0]['author']['did']}?ref_src=embed">@{$items['posts'][0]['author']['handle']}</a>) <a href="https://bsky.app/profile/{$items['posts'][0]['uri']}?ref_src=embed">{$dt}</a></blockquote><script async src="https://embed.bsky.app/static/embed.js" charset="utf-8"></script>
1214:
1215: EOT;
1216: }