Function putManyImpl

packages/core/sdk/src/executor.ts:1456–1503

(
    owner: Owner,
    entries: readonly {
      readonly collection: string;
      readonly key: string;
      readonly data: unknown;
    }[],
  )

    });

  const putManyImpl = (
    owner: Owner,
    entries: readonly {
      readonly collection: string;
      readonly key: string;
      readonly data: unknown;
    }[],
  ) =>
    input.core.transaction(
      Effect.gen(function* () {
        const os = ownerSubject(owner);
        if (!os) {
          return yield* new StorageError({
            message: `Cannot write plugin storage for owner "user": executor has no subject.`,
            cause: undefined,
          });
        }
        const entriesById = new Map(
          entries.map((entry) => [
            pluginStorageId({
              pluginId: input.pluginId,
              collection: entry.collection,
              key: entry.key,
            }),
            entry,
          ]),
        );
        const uniqueEntries = [...entriesById.values()];
        if (uniqueEntries.length === 0) return;

        const now = new Date();
        yield* input.core.upsertMany("plugin_storage", {
          target: ["tenant", "owner", "subject", "plugin_id", "collection", "key"],
          update: ["data", "updated_at"],
          values: uniqueEntries.map((entry) => ({
            tenant,
            owner: os.owner,
            subject: os.subject,
            plugin_id: input.pluginId,
            collection: entry.collection,
            key: entry.key,
            data: entry.data,
            created_at: now,
            updated_at: now,
          })),
        });
      }),
    );

  const removeManyImpl = (
    owner: Owner,