Add manage conversation after sending message

Author: LordOfTheVillage

linkedapi/__init__.py

@@ -71,7 +71,7 @@
 from linkedapi.types import __all__ as _types_all
 from linkedapi.webhooks import parse_webhook_event
 
-__version__ = "1.1.2"
+__version__ = "1.1.3"
 PredefinedOperation = Operation
 
 __all__ = [

linkedapi/mappers/__init__.py

@@ -1,5 +1,6 @@
 from linkedapi.mappers.array import ArrayWorkflowMapper
 from linkedapi.mappers.base import BaseMapper, MappedResponse
+from linkedapi.mappers.send_message import SendMessageMapper
 from linkedapi.mappers.simple import SimpleWorkflowMapper
 from linkedapi.mappers.then import ActionConfig, ResponseMapping, ThenWorkflowMapper
 from linkedapi.mappers.void import VoidWorkflowMapper
@@ -10,6 +11,7 @@
     "BaseMapper",
     "MappedResponse",
     "ResponseMapping",
+    "SendMessageMapper",
     "SimpleWorkflowMapper",
     "ThenWorkflowMapper",
     "VoidWorkflowMapper",

linkedapi/mappers/send_message.py

@@ -0,0 +1,47 @@
+from __future__ import annotations
+
+from typing import Any
+
+from linkedapi.mappers.base import (
+    BaseMapper,
+    MappedResponse,
+    as_action_dict,
+    collect_action_errors,
+)
+from linkedapi.types import WorkflowCompletion, WorkflowDefinition, serialize_model
+from linkedapi.types.message import SendMessageParams
+
+
+class SendMessageMapper(BaseMapper[SendMessageParams, None]):
+    def map_request(self, params: SendMessageParams | None = None) -> WorkflowDefinition:
+        serialized = serialize_model(params)
+        manage_conversation = serialized.pop("manageConversation", None)
+        definition: dict[str, Any] = {"actionType": "st.sendMessage", **serialized}
+        # The child st.manageConversation acts on the conversation this message was sent into, so it
+        # carries only `operation` — no threadId. Core rejects a threadId on a child manageConversation.
+        # Guard on `operation` so an empty passthrough (e.g. Make sending {"operation": ""}) is ignored.
+        if manage_conversation and manage_conversation.get("operation"):
+            definition["then"] = {
+                "actionType": "st.manageConversation",
+                "operation": manage_conversation["operation"],
+            }
+        return definition
+
+    def map_response(self, completion: WorkflowCompletion) -> MappedResponse[None]:
+        if isinstance(completion, list):
+            errors = collect_action_errors(
+                [as_action_dict(action).get("error") for action in completion]
+            )
+            return MappedResponse(data=None, errors=errors)
+
+        action = as_action_dict(completion)
+        raw_errors: list[Any] = [action.get("error")]
+
+        single_data = action.get("data")
+        if single_data is not None:
+            then_actions = as_action_dict(single_data).get("then")
+            if then_actions:
+                child_actions = then_actions if isinstance(then_actions, list) else [then_actions]
+                raw_errors.extend(as_action_dict(child).get("error") for child in child_actions)
+
+        return MappedResponse(data=None, errors=collect_action_errors(raw_errors))

linkedapi/operations/send_message.py

@@ -1,12 +1,12 @@
 from __future__ import annotations
 
 from linkedapi.core import Operation
-from linkedapi.mappers import VoidWorkflowMapper
+from linkedapi.mappers import SendMessageMapper
 from linkedapi.types import SendMessageParams
 
 
 class SendMessage(Operation[SendMessageParams, None]):
     """Send a standard LinkedIn message."""
 
     operation_name = "sendMessage"
-    mapper = VoidWorkflowMapper[SendMessageParams]("st.sendMessage")
+    mapper = SendMessageMapper()

linkedapi/types/__init__.py

@@ -110,6 +110,7 @@
     NvSendMessageParams,
     NvSyncConversationParams,
     NvSyncInboxParams,
+    SendMessageManageConversation,
     SendMessageParams,
     SyncConversationParams,
     SyncInboxParams,
@@ -375,6 +376,7 @@
     "SearchPeopleResult",
     "SeatType",
     "SendConnectionRequestParams",
+    "SendMessageManageConversation",
     "SendMessageParams",
     "SetLimitEntry",
     "SetLimitsParams",

linkedapi/types/message.py

@@ -9,10 +9,15 @@
 MessageSender = Literal["us", "them"]
 
 
+class SendMessageManageConversation(LinkedApiModel):
+    operation: str
+
+
 class SendMessageParams(BaseActionParams):
     text: str
     person_url: str | None = None
     thread_id: str | None = None
+    manage_conversation: SendMessageManageConversation | None = None
 
 
 class SyncConversationParams(BaseActionParams):

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "linkedapi"
-version = "1.1.2"
+version = "1.1.3"
 description = "Official synchronous Python SDK for Linked API."
 readme = "README.md"
 requires-python = ">=3.10"