diff --git a/src/device-registry/bin/index.js b/src/device-registry/bin/index.js index ccfd6d2053..e9914ed59f 100644 --- a/src/device-registry/bin/index.js +++ b/src/device-registry/bin/index.js @@ -9,7 +9,7 @@ const constants = require("@config/constants"); const log4jsConfiguration = require("@config/log4js"); log4js.configure(log4jsConfiguration); const logger = log4js.getLogger(`${constants.ENVIRONMENT} -- bin/index`); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); try { require("fs").mkdirSync("./log"); @@ -24,7 +24,7 @@ const startKafka = async () => { await kafkaConsumer().catch((error) => { logObject("KAFKA error in the main()", error); logger.error( - `πŸ›πŸ› KAFKA: internal server error in the main() -- ${jsonify(error)}` + `πŸ›πŸ› KAFKA: internal server error in the main() -- ${stringify(error)}` ); logger.error( `πŸ›πŸ› KAFKA error message: internal server error in the main() -- ${error.message}` @@ -37,11 +37,11 @@ const main = async () => { await startKafka(); createServer(); } catch (error) { - logger.error(`πŸ›πŸ› error in the main() -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› error in the main() -- ${stringify(error)}`); } }; main().catch((error) => { console.error("πŸ›πŸ› Error starting the application: ", error); - logger.error(`πŸ›πŸ› Error starting the application -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Error starting the application -- ${stringify(error)}`); }); diff --git a/src/device-registry/bin/jobs/kafka-consumer.js b/src/device-registry/bin/jobs/kafka-consumer.js index 6101dceb39..604dbb6dad 100644 --- a/src/device-registry/bin/jobs/kafka-consumer.js +++ b/src/device-registry/bin/jobs/kafka-consumer.js @@ -10,7 +10,7 @@ const Joi = require("joi"); const { jsonrepair } = require("jsonrepair"); const cleanDeep = require("clean-deep"); const isEmpty = require("is-empty"); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); const eventSchema = Joi.object({ s2_pm2_5: Joi.number().optional(), @@ -68,7 +68,7 @@ const consumeHourlyMeasurements = async (messageData) => { try { if (isEmpty(messageData)) { logger.error( - `KAFKA: the sent message in undefined --- ${jsonify(messageData)}` + `KAFKA: the sent message in undefined --- ${stringify(messageData)}` ); } const repairedJSONString = jsonrepair(messageData); @@ -78,7 +78,7 @@ const consumeHourlyMeasurements = async (messageData) => { // const measurements = JSON.parse(repairedJSONString); if (!Array.isArray(measurements) || isEmpty(measurements)) { // logger.error( - // `KAFKA: the sent measurements are not an array or they are just empty (undefined) --- ${jsonify( + // `KAFKA: the sent measurements are not an array or they are just empty (undefined) --- ${stringify( // measurements // )}` // ); @@ -122,17 +122,17 @@ const consumeHourlyMeasurements = async (messageData) => { // }; }); // logger.error( - // `KAFKA: Input validation formatted errors -- ${jsonify( + // `KAFKA: Input validation formatted errors -- ${stringify( // errorDetails // )}` // ); // logger.error( - // `KAFKA: ALL the input validation errors --- ${jsonify(error.details)}` + // `KAFKA: ALL the input validation errors --- ${stringify(error.details)}` // ); // logger.info( - // `KAFKA: the VALUE for ALL the shared input validation errors --- ${jsonify(value)}` + // `KAFKA: the VALUE for ALL the shared input validation errors --- ${stringify(value)}` // ); } // logObject("value", value); @@ -150,14 +150,14 @@ const consumeHourlyMeasurements = async (messageData) => { if (responseFromInsertMeasurements.success === false) { console.log("KAFKA: failed to store the measurements"); // logger.error( - // `KAFKA: responseFromInsertMeasurements --- ${jsonify( + // `KAFKA: responseFromInsertMeasurements --- ${stringify( // responseFromInsertMeasurements // )}` // ); } else if (responseFromInsertMeasurements.success === true) { console.log("KAFKA: successfully stored the measurements"); // logger.info( - // `KAFKA: successfully inserted the measurements --- ${jsonify(responseFromInsertMeasurements.message ? + // `KAFKA: successfully inserted the measurements --- ${stringify(responseFromInsertMeasurements.message ? // responseFromInsertMeasurements.message : // "")}` // ); @@ -172,7 +172,7 @@ const consumeHourlyMeasurements = async (messageData) => { `ℹ️ℹ️ incoming KAFKA value's TYPE which is causing errors --- ${typeof message.value}` ); logger.error(`πŸ›πŸ› KAFKA: error message --- ${error.message}`); - logger.error(`πŸ›πŸ› KAFKA: full error object --- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› KAFKA: full error object --- ${stringify(error)}`); } }; @@ -212,7 +212,7 @@ const kafkaConsumer = async () => { } } catch (error) { logger.error( - `πŸ›πŸ› Error processing Kafka message for topic ${topic}: ${jsonify( + `πŸ›πŸ› Error processing Kafka message for topic ${topic}: ${stringify( error )}` ); @@ -223,7 +223,7 @@ const kafkaConsumer = async () => { ); } catch (error) { logObject("Error connecting to Kafka", error); - logger.error(`πŸ“ΆπŸ“Ά Error connecting to Kafka: ${jsonify(error)}`); + logger.error(`πŸ“ΆπŸ“Ά Error connecting to Kafka: ${stringify(error)}`); } }; diff --git a/src/device-registry/bin/jobs/new-store-readings-job.js b/src/device-registry/bin/jobs/new-store-readings-job.js index 255b09c733..2c8c59874a 100644 --- a/src/device-registry/bin/jobs/new-store-readings-job.js +++ b/src/device-registry/bin/jobs/new-store-readings-job.js @@ -8,7 +8,7 @@ const DeviceModel = require("@models/Device"); const SiteModel = require("@models/Site"); const ReadingModel = require("@models/Reading"); const { logText, logObject } = require("@utils/log"); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); const asyncRetry = require("async-retry"); const generateFilter = require("@utils/generate-filter"); const cron = require("node-cron"); @@ -55,7 +55,7 @@ async function updateEntityStatus(Model, filter, time, entityType) { }; const updateResult = await Model.updateOne(filter, updateData); } else { - logger.warn(`${entityType} not found with filter: ${jsonify(filter)}`); + logger.warn(`${entityType} not found with filter: ${stringify(filter)}`); } } catch (error) { logger.error(`Error updating ${entityType}'s status: ${error.message}`); @@ -129,13 +129,13 @@ const fetchAndStoreDataIntoReadingsModel = async () => { viewEventsResponse = await EventModel("airqo").fetch(filter); logText("Running the data insertion script"); } catch (fetchError) { - logger.error(`Error fetching events: ${jsonify(fetchError)}`); + logger.error(`Error fetching events: ${stringify(fetchError)}`); return; } if (!viewEventsResponse || typeof viewEventsResponse !== "object") { logger.error( - `Unexpected response from EventModel.fetch(): ${jsonify( + `Unexpected response from EventModel.fetch(): ${stringify( viewEventsResponse )}` ); @@ -175,7 +175,7 @@ const fetchAndStoreDataIntoReadingsModel = async () => { logObject("the error inside processing of batches", error); if (error.name === "MongoError" && error.code !== 11000) { logger.error( - `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoReadingsModel -- ${jsonify( + `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoReadingsModel -- ${stringify( error )}` ); @@ -183,7 +183,7 @@ const fetchAndStoreDataIntoReadingsModel = async () => { } else if (error.code === 11000) { // Ignore duplicate key errors console.warn( - `Duplicate key error for document: ${jsonify(doc)}` + `Duplicate key error for document: ${stringify(doc)}` ); } } @@ -204,7 +204,7 @@ const fetchAndStoreDataIntoReadingsModel = async () => { viewEventsResponse ); logger.error( - `πŸ›πŸ› Unable to retrieve Events to insert into Readings -- ${jsonify( + `πŸ›πŸ› Unable to retrieve Events to insert into Readings -- ${stringify( viewEventsResponse )}` ); @@ -212,7 +212,7 @@ const fetchAndStoreDataIntoReadingsModel = async () => { } } catch (error) { logObject("error", error); - logger.error(`πŸ›πŸ› Internal Server Error ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Error ${stringify(error)}`); } }; diff --git a/src/device-registry/bin/jobs/store-readings-job.js b/src/device-registry/bin/jobs/store-readings-job.js index 15ebd9a784..694a770cdf 100644 --- a/src/device-registry/bin/jobs/store-readings-job.js +++ b/src/device-registry/bin/jobs/store-readings-job.js @@ -6,7 +6,7 @@ const logger = log4js.getLogger( const EventModel = require("@models/Event"); const ReadingModel = require("@models/Reading"); const { logText, logObject } = require("@utils/log"); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); const asyncRetry = require("async-retry"); const generateFilter = require("@utils/generate-filter"); const cron = require("node-cron"); @@ -67,7 +67,7 @@ const fetchAndStoreDataIntoReadingsModel = async () => { } catch (error) { if (error.name === "MongoError" && error.code !== 11000) { logger.error( - `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoReadingsModel -- ${jsonify( + `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoReadingsModel -- ${stringify( error )}` ); @@ -75,7 +75,7 @@ const fetchAndStoreDataIntoReadingsModel = async () => { } else if (error.code === 11000) { // Ignore duplicate key errors console.warn( - `Duplicate key error for document: ${jsonify(doc)}` + `Duplicate key error for document: ${stringify(doc)}` ); } } @@ -97,7 +97,7 @@ const fetchAndStoreDataIntoReadingsModel = async () => { ); logger.error( - `πŸ›πŸ› Unable to retrieve Events to insert into Readings -- ${jsonify( + `πŸ›πŸ› Unable to retrieve Events to insert into Readings -- ${stringify( viewEventsResponse )}` ); diff --git a/src/device-registry/bin/jobs/store-signals-job.js b/src/device-registry/bin/jobs/store-signals-job.js index 5bb990ba45..dd30c66e17 100644 --- a/src/device-registry/bin/jobs/store-signals-job.js +++ b/src/device-registry/bin/jobs/store-signals-job.js @@ -6,7 +6,7 @@ const logger = log4js.getLogger( const EventModel = require("@models/Event"); const SignalModel = require("@models/Signal"); const { logText, logObject } = require("@utils/log"); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); const asyncRetry = require("async-retry"); const generateFilter = require("@utils/generate-filter"); const cron = require("node-cron"); @@ -67,7 +67,7 @@ const fetchAndStoreDataIntoSignalsModel = async () => { } catch (error) { if (error.name === "MongoError" && error.code !== 11000) { logger.error( - `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoSignalsModel -- ${jsonify( + `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoSignalsModel -- ${stringify( error )}` ); @@ -75,7 +75,7 @@ const fetchAndStoreDataIntoSignalsModel = async () => { } else if (error.code === 11000) { // Ignore duplicate key errors console.warn( - `Duplicate key error for document: ${jsonify(doc)}` + `Duplicate key error for document: ${stringify(doc)}` ); } } @@ -97,7 +97,7 @@ const fetchAndStoreDataIntoSignalsModel = async () => { ); logger.error( - `πŸ›πŸ› Unable to retrieve Events to insert into Signals -- ${jsonify( + `πŸ›πŸ› Unable to retrieve Events to insert into Signals -- ${stringify( viewEventsResponse )}` ); diff --git a/src/device-registry/bin/server.js b/src/device-registry/bin/server.js index 1331ec6a1c..276f5d5f71 100644 --- a/src/device-registry/bin/server.js +++ b/src/device-registry/bin/server.js @@ -22,7 +22,7 @@ const debug = require("debug")("auth-service:server"); const isEmpty = require("is-empty"); const logger = log4js.getLogger(`${constants.ENVIRONMENT} -- bin/server`); const { logText, logObject } = require("@utils/log"); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); require("@bin/jobs/store-signals-job"); require("@bin/jobs/new-store-readings-job"); // require("@bin/jobs/new-check-network-status-job"); @@ -90,28 +90,28 @@ app.use(function(err, req, res, next) { errors: { message: err.message }, }); } else if (err.status === 400) { - logger.error(`Bad request error --- ${jsonify(err)}`); + logger.error(`Bad request error --- ${stringify(err)}`); res.status(err.status).json({ success: false, message: "Bad request error", errors: { message: err.message }, }); } else if (err.status === 401) { - logger.error(`Unauthorized --- ${jsonify(err)}`); + logger.error(`Unauthorized --- ${stringify(err)}`); res.status(err.status).json({ success: false, message: "Unauthorized", errors: { message: err.message }, }); } else if (err.status === 403) { - logger.error(`Forbidden --- ${jsonify(err)}`); + logger.error(`Forbidden --- ${stringify(err)}`); res.status(err.status).json({ success: false, message: "Forbidden", errors: { message: err.message }, }); } else if (err.status === 500) { - // logger.error(`Internal Server Error --- ${jsonify(err)}`); + // logger.error(`Internal Server Error --- ${stringify(err)}`); // logger.error(`Stack Trace: ${err.stack}`); logObject("the error", err); res.status(err.status).json({ @@ -120,14 +120,14 @@ app.use(function(err, req, res, next) { errors: { message: err.message }, }); } else if (err.status === 502 || err.status === 503 || err.status === 504) { - logger.error(`${err.message} --- ${jsonify(err)}`); + logger.error(`${err.message} --- ${stringify(err)}`); res.status(err.status).json({ success: false, message: err.message, errors: { message: err.message }, }); } else { - logger.error(`Internal Server Error --- ${jsonify(err)}`); + logger.error(`Internal Server Error --- ${stringify(err)}`); logObject("Internal Server Error", err); logger.error(`Stack Trace: ${err.stack}`); res.status(err.status || 500).json({ @@ -138,7 +138,7 @@ app.use(function(err, req, res, next) { } } else { logger.info( - `🍻🍻 HTTP response already sent to the client -- ${jsonify(err)}` + `🍻🍻 HTTP response already sent to the client -- ${stringify(err)}` ); } }); diff --git a/src/device-registry/utils/create-event.js b/src/device-registry/utils/create-event.js index 20576cdeec..fd8c9ebec2 100644 --- a/src/device-registry/utils/create-event.js +++ b/src/device-registry/utils/create-event.js @@ -31,7 +31,7 @@ const util = require("util"); const redisGetAsync = util.promisify(redis.get).bind(redis); const redisSetAsync = util.promisify(redis.set).bind(redis); const redisExpireAsync = util.promisify(redis.expire).bind(redis); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); const asyncRetry = require("async-retry"); const listDevices = async (request, next) => { @@ -52,7 +52,7 @@ const listDevices = async (request, next) => { ? responseFromListDevice.errors : { message: "" }; try { - let errorsString = errors ? jsonify(errors) : ""; + let errorsString = errors ? stringify(errors) : ""; logger.error( `responseFromListDevice was not a success -- ${responseFromListDevice.message} -- ${errorsString}` ); @@ -141,13 +141,13 @@ async function transformManyReadings(request, next) { next ); if (responseFromTransformEvent.success === true) { - logger.info(`Transformed event: ${JSON.jsonify(event)}`); + logger.info(`Transformed event: ${JSON.stringify(event)}`); return responseFromTransformEvent; } else if (responseFromTransformEvent.success === false) { let errors = responseFromTransformEvent.errors ? responseFromTransformEvent.errors : { message: "" }; - logger.error(`Failed to transform event -- ${jsonify(errors)}`); + logger.error(`Failed to transform event -- ${stringify(errors)}`); return responseFromTransformEvent; } }); @@ -355,7 +355,7 @@ const createEvent = { } else if (responseFromGetDeviceDetails.success === false) { try { logger.error( - `unable to retrieve device details --- ${jsonify( + `unable to retrieve device details --- ${stringify( responseFromGetDeviceDetails.errors )}` ); @@ -699,7 +699,7 @@ const createEvent = { return cacheResult.data; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } if (page) { @@ -756,11 +756,11 @@ const createEvent = { const errors = resultOfCacheOperation.errors ? resultOfCacheOperation.errors : { message: "Internal Server Error" }; - logger.error(`πŸ›πŸ› Internal Server Error -- ${jsonify(errors)}`); + logger.error(`πŸ›πŸ› Internal Server Error -- ${stringify(errors)}`); // return resultOfCacheOperation; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } logText("Cache set."); @@ -778,7 +778,7 @@ const createEvent = { }; } else { logger.error( - `Unable to retrieve events --- ${jsonify( + `Unable to retrieve events --- ${stringify( responseFromListEvents.errors )}` ); @@ -828,7 +828,7 @@ const createEvent = { return cacheResult.data; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } const viewEventsResponse = await EventModel(tenant).view(filter, next); @@ -874,11 +874,11 @@ const createEvent = { const errors = resultOfCacheOperation.errors ? resultOfCacheOperation.errors : { message: "Internal Server Error" }; - logger.error(`πŸ›πŸ› Internal Server Error -- ${jsonify(errors)}`); + logger.error(`πŸ›πŸ› Internal Server Error -- ${stringify(errors)}`); // return resultOfCacheOperation; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } logText("Cache set."); @@ -896,7 +896,9 @@ const createEvent = { }; } else { logger.error( - `Unable to retrieve events --- ${jsonify(viewEventsResponse.errors)}` + `Unable to retrieve events --- ${stringify( + viewEventsResponse.errors + )}` ); return { @@ -960,7 +962,7 @@ const createEvent = { } catch (error) { if (error.name === "MongoError" && error.code !== 11000) { logger.error( - `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoReadingsModel -- ${jsonify( + `πŸ›πŸ› MongoError -- fetchAndStoreDataIntoReadingsModel -- ${stringify( error )}` ); @@ -968,7 +970,7 @@ const createEvent = { } else if (error.code === 11000) { // Ignore duplicate key errors console.warn( - `Duplicate key error for document: ${jsonify(doc)}` + `Duplicate key error for document: ${stringify(doc)}` ); } } @@ -993,7 +995,7 @@ const createEvent = { ); logger.error( - `πŸ›πŸ› Unable to retrieve Events to insert into Readings -- ${jsonify( + `πŸ›πŸ› Unable to retrieve Events to insert into Readings -- ${stringify( viewEventsResponse )}` ); @@ -1040,7 +1042,7 @@ const createEvent = { return cacheResult.data; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } const readingsResponse = await ReadingModel(tenant).latest( @@ -1090,11 +1092,11 @@ const createEvent = { const errors = resultOfCacheOperation.errors ? resultOfCacheOperation.errors : { message: "Internal Server Error" }; - logger.error(`πŸ›πŸ› Internal Server Error -- ${jsonify(errors)}`); + logger.error(`πŸ›πŸ› Internal Server Error -- ${stringify(errors)}`); // return resultOfCacheOperation; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } logText("Cache set."); @@ -1112,7 +1114,7 @@ const createEvent = { }; } else { logger.error( - `Unable to retrieve events --- ${jsonify(readingsResponse.errors)}` + `Unable to retrieve events --- ${stringify(readingsResponse.errors)}` ); return { @@ -1161,7 +1163,7 @@ const createEvent = { return cacheResult.data; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } const readingsResponse = await ReadingModel(tenant).recent( @@ -1208,11 +1210,11 @@ const createEvent = { const errors = resultOfCacheOperation.errors ? resultOfCacheOperation.errors : { message: "Internal Server Error" }; - logger.error(`πŸ›πŸ› Internal Server Error -- ${jsonify(errors)}`); + logger.error(`πŸ›πŸ› Internal Server Error -- ${stringify(errors)}`); // return resultOfCacheOperation; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } logText("Cache set."); @@ -1230,7 +1232,7 @@ const createEvent = { }; } else { logger.error( - `Unable to retrieve events --- ${jsonify(readingsResponse.errors)}` + `Unable to retrieve events --- ${stringify(readingsResponse.errors)}` ); return { @@ -1278,7 +1280,7 @@ const createEvent = { return cacheResult.data; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } const readingsResponse = await SignalModel(tenant).latest( @@ -1328,11 +1330,11 @@ const createEvent = { const errors = resultOfCacheOperation.errors ? resultOfCacheOperation.errors : { message: "Internal Server Error" }; - logger.error(`πŸ›πŸ› Internal Server Error -- ${jsonify(errors)}`); + logger.error(`πŸ›πŸ› Internal Server Error -- ${stringify(errors)}`); // return resultOfCacheOperation; } } catch (error) { - logger.error(`πŸ›πŸ› Internal Server Errors -- ${jsonify(error)}`); + logger.error(`πŸ›πŸ› Internal Server Errors -- ${stringify(error)}`); } logText("Cache set."); @@ -1350,7 +1352,7 @@ const createEvent = { }; } else { logger.error( - `Unable to retrieve events --- ${jsonify(readingsResponse.errors)}` + `Unable to retrieve events --- ${stringify(readingsResponse.errors)}` ); return { @@ -1731,7 +1733,7 @@ const createEvent = { .catch(function(error) { try { logger.error( - `internal server error -- ${jsonify( + `internal server error -- ${stringify( error.response.data.error.details )}` ); @@ -1849,7 +1851,7 @@ const createEvent = { .catch(function(error) { try { logger.error( - `internal server error -- ${jsonify(error.response.data.error)}` + `internal server error -- ${stringify(error.response.data.error)}` ); } catch (error) { logger.error(`internal server error -- ${error.message}`); @@ -1946,7 +1948,7 @@ const createEvent = { const cacheID = createEvent.generateCacheID(request, next); await redisSetAsync( cacheID, - jsonify({ + stringify({ isCache: true, success: true, message: "Successfully retrieved the measurements", @@ -2119,7 +2121,7 @@ const createEvent = { logger.error( `responseFromGetDeviceDetails was not a success -- ${ responseFromGetDeviceDetails.message - } -- ${jsonify(errors)}` + } -- ${stringify(errors)}` ); } catch (error) { logger.error(`internal server error -- ${error.message}`); @@ -2165,7 +2167,7 @@ const createEvent = { : { message: "" }; try { logger.error( - `transformEventsResponse is not a success -- unable to transform -- ${jsonify( + `transformEventsResponse is not a success -- unable to transform -- ${stringify( errors )}` ); @@ -2324,7 +2326,7 @@ const createEvent = { if (errors.length > 0 && isEmpty(data)) { logger.error( - `finished the operation with some errors -- ${jsonify(errors)}` + `finished the operation with some errors -- ${stringify(errors)}` ); return { success: false, @@ -2418,7 +2420,7 @@ const createEvent = { logger.error( `internal server error -- unable to transform measurements -- ${ responseFromTransformMeasurements.message - }, ${jsonify(measurements)}` + }, ${stringify(measurements)}` ); } @@ -2530,6 +2532,9 @@ const createEvent = { if (errors.length > 0 && isEmpty(eventsAdded)) { console.log("API: failed to store measurements"); + logger.error( + `πŸ›πŸ› API: failed to store measurements ${stringify(errors)}` + ); return { success: false, message: "finished the operation with some errors", diff --git a/src/device-registry/utils/create-grid.js b/src/device-registry/utils/create-grid.js index 889e6c7553..9d5aed2562 100644 --- a/src/device-registry/utils/create-grid.js +++ b/src/device-registry/utils/create-grid.js @@ -15,7 +15,7 @@ const log4js = require("log4js"); const logger = log4js.getLogger(`${constants.ENVIRONMENT} -- create-grid-util`); const { Kafka } = require("kafkajs"); const fs = require("fs"); -const jsonify = require("@utils/jsonify"); +const stringify = require("@utils/stringify"); const kafka = new Kafka({ clientId: constants.KAFKA_CLIENT_ID, brokers: constants.KAFKA_BOOTSTRAP_SERVERS, @@ -109,7 +109,7 @@ const createGrid = { messages: [ { action: "create", - value: jsonify(responseFromRegisterGrid.data), + value: stringify(responseFromRegisterGrid.data), }, ], }); @@ -296,7 +296,7 @@ const createGrid = { } } catch (error) { logger.error( - `πŸ›πŸ› Internal Server Error -- grid refresh -- Remove the Grid from INACTIVE Sites -- ${jsonify( + `πŸ›πŸ› Internal Server Error -- grid refresh -- Remove the Grid from INACTIVE Sites -- ${stringify( error )}` ); diff --git a/src/device-registry/utils/jsonify.js b/src/device-registry/utils/stringify.js similarity index 100% rename from src/device-registry/utils/jsonify.js rename to src/device-registry/utils/stringify.js