/**
* Parses data from message queues (simulated for this example).
* This script is designed for a one-off task and does not prioritize performance.
*/
function parseMessageQueueData(queueData) {
const parsedData = [];
if (!queueData || !Array.isArray(queueData)) {
console.error("Invalid queue data: Must be an array.");
return parsedData; // Return empty array on error
}
for (let i = 0; i < queueData.length; i++) {
const message = queueData[i];
if (typeof message === 'object' && message !== null) { //Check if message is an object
//Basic parsing - adjust as needed for your message format
const messageId = message.id || "N/A"; //Default if id is missing
const messageType = message.type || "Unknown";
const payload = message.payload || "No payload";
const parsedMessage = {
id: messageId,
type: messageType,
payload: payload
};
parsedData.push(parsedMessage);
} else {
console.warn(`Skipping invalid message: ${message}`); //Log invalid messages
}
}
return parsedData;
}
//Simulated message queue data
const messageQueueData = [
{ id: 1, type: "order", payload: { orderId: "123" } },
{ id: 2, type: "event", payload: "user logged in" },
{ type: "warning", payload: "System overload" }, //Missing id
"invalid message",
{ id: 3, type: "update" } //Missing payload
];
const parsedResults = parseMessageQueueData(messageQueueData);
console.log(JSON.stringify(parsedResults, null, 2)); //Output the parsed data in JSON format
Add your comment