Manage invitations

Author: KirillSergeevich

linkedapi/__init__.py

@@ -29,6 +29,7 @@
     VoidWorkflowMapper,
 )
 from linkedapi.operations import (
+    AcceptConnectionRequest,
     CheckConnectionStatus,
     CommentOnPost,
     CreatePost,
@@ -41,6 +42,7 @@
     FetchPersonMapper,
     FetchPost,
     FetchPostMapper,
+    IgnoreConnectionRequest,
     ManageConversation,
     NvFetchCompany,
     NvFetchCompanyMapper,
@@ -54,6 +56,7 @@
     NvSyncInbox,
     ReactToPost,
     RemoveConnection,
+    RetrieveConnectionRequests,
     RetrieveConnections,
     RetrievePendingRequests,
     RetrievePerformance,
@@ -71,11 +74,12 @@
 from linkedapi.types import __all__ as _types_all
 from linkedapi.webhooks import parse_webhook_event
 
-__version__ = "1.1.2"
+__version__ = "1.2.0"
 PredefinedOperation = Operation
 
 __all__ = [
     *_types_all,
+    "AcceptConnectionRequest",
     "AdminAccounts",
     "AdminHttpClient",
     "AdminLimits",
@@ -97,6 +101,7 @@
     "FetchPost",
     "FetchPostMapper",
     "HttpClient",
+    "IgnoreConnectionRequest",
     "LINKED_API_ACTION_ERROR_TYPES",
     "LINKED_API_ERROR_TYPES",
     "LinkedApi",
@@ -124,6 +129,7 @@
     "ReactToPost",
     "RemoveConnection",
     "ResponseMapping",
+    "RetrieveConnectionRequests",
     "RetrieveConnections",
     "RetrievePendingRequests",
     "RetrievePerformance",

linkedapi/client.py

@@ -8,6 +8,7 @@
 from linkedapi.http import HttpClient, LinkedApiHttpClient
 from linkedapi.mappers import MappedResponse
 from linkedapi.operations import (
+    AcceptConnectionRequest,
     CheckConnectionStatus,
     CommentOnPost,
     CreatePost,
@@ -16,6 +17,7 @@
     FetchJob,
     FetchPerson,
     FetchPost,
+    IgnoreConnectionRequest,
     ManageConversation,
     NvFetchCompany,
     NvFetchPerson,
@@ -27,6 +29,7 @@
     NvSyncInbox,
     ReactToPost,
     RemoveConnection,
+    RetrieveConnectionRequests,
     RetrieveConnections,
     RetrievePendingRequests,
     RetrievePerformance,
@@ -68,7 +71,10 @@ def __init__(self, config: LinkedApiConfig | HttpClient[Any]) -> None:
         self.check_connection_status = CheckConnectionStatus(self.http_client)
         self.send_connection_request = SendConnectionRequest(self.http_client)
         self.withdraw_connection_request = WithdrawConnectionRequest(self.http_client)
+        self.accept_connection_request = AcceptConnectionRequest(self.http_client)
+        self.ignore_connection_request = IgnoreConnectionRequest(self.http_client)
         self.retrieve_pending_requests = RetrievePendingRequests(self.http_client)
+        self.retrieve_connection_requests = RetrieveConnectionRequests(self.http_client)
         self.retrieve_connections = RetrieveConnections(self.http_client)
         self.remove_connection = RemoveConnection(self.http_client)
         self.search_companies = SearchCompanies(self.http_client)
@@ -101,7 +107,10 @@ def __init__(self, config: LinkedApiConfig | HttpClient[Any]) -> None:
             self.check_connection_status,
             self.send_connection_request,
             self.withdraw_connection_request,
+            self.accept_connection_request,
+            self.ignore_connection_request,
             self.retrieve_pending_requests,
+            self.retrieve_connection_requests,
             self.retrieve_connections,
             self.remove_connection,
             self.search_companies,

linkedapi/operations/__init__.py

@@ -1,3 +1,4 @@
+from linkedapi.operations.accept_connection_request import AcceptConnectionRequest
 from linkedapi.operations.check_connection_status import CheckConnectionStatus
 from linkedapi.operations.comment_on_post import CommentOnPost
 from linkedapi.operations.create_post import CreatePost
@@ -6,6 +7,7 @@
 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.ignore_connection_request import IgnoreConnectionRequest
 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
@@ -17,6 +19,7 @@
 from linkedapi.operations.nv_sync_inbox import NvSyncInbox
 from linkedapi.operations.react_to_post import ReactToPost
 from linkedapi.operations.remove_connection import RemoveConnection
+from linkedapi.operations.retrieve_connection_requests import RetrieveConnectionRequests
 from linkedapi.operations.retrieve_connections import RetrieveConnections
 from linkedapi.operations.retrieve_pending_requests import RetrievePendingRequests
 from linkedapi.operations.retrieve_performance import RetrievePerformance
@@ -31,6 +34,7 @@
 from linkedapi.operations.withdraw_connection_request import WithdrawConnectionRequest
 
 __all__ = [
+    "AcceptConnectionRequest",
     "CheckConnectionStatus",
     "CommentOnPost",
     "CreatePost",
@@ -43,6 +47,7 @@
     "FetchPersonMapper",
     "FetchPost",
     "FetchPostMapper",
+    "IgnoreConnectionRequest",
     "ManageConversation",
     "NvFetchCompany",
     "NvFetchCompanyMapper",
@@ -56,6 +61,7 @@
     "NvSyncInbox",
     "ReactToPost",
     "RemoveConnection",
+    "RetrieveConnectionRequests",
     "RetrieveConnections",
     "RetrievePendingRequests",
     "RetrievePerformance",

linkedapi/operations/accept_connection_request.py

@@ -0,0 +1,12 @@
+from __future__ import annotations
+
+from linkedapi.core import Operation
+from linkedapi.mappers import VoidWorkflowMapper
+from linkedapi.types import AcceptConnectionRequestParams
+
+
+class AcceptConnectionRequest(Operation[AcceptConnectionRequestParams, None]):
+    """Accept an incoming standard LinkedIn connection request."""
+
+    operation_name = "acceptConnectionRequest"
+    mapper = VoidWorkflowMapper[AcceptConnectionRequestParams]("st.acceptConnectionRequest")

linkedapi/operations/ignore_connection_request.py

@@ -0,0 +1,12 @@
+from __future__ import annotations
+
+from linkedapi.core import Operation
+from linkedapi.mappers import VoidWorkflowMapper
+from linkedapi.types import IgnoreConnectionRequestParams
+
+
+class IgnoreConnectionRequest(Operation[IgnoreConnectionRequestParams, None]):
+    """Ignore an incoming standard LinkedIn connection request."""
+
+    operation_name = "ignoreConnectionRequest"
+    mapper = VoidWorkflowMapper[IgnoreConnectionRequestParams]("st.ignoreConnectionRequest")

linkedapi/operations/retrieve_connection_requests.py

@@ -0,0 +1,15 @@
+from __future__ import annotations
+
+from linkedapi.core import Operation
+from linkedapi.mappers import ArrayWorkflowMapper
+from linkedapi.types import RetrieveConnectionRequestsResult
+
+
+class RetrieveConnectionRequests(Operation[None, list[RetrieveConnectionRequestsResult]]):
+    """Retrieve incoming standard LinkedIn connection requests."""
+
+    operation_name = "retrieveConnectionRequests"
+    mapper = ArrayWorkflowMapper[None, RetrieveConnectionRequestsResult](
+        "st.retrieveConnectionRequests",
+        RetrieveConnectionRequestsResult,
+    )

linkedapi/types/__init__.py

@@ -68,13 +68,16 @@
     StCompanyEmployeesRetrievalConfig,
 )
 from linkedapi.types.connection import (
+    AcceptConnectionRequestParams,
     CheckConnectionStatusParams,
     CheckConnectionStatusResult,
     ConnectionPerson,
     ConnectionStatus,
+    IgnoreConnectionRequestParams,
     NvOpenPersonPageParams,
     NvOpenPersonPageResult,
     RemoveConnectionParams,
+    RetrieveConnectionRequestsResult,
     RetrieveConnectionsFilter,
     RetrieveConnectionsParams,
     RetrieveConnectionsResult,
@@ -221,6 +224,7 @@
 )
 
 __all__ = [
+    "AcceptConnectionRequestParams",
     "AccountInfo",
     "AccountWebhookEvent",
     "AccountWebhookEventData",
@@ -277,6 +281,7 @@
     "GetConnectionSessionParams",
     "GetLimitsParams",
     "GetLimitsUsageParams",
+    "IgnoreConnectionRequestParams",
     "InboxMessage",
     "InboxPollRequest",
     "Job",
@@ -356,6 +361,7 @@
     "ReparseAccountInfoResult",
     "ReplayWebhookDeliveryParams",
     "ResetLimitsParams",
+    "RetrieveConnectionRequestsResult",
     "RetrieveConnectionsFilter",
     "RetrieveConnectionsParams",
     "RetrieveConnectionsResult",

linkedapi/types/connection.py

@@ -5,7 +5,7 @@
 from linkedapi.types.base import LinkedApiModel
 from linkedapi.types.params import BaseActionParams, LimitParams
 
-ConnectionStatus = Literal["connected", "pending", "notConnected"]
+ConnectionStatus = Literal["connected", "pending", "incoming", "notConnected"]
 
 
 class ConnectionPerson(LinkedApiModel):
@@ -42,6 +42,20 @@ class RetrievePendingRequestsResult(LinkedApiModel):
     sent_time: str | None = None
 
 
+class AcceptConnectionRequestParams(BaseActionParams):
+    person_url: str
+
+
+class IgnoreConnectionRequestParams(BaseActionParams):
+    person_url: str
+
+
+class RetrieveConnectionRequestsResult(LinkedApiModel):
+    name: str | None = None
+    public_url: str | None = None
+    headline: str | None = None
+
+
 class RetrieveConnectionsFilter(LinkedApiModel):
     first_name: str | None = None
     last_name: str | None = None

pyproject.toml

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

tests/test_operations.py

@@ -29,7 +29,10 @@ def test_linked_api_exposes_all_predefined_operations() -> None:
         "send_connection_request",
         "check_connection_status",
         "withdraw_connection_request",
+        "accept_connection_request",
+        "ignore_connection_request",
         "retrieve_pending_requests",
+        "retrieve_connection_requests",
         "retrieve_connections",
         "remove_connection",
         "send_message",
@@ -52,7 +55,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) == 31
+    assert len(linkedapi.operations) == 34
 
 
 def test_operation_mappers_match_node_contract() -> None:
@@ -68,6 +71,15 @@ def test_operation_mappers_match_node_contract() -> None:
     assert linkedapi.fetch_job.mapper.default_params == {"basicInfo": True}
     assert isinstance(linkedapi.send_connection_request.mapper, VoidWorkflowMapper)
     assert linkedapi.send_connection_request.mapper.action_type == "st.sendConnectionRequest"
+    assert isinstance(linkedapi.accept_connection_request.mapper, VoidWorkflowMapper)
+    assert linkedapi.accept_connection_request.mapper.action_type == "st.acceptConnectionRequest"
+    assert isinstance(linkedapi.ignore_connection_request.mapper, VoidWorkflowMapper)
+    assert linkedapi.ignore_connection_request.mapper.action_type == "st.ignoreConnectionRequest"
+    assert isinstance(linkedapi.retrieve_connection_requests.mapper, ArrayWorkflowMapper)
+    assert (
+        linkedapi.retrieve_connection_requests.mapper.base_action_type
+        == "st.retrieveConnectionRequests"
+    )
     assert isinstance(linkedapi.sync_inbox.mapper, VoidWorkflowMapper)
     assert linkedapi.sync_inbox.mapper.action_type == "st.syncInbox"
     assert isinstance(linkedapi.nv_sync_inbox.mapper, VoidWorkflowMapper)