Function integrationsRemove

packages/core/sdk/src/executor.ts:3128–3168

(
      slug: IntegrationSlug,
    )

      });

    const integrationsRemove = (
      slug: IntegrationSlug,
    ): Effect.Effect<void, IntegrationRemovalNotAllowedError | StorageFailure> =>
      transaction(
        Effect.gen(function* () {
          const existing = yield* findIntegrationRow(slug);
          if (!existing) return null;
          if (!existing.can_remove) {
            return yield* new IntegrationRemovalNotAllowedError({ slug });
          }
          const runtime = runtimes.get(existing.plugin_id);
          if (runtime?.plugin.removeIntegration) {
            yield* runtime.plugin
              .removeIntegration({
                ctx: runtime.ctx,
                integration: rowToIntegrationRecord(existing, describeAuthMethodsForRow(existing)),
              })
              .pipe(
                Effect.mapError((cause) =>
                  pluginStorageFailure(existing.plugin_id, "removeIntegration", cause),
                ),
              );
          }
          // Drop owned connections / tools / definitions for this integration.
          const where = (b: AnyCb) => b("integration", "=", String(slug));
          yield* core.deleteMany("tool", { where });
          yield* core.deleteMany("definition", { where });
          yield* core.deleteMany("connection", { where });
          yield* core.deleteMany("integration", {
            where: (b: AnyCb) => b("slug", "=", String(slug)),
          });
          return existing.plugin_id;
        }),
      ).pipe(
        Effect.tap((removedPluginId) =>
          removedPluginId !== null
            ? notifyIntegrationChange({ kind: "removed", pluginKey: removedPluginId, slug })
            : Effect.void,
        ),
        Effect.asVoid,
      );

    const integrationsDetect = (
      url: string,