server.js

const express = require('express');
var router = express.Router();
const dotenv = require('dotenv').config();
const app = express();

const parser = require('./modules/chunkParser');
const connect = require('./RabbitMQ/publisher');
const consul = require('./consul/consul');

consul.register();


app.get("/queue", function (req, res) {
    res.writeHead(200, { 'Content-Type': 'text plain' });
    res.write('Work in progress');
    res.end();
});

app.post("/", function (req, res) {
    try {
        req.on('data', function (chunk) {
            const res = parser.cleanJSONObject(chunk);
            console.log(res)
            res.then(result => connect.connect(result));
        });
        res.writeHead(200, { 'Content-Type': 'text plain' });
        res.write('Sucessful commit');
        res.end();
    } catch (err) {
        console.log(err);
    }
    
});


app.get('/test', (req, res) => {
    res.send({ hello: 'world' });
});

// app.post("/healthcheck", function(req, res){
//     let a = consul.serviceId;

//     consul.healthcheck(consul.serviceId);
//     res.writeHead(200, { 'Content-Type': 'text plain' });
//     res.write('Sucessful test health');
//     res.end();
    
// });

app.post("/unregister", function(req, res){
    consul.unregister(consul.serviceId);
    res.writeHead(200, { 'Content-Type': 'text plain' });
    res.write('Sucessful unregistred');
    res.end();
    
});


var swaggerUi = require('swagger-ui-express'),
    swaggerDocument = require('./swagger.json');

app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(swaggerDocument));
app.use('/api/v1', router);
app.listen(4666, () => console.log("Service listening on port 4666"));