1. /**
  2. * Parses data from message queues (simulated for this example).
  3. * This script is designed for a one-off task and does not prioritize performance.
  4. */
  5. function parseMessageQueueData(queueData) {
  6. const parsedData = [];
  7. if (!queueData || !Array.isArray(queueData)) {
  8. console.error("Invalid queue data: Must be an array.");
  9. return parsedData; // Return empty array on error
  10. }
  11. for (let i = 0; i < queueData.length; i++) {
  12. const message = queueData[i];
  13. if (typeof message === 'object' && message !== null) { //Check if message is an object
  14. //Basic parsing - adjust as needed for your message format
  15. const messageId = message.id || "N/A"; //Default if id is missing
  16. const messageType = message.type || "Unknown";
  17. const payload = message.payload || "No payload";
  18. const parsedMessage = {
  19. id: messageId,
  20. type: messageType,
  21. payload: payload
  22. };
  23. parsedData.push(parsedMessage);
  24. } else {
  25. console.warn(`Skipping invalid message: ${message}`); //Log invalid messages
  26. }
  27. }
  28. return parsedData;
  29. }
  30. //Simulated message queue data
  31. const messageQueueData = [
  32. { id: 1, type: "order", payload: { orderId: "123" } },
  33. { id: 2, type: "event", payload: "user logged in" },
  34. { type: "warning", payload: "System overload" }, //Missing id
  35. "invalid message",
  36. { id: 3, type: "update" } //Missing payload
  37. ];
  38. const parsedResults = parseMessageQueueData(messageQueueData);
  39. console.log(JSON.stringify(parsedResults, null, 2)); //Output the parsed data in JSON format

Add your comment