BlueskyのBot作成をしてみた

Bluesky

X(旧Twitter)のAPI規制が強いのでBluesky向けのBotを作成することにしました。

BlueskyのAPIにもRate Limitsは存在するのですが、Xのものに比べて格段に緩いので、今後Botを作成するのであればBlueskyのBotは検討の余地があると思います。

技術スタック

BluskyのSDKはTypeScript向けのものがあるのでそれを利用しましょう。一応Python向けのもありますがCloudflare Workersで動作させたいのでそっちの方がいいと思います。

TypeScript
Bun/Node.js
Hono
Cloudflare Workers
Cloudflare R2

今回は上記の技術スタックを採用しました。

Cloudflare WorkersにはCron Eventsという定期実行の仕組みがあるので、それを利用することで定期的にBotを動作させることができます。

Cloudflare R2は必ずしも必要ではないのですが、今回は採用した将棋Botでデータを毎回ソースにアクセスするのではなくR2に保存しておくことで最初の一回以外は負荷をかけないように対策しました。

仕様

毎週データ更新
毎朝九時に対局情報
毎朝八時に詰将棋情報
十五分ごとに局面情報

をポストするようにしました。

データはあれば参照したものがあればR2から、なければソースから取得してR2に保存するようになっています。

毎週のデータ取得は本来は不要なのですが、一応更新するようにしています

1
[triggers]
2
crons = ["0 0 * * 1", "*/15 0-15 * * *", "0 0 * * *", "0 23 * * *"]

これを実行するためのwrangler.tomlは上のようになります。

Cron EventsはUTC基準なので日本時間であるJSTに変換するには+9する必要があります。

よって"0 23 * * *"は日本時間で23+9 mod 24 = 8となり、毎朝八時に実行することを意味するわけです。

コード解説

では実際に使われているコードを解説します。

本当はレポジトリを公開したかったのですが、認証に関するアルゴリズムを含むため残念ながら公開することができません。

ただし、基本的なコードはテンプレートレポジトリで公開しているので、こちらを利用してください。

1
export const scheduled = async (event: ScheduledController, env: Bindings, ctx: ExecutionContext): Promise<void> => {
2
  switch (event.cron) {
3
    case '0 0 * * *':
4
      break
5
    case '0 23 * * *':
6
      break
7
    case '*/15 0-15 * * *':
8
      break
9
    case '0 0 * * 1':
10
      break
11
    default:
12
      break
13
  }
14
}

wrangler.tomlでは複数のスケジュールを定義することができないので、ScheduledControllerのevent.cronを利用して分岐します。

Bluesky SDK

1
bun add @atproto/api

で追加できます。ドキュメントも豊富でわかりやすいです。

Botの実装

ログインするにあたってIDとパスワードが必要です。ただし、一般的なパスワードではなくアプリパスワードが必要になります。

アプリパスワードはこのリンクから発行できます。一度発行すると二度と表示されないので、必ずどこかに保存しておきましょう。

また、このIDとパスワードを.dev.varsに書き込みます。

1
BLUESKY_IDENTIFIER=
2
BLUESKY_APP_PASSWORD=

1
import { AtpAgent, type ComAtprotoRepoStrongRef, RichText } from '@atproto/api'
2

3
const agent = new AtpAgent({
4
  service: 'https://bsky.social'
5
})
6

7
export const post = async (env: Bindings): Promise<void> => {
8
  // ここに処理を書きます
9
}
10

11
export const scheduled = async (event: ScheduledController, env: Bindings, ctx: ExecutionContext): Promise<void> => {
12
  await agent.login({
13
    identifier: env.BLUESKY_IDENTIFIER,
14
    password: env.BLUESKY_APP_PASSWORD
15
  })
16
  switch (event.cron) {
17
    case '0 0 * * *':
18
      break
19
    case '0 23 * * *':
20
      break
21
    case '*/15 0-15 * * *':
22
      break
23
    case '0 0 * * 1':
24
      break
25
    default:
26
      ctx.waitUntil(post(env))
27
      break
28
  }
29
}

BskyAgentは非推奨ですのでAtpAgentを使うようにしてください。正しくBindingsを定義していればこのようにしてログインができます。Envが使えればもうちょっと便利だと思うのですが、使い方がわかっていません。

await post(env)と書いても動作させることはできるのですが、Cloudflare WorkersはCPU時間の制限があるのでこの書き方をすると処理が重い場合にタイム・アウトしてしまいます。

ところがctx.waitUntil(post(env))とすればWorkers自体が終了しても裏で処理が実行できます。

リッチテキスト

ただのテキストではなくハイパーリンクやハッシュタグを利用したい場合には一度RichTextを経由する必要があります。

1
const richText: RichText = new RichText({ text: 'ハッシュタグやリンクを含むテキスト' })
2
await richText.detectFacets(agent) // 忘れずに実行しよう
3
return agent.post({
4
  text: richText.text,
5
  facets: richText.facets
6
})

ちなみにテキストにハッシュタグやリンクが含まれていなくても大丈夫です。

画像投稿

1
const result = agent.uploadBlob(image, { encoding: 'image/png' })
2
const richText: RichText = new RichText({ text: 'ハッシュタグやリンクを含むテキスト' })
3
await richText.detectFacets(agent) // 忘れずに実行しよう
4
return agent.post({
5
  text: richText.text,
6
  facets: richText.facets,
7
  embed: {
8
  $type: 'app.bsky.embed.images',
9
  images: [{
10
      alt: '',
11
      image: result.data.blob,
12
      aspectRatio: {
13
        width: 600,
14
        height: 550
15
      }
16
  }]
17
})

画像はそのままポストに埋め込むのではなく、事前にアップロードすることが必要になります。また、配列を利用すれば読ん枚までアップロードできます。

uploadBlob()に渡す引数はUint8ArrayですのでBufferを利用するなりでうまく変換してください。encodingに関してはimage/pngの他にimage/jpegなども指定できるみたいですが、最高画質でアップロードしたいならimage/png一択です。

動画もどうやらSDK的には対応しているのですが、サーバーが未対応なのかアップロードしようとすると失敗します。

リプライ

リプライするにはparentとrootを指定する必要があります。試していないのでわからないのですがrootはリプライツリーが始まった一番最初のポストである必要があるかもしれません。

parentはいわゆるリプライ先になるので、A->B->Cのようなリプライツリーを作りたい場合には、まず最初にリプライを指定せずにポストしてAのuriとcidを取得し、それをparantとrootに設定してポストすることでBを作成。最後にparentにB, rootにBを指定してポストすることでCを作成するといった感じです。ちょっとめんどくさいですが、理にはかなっています。

uriとcidの値はagent.post()の返り値として受け取ることができます。

まとめ

BlueskyのSDKを触ってみましたが、Xとは異なる仕様のため難しく感じる箇所もありました。

ただ、アプリパスワードを使って簡単に認証が行える点、レートリミットが比較的緩い点、デベロッパーアカウントの開設が不要な点などが便利でした。SDKに関してはまだまだ改善する余地があると思いますが、今後の発展性について期待できる内容でした。

記事は以上。