feat: support line group

Author: pipech

raven/omni_channel_chat/omni_channel_raven_connector.py

@@ -59,16 +59,16 @@ def get_provider_pk(self, provider_id: str) -> str:
 	def get_channel_name(self, destination_id: str) -> str:
 		return f"{self.provider.provider_config.name}_{destination_id}"
 
-	def get_sender_info(self, owner: str) -> "UserDisplay | None":
+	def get_sender_info(self, sender: RavenUserId) -> "UserDisplay | None":
 		raven_user = frappe.db.get_value(
-			"Raven User", owner, ["full_name", "user_image"], as_dict=True
+			"Raven User", sender.user_id, ["full_name", "user_image"], as_dict=True
 		)
 		if not raven_user:
 			return None
 		icon_url = raven_user["user_image"]
 		if icon_url and icon_url.startswith("/"):
 			icon_url = get_url(icon_url)
-		return UserDisplay(name=raven_user["full_name"] or "", icon_url=icon_url or None)
+		return UserDisplay(name=raven_user["full_name"], icon_url=icon_url)
 
 	def get_user_id(self, channel_id: str) -> str:
 		"""Return the provider user_id for a 1:1 customer channel via social login lookup."""
@@ -256,20 +256,34 @@ def create_raven_message(
 		message: StdMessage,
 		sender_user: "User | None" = None,
 		provider_metadata: dict | None = None,
+		raven_user: "RavenUserId | None" = None,
+		raven_message_data: dict | None = None,
 	) -> None:
-		owner = sender_user.name if sender_user else raven_channel.customer_user
-
 		doc = frappe.new_doc(doctype="Raven Message")
 		doc.update(
 			{
 				"channel_id": raven_channel.name,
 				"message_type": message.type,
 				"is_customer_message": True,
-				"owner": owner,
 				"omni_channel_msg_meta": provider_metadata,
 			}
 		)
 
+		if raven_user is not None:
+			if raven_user.user_type == "Raven User":
+				doc.update(
+					{
+						"owner": raven_user.user_id,
+					}
+				)
+			elif raven_user.user_type == "Raven Bot":
+				doc.update(
+					{
+						"is_bot_message": True,
+						"bot": raven_user.user_id,
+					}
+				)
+
 		if isinstance(message, TextMessage):
 			doc.text = message.text
 		elif isinstance(message, (ImageMessage, FileMessage)) and isinstance(
@@ -286,6 +300,8 @@ def create_raven_message(
 			file_doc.insert(ignore_permissions=True)
 			doc.file = file_doc.file_url
 
+		doc.update(raven_message_data or {})
+
 		doc.insert(ignore_permissions=True)
 
 	# ── Provider Message → Raven Message (inbound) ─────────────────────────────
@@ -343,6 +359,7 @@ def handle_outbound(self, raven_message: "RavenMessage") -> None:
 			raven_message.is_customer_message
 			or raven_message.is_bot_message
 			or raven_message.message_type in ("System", "Poll")
+			or raven_message.omni_channel_skip_push_to_provider
 		):
 			return
 
@@ -356,6 +373,40 @@ def handle_outbound(self, raven_message: "RavenMessage") -> None:
 			return
 
 		destination_id = self.get_destination_id(raven_message.channel_id)
-		sender = self.get_sender_info(owner=raven_message.owner)
+		sender = self.get_sender_info(
+			owner=RavenUserId(user_type="Raven User", user_id=raven_message.owner)
+		)
 		outbound_msg = self.raven_to_std_msg(raven_message=raven_message, sender=sender)
 		self.provider.send_message(destination_id=destination_id, message=outbound_msg)
+
+	# ── Inject ─────────────────────────────────────────────────────────────────
+
+	def handle_inject(
+		self,
+		destination: ChatDestination,
+		std_message: StdMessage,
+		raven_user: RavenUserId,
+	) -> None:
+		"""Handle programmatically injected messages, e.g. from a bot or workflow.
+
+		Saves the message to the Raven channel. The after_insert hook on RavenMessage
+		automatically calls handle_outbound which pushes the message to the provider.
+		"""
+		raven_channel = self.get_or_create_channel(
+			destination=destination,
+		)
+
+		self.create_raven_message(
+			raven_channel=raven_channel,
+			message=std_message,
+			raven_user=raven_user,
+			raven_message_data={"omni_channel_skip_push_to_provider": True},
+		)
+
+		sender_info = self.get_sender_info(sender=raven_user)
+		std_message.sender = sender_info
+
+		self.provider.send_message(
+			destination_id=destination.destination_id,
+			message=std_message,
+		)

raven/raven_channel_management/doctype/raven_channel/raven_channel.json

@@ -28,7 +28,6 @@
   "last_message_timestamp",
   "dm_user_1",
   "dm_user_2",
-  "customer_user",
   "omni_channel_chat_provider",
   "omni_channel_destination_id",
   "column_break_eckt",
@@ -237,14 +236,6 @@
    "label": "Is Customer",
    "set_only_once": 1
   },
