salmanagustian

import { Module } from '@nestjs/common';
import { AppController } from './app.controller';
import { AppService } from './app.service';
import { QueueConfigModule } from './config/queue/config.module';
import { PurchaseModule } from './purchase/purchase.module';

@Module({
  imports: [QueueConfigModule, PurchaseModule],
  controllers: [AppController],
  providers: [AppService],

salmanagustian

import { BullModule } from '@nestjs/bull';
import { Module } from '@nestjs/common';
import { PurchaseProcessor } from './purchase-queue.processor';

@Module({
  imports: [
    BullModule.registerQueue({
      name: 'send-invoice',
    }),
  ],

salmanagustian

import { OnQueueCompleted, Process, Processor } from '@nestjs/bull';
import { Logger } from '@nestjs/common';
import { Job } from 'bull';

@Processor('send-invoice')
export class PurchaseProcessor {
  private readonly logger = new Logger(PurchaseProcessor.name);

  // Consumers
  @Process()

salmanagustian

import { BullModule } from '@nestjs/bull';
import { Module } from '@nestjs/common';
import { PurchaseQueueModule } from 'src/job/purchase/purchase-queue.module';
import { PurchaseController } from './purchase.controller';
import { PurchaseService } from './purchase.service';

@Module({
  imports: [PurchaseQueueModule],
  controllers: [PurchaseController],
  providers: [PurchaseService],

salmanagustian

import { InjectQueue } from '@nestjs/bull';
import { Injectable } from '@nestjs/common';
import { Queue } from 'bull';
import { IUserPurchase } from './interface/user-purchasing.interface';

@Injectable()
export class PurchaseService {
  constructor(@InjectQueue('send-invoice') private purchaseQueue: Queue) {}
  async sendInvoiceToCustomer(data: IUserPurchase[]) {
    // Producers

salmanagustian

import { Controller, Get, Post } from '@nestjs/common';
import { IUserPurchase } from './interface/user-purchasing.interface';
import { PurchaseService } from './purchase.service';

@Controller('/api/purchase')
export class PurchaseController {
  constructor(private readonly purchaseService: PurchaseService) {}

  @Post()
  async send() {

salmanagustian

import * as dotenv from 'dotenv';
import * as fs from 'fs';
const env = dotenv.parse(fs.readFileSync('.env'));

export default {
  redis: {
    host: env.REDIS_HOST,
    port: env.REDIS_PORT,
    db: env.REDIS_DB,
    password: env.REDIS_PASSWORD,

salmanagustian

import { SharedBullConfigurationFactory } from '@nestjs/bull';
import { Injectable } from '@nestjs/common';
import { QueueOptions } from 'bull';
import * as config from './config';

@Injectable()
export class QueueConfigProvider implements SharedBullConfigurationFactory {
  createSharedConfiguration(): QueueOptions {
    return config as any;
  }

salmanagustian

import { BullModule } from '@nestjs/bull';
import { Module } from '@nestjs/common';
import { PurchaseQueueModule } from 'src/job/purchase/purchase-queue.module';
import { PurchaseProcessor } from 'src/job/purchase/purchase-queue.processor';
import { QueueConfigProvider } from './config.provider';

@Module({
  imports: [
    BullModule.forRootAsync({ useClass: QueueConfigProvider }),
    BullModule.registerQueue({ name: 'send-invoice' }),