( entry: TaskRunLogEntry )
| 244 | }; |
| 245 | |
| 246 | export const getEntryTimeRange = ( |
| 247 | entry: TaskRunLogEntry |
| 248 | ): { start: number; end: number } => { |
| 249 | switch (entry.type) { |
| 250 | case TaskRunLogEntry_Type.COMMAND_EXECUTE: { |
| 251 | const start = getTimestampMs(entry.commandExecute?.logTime); |
| 252 | const end = getTimestampMs(entry.commandExecute?.response?.logTime); |
| 253 | return { start: start || 0, end: end || start || 0 }; |
| 254 | } |
| 255 | case TaskRunLogEntry_Type.SCHEMA_DUMP: |
| 256 | return { |
| 257 | start: getTimestampMs(entry.schemaDump?.startTime), |
| 258 | end: getTimestampMs(entry.schemaDump?.endTime), |
| 259 | }; |
| 260 | case TaskRunLogEntry_Type.DATABASE_SYNC: |
| 261 | return { |
| 262 | start: getTimestampMs(entry.databaseSync?.startTime), |
| 263 | end: getTimestampMs(entry.databaseSync?.endTime), |
| 264 | }; |
| 265 | case TaskRunLogEntry_Type.PRIOR_BACKUP: |
| 266 | return { |
| 267 | start: getTimestampMs(entry.priorBackup?.startTime), |
| 268 | end: getTimestampMs(entry.priorBackup?.endTime), |
| 269 | }; |
| 270 | case TaskRunLogEntry_Type.COMPUTE_DIFF: |
| 271 | return { |
| 272 | start: getTimestampMs(entry.computeDiff?.startTime), |
| 273 | end: getTimestampMs(entry.computeDiff?.endTime), |
| 274 | }; |
| 275 | case TaskRunLogEntry_Type.GHOST_MIGRATION: |
| 276 | return { |
| 277 | start: getTimestampMs(entry.ghostMigration?.startTime), |
| 278 | end: getTimestampMs(entry.ghostMigration?.endTime), |
| 279 | }; |
| 280 | default: { |
| 281 | const time = getTimestampMs(entry.logTime); |
| 282 | return { start: time, end: time }; |
| 283 | } |
| 284 | } |
| 285 | }; |
| 286 | |
| 287 | const extractStatementFromRange = ( |
| 288 | range: { start: number; end: number }, |
nothing calls this directly
no test coverage detected