msgParser.js

"use strict";

module.exports = ({ requestBody, currentWABA_ID }) => {
  // THIS FUNCTION IS NOT YET OPTIMIZED FOR PERFORMANCE. IT IS ONLY MADE AS A TEMPORARY SOLUTION.
  if (!requestBody) {
    throw new Error('"requestBody" is required');
  }

  if (!currentWABA_ID) {
    throw new Error(
      "currentWABA_ID is required. This is the business ID that you have configured in your WABA account."
    );
  }

  let WABA_ID = requestBody.entry[0]?.id; // extract the business ID from the webhook payload
  if (WABA_ID == 0) {
    signale.warn({
      message: `WABA_ID is 0. You seem to be testing with Meta test subscription. This is not really a valid WABA_ID. I recommend you to send an actual message from an actual whatsapp customer's number.`,
    });
  }

  // this was causing aafatinfo bot to not work
  // commenting this out works well
  // if (!WABA_ID || WABA_ID !== currentWABA_ID) {
  //   throw new Error(
  //     "WABA_ID is not valid. Hint: the message is not intended for this Whatsapp Business Account."
  //   );
  // }

  //first check if the message is a whatsapp message
  if (
    !requestBody.object ||
    requestBody.object !== "whatsapp_business_account"
  ) {
    throw new Error(
      'requestBody is not a valid whatsapp message. Hint: check the "object" property'
    );
  }

  if (!requestBody.entry || !requestBody.entry?.length) {
    throw new Error(
      'requestBody is not a valid whatsapp message. Hint: check the "entry" property'
    );
  }

  if (
    !requestBody.entry[0].changes?.length ||
    requestBody.entry[0].changes[0].field !== "messages"
  ) {
    throw new Error(
      'requestBody is not a valid whatsapp message. Hint: check the "changes" property'
    );
  }

  let metadata = requestBody.entry[0].changes[0].value.metadata;
  let contacts = requestBody.entry[0].changes[0].value
    ?.whatsapp_business_api_data?.contacts?.length
    ? requestBody.entry[0].changes[0].value?.whatsapp_business_api_data
        ?.contacts[0]
    : null;
  // Messages vs Notifications
  let message = requestBody.entry[0].changes[0].value
    ?.whatsapp_business_api_data?.messages?.length
    ? requestBody.entry[0].changes[0].value?.whatsapp_business_api_data
        ?.messages[0]
    : requestBody.entry[0].changes[0].value?.messages?.length
    ? requestBody.entry[0].changes[0].value?.messages[0]
    : null;

  let notificationMessage = requestBody.entry[0].changes[0].value
    ?.whatsapp_business_api_data?.statuses?.length
    ? requestBody.entry[0].changes[0].value?.whatsapp_business_api_data
        ?.statuses[0]
    : requestBody.entry[0].changes[0].value?.statuses?.length
    ? requestBody.entry[0].changes[0].value?.statuses[0]
    : null;

  const output = {
    metadata,
    contacts,
    WABA_ID,
  };

  if (notificationMessage) {
    output["isNotificationMessage"] = true;
    output["isMessage"] = false;
    output["notificationType"] = notificationMessage.status;
    notificationMessage["from"] = {
      name: null, //name is not available for notifications, it is only available for messages
      phone: notificationMessage.recipient_id,
    };
    notificationMessage["conversation"] = notificationMessage.conversation;
    output["notificationMessage"] = notificationMessage;
  } else if (message) {
    output["isNotificationMessage"] = false;
    output["isMessage"] = true;
    let msgType;
    if (message.type === "text" && message.referral) {
      msgType = "ad_message";
    } else if (message.type === "text") {
      msgType = "text_message";
    } else if (message.type === "sticker") {
      msgType = "sticker_message";
    } else if (message.type === "image") {
      msgType = "media_message";
    } else if (message.location) {
      msgType = "location_message";
    } else if (message.contacts) {
      msgType = "contact_message";
    } else if (message.type === "button") {
      msgType = "quick_reply_message";
    } else if (message.type === "interactive") {
      if (message.interactive?.type === "list_reply") {
        msgType = "radio_button_message";
        message["list_reply"] = message.interactive.list_reply;
      } else if (message.interactive?.type === "button_reply") {
        msgType = "simple_button_message";
        message["button_reply"] = message.interactive.button_reply;
      }
    } else if (message.type === "unsupported") {
      msgType = "unknown_message";
      if (message.errors?.length) {
        console.log({ Q: message.errors });
        output["isNotificationMessage"] = true;
        output["isMessage"] = false;
        notificationMessage = {
          errors: message.errors,
        };
      }
    }
    message["type"] = msgType;
    message["from"] = {
      name: contacts?.profile?.name,
      phone: message?.from,
    };

    if (output.isMessage) {
      let thread = null;

      if (message.context) {
        thread = {
          from: {
            name: null,
            phone: message.context?.from,
            message_id: message.context?.id,
          },
        };
      }

      output["message"] = {
        ...message,
        thread,
        message_id: message.id || null,
      };

      delete output.message.id; //keep the data light
      delete output.context; //keep the data light
    }
  } else {
    console.warn("An unidentified.");
  }

  return output;
};