Function makeToolkitsExtension

packages/plugins/toolkits/src/server.ts:231–565

(ctx: PluginCtx<ToolkitStorage>)

});

const makeToolkitsExtension = (ctx: PluginCtx<ToolkitStorage>) => {
  const storage = ctx.storage;

  const list = () =>
    storage.toolkits
      .query({ orderBy: [{ field: "name" }] })
      .pipe(
        Effect.map((entries) =>
          entries
            .map(toolkitToResponse)
            .sort(
              (a, b) =>
                (a.owner === b.owner ? 0 : a.owner === "org" ? -1 : 1) ||
                a.name.localeCompare(b.name) ||
                a.slug.localeCompare(b.slug),
            ),
        ),
      );

  const getEntry = (toolkitId: string) => storage.toolkits.get({ key: toolkitId });

  const getBySlugEntry = (slug: string) =>
    storage.toolkits
      .query({ where: { slug } })
      .pipe(
        Effect.map(
          (entries) => entries.find((entry) => entry.owner === "org") ?? entries[0] ?? null,
        ),
      );

  const requireToolkit = (toolkitId: string) =>
    getEntry(toolkitId).pipe(
      Effect.flatMap((entry) => (entry ? Effect.succeed(entry) : fail("Toolkit not found."))),
    );

  const assertSlugAvailable = (slug: string, ignoreToolkitId?: string) =>
    storage.toolkits.query({ where: { slug } }).pipe(
      Effect.flatMap((entries) => {
        const collision = entries.find((entry) => entry.data.id !== ignoreToolkitId);
        return collision ? fail(`Toolkit slug "${slug}" is already in use.`) : Effect.void;
      }),
    );

  const listPoliciesForRecord = (toolkitId: string) =>
    storage.policies
      .query({ where: { toolkitId } })
      .pipe(Effect.map((entries) => entries.map((entry) => entry.data).sort(comparePositioned)));

  const listConnectionsForRecord = (toolkitId: string) =>
    storage.connections
      .query({ where: { toolkitId } })
      .pipe(Effect.map((entries) => entries.map((entry) => entry.data).sort(comparePositioned)));

  const requirePolicy = (toolkitId: string, policyId: string, owner: Owner) =>
    storage.policies
      .getForOwner({ owner, key: policyId })
      .pipe(
        Effect.flatMap((entry) =>