Function integrationsRegister

packages/core/sdk/src/executor.ts:2676–2721

(
      pluginId: string,
      input: RegisterIntegrationInput,
    )

      config.onIntegrationChange ? afterCommit(config.onIntegrationChange(event)) : Effect.void;

    const integrationsRegister = (
      pluginId: string,
      input: RegisterIntegrationInput,
    ): Effect.Effect<void, StorageFailure> =>
      transaction(
        Effect.gen(function* () {
          const now = new Date();
          const existing = yield* findIntegrationRow(input.slug);
          const config = input.config === undefined ? null : input.config;
          if (existing) {
            yield* core.updateMany("integration", {
              where: (b: AnyCb) => b("slug", "=", String(input.slug)),
              set: {
                plugin_id: pluginId,
                name: input.name ?? existing.name ?? null,
                description: input.description,
                config,
                can_remove: input.canRemove ?? Boolean(existing.can_remove),
                can_refresh: input.canRefresh ?? Boolean(existing.can_refresh),
                updated_at: now,
              },
            });
            return false;
          }
          yield* core.create("integration", {
            tenant,
            slug: String(input.slug),
            plugin_id: pluginId,
            name: input.name ?? null,
            description: input.description,
            config,
            can_remove: input.canRemove ?? true,
            can_refresh: input.canRefresh ?? false,
            created_at: now,
            updated_at: now,
          });
          return true;
        }),
      ).pipe(
        Effect.tap((created) =>
          created
            ? notifyIntegrationChange({ kind: "added", pluginKey: pluginId, slug: input.slug })
            : Effect.void,
        ),
        Effect.asVoid,
      );

    const integrationsUpdate = (
      slug: IntegrationSlug,