in src/homedelivery/export.ts [130:150]
function getHolidaySuspensions(
downloadStream: ReadStream,
): Promise<Set<string>> {
return new Promise((resolve, reject) => {
const suspendedSubs = new Set<string>();
downloadStream
.pipe(csv.parse({ headers: true }))
.on('error', (error) =>
reject(Error(`Failed to read HolidaySuspensions raw CSV: ${error}`)),
)
.on('data', (row) => {
const subName = row['Subscription.Name'];
suspendedSubs.add(subName);
})
.on('end', (rowCount: number) => {
console.log(`Successfully read ${rowCount} rows of HolidaySuspensions`);
resolve(suspendedSubs);
});
});
}