feat(conversations): add send_message support with dry-run mode

New MCP tool and scraper method to send messages in existing or new
LinkedIn conversations. Includes dry-run mode for verifying UI elements
without actually sending. Covers both participant-name and profile-url
targeting with multi-strategy DOM element detection.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: kgritesh

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [Unreleased]
+
+### Added
+
+- `send_message` tool — send messages in existing or new LinkedIn conversations with dry-run support
+
 ## [v0.2.5] - 2026-03-19
 
 - No changes

README.md

@@ -16,7 +16,7 @@ A modern LinkedIn scraping library with built-in anti-detection, available as a
 - **Profile scraping** with experience, education, skills, and contact details
 - **Company scraping** with industry, size, specialties, and more
 - **Connection management** — retrieve and send connection requests
-- **Conversations** — list threads and read message history
+- **Conversations** — list threads, read message history, and send messages
 - **Proxy support** — route traffic through HTTP or SOCKS5 proxies
 - **Anti-detection** — human-like behavior simulation, stealth mode, session persistence
 
@@ -73,7 +73,11 @@ What has OpenAI been posting about recently? https://www.linkedin.com/company/op
 Show me my pending connection requests and summarize who they are
 ```
 
-It provides 11 tools:
+```
+Send a message to John Doe saying "Thanks for connecting!"
+```
+
+It provides 12 tools:
 
 | Tool                          | Description                                                             |
 | ----------------------------- | ----------------------------------------------------------------------- |
@@ -86,6 +90,7 @@ It provides 11 tools:
 | `send_connection_request`     | Send a connection request with optional note                            |
 | `scrape_conversations_list`   | List messaging conversations                                            |
 | `scrape_conversation`         | Read messages from a conversation                                       |
+| `send_message`                | Send a message in an existing or new conversation                       |
 | `get_session_status`          | Check if the browser session is active                                  |
 | `reset_session`               | Close and reset the browser session                                     |
 
@@ -241,6 +246,7 @@ scraper.send_connection_request("https://linkedin.com/in/someone", note="Hi!")
 # Conversations
 threads = scraper.scrape_conversations_list(max_results=10)
 messages = scraper.scrape_conversation_messages("John Doe")
+scraper.send_message("Thanks for connecting!", participant_name="John Doe")
 
 # Always clean up
 scraper.close()

src/linkedin_spider/core/scraper.py

@@ -207,6 +207,18 @@ def scrape_conversation_messages(
         """Scrape messages from a conversation."""
         return self.conversation_scraper.scrape_conversation_messages(participant_name)
 
+    def send_message(
+        self,
+        message: str,
+        participant_name: str | None = None,
+        profile_url: str | None = None,
+        dry_run: bool = False,
+    ) -> bool:
+        """Send a message in an existing or new conversation."""
+        return self.conversation_scraper.send_message(
+            message, participant_name, profile_url, dry_run=dry_run
+        )
+
     def send_connection_request(self, profile_url: str, note: str | None = None) -> bool:
         """Send a connection request to a profile."""
         return self.connection_scraper.send_connection_request(profile_url, note)

src/linkedin_spider/mcp/server.py

@@ -291,6 +291,50 @@ async def send_connection_request(profile_url: str, note: str | None = None) ->
         return f"Error sending connection request to {profile_url}: {e!s}"
 
 
+@mcp_app.tool()
+async def send_message(
+    message: str,
+    participant_name: str | None = None,
+    profile_url: str | None = None,
+    dry_run: bool = False,
+) -> str:
+    """Send a message in a LinkedIn conversation.
+
+    Args:
+        message: The message text to send
+        participant_name: Name of existing conversation participant (for existing conversations)
+        profile_url: LinkedIn profile URL (for starting new conversations)
+        dry_run: If True, verify message input and send button exist but do not send
+
+    Provide either participant_name or profile_url, not both.
+    """
+    if not message or not message.strip():
+        raise ValueError("message is required")
+
+    try:
+        scraper = get_scraper()
+        success = scraper.send_message(message, participant_name, profile_url, dry_run=dry_run)
+
+        if dry_run:
+            status = "Dry run verification passed" if success else "Dry run verification failed"
+        else:
+            status = "Message sent successfully" if success else "Failed to send message"
+
+        result = {
+            "message": message[:100],
+            "participant_name": participant_name,
+            "profile_url": profile_url,
+            "dry_run": dry_run,
+            "success": success,
+            "status": status,
+        }
+
+        return f"send_message_result:\n{json.dumps(result, indent=2, ensure_ascii=False)}"
+
+    except Exception as e:
+        return f"Error sending message: {e!s}"
+
+
 @cli_app.command
 def serve(
     transport: Annotated[
@@ -359,7 +403,7 @@ def serve(
     logger.info(
         f"FastMCP {transport.upper()} Server initialized with tools: scrape_profile, search_profiles, scrape_company, "
         "search_posts, scrape_incoming_connections, scrape_outgoing_connections, scrape_conversations_list, "
-        "scrape_conversation, send_connection_request, get_session_status, reset_session"
+        "scrape_conversation, send_connection_request, send_message, get_session_status, reset_session"
     )
 
     if transport in ["sse", "http", "streamable-http"]: