import { Injectable } from '@nestjs/common';
import { InjectQueue } from '@nestjs/bull';
import { Queue } from 'bull';

@Injectable()
export class QService {
  constructor(
    @InjectQueue('cloud-request') private cloudQueue: Queue,
    @InjectQueue('device-request') private deviceQueue: Queue,
    @InjectQueue('validation-processor') private validationQueue: Queue
  ) {
  }

  certificate(payload, metadata) {
    return this.deviceQueue.add('certificate', { payload, metadata });
  }

  register(payload, metadata) {
    return this.cloudQueue.add('register', { payload, metadata });
  }

  validation(payload, metadata) {
    return this.validationQueue.add('validation', { payload, metadata });
  }
}