-  {
-   "depends_on": "eval:doc.is_customer;",
-   "fieldname": "customer_user",
-   "fieldtype": "Link",
-   "label": "Customer",
-   "options": "Raven User",
-   "read_only": 1
-  },
   {
    "depends_on": "eval:doc.is_customer;",
    "fieldname": "omni_channel_chat_provider",
@@ -271,7 +262,7 @@
    "link_fieldname": "channel_id"
   }
  ],
- "modified": "2026-04-19 14:41:55.728586",
+ "modified": "2026-04-22 13:32:23.357346",
  "modified_by": "Administrator",
  "module": "Raven Channel Management",
  "name": "Raven Channel",

raven/raven_channel_management/doctype/raven_channel/raven_channel.py

@@ -20,7 +20,6 @@ class RavenChannel(Document):
 
 		channel_description: DF.SmallText | None
 		channel_name: DF.Data
-		customer_user: DF.Link | None
 		dm_user_1: DF.Link | None
 		dm_user_2: DF.Link | None
 		is_ai_thread: DF.Check
@@ -36,6 +35,7 @@ class RavenChannel(Document):
 		linked_doctype: DF.Link | None
 		linked_document: DF.DynamicLink | None
 		omni_channel_chat_provider: DF.Link | None
+		omni_channel_destination_id: DF.Data | None
 		openai_thread_id: DF.Data | None
 		pinned_messages: DF.Table[RavenPinnedMessages]
 		pinned_messages_string: DF.SmallText | None

raven/raven_messaging/doctype/raven_message/raven_message.json

@@ -38,6 +38,7 @@
   "hide_link_preview",
   "notification",
   "is_customer_message",
+  "omni_channel_skip_push_to_provider",
   "omni_channel_msg_meta"
  ],
  "fields": [
@@ -221,11 +222,17 @@
    "fieldname": "omni_channel_msg_meta",
    "fieldtype": "JSON",
    "label": "Omni-Channel Message Meta"
+  },
+  {
+   "default": "0",
+   "fieldname": "omni_channel_skip_push_to_provider",
+   "fieldtype": "Check",
+   "label": "Omni-channel Skip Push to Provider"
   }
  ],
  "index_web_pages_for_search": 1,
  "links": [],
- "modified": "2026-04-19 16:05:30.311091",
+ "modified": "2026-04-22 13:42:16.280165",
  "modified_by": "Administrator",
  "module": "Raven Messaging",
  "name": "Raven Message",

raven/raven_messaging/doctype/raven_message/raven_message.py

@@ -34,7 +34,6 @@ class RavenMessage(Document):
 
 	if TYPE_CHECKING:
 		from frappe.types import DF
-
 		from raven.raven_messaging.doctype.raven_mention.raven_mention import RavenMention
 
 		blurhash: DF.SmallText | None
@@ -62,6 +61,7 @@ class RavenMessage(Document):
 		message_type: DF.Literal["Text", "Image", "File", "Poll", "System"]
 		notification: DF.Data | None
 		omni_channel_msg_meta: DF.JSON | None
+		omni_channel_skip_push_to_provider: DF.Check
 		poll_id: DF.Link | None
 		replied_message_details: DF.JSON | None
 		text: DF.LongText | None