diff --git a/src/service/kafkaQumlConsumerService.js b/src/service/kafkaQumlConsumerService.js
index 8bfeeed0ae471242f83f22aa511287c2f5fbacd9..1a7242ec8f868ba336dce73567cf4c2e8e05f518 100644
--- a/src/service/kafkaQumlConsumerService.js
+++ b/src/service/kafkaQumlConsumerService.js
@@ -55,7 +55,7 @@ const qumlConsumer = () => {
consumerGroup.on("message", function (message) {
logger.info({ message: "Entered into the consumer service" });
let parsedJsonValue = JSON.parse(message.value);;
- console.log("Kafka consumer :: ", parsedJsonValue);
+ console.log("Kafka consumer :: =====> ", JSON.stringify(parsedJsonValue));
initQuestionCreateProcess(parsedJsonValue);
}).on("error", function (message) {
client.close();
@@ -88,7 +88,7 @@ const initQuestionCreateProcess = (questionData) => {
err
);
}
- console.log('initQuestionCreateProcess :: SUCCESS ::', JSON.stringify(result));
+ console.log('initQuestionCreateProcess :: SUCCESS :: =====> ', JSON.stringify(result));
});
};
@@ -102,7 +102,7 @@ const startDownloadFileProcess = (question, outerCallback) => {
const fileId = getIdFromUrl(data);
if(_.has(downloadedFiles,fileId)) {
question[key] = _.get(downloadedFiles,fileId);
- console.log(key, " :: File already downloaded :: ", data)
+ console.log(key, " :: File already downloaded :: =====> ", JSON.stringify(data))
callback(null, 'File');
} else {
async.waterfall([
@@ -134,7 +134,7 @@ const downloadFile = (data, callback) => {
const googleAuth = new GoogleOauth();
const fileId = getIdFromUrl(data);
googleAuth.downloadFile(fileId).then((result) => {
- console.log("RESULT ::", result);
+ console.log("RESULT :: =====> ", JSON.stringify(result));
callback(null, result);
}).catch((error) => {
callback(error);
@@ -156,7 +156,7 @@ const createAssest = (question, data, callback) => {
}
}
};
- console.log("createAssest request Body =====>", reqBody);
+ console.log("createAssest request Body =====> ", JSON.stringify(reqBody));
fetch(`${envVariables.baseURL}${API_URL.ASSET_CREATE}`, {
method: "POST", // or 'PUT'
headers: {
@@ -168,26 +168,25 @@ const createAssest = (question, data, callback) => {
})
.then((response) => response.json())
.then((assetResponseData) => {
- console.log("createAssest response =====>", assetResponseData);
+ console.log("createAssest response =====> ", JSON.stringify(assetResponseData));
if (assetResponseData.responseCode && _.toLower(assetResponseData.responseCode) === "ok") {
data['identifier'] = assetResponseData.result.identifier;
callback(null, data);
} else {
- console.log("assetResponseData", assetResponseData);
callback(assetResponseData);
}
})
.catch((error) => {
console.log("catchcatch", error);
logger.error({
- message: `Error while creating the assest :: ${JSON.stringify(error)}`,
+ message: `Error while creating the assest :: =====> ${JSON.stringify(error)}`,
});
callback(error);
});
}
const uploadAsset = (data, callback) => {
- console.log("uploadAsset : ==> ", data);
+ console.log("uploadAsset : =====> ", JSON.stringify(data));
var formdata = new FormData();
formdata.append("file", fs.createReadStream(data.filePath), data.name);
fetch(`${envVariables.baseURL}${API_URL.ASSET_UPLOAD}${data.identifier}`, {
@@ -199,7 +198,7 @@ const uploadAsset = (data, callback) => {
})
.then((response) => response.json())
.then((uploadResponseData) => {
- console.log("uploadResponseData ::: ==> ", JSON.stringify(uploadResponseData));
+ console.log("uploadResponseData ::: =====> ", JSON.stringify(uploadResponseData));
if (uploadResponseData.responseCode && _.toLower(uploadResponseData.responseCode) === "ok") {
data['artifactUrl'] = uploadResponseData.result.artifactUrl;
callback(null, data);
@@ -216,7 +215,7 @@ const uploadAsset = (data, callback) => {
}
const deleteFileFromTemp = (data, callback) => {
- console.log("deleteFileFromTemp :: ===>", data);
+ console.log("deleteFileFromTemp :: =====> ", data);
fs.unlink(data.filePath, function(err) {
if(err && err.code == 'ENOENT') {
console.info("File doesn't exist, won't remove it. :: ", data.filePath);
@@ -260,7 +259,7 @@ const prepareQuestionBody = (question, callback) => {
'channel', 'framework', 'topic', 'createdBy', 'questionFileRefId', 'processId']));
metadata.editorState.question = mergeQuestionTextAndImage(question.questionText, question.questionImage);
metadata = _.omitBy(metadata, _.isEmpty);
- console.log("prepareQuestionBody :: => ", metadata);
+ console.log("prepareQuestionBody :: => ", JSON.stringify(metadata));
callback(null, metadata);
}
@@ -343,7 +342,7 @@ const createQuestion = (questionBody, callback) => {
}
};
//fetch call for creating a question.
- console.log('createQuestionBody::' , JSON.stringify(createApiData));
+ console.log('createQuestionBody:: =====> ' , JSON.stringify(createApiData));
fetch(`${envVariables.SUNBIRD_ASSESSMENT_SERVICE_BASE_URL}${API_URL.QUESTION_CREATE}`, {
method: "POST", // or 'PUT'
headers: {
@@ -388,7 +387,7 @@ const reviewQuestion = (status, questionRes, callback) => {
)
.then((response) => response.json())
.then((reviewResponseData) => {
- console.log("reviewQuestion response:: ", reviewResponseData);
+ console.log("reviewQuestion response:: =====> ", JSON.stringify(reviewResponseData));
if (reviewResponseData.responseCode && _.toLower(reviewResponseData.responseCode) === "ok") {
callback(null, reviewResponseData);
} else {
@@ -424,7 +423,7 @@ const publishQuestion = (status, questionRes, callback) => {
})
.then((response) => response.json())
.then((publishResponseData) => {
- console.log("reviewQuestion response:: ", publishResponseData);
+ console.log("reviewQuestion response:: =====> ", JSON.stringify(publishResponseData));
if (publishResponseData.responseCode && _.toLower(publishResponseData.responseCode) === "ok") {
callback(null, publishResponseData);
} else {
@@ -505,7 +504,7 @@ const updateResponse = (updateData, updateMessage) => {
}
}
};
- console.log("updateResponse :: request Body::", updateNewData);
+ console.log("updateResponse :: request Body:: =====> ", JSON.stringify(updateNewData));
fetch(`${envVariables.SUNBIRD_ASSESSMENT_SERVICE_BASE_URL}${API_URL.QUESTION_UPDATE}${updateData}`, {
method: "PATCH", // or 'PUT'
headers: {
@@ -516,7 +515,7 @@ const updateResponse = (updateData, updateMessage) => {
})
.then((response) => response.json())
.then((updateResult) => {
- console.log("updateResult :: ======> ", updateResult);
+ console.log("updateResult :: ======> ", JSON.stringify(updateResult));
rspObj.responseCode = "OK";
rspObj.result = {
questionStatus: `Successfully updated the question data for the identifier: ${updateData}`,
diff --git a/src/service/qumlBulkService.js b/src/service/qumlBulkService.js
index cd4b376fbf66fcd52f1dfa9f9b9cfd4ead335789..83f0ebd9a789e141e94cf4823ad3f7dc20395ef9 100644
--- a/src/service/qumlBulkService.js
+++ b/src/service/qumlBulkService.js
@@ -38,7 +38,7 @@ const bulkUpload = async (req, res) => {
logger.info({ message: "Qeustionset ID ===>", questionSetID: _.get(req, 'body.request.questionSetId', null)});
getQuestionSetHierarchy(_.get(req, 'body.request.questionSetId'), reqHeaders, (err, data) => {
if(err) {
- console.log('Error fetching hierarchy for questionSet', JSON.stringify(err));
+ console.log('Error fetching hierarchy for questionSet ======> ', JSON.stringify(err));
rspObj.errCode = _.get(err, 'params.err') || programMessages.QUML_BULKUPLOAD.HIERARCHY_FAILED_CODE;
rspObj.errMsg = _.get(err, 'params.errmsg') || programMessages.QUML_BULKUPLOAD.HIERARCHY_FAILED_MESSAGE;
rspObj.responseCode = _.get(err, 'responseCode') || responseCode.SERVER_ERROR;
@@ -63,7 +63,7 @@ const bulkUpload = async (req, res) => {
question = prepareQuestionData(question, req);
question['questionSetSectionId'] = flattenHierarchyObj[question.level1];
question["processId"] = pId;
- console.log("Prepared Question body : =====>", question)
+ console.log("Prepared Question body : =====>", JSON.stringify(question))
sendRecordToKafkaTopic(question);
});
logger.info({ message: "Bulk Upload process has started successfully for the process Id", pId});
@@ -72,7 +72,7 @@ const bulkUpload = async (req, res) => {
loggerService.exitLog({responseCode: rspObj.responseCode}, logObject);
return res.status(200).send(successResponse(rspObj))
}).catch(err => {
- console.log('Error while validating the CSV file :: ', JSON.stringify(err));
+ console.log('Error while validating the CSV file =====> ', JSON.stringify(err));
rspObj.errCode = programMessages.QUML_BULKUPLOAD.FAILED_CODE;
rspObj.errMsg = programMessages.QUML_BULKUPLOAD.FAILED_MESSAGE;
rspObj.responseCode = responseCode.SERVER_ERROR;
@@ -250,7 +250,7 @@ const qumlSearch = (req, res) => {
return res.status(200).send(successResponse(rspObj))
})
.catch((error) => {
- console.log('Error while fetching the question :: ', JSON.stringify(error));
+ console.log('Error while fetching the question :: =====> ', JSON.stringify(error));
rspObj.errCode = programMessages.QUML_BULKSTATUS.FAILED_CODE;
rspObj.errMsg = programMessages.QUML_BULKSTATUS.FAILED_MESSAGE;
rspObj.responseCode = responseCode.SERVER_ERROR;