in src/weekly/export.ts [203:235]
export async function weeklyExport(input: Input) {
const stage = await getStage();
const deliveryDate = await getDeliveryDate(input);
const holidaySuspensionsStream = await getDownloadStream(
input.results,
stage,
HOLIDAYS_QUERY_NAME,
);
const holidaySuspensions = await getHolidaySuspensions(
holidaySuspensionsStream,
);
const introductoryPeriodStream = await getDownloadStream(
input.results,
stage,
INTRODUCTORY_QUERY_NAME,
);
const NonIntroductorySubsStream = await getDownloadStream(
input.results,
stage,
SUBSCRIPTIONS_QUERY_NAME,
);
const subscriptionsStream = new MultiStream([
introductoryPeriodStream,
NonIntroductorySubsStream,
]);
const outputFileNames = await processSubs(
subscriptionsStream,
deliveryDate,
stage,
holidaySuspensions,
);
return outputFileNames.map((f) => f.filename).join();
}