Function clearInWorkflowCheckpoints

apps/sim/lib/credentials/deletion.ts:195–223

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

}

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

  for (const row of rows) {
    const next = clearCredentialInValue(row.workflowState, credentialId)
    if (next.changed) {
      await db
        .update(schema.workflowCheckpoints)
        .set({ workflowState: next.value, updatedAt: new Date() })
        .where(eq(schema.workflowCheckpoints.id, row.id))
    }
  }
}

async function clearInKnowledgeConnectors(credentialId: string): Promise<void> {
  await db