Function pluginBlobStore

packages/core/sdk/src/blob.ts:78–123

(
  store: BlobStore,
  partitions: OwnerPartitions,
  pluginId: string,
)

 * executor to build the `blobs` field handed to each plugin's `storage` factory.
 */
export const pluginBlobStore = (
  store: BlobStore,
  partitions: OwnerPartitions,
  pluginId: string,
): PluginBlobStore => {
  const readNamespaces = (): readonly string[] =>
    (partitions.user == null ? [partitions.org] : [partitions.user, partitions.org]).map((p) =>
      nsFor(p, pluginId),
    );

  const partitionFor = (owner: Owner): Effect.Effect<string, StorageError> => {
    if (owner === "org") return Effect.succeed(partitions.org);
    if (partitions.user == null) {
      return Effect.fail(
        new StorageError({
          message: 'Blob write targets owner "user" but the executor has no subject.',
          cause: undefined,
        }),
      );
    }
    return Effect.succeed(partitions.user);
  };

  return {
    get: (key) =>
      Effect.gen(function* () {
        const namespaces = readNamespaces();
        const hits = yield* store.getMany(namespaces, key);
        if (hits.size === 0) return null;
        for (const ns of namespaces) {
          const v = hits.get(ns);
          if (v !== undefined) return v;
        }
        return null;
      }),
    put: (key, value, options) =>
      Effect.flatMap(partitionFor(options.owner), (partition) =>
        store.put(nsFor(partition, pluginId), key, value),
      ),
    delete: (key, options) =>
      Effect.flatMap(partitionFor(options.owner), (partition) =>
        store.delete(nsFor(partition, pluginId), key),
      ),
    has: (key) => store.getMany(readNamespaces(), key).pipe(Effect.map((hits) => hits.size > 0)),
  };
};

/**
 * Minimal in-memory BlobStore — good for tests and trivial hosts. Real