Function integrationsRemove

packages/core/sdk/src/executor.ts:3368–3424

(
      slug: IntegrationSlug,
    )

      });

    const integrationsRemove = (
      slug: IntegrationSlug,
    ): Effect.Effect<
      void,
      IntegrationRemovalNotAllowedError | OrgWriteDeniedError | StorageFailure
    > =>
      transaction(
        Effect.gen(function* () {
          yield* guardOrgWrite();
          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) {
            const authMethods = yield* describeAuthMethodsForRow(existing);
            yield* runtime.plugin
              .removeIntegration({
                ctx: runtime.ctx,
                integration: rowToIntegrationRecord(existing, authMethods),
              })
              .pipe(
                Effect.mapError((cause) =>
                  pluginStorageFailure(existing.plugin_id, "removeIntegration", cause),
                ),
              );
          }
          // The catalog row goes first through the bound handle: a read-only
          // (platform-view) context is refused here, before the widened
          // cascade below could touch anything.
          yield* core.deleteMany("integration", {
            where: (b: AnyCb) => b("slug", "=", String(slug)),
          });
          // Drop connections / tools / definitions for this integration across
          // EVERY subject in the tenant, not just the remover's own rows. A
          // removed integration has no reason to keep anyone's rows, and rows
          // left behind become orphans: invisible in the catalog, yet still
          // listed to agents and still targetable by reconnect.
          const where = (b: AnyCb) => b("integration", "=", String(slug));
          yield* cascadeCore.deleteMany("tool", { where });
          yield* cascadeCore.deleteMany("definition", { where });
          yield* cascadeCore.deleteMany("connection", { where });
          return existing.plugin_id;
        }),
      ).pipe(
        Effect.tap((removedPluginId) =>
          removedPluginId !== null
            ? notifyIntegrationChange({
                kind: "removed",
                pluginKey: removedPluginId,
                slug,
              })
            : Effect.void,
        ),
        Effect.asVoid,
      );