|
| 1 | +import { Settings } from 'luxon'; |
1 | 2 | import { DateInterval, type UnsecuredDto } from '~/common';
|
2 | 3 | import { EventsHandler, type IEventHandler, ILogger, Logger } from '~/core';
|
3 | 4 | import { EngagementService } from '../../engagement';
|
@@ -89,12 +90,33 @@ export class SyncProgressReportToEngagementDateRange
|
89 | 90 | : [event.engagement];
|
90 | 91 |
|
91 | 92 | for (const engagement of engagements) {
|
| 93 | + Settings.throwOnInvalid = false; |
92 | 94 | const [updated, prev] =
|
93 | 95 | event instanceof ProjectUpdatedEvent
|
94 | 96 | ? this.intervalsFromProjectChange(engagement, event)
|
95 | 97 | : event instanceof EngagementCreatedEvent
|
96 | 98 | ? [engagementRange(event.engagement), null]
|
97 |
| - : [engagementRange(event.updated), engagementRange(event.previous)]; |
| 99 | + : [ |
| 100 | + engagementRange(event.updated), // |
| 101 | + engagementRange(event.previous), |
| 102 | + ]; |
| 103 | + Settings.throwOnInvalid = true; |
| 104 | + if (prev && !prev.isValid) { |
| 105 | + this.logger.error('Found invalid date range for event', { |
| 106 | + eventType: event.constructor.name, |
| 107 | + diffSide: 'before', |
| 108 | + event, |
| 109 | + }); |
| 110 | + throw new Error('Invalid engagement date range'); |
| 111 | + } |
| 112 | + if (updated && !updated.isValid) { |
| 113 | + this.logger.error('Found invalid date range for event', { |
| 114 | + eventType: event.constructor.name, |
| 115 | + diffSide: 'after', |
| 116 | + event, |
| 117 | + }); |
| 118 | + throw new Error('Invalid engagement date range'); |
| 119 | + } |
98 | 120 |
|
99 | 121 | const diff = this.diffBy(updated, prev, 'quarter');
|
100 | 122 |
|
|
0 commit comments