server.js

require('dotenv').config();
const express = require('express');
const morgan = require('morgan');
const logger = require('./src/logger');
const { handleWebhook } = require('./src/webhook-handler');

const app = express();
const PORT = process.env.PORT || 3000;

app.use(express.json());

app.use(morgan('combined', {
  stream: {
    write: (message) => logger.info(message.trim())
  }
}));

app.get('/health', (req, res) => {
  res.status(200).json({
    status: 'healthy',
    timestamp: new Date().toISOString(),
    service: 'feature-flag-webhook-receiver'
  });
});

app.post('/webhook', handleWebhook);

app.use((err, req, res, next) => {
  logger.error('Unhandled error', {
    error: err.message,
    stack: err.stack
  });

  res.status(500).json({
    error: 'Internal server error',
    details: err.message
  });
});

const server = app.listen(PORT, () => {
  logger.info(`Server started on port ${PORT}`);
  logger.info('Endpoints:');
  logger.info(`  POST http://localhost:${PORT}/webhook - Receive feature flag webhooks`);
  logger.info(`  GET  http://localhost:${PORT}/health - Health check`);
});

process.on('SIGTERM', () => {
  logger.info('SIGTERM received, shutting down gracefully');
  server.close(() => {
    logger.info('Server closed');
    process.exit(0);
  });
});

process.on('SIGINT', () => {
  logger.info('SIGINT received, shutting down gracefully');
  server.close(() => {
    logger.info('Server closed');
    process.exit(0);
  });
});

module.exports = app;