Miguel API nodeJS

var express = require('express');
// var   bodyParser = require('body-parser');
var app = express();
var fs = require("fs");

// parse application/x-www-form-urlencoded
//app.use(bodyParser.urlencoded({ extended: false }))

// parse application/json

var app = express();

const bodyParser = require("body-parser");
app.use(bodyParser.json());



app.post('/', function(request, response){

console.log(request.body);


 var amqp = require('amqplib/callback_api');
amqp.connect('amqp://miguel:miguel123@152.228.133.222:32777/mobile_app', function(error0, connection) {
  if (error0) {
    throw error0;
  }
  connection.createChannel(function(error1, channel) {
    if (error1) {
      throw error1;
    }
    var exchange = 'crowd_sensing_exchange';
    var severity = 'crowd_sensing';


   var JsonMsg = request.body;


  var JsonMsg2={
      "user_id": "1",
     "device_id":"sabri test",
      "datetime":"10-22-2020 15:21:50",
      "location":{
          "lat":43.48,
         "lng":-1.49
     },
     "sensors":{
         "temperature": "27"
     }
    }


   // var JsonMsg=request.body;

    var msg = JSON.stringify(JsonMsg2);
console.log(msg);
    channel.publish(exchange, severity, Buffer.from(msg));
    console.log(" [x] Sent %s: '%s'", severity, msg);

  });

  response.end("yes");

});
});


var server = app.listen(3000, function () {
   var host = server.address().address
   var port = server.address().port
   console.log("Example app listening at http://%s:%s", host, port)
})