app.js

const express = require('express');
const path = require('path');
const cookieParser = require('cookie-parser');
const logger = require('morgan');
const bodyParser = require('body-parser');
const barnRouter = require('./routes/barn');
const config = require('./utils/config.js');
const MessageConsumer = require('./service/kafka/message-consumer-service.js');
const SSE = require('sse');


const app = express();

app.use(logger('dev'));
app.use(express.json());
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));
app.use(express.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.get('/', (req, res, next) => {
    res.setHeader('Content-Type', 'application/json');
    res.send(JSON.stringify({ health: "OK", at: new Date(), source: 'node-express' }));
})

app.use('/barn', barnRouter);

const consumer = new MessageConsumer(config.outTopicName, config.kafkaOutgoingBootstrapServer, app);
consumer.start();

module.exports = app;