最近、SNS「Bluesky」が人気急上昇中ですね！
招待制ではなくなったので、一気に登録者が増えているようです。

そんなBlueskyへ、ノーコードのデータ連携ツール「ASTERIA Warp」から投稿するフローを作成してみました！
この記事では、そのフローの内容や作成中につまずいた点を解説したいと思います。

（ご注意：ASTERIA Warpの基本的な使い方をご存じのかた向けに書かれています）

なお、ASTERIA Warp 2312で試しています。JSONストリームを使用していますので、ASTERIA Warp 2212以降のバージョンが必要です。

投稿した内容

システムを初めて動かすときのお決まりの言葉といえばHello world!ですね。
ここではこんな投稿をしてみました。
固定文言+投稿日時という内容です。

APIの仕様を把握する

フロー作成の前に、まずはBlueskyのAPI仕様を把握する必要があります。
公式サイトで確認しましょう。

公式サイトにはTypeScript/CURL/Pythonでのサンプルコードが掲載されていますが、ここではCURLでの接続方法を参考にします。これは、TypeScriptやPythonのサンプルコードは専用クライアントをインストールする前提になっているのに対し、CURLでは専用クライアント無しでAPIを呼び出す方法が書かれているためです。ASTERIA Warpから接続するときは「RESTコンポーネント」を使ってAPIを呼び出しますので、専用クライアント無しでの接続方法を把握する必要があります。

把握したこと

処理の流れ
- 最初にセッションを作成し、アクセストークンを入手する（Create a session）
- そのアクセストークンを使って、投稿を実施する（Create a post）
入力が必要な情報
- ハンドル（ユーザーID）
- パスワード
- （セッション作成時に入手した）アクセストークン
各APIのエンドポイント
- セッション作成 https://bsky.social/xrpc/com.atproto.server.createSession
- 投稿 https://bsky.social/xrpc/com.atproto.repo.createRecord
各APIのリクエストとレスポンスのJSONデータ構造（詳細はここでは省略します）

これらの情報を元に、フロー作成をはじめましょう！

フロー作成

先に完成品をお見せします

セッション作成フロー「CreateSession」

投稿フロー「CreatePost」

とてもシンプルなフローにできました

※注：このフローでは、アクセストークンが期限切れになったときリフレッシュトークンを用いて再取得する処理は考慮していません。

準備

ハンドル、パスワード、アクセストークンは「外部変数セット」に保存しておくことにします。
これは、秘密にすべき情報をフローの中に直接書き込むことを避けるためと、同じ情報を複数の箇所に重複保管しないために選択しました。

ここでは外部変数セット「BlueskySocial」を、以下の内容で作成しました。

定数
- BLUESKY_HANDLE
  - 初期値(上記画像ではyour_idと書いてある場所)にハンドル（ユーザーID）を入れておきます
  - 私の場合ですと shozzy-bsky.bsky.social を設定しました。
    - ブラウザでログインするときは shozzy-bsky だけで良いのですが、ここでは省略なしで書く必要がありました（つまづいたポイント1つめ）
- BLUESKY_PASSWORD
  - 初期値(上記画像ではyour_passwordと書いてある場所)にパスワードを入れておきます
アプリケーション変数
- accessJWT
  - アクセストークン保存用
- refreshJWT
  - リフレッシュトークン保存用（今回は使っていませんが、保存だけしてあります）

プロジェクト作成

プロジェクト名「BlueskySocial」で作成しました。

セッション作成フロー

フロー名「CreateSession」で作成しました。

全体の流れ（再掲）

設定のポイント

デフォルトから変更した箇所を解説します。

外部変数セット「BlueskySocial」を貼り付け
1つめのMapperコンポーネント
- 出力ストリーム JSON
- マッピング内容
  - このマッピングで、API仕様の通りにハンドル(ユーザーID)とパスワードが書かれたJSONデータを用意しています
RESTコンポーネント
- 出力ストリーム JSON
- コネクションを使用 いいえ
- URL https://bsky.social/xrpc/com.atproto.server.createSession
- HTTPメソッド POST

ヒント：
これだけの項目数を手入力するのは大変すぎますので、ストリームの項目定義をインポートすると便利です。
以下のような方法でインポート可能です。
・RESTのテスト実行機能で入手したJSONを「フィールド定義のインポート」で取り込む
・一度ストリームの項目設定をしない状態でフローを動作させて入手したJSONデータをローカルファイルに保存しておき、ストリームの右クリックメニューから「インポート」して取り込む

2つめのMapperコンポーネント
- 入力をそのまま出力 はい
- マッピング内容
  - このマッピングで、アプリケーション変数にアクセストークンなどを保存しています
  - アプリケーション変数に保存したデータは永続化されますので、保存された値を他のフローで利用することができます

これでセッション作成フローは完成です！

投稿フロー

フロー名「CreatePost」で作成しました。

全体の流れ（再掲）

設定のポイント

先ほどと同様に、デフォルトから変更した箇所の解説です。

外部変数セット「BlueskySocial」を貼り付け
Mapperコンポーネント
- 出力ストリーム JSON
- マッピング内容
- マッパー関数の詳細
  - 上のConst関数
    - データ app.bsky.feed.post
  - 下のConst関数
    - データ はろー青空わーるど！
  - Now関数
    - 日付フォーマット yyyy-MM-dd'T'HH:mm:ss'Z'
    - タイムゾーン (GMT)
      - API仕様で、UTCでの投稿日時をISO8601形式で設定する必要があるため、この設定が必要です
      - 日付フォーマットは上記テキストを直接入力してください。プルダウンではこの選択肢は出てきません
      - ここがつまづいたポイント2つめでした。TとZをシングルクオートで括る必要があることに気付くまで、少し時間がかかりました...
  - Concat関数
    - 区切り文字 \n
    - 区切り文字にメタ文字を使用 はい
    - 入力順
RESTコンポーネント
- 出力ストリーム JSON
- コネクションを使用 いいえ
- URL https://bsky.social/xrpc/com.atproto.repo.createRecord
- HTTPメソッド POST
- 送信ヘッダー（以下の1行を追加）
  - ヘッダー名 Authorization
  - 値 Bearer ${exvar.BlueskySocial.accessJWT}
    - 値は、右端の歯車マークをクリックし「プロパティ式」機能を利用して設定してください

これでフロー完成です！！

あとは、先にセッション作成フローを動かし、続いて投稿フローを動かせば、投稿できます！

おわりに

少し詰まる点もありましたが、思い立って1時間ほどで完成形にすることができました。
詰まらなければもっと短時間で作成できますね。

100種類以上の様々なデータソースと接続できるASTERIA Warpですから、社内システムと連携して自動投稿botを作成したり、投稿を取得するAPIを利用すれば自分の投稿への反応を抽出したりと、いろいろ応用できそうです！

最後までご覧いただきありがとうございました！

[PR] 弊社アステリア株式会社では、居住地不問で一緒に働く仲間を募集しています！新卒採用もしてますよ！
https://www.wantedly.com/companies/asteria/projects