Function clearInDeploymentVersions

apps/sim/lib/credentials/deletion.ts:135–163

(
  credentialId: string,
  workspaceId: string,
  needle: string
)

}

async function clearInDeploymentVersions(
  credentialId: string,
  workspaceId: string,
  needle: string
): Promise<void> {
  const rows = await db
    .select({
      id: schema.workflowDeploymentVersion.id,
      state: schema.workflowDeploymentVersion.state,
    })
    .from(schema.workflowDeploymentVersion)
    .innerJoin(schema.workflow, eq(schema.workflow.id, schema.workflowDeploymentVersion.workflowId))
    .where(
      and(
        eq(schema.workflow.workspaceId, workspaceId),
        sql`${schema.workflowDeploymentVersion.state}::text LIKE ${needle}`
      )
    )

  for (const row of rows) {
    const next = clearCredentialInValue(row.state, credentialId)
    if (next.changed) {
      await db
        .update(schema.workflowDeploymentVersion)
        .set({ state: next.value })
        .where(eq(schema.workflowDeploymentVersion.id, row.id))
    }
  }
}

async function clearInPausedExecutions(
  credentialId: string,