Add manage conversation actions

Author: LordOfTheVillage

linkedapi/__init__.py

@@ -41,10 +41,12 @@
     FetchPersonMapper,
     FetchPost,
     FetchPostMapper,
+    ManageConversation,
     NvFetchCompany,
     NvFetchCompanyMapper,
     NvFetchPerson,
     NvFetchPersonMapper,
+    NvManageConversation,
     NvSearchCompanies,
     NvSearchPeople,
     NvSendMessage,
@@ -105,11 +107,13 @@
     "LinkedApiErrorType",
     "LinkedApiHttpClient",
     "LinkedApiWorkflowTimeoutError",
+    "ManageConversation",
     "MappedResponse",
     "NvFetchCompany",
     "NvFetchCompanyMapper",
     "NvFetchPerson",
     "NvFetchPersonMapper",
+    "NvManageConversation",
     "NvSearchCompanies",
     "NvSearchPeople",
     "NvSendMessage",

linkedapi/client.py

@@ -16,8 +16,10 @@
     FetchJob,
     FetchPerson,
     FetchPost,
+    ManageConversation,
     NvFetchCompany,
     NvFetchPerson,
+    NvManageConversation,
     NvSearchCompanies,
     NvSearchPeople,
     NvSendMessage,
@@ -62,6 +64,7 @@ def __init__(self, config: LinkedApiConfig | HttpClient[Any]) -> None:
         self.send_message = SendMessage(self.http_client)
         self.sync_conversation = SyncConversation(self.http_client)
         self.sync_inbox = SyncInbox(self.http_client)
+        self.manage_conversation = ManageConversation(self.http_client)
         self.check_connection_status = CheckConnectionStatus(self.http_client)
         self.send_connection_request = SendConnectionRequest(self.http_client)
         self.withdraw_connection_request = WithdrawConnectionRequest(self.http_client)
@@ -83,6 +86,7 @@ def __init__(self, config: LinkedApiConfig | HttpClient[Any]) -> None:
         self.nv_send_message = NvSendMessage(self.http_client)
         self.nv_sync_conversation = NvSyncConversation(self.http_client)
         self.nv_sync_inbox = NvSyncInbox(self.http_client)
+        self.nv_manage_conversation = NvManageConversation(self.http_client)
         self.nv_search_companies = NvSearchCompanies(self.http_client)
         self.nv_search_people = NvSearchPeople(self.http_client)
         self.nv_fetch_company = NvFetchCompany(self.http_client)
@@ -93,6 +97,7 @@ def __init__(self, config: LinkedApiConfig | HttpClient[Any]) -> None:
             self.send_message,
             self.sync_conversation,
             self.sync_inbox,
+            self.manage_conversation,
             self.check_connection_status,
             self.send_connection_request,
             self.withdraw_connection_request,
@@ -114,6 +119,7 @@ def __init__(self, config: LinkedApiConfig | HttpClient[Any]) -> None:
             self.nv_send_message,
             self.nv_sync_conversation,
             self.nv_sync_inbox,
+            self.nv_manage_conversation,
             self.nv_search_companies,
             self.nv_search_people,
             self.nv_fetch_company,

linkedapi/errors.py

@@ -23,6 +23,7 @@
     "noPostingPermission",
     "noSalesNavigator",
     "conversationsNotSynced",
