Function planMigration

packages/core/sdk/src/migration-spec.ts:1298–1805

(input: MigrationInput)

  `${op.targetProvider}\0${op.owner.tenant}\0${op.owner.owner}\0${op.owner.subject}\0${op.itemId}`;

export const planMigration = (input: MigrationInput): MigrationPlan => {
  const warnings: string[] = [];
  const secretOps: SecretOp[] = [];
  const connections: PlannedConnectionFull[] = [];
  const ownerForScope = input.ownerForScope ?? parseScope;
  const defaultWritableProvider = input.defaultWritableProvider ?? "workos-vault";

  // --- Integrations (one per source) + the policy slug map (source ∪ tool ids).
  const integrations: PlannedIntegrationRow[] = [];
  const slugMap = new Map<string, string>();
  const sourceIdsByTenant = new Map<string, Set<string>>();
  const addSourceIdForOwner = (owner: OwnerKeys | null, sourceId: string): void => {
    if (!owner) return;
    const set = sourceIdsByTenant.get(owner.tenant) ?? new Set<string>();
    set.add(sourceId);
    sourceIdsByTenant.set(owner.tenant, set);
  };
  for (const id of input.toolSourceIds) slugMap.set(id, id);
  for (const source of input.sources) {
    slugMap.set(source.id, source.id);
    addSourceIdForOwner(ownerForScope(source.scopeId), source.id);
    const migrated = input.migratedConfigs.get(sourceKey(source.scopeId, source.id));
    const row = planIntegrationRow({
      scopeId: source.scopeId,
      sourceId: source.id,
      pluginId: source.pluginId,
      description: source.name,
      config: migrated?.config ?? {},
      ownerForScope,
    });
    if (!row) {
      warnings.push(`Skipped source "${source.id}": unparseable scope "${source.scopeId}".`);
      continue;
    }
    integrations.push(row);
    for (const w of migrated?.warnings ?? []) warnings.push(`[${source.id}] ${w}`);
  }

  const policySlugMapForOwner = (owner: OwnerKeys): ReadonlyMap<string, string> => {
    const tenantSourceIds = sourceIdsByTenant.get(owner.tenant);
    if (
      tenantSourceIds?.has(MICROSOFT_GRAPH_CURATED_SLUG) &&
      !tenantSourceIds.has(MICROSOFT_GRAPH_LEGACY_SLUG)
    ) {
      return new Map(slugMap).set(MICROSOFT_GRAPH_LEGACY_SLUG, MICROSOFT_GRAPH_CURATED_SLUG);
    }
    return slugMap;
  };

  // --- Group bindings by (scope, source); each group → one connection.
  const groups = new Map<string, V1BindingRow[]>();
  for (const b of input.bindings) {
    const key = sourceKey(b.scopeId, b.sourceId);
    const list = groups.get(key) ?? [];
    list.push(b);
    groups.set(key, list);
  }
  const connectionById = new Map<string, V1ConnectionRow>();