Function makeR2BlobStore

packages/hosts/cloudflare/src/blob-store.ts:28–70

(bucket: R2Bucket)

  new StorageError({ message: `R2 blob ${op} failed`, cause });

export const makeR2BlobStore = (bucket: R2Bucket): BlobStore => ({
  get: (namespace, key) =>
    Effect.tryPromise({
      try: async () => {
        const object = await bucket.get(objectName(namespace, key));
        return object == null ? null : await object.text();
      },
      catch: storeError("get"),
    }),
  // R2 has no multi-get; fetch the (at most two — user + org partition)
  // namespaces concurrently.
  getMany: (namespaces, key) =>
    Effect.tryPromise({
      try: async () => {
        const hits = new Map<string, string>();
        await Promise.all(
          namespaces.map(async (namespace) => {
            const object = await bucket.get(objectName(namespace, key));
            if (object != null) hits.set(namespace, await object.text());
          }),
        );
        return hits;
      },
      catch: storeError("getMany"),
    }),
  put: (namespace, key, value) =>
    Effect.tryPromise({
      try: async () => {
        await bucket.put(objectName(namespace, key), value);
      },
      catch: storeError("put"),
    }),
  delete: (namespace, key) =>
    Effect.tryPromise({
      try: () => bucket.delete(objectName(namespace, key)),
      catch: storeError("delete"),
    }),
  has: (namespace, key) =>
    Effect.tryPromise({
      try: async () => (await bucket.head(objectName(namespace, key))) != null,
      catch: storeError("has"),
    }),
});