+    "threadNotFound",
 ]
 LINKED_API_ACTION_ERROR_TYPES: tuple[str, ...] = (
     "personNotFound",
@@ -45,6 +46,7 @@
     "noPostingPermission",
     "noSalesNavigator",
     "conversationsNotSynced",
+    "threadNotFound",
 )
 
 LinkedApiErrorType = Literal[

linkedapi/operations/__init__.py

@@ -6,8 +6,10 @@
 from linkedapi.operations.fetch_job import FetchJob, FetchJobMapper
 from linkedapi.operations.fetch_person import FetchPerson, FetchPersonMapper
 from linkedapi.operations.fetch_post import FetchPost, FetchPostMapper
+from linkedapi.operations.manage_conversation import ManageConversation
 from linkedapi.operations.nv_fetch_company import NvFetchCompany, NvFetchCompanyMapper
 from linkedapi.operations.nv_fetch_person import NvFetchPerson, NvFetchPersonMapper
+from linkedapi.operations.nv_manage_conversation import NvManageConversation
 from linkedapi.operations.nv_search_companies import NvSearchCompanies
 from linkedapi.operations.nv_search_people import NvSearchPeople
 from linkedapi.operations.nv_send_message import NvSendMessage
@@ -41,10 +43,12 @@
     "FetchPersonMapper",
     "FetchPost",
     "FetchPostMapper",
+    "ManageConversation",
     "NvFetchCompany",
     "NvFetchCompanyMapper",
     "NvFetchPerson",
     "NvFetchPersonMapper",
+    "NvManageConversation",
     "NvSearchCompanies",
     "NvSearchPeople",
     "NvSendMessage",

linkedapi/operations/manage_conversation.py

@@ -0,0 +1,12 @@
+from __future__ import annotations
+
+from linkedapi.core import Operation
+from linkedapi.mappers import VoidWorkflowMapper
+from linkedapi.types import ManageConversationParams
+
+
+class ManageConversation(Operation[ManageConversationParams, None]):
+    """Manage a standard LinkedIn conversation thread."""
+
+    operation_name = "manageConversation"
+    mapper = VoidWorkflowMapper[ManageConversationParams]("st.manageConversation")

linkedapi/operations/nv_manage_conversation.py

@@ -0,0 +1,12 @@
+from __future__ import annotations
+
+from linkedapi.core import Operation
+from linkedapi.mappers import VoidWorkflowMapper
+from linkedapi.types import NvManageConversationParams
+
+
+class NvManageConversation(Operation[NvManageConversationParams, None]):
+    """Manage a Sales Navigator conversation thread."""
+
+    operation_name = "nvManageConversation"
+    mapper = VoidWorkflowMapper[NvManageConversationParams]("nv.manageConversation")

linkedapi/types/__init__.py

@@ -103,8 +103,10 @@
     ConversationType,
     InboxMessage,
     InboxPollRequest,
+    ManageConversationParams,
     Message,
     MessageSender,
+    NvManageConversationParams,
     NvSendMessageParams,
     NvSyncConversationParams,
     NvSyncInboxParams,
@@ -298,6 +300,7 @@
     "LinkedApiRequestError",
     "LinkedApiResponse",
     "LocationType",
+    "ManageConversationParams",
     "MaxAnnualRevenue",
     "Message",
     "MessageSender",
@@ -313,6 +316,7 @@
     "NvCompanyEmployeeRetrievalConfig",
     "NvFetchCompanyParams",
     "NvFetchCompanyResult",
+    "NvManageConversationParams",
     "NvOpenPersonPageParams",
     "NvOpenPersonPageResult",
     "NvSearchCompaniesFilter",

linkedapi/types/message.py

@@ -23,6 +23,11 @@ class SyncInboxParams(BaseActionParams):
     pass
 
 
+class ManageConversationParams(BaseActionParams):
+    thread_id: str
+    operation: str
+
+
 class NvSendMessageParams(BaseActionParams):
     text: str
     person_url: str | None = None
@@ -38,6 +43,11 @@ class NvSyncInboxParams(BaseActionParams):
     pass
 
 
+class NvManageConversationParams(BaseActionParams):
+    thread_id: str
+    operation: str
+
+
 class ConversationPollRequest(LinkedApiModel):
     person_url: str
     type: ConversationType

tests/test_errors.py

@@ -49,6 +49,7 @@ def test_error_type_sets_match_node_contract() -> None:
         "noPostingPermission",
         "noSalesNavigator",
         "conversationsNotSynced",
+        "threadNotFound",
     )
 
 

tests/test_operations.py

@@ -35,9 +35,11 @@ def test_linked_api_exposes_all_predefined_operations() -> None:
         "send_message",
         "sync_conversation",
         "sync_inbox",
+        "manage_conversation",
         "nv_send_message",
         "nv_sync_conversation",
         "nv_sync_inbox",
+        "nv_manage_conversation",
         "react_to_post",
         "comment_on_post",
         "create_post",
@@ -50,7 +52,7 @@ def test_linked_api_exposes_all_predefined_operations() -> None:
         assert hasattr(operation, "execute")
         assert hasattr(operation, "result")
         assert hasattr(operation, "cancel")
-    assert len(linkedapi.operations) == 29
+    assert len(linkedapi.operations) == 31
 
 
 def test_operation_mappers_match_node_contract() -> None:
@@ -70,6 +72,10 @@ def test_operation_mappers_match_node_contract() -> None:
     assert linkedapi.sync_inbox.mapper.action_type == "st.syncInbox"
     assert isinstance(linkedapi.nv_sync_inbox.mapper, VoidWorkflowMapper)
     assert linkedapi.nv_sync_inbox.mapper.action_type == "nv.syncInbox"
+    assert isinstance(linkedapi.manage_conversation.mapper, VoidWorkflowMapper)
+    assert linkedapi.manage_conversation.mapper.action_type == "st.manageConversation"
+    assert isinstance(linkedapi.nv_manage_conversation.mapper, VoidWorkflowMapper)
+    assert linkedapi.nv_manage_conversation.mapper.action_type == "nv.manageConversation"
 
 
 def test_execute_and_result_flow_returns_pydantic_data(