Function listOperationRows

packages/plugins/graphql/src/sdk/store.ts:108–118

(integration: string)

export const makeDefaultGraphqlStore = ({ pluginStorage, blobs }: StorageDeps): GraphqlStore => {
  const listOperationRows = (integration: string) =>
    pluginStorage
      .list({
        collection: OPERATION_COLLECTION,
        keyPrefix: `${integration}.`,
      })
      .pipe(
        Effect.map((rows) =>
          rows.filter((row) => rowToOperation(row)?.integration === integration),
        ),
      );

  const removeOperations = (integration: string) =>
    Effect.gen(function* () {