Extract Data

Execution & Payload Details:

• Reads from:

  • msg.payload.slots.cimEvent.data → source data block.

  • msg.payload.conversation → to derive session and identifiers.

• Logic:

  • data = slots.cimEvent?.data || {}.

  • session = conversation.metadata.lastUsedChannelSession (throws error if missing).

  • customer_id = conversation.customer?._id || null.

  • channel_type = session.channel?.channelType?.name || null.

  • direction = conversation.conversationDirection || null.

  • fallback_queue_id = session.channel?.channelConfig?.routingPolicy?.routingObjectId || null.

• Writes to:

  • msg.payload.data (object)

  • msg.payload.session (object)

  • msg.payload.customer_id (string/number or null)

  • msg.payload.channel_type (string or null)

  • msg.payload.direction (string or null)

  • msg.payload.fallback_queue_id (string/number or null)

• Behavior:

  • On success: logs and forwards the message with the above fields set.

  • On error (e.g., missing last used channel session): logs and raises a node error.