javascript 模拟kue获取所有创建和处理的作业

Posted 2021-05-03

/* eslint-disable no-console */
let jobs = {
  created: [],
  processed: [],
};

const kue = {
  getJobs: () => jobs,
  clearJobs: () => {
    console.log('clearJobs');
    jobs = {
      created: [],
      processed: [],
    };
  },
  createQueue: () => ({
    create: (type, data) => ({
      save: () => {
        jobs.created = [
          ...jobs.created,
          {
            type,
            payload: data,
          },
        ];
      },
    }),
    process: process => jobs.processed.push(process),
  }),
};

export default kue;