MermsEventsManager/service/ebroker.js

'use strict';

const request = require('request');
const db = require('../app/db')
const logger = require('../app/logger');
const KafkaConfig = require("../app/kconfig");

var ebroker = {
    eventPublish: function (req, res, next) {

        try {
            const { message } = req.body;
            console.log('THIS-> req.body ->  ', req.body);
            const kafkaConfig = new KafkaConfig();
            const messages = [{ key: "key1", value: message }];
           // const messages = [{ key: "key1", value: "ameye olusesan" }];
             kafkaConfig.produce("FLUTTER_PAYMENT_RECEIVED", messages).then(r =>{
                 console.log('THIS->RET->  ',r);
             } );

            res.status(200).json({
                status: "Ok!",
                message: "Message successfully send!",
            });
        } catch (error) {
            console.log(error);
        }

        let resultItem ={
            "result": [],
            "total_record": 0
        }
        next(null,  resultItem ); // pass control to the next handler
    },
    eventSendMoney: function (req, res, next) {

        try {
            const { message } = req.body;
            console.log('THIS-> req.body ->  ', req.body);
            const kafkaConfig = new KafkaConfig();
            const messages = [{ key: "send", value: JSON.stringify(message) }];
            kafkaConfig.produce("SENDMONEY_RECEIVED", messages).then(r =>{
                console.log('THIS->RET->  ',r);
            } );

            res.status(200).json({
                status: "Ok!",
                message: "Message successfully send!",
            });
        } catch (error) {
            console.log(error);
        }

        let resultItem ={
            "result": [],
            "total_record": 0
        }
        next(null,  resultItem ); // pass control to the next handler
    },
    eventConsumer: function (req, res, next) {

        //console.log("REQ---->",req.body.uid);
        var data = {
            "uid": req.body.uid,
            "member_id": req.body.member_id,
            "limit": (req.body.limit != null && req.body.limit !== "") ? req.body.limit : 20,
            "sessionid": req.body.sessionid,
            "page": req.body.page
        };


    }
};
module.exports = ebroker;