Function requireConnection

packages/plugins/toolkits/src/server.ts:294–303

(toolkitId: string, connectionId: string, owner: Owner)

      );

  const requireConnection = (toolkitId: string, connectionId: string, owner: Owner) =>
    storage.connections
      .getForOwner({ owner, key: connectionId })
      .pipe(
        Effect.flatMap((entry) =>
          entry && entry.data.toolkitId === toolkitId
            ? Effect.succeed(entry)
            : fail("Toolkit connection not found."),
        ),
      );

  const create = (input: {
    readonly owner: Owner;