Function applyOrg

packages/plugins/provider-service-split/src/sqlite.ts:280–518

(
  client: SqliteDataMigrationClient,
  org: OrgPlan,
)

  });

const applyOrg = (
  client: SqliteDataMigrationClient,
  org: OrgPlan,
): Effect.Effect<void, DataMigrationError> =>
  Effect.gen(function* () {
    if (org.completed) return;
    if (org.hardErrors.length > 0) return;
    const now = Date.now();

    for (const copy of org.blobCopies.filter((item) => item.backend === "database")) {
      const rowId = yield* stableId("blob", org.tenant, copy.targetNamespace, copy.key);
      const source = yield* execute(client, {
        sql: "SELECT value FROM blob WHERE namespace = ? AND key = ? LIMIT 1",
        args: [copy.sourceNamespace, copy.key],
      });
      const sourceRow = source.rows[0];
      if (!sourceRow || typeof sourceRow.value !== "string") {
        return yield* new DataMigrationError({
          migration: MIGRATION_NAME,
          cause: `Missing source blob ${copy.sourceNamespace}/${copy.key}`,
        });
      }
      yield* execute(client, {
        sql: `INSERT INTO blob (namespace, key, value, row_id, id)
          VALUES (?, ?, ?, ?, ?)
          ON CONFLICT(id) DO NOTHING`,
        args: [
          copy.targetNamespace,
          copy.key,
          sourceRow.value,
          rowId,
          JSON.stringify([copy.targetNamespace, copy.key]),
        ],
      });
    }

    for (const row of org.integrations.filter((item) => item.action === "create")) {
      const rowId = yield* stableId("integration", org.tenant, row.target.slug);
      yield* execute(client, {
        sql: `INSERT INTO integration
          (slug, plugin_id, name, description, config, health_check, config_revised_at,
           can_remove, can_refresh, created_at, updated_at, row_id, tenant)
          VALUES (?, ?, ?, ?, ?, ?, NULL, 1, 1, ?, ?, ?, ?)
          ON CONFLICT(tenant, slug) DO NOTHING`,
        args: [
          row.target.slug,
          row.target.pluginId,
          row.target.name,
          row.target.description,
          JSON.stringify(scrubJson(row.config)),
          row.healthCheck ? JSON.stringify(scrubJson(row.healthCheck)) : null,
          now,
          now,
          rowId,
          org.tenant,
        ],
      });
    }