CloudflareでBlueskyの簡易的なフィードを作る

/**
 * Welcome to Cloudflare Workers! This is your first worker.
 *
 * - Run `npm run dev` in your terminal to start a development server
 * - Open a browser tab at http://localhost:8787/ to see your worker in action
 * - Run `npm run deploy` to publish your worker
 *
 * Bind resources to your worker in `wrangler.toml`. After adding bindings, a type definition for the
 * `Env` object can be regenerated with `npm run cf-typegen`.
 *
 * Learn more at https://developers.cloudflare.com/workers/
 */

/** `/xrpc/app.bsky.feed.getFeedSkeleton` にアクセスされたときの処理 */
const feed = async (url: URL): Promise<Response> => {
  // クエリパラメータの feed には以下の形式で渡される
  // at://<フィード作成者のDID>/app.bsky.feed.generator/<フィードのショートネーム>
  // そこからフィードのショートネームを抽出し、変数 feedName に格納している
  const feedParam = url.searchParams.get('feed');
  const prefix = 'at://did:plc:osec57qucip46vc4vm4vdtu6/app.bsky.feed.generator/';
  if (!feedParam?.startsWith(prefix)) {
    return new Response('正しい形式のフィード名が必要です。', { status: 400 });
  }
  const feedName = feedParam.substring(prefix.length);

  // 1つのWorkerで複数のフィードを登録できるため、ショートネームで分岐してフィード毎の処理を行う
  switch (feedName) {
    case 'short-name':
      return Response.json({
        feed: [
          // post には AT URI の形式を渡す
          { post: 'at://did:plc:osec57qucip46vc4vm4vdtu6/app.bsky.feed.post/3lczymzg6xs2z' }
          // フィードに複数のポストがある場合、上記の形式のオブジェクトが複数ある
        ],
      });

    default:
      return new Response('不明なフィードです。', { status: 400 });
  }
};

export default {
  async fetch(request, env, ctx): Promise<Response> {
    const url = new URL(request.url);
    switch (url.pathname) {
      // 2つのパスにGETメソッドでアクセスされるため、対応する
      case '/.well-known/did.json':
        // 以下のコメントが付いていない部分は固定の文字列で良い
        return Response.json({
          '@context': ['https://www.w3.org/ns/did/v1'],
          // id は did:web:<WorkersのFQDN> の形式
          id: 'did:web:workers-name.subdomain.workers.dev',
          service: [
            {
              id: '#bsky_fg',
              type: 'BskyFeedGenerator',
              // serviceEndPoint は https://<WorkersのFQDN> の形式
              serviceEndPoint: 'https://workers-name.subdomain.workers.dev',
            },
          ],
        });

      case '/xrpc/app.bsky.feed.getFeedSkeleton':
        return feed(url);

      default:
        return new Response('Hello World!');
    }
  },
} satisfies ExportedHandler<Env>;

axum  = { version = "0.7", default-features = false, features=["json", "query"] }
serde = "1.0"
serde_json = "1.0"

use axum::{routing::get, Router};
use tower_service::Service;
use worker::*;

fn router() -> Router {
    Router::new()
        .route("/", get(root))
        // 以下の2つのパスにGETメソッドでアクセスされる
        .route("/.well-known/did.json", get(well_known))
        .route("/xrpc/app.bsky.feed.getFeedSkeleton", get(feed))
}

/// `/.well-known/did.json` にアクセスされたときの処理
async fn well_known() -> axum::Json<serde_json::Value> {
    // 以下のコメントが付いていない部分は固定の文字列で良い
    axum::Json(serde_json::json!({
        "@context": ["https://www.w3.org/ns/did/v1"],
        // id は did:web:<WorkersのFQDN> の形式
        "id": "did:web:workers-name.subdomain.workers.dev",
        "service": [
            {
                "id": "#bsky_fg",
                "type": "BskyFeedGenerator",
                // serviceEndPoint は https://<WorkersのFQDN> の形式
                "serviceEndPoint": "https://workers-name.subdomain.workers.dev"
            }
        ]
    }))
}

#[derive(serde::Deserialize)]
struct FeedParams {
    feed: String,
}

/// `/xrpc/app.bsky.feed.getFeedSkeleton` にアクセスされたときの処理
async fn feed(
    // クエリパラメータの feed の中にフィード名が含まれるため、受け取れるようにしておく
    axum::extract::Query(params): axum::extract::Query<FeedParams>,
) -> axum::response::Result<axum::Json<serde_json::Value>> {
    // クエリパラメータの feed には以下の形式で渡される
    // at://<フィード作成者のDID>/app.bsky.feed.generator/<フィードのショートネーム>
    // そこからフィードのショートネームを抽出し、変数 feed_name に格納している
    let feed_name = params
        .feed
        .strip_prefix("at://did:plc:osec57qucip46vc4vm4vdtu6/app.bsky.feed.generator/")
        .ok_or(axum::http::StatusCode::BAD_REQUEST)?;

    // 1つのWorkerで複数のフィードを登録できるため、ショートネームで分岐してフィード毎の処理を行う
    match feed_name {
        "short-name" => Ok(axum::Json(serde_json::json!({
            "feed": [
                // post には AT URI の形式を渡す
                { "post": "at://did:plc:osec57qucip46vc4vm4vdtu6/app.bsky.feed.post/3lczymzg6xs2z" }
                // フィードに複数のポストがある場合、上記の形式のオブジェクトが複数ある
            ]
        }))),
        _ => Err(axum::http::StatusCode::BAD_REQUEST.into()),
    }
}

#[event(fetch)]
async fn fetch(
    req: HttpRequest,
    _env: Env,
    _ctx: Context,
) -> Result<axum::http::Response<axum::body::Body>> {
    console_error_panic_hook::set_once();
    Ok(router().call(req).await?)
}

// デフォルトで作成されるのでとりあえず残している
// 多分いらないかも...
pub async fn root() -> &'static str {
    "Hello Axum!"
}