Function createConnection

packages/plugins/toolkits/src/server.ts:438–470

(
    toolkitId: string,
    input: {
      readonly pattern: string;
      readonly position?: string;
    },
  )

    requireToolkit(toolkitId).pipe(Effect.flatMap(() => listConnectionsForRecord(toolkitId)));

  const createConnection = (
    toolkitId: string,
    input: {
      readonly pattern: string;
      readonly position?: string;
    },
  ) =>
    Effect.gen(function* () {
      yield* validatePolicyPattern(input.pattern);
      const toolkit = yield* requireToolkit(toolkitId);
      const existing = yield* listConnectionsForRecord(toolkitId);
      const duplicate = existing.find((connection) => connection.pattern === input.pattern);
      if (duplicate) return connectionToResponse(duplicate);
      const minPosition = existing
        .map((row) => row.position)
        .sort()
        .at(0);
      const now = Date.now();
      const id = newId("tkconn");
      const entry = yield* storage.connections.put({
        owner: toolkit.owner,
        key: id,
        data: {
          id,
          toolkitId,
          pattern: input.pattern,
          position: input.position ?? generateKeyBetween(null, minPosition ?? null),
          createdAt: now,
          updatedAt: now,
        },
      });
      return connectionToResponse(entry.data);
    });

  const removeConnection = (toolkitId: string, connectionId: string) =>
    Effect.gen(function* () {