All files / src/util schedule.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
1x
 
 
 
 
 
 
 
 
 
 
 
 
 
1x
2x
2x
2x
 
 
 
 
1x
 
 
 
 
 
 
 
import * as fs from 'fs';
 
export type ScheduleConfig = {
  queue: string;
  cron: string;
  data: object;
  scheduleOptions: object;
};
type RawSchedulesConfig = {
  schedules: {
    sharedScheduleOptions: {};
    list: Array<ScheduleConfig>;
  };
};
export const readScheduleConfig = (filePath: string): Array<ScheduleConfig> => {
  try {
    const { schedules } = JSON.parse(fs.readFileSync(filePath, 'utf-8')) as RawSchedulesConfig;
    return schedules.list.map((schedule) => ({
      ...schedule,
      scheduleOptions: { ...schedules.sharedScheduleOptions, ...schedule.scheduleOptions }
    }));
  } catch (error) {
    throw new Error(
      `Failed to parse the schedule config from file: ${filePath}\n error: ${
        error instanceof Error ? error.message : JSON.stringify(error)
      }`
    );
  }
};