Cloudflare R2 Adapter

import { MemoFS, RemoteBlobMemoryStore } from "@memofs/core";
import { createR2BlobClient } from "@memofs/adapter-r2";
import { createTursoMetadataStore } from "@memofs/adapter-turso";
import { createClient } from "@libsql/client";

export interface Env {
  BLOBS: R2Bucket; // R2 Bucket binding from wrangler.jsonc / wrangler.toml
  TURSO_DATABASE_URL: string;
  TURSO_AUTH_TOKEN: string;
}

export default {
  async fetch(request: Request, env: Env): Promise<Response> {
    const projectId = "team-workspace";

    // 1. Initialize R2 Blob Client (implements BlobClient)
    const blobClient = createR2BlobClient({
      binding: env.BLOBS,
    });

    // 2. Initialize Turso Metadata Store (implements MetadataStore)
    const metadata = createTursoMetadataStore({
      client: createClient({
        url: env.TURSO_DATABASE_URL,
        authToken: env.TURSO_AUTH_TOKEN,
      }),
      projectId,
    });

    // 3. Compose the provider-neutral RemoteBlobMemoryStore
    const store = new RemoteBlobMemoryStore({
      blobClient,
      metadata,
      rootKey: projectId,
    });

    // 4. Initialize MemoFS
    const memo = new MemoFS({
      store,
      projectId,
      mode: "local",
    });

    const coreMemory = await memo.core.read();
    return new Response(coreMemory, {
      headers: { "Content-Type": "text/markdown" },
    });
  },
};

interface BlobClient {
  /** Reads raw bytes from R2; returns null if key is absent. */
  get(key: string): Promise<ArrayBuffer | null>;
  /** Writes bytes or streams to R2 under the content-derived key. */
  put(key: string, body: BufferSource | ReadableStream<Uint8Array>): Promise<void>;
  /** Deletes a blob from R2; idempotent. */
  delete(key: string): Promise<void>;
}