export interface TriggerDevJobConsumer<TTrigger extends Trigger<EventSpecification<any>>, TIntegrations extends Record<string, TriggerIntegration> {
  getTrigger(): TTrigger;
  run: (payload: TriggerEventType<TTrigger>, io: IOWithIntegrations<TIntegrations>, context: TriggerContext) => Promise<any>;
}

@Job({
  id: "test-job",
  name: "Test Job One",
  version: "0.0.1",
})
export class MyCustomJobConsumer {
  public getTrigger() {
    return eventTrigger({
      name: "test.event",
    });
  }

  public async run(payload, io, ctx) {
    await io.logger.info("Hello world!", { payload });

    return {
      message: "Hello world!",
    };
  }
}