diff --git a/src/ozonetel/cdr-enrichment.service.ts b/src/ozonetel/cdr-enrichment.service.ts index 2d5ed6c..19cc7be 100644 --- a/src/ozonetel/cdr-enrichment.service.ts +++ b/src/ozonetel/cdr-enrichment.service.ts @@ -53,8 +53,12 @@ export class CdrEnrichmentService implements OnModuleInit, OnModuleDestroy { let skipped = 0; // Walk the IST-date window. For each date, pull CDR + patch Calls. + // Sleep 35s between dates — Ozonetel caps CDR endpoints at 2 req/min + // and the dispose flow shares that budget (fetchCdrByUCID per outbound). const dates = this.recentDatesIst(ENRICHMENT_DATE_WINDOW_DAYS); - for (const date of dates) { + for (let i = 0; i < dates.length; i++) { + const date = dates[i]; + if (i > 0) await new Promise((r) => setTimeout(r, 35_000)); const cdrRows = await this.ozonetel.fetchCDR({ date }).catch(() => []); if (cdrRows.length === 0) continue;