upgrade handlers

lib/server/handlers/sthGetLogLevelHandler.js

@@ -55,6 +55,7 @@ function getLogLevelHandler(request, reply) {
 
     const response = reply(getLogLevelResponse(level));
     sthServerUtils.addFiwareCorrelator(request, response);
+    return response;
 }
 
 module.exports = getLogLevelHandler;

lib/server/handlers/sthGetVersionHandler.js

@@ -31,7 +31,7 @@ const sthUtils = require(ROOT_PATH + '/lib/utils/sthUtils');
  */
 function getVersionHandler(request, reply) {
     const message = sthUtils.getVersion();
-    return reply(message);
+    return reply.response(message);
 }
 
 module.exports = getVersionHandler;

lib/server/handlers/sthNotFoundHandler.js

@@ -41,11 +41,12 @@ function notFoundHandler(request, reply) {
         '404 - Not Found route for the request: ' + request.method.toUpperCase() + ' ' + request.url.path
     );
     if (request.path.startsWith('/STH/v2')) {
-        response = reply({ error: 'NotFound', description: 'invalid path' }).code(404);
+        response = reply.response({ error: 'NotFound', description: 'invalid path' }).code(404);
     } else {
-        response = reply({ statusCode: 404, error: 'Not Found' }).code(404);
+        response = reply.response({ statusCode: 404, error: 'Not Found' }).code(404);
     }
     sthServerUtils.addFiwareCorrelator(request, response);
+    return response;
 }
 
 module.exports = notFoundHandler;

lib/server/handlers/sthNotificationHandler.js

@@ -195,7 +195,7 @@ function storeRawData(data, reply, callback) {
                                 sthLogger.debug(request.sth.context, 'Raw data successfully stored');
                             }
                             if (++counterObj.counter === totalTasks) {
-                                response = reply(err);
+                                response = reply.response(err);
                                 sthServerUtils.addFiwareCorrelator(request, response);
                             }
                             process.nextTick(callback.bind(null, err));
@@ -255,7 +255,7 @@ function storeAggregatedData(data, reply) {
                 // There was an error when getting the collection
                 sthLogger.error(request.sth.context, 'Error when getting the aggregated data collection for storing');
                 if (++counterObj.counter === totalTasks) {
-                    response = reply(err);
+                    response = reply.response(err);
                     sthServerUtils.addFiwareCorrelator(request, response);
                 }
             } else {
@@ -282,7 +282,7 @@ function storeAggregatedData(data, reply) {
                                 sthLogger.debug(request.sth.context, 'Aggregated data successfully stored');
                             }
                             if (++counterObj.counter === totalTasks) {
-                                response = reply(err);
+                                response = reply.response(err);
                                 sthServerUtils.addFiwareCorrelator(request, response);
                             }
                         }
@@ -390,7 +390,7 @@ function processNotification(recvTime, request, reply) {
         );
         const error = boom.badRequest(message);
         error.output.payload.validation = { source: 'payload', keys: ['attributes'] };
-        return reply(error);
+        return reply.response(error);
     }
 
     for (let i = 0; i < contextResponses.length; i++) {

lib/server/handlers/sthSetLogLevelHandler.js

@@ -41,8 +41,9 @@ function setLogLevelHandler(request, reply) {
 
     sthLogger.info(request.sth.context, 'Log level set to: ' + level);
 
-    const response = reply();
+    const response = reply.response();
     sthServerUtils.addFiwareCorrelator(request, response);
+    return response;
 }
 
 module.exports = setLogLevelHandler;