Using bull with Ts.ED

BullBuilder.ts

import {createInjector, InjectorService, Provider} from "@tsed/common";
import {Store} from "@tsed/core";

export class BullBuilder {
  readonly injector: InjectorService;

  constructor(settings: any) {
    this.injector = createInjector({
      settings,
      providers: []
    });
  }

  static async bootstrap(settings: any) {
    const builder = new BullBuilder(settings);

    await builder.injector.load();

    return builder;
  }

  getJobs() {
    return this.injector.getProviders("job:service").reduce((map: Map<string, any>, provider: Provider) => {
      const jobs = provider.store.get("jobs");

      Object.entries(jobs).forEach(([jobName, propertyKey]: [string, string]) => {
        map.set(jobName, (job: Job<any>) => {
          const service: any = this.injector.get(provider.token);

          return service[propertyKey](job);
        });
      });

      return map;
    }, new Map());
  }

  runJob(job: Job<any>) {
    const jobs = this.getJobs();
    const handler = jobs.get(job.data.jobName);

    if (job) {
      this.injector.logger.info(`Handle ${job.data.jobName}`);
      return handler(job);
    }

    this.injector.logger.warning(`No job found for ${job.data.jobName}`);
    // do somethings
  }
}

index.ts

import {BullBuilder} from "./BullBuilder"
import {configuration} from "./path/to/your/config";  // share the Ts.ED server configuration with this platform

import "./jobs/MyJobService"; // import manually all job services in this files

export default async function boostrap(job: Job<any>) {
  const platform = await BullBuilder.bootstrap(configuration);

  return platform.runJob(job);
}

job.ts

/**
 * Register a method to a jobName
 * @param name
 * @constructor
 */
export function Job(name: string): MethodDecorator {
  return (target, propertyKey, descriptor) => {
    Store.from(target).merge("jobs", {
      [name]: propertyKey
    });
  };
}

jobService.ts

export function JobService () {
  return Injectable({type: "job:service"})
}

MyJobService.ts

@JobService()
class MyJobService {
    @Job("jobname")
    myJobHandler(job) {}
}