Function clearInWorkflowBlocks

apps/sim/lib/credentials/deletion.ts:96–133

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

}

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

  let updated = 0
  for (const row of rows) {
    const next = clearCredentialInValue(row.subBlocks, credentialId)
    if (next.changed) {
      await db
        .update(schema.workflowBlocks)
        .set({ subBlocks: next.value, updatedAt: new Date() })
        .where(eq(schema.workflowBlocks.id, row.id))
      updated += 1
    }
  }
  if (updated > 0) {
    logger.info('Cleared credential refs in workflow_blocks', {
      credentialId,
      workspaceId,
      updated,
    })
  }
}

async function clearInDeploymentVersions(
  credentialId: string,