Function processCredentialDraft

apps/sim/lib/credentials/draft-processor.ts:23–70

(params: ProcessCredentialDraftParams)

 * Used by Better Auth's `account.create.after` hook and custom OAuth flows (Shopify, Trello).
 */
export async function processCredentialDraft(params: ProcessCredentialDraftParams): Promise<void> {
  const { userId, providerId, accountId } = params

  const [draft] = await db
    .select()
    .from(schema.pendingCredentialDraft)
    .where(
      and(
        eq(schema.pendingCredentialDraft.userId, userId),
        eq(schema.pendingCredentialDraft.providerId, providerId),
        sql`${schema.pendingCredentialDraft.expiresAt} > NOW()`
      )
    )
    .limit(1)

  if (!draft) return

  const now = new Date()

  if (draft.credentialId) {
    await handleReconnectCredential({
      draft,
      newAccountId: accountId,
      workspaceId: draft.workspaceId,
      userId,
      now,
    })
  } else {
    await handleCreateCredentialFromDraft({
      draft,
      accountId,
      providerId,
      userId,
      now,
    })
  }

  await db
    .delete(schema.pendingCredentialDraft)
    .where(eq(schema.pendingCredentialDraft.id, draft.id))

  logger.info('Processed credential draft', {
    draftId: draft.id,
    userId,
    providerId,
    isReconnect: Boolean(draft.credentialId),
  })
}