import { getQueue } from '@spokenio/jobqueue-producer';
import { Body, Controller, Post, Route } from 'tsoa';
import { AddJobInput, AddJobPayload } from './types';

@Route('jobqueue')
export class JobQueueController extends Controller {
  @Post()
  async jobQueues(
    @Body()
    requestBody: AddJobInput
  ): Promise<AddJobPayload> {
    const queue = getQueue(requestBody.kind);
    const response = await queue.add(requestBody.data);
    return {
      id: response.id.toString(),
    };
  }
}