( syncLogId: string, status: 'completed' | 'failed', result: SyncResult, errorMessage?: string )
| 195 | } |
| 196 | |
| 197 | async function completeSyncLog( |
| 198 | syncLogId: string, |
| 199 | status: 'completed' | 'failed', |
| 200 | result: SyncResult, |
| 201 | errorMessage?: string |
| 202 | ): Promise<void> { |
| 203 | await db |
| 204 | .update(knowledgeConnectorSyncLog) |
| 205 | .set({ |
| 206 | status, |
| 207 | completedAt: new Date(), |
| 208 | ...(errorMessage != null && { errorMessage }), |
| 209 | docsAdded: result.docsAdded, |
| 210 | docsUpdated: result.docsUpdated, |
| 211 | docsDeleted: result.docsDeleted, |
| 212 | docsUnchanged: result.docsUnchanged, |
| 213 | docsFailed: result.docsFailed, |
| 214 | }) |
| 215 | .where(eq(knowledgeConnectorSyncLog.id, syncLogId)) |
| 216 | } |
| 217 | |
| 218 | /** |
| 219 | * Decides whether deletion reconciliation may run for a sync. |
no test coverage detected