A service to create and fire events

events.service.ts

import { Injectable } from '@nestjs/common';
import { PrismaService } from 'src/prisma.service';
import { EventCreateDTO } from '../dto/event-create.dto';
import { OnEvent, EventEmitter2 } from '@nestjs/event-emitter';
import { EventTriggeredEvent } from '../events/event-triggered.event';
import { HttpService } from '@nestjs/axios';

@Injectable()
export class EventService {
  constructor(
    private readonly prisma: PrismaService,
    private eventEmitter: EventEmitter2,
    private readonly httpService: HttpService,
  ) {}

  async createEvent(data: EventCreateDTO) {
    const event = await this.prisma.event.create({
      data: {
        name: data.name,
      },
    });

    return event;
  }

  async triggerEvent(eventId: number, payload) {
    this.eventEmitter.emit(
      'event.triggered',
      new EventTriggeredEvent(eventId, payload),
    );
  }

  @OnEvent('event.triggered')
  public async onTriggerRecieved(event: EventTriggeredEvent) {
    const actions = await this.prisma.action.findMany({
      where: {
        event_id: event.eventId,
      },
    });

    for await (const action of actions) {
      try {
        await this.httpService.axiosRef.post(trigger.endpoint, event.payload, {
          baseURL: null,
          insecureHTTPParser: true,
        });
      } catch (err) {
        console.log(err);
      }
    }
  }
}