import { Injectable, OnModuleInit } from "@nestjs/common";

@Injectable()
export class MessagingStartupService implements OnModuleInit {

    public onModuleInit(): any {

        const amqp = require('amqplib/callback_api');

        amqp.connect(process.env.RABBITMQ_URI, function (error0, connection) {

            if (error0) {

                throw error0;

            }

            connection.createChannel(function (error1, channel) {

                if (error1) {

                    throw error1;

                }

                console.log(channel);

                channel.assertExchange(process.env.RABBITMQ_EXCHANGE, 'topic', {

                    durable: true

                });
                channel.bindQueue('rbac', process.env.RABBITMQ_EXCHANGE, '');

            });

        });

    }

}