(id: string, options?: { includeArchived?: boolean })
| 19 | export type WorkflowScope = 'active' | 'archived' | 'all' |
| 20 | |
| 21 | export async function getWorkflowById(id: string, options?: { includeArchived?: boolean }) { |
| 22 | const { includeArchived = false } = options ?? {} |
| 23 | const rows = await db |
| 24 | .select() |
| 25 | .from(workflowTable) |
| 26 | .where( |
| 27 | includeArchived |
| 28 | ? eq(workflowTable.id, id) |
| 29 | : and(eq(workflowTable.id, id), isNull(workflowTable.archivedAt)) |
| 30 | ) |
| 31 | .limit(1) |
| 32 | |
| 33 | return rows[0] |
| 34 | } |
| 35 | |
| 36 | export async function listWorkflows(workspaceId: string, options?: { scope?: WorkflowScope }) { |
| 37 | const { scope = 'active' } = options ?? {} |
no test coverage detected