From ea765f75091079393c06e96d25a1545a58bf7b03 Mon Sep 17 00:00:00 2001
From: Ishaan Jaffer <ishaan@berri.ai>
Date: Sat, 11 Apr 2026 17:43:16 -0700
Subject: [PATCH] feat(advisor): add MessagesInterceptor ABC and registry

---
 .../messages/interceptors/__init__.py         | 17 ++++++++
 .../messages/interceptors/base.py             | 41 +++++++++++++++++++
 2 files changed, 58 insertions(+)
 create mode 100644 litellm/llms/anthropic/experimental_pass_through/messages/interceptors/__init__.py
 create mode 100644 litellm/llms/anthropic/experimental_pass_through/messages/interceptors/base.py

diff --git a/litellm/llms/anthropic/experimental_pass_through/messages/interceptors/__init__.py b/litellm/llms/anthropic/experimental_pass_through/messages/interceptors/__init__.py
new file mode 100644
index 00000000000..68f9f471809
--- /dev/null
+++ b/litellm/llms/anthropic/experimental_pass_through/messages/interceptors/__init__.py
@@ -0,0 +1,17 @@
+from typing import List
+
+from .advisor import AdvisorOrchestrationHandler
+from .base import MessagesInterceptor
+
+_interceptors: List[MessagesInterceptor] = [
+    AdvisorOrchestrationHandler(),
+]
+
+
+def get_messages_interceptors() -> List[MessagesInterceptor]:
+    """Return the list of active MessagesInterceptors.
+
+    Order matters: interceptors are tried in list order; the first one whose
+    ``can_handle()`` returns True wins.
+    """
+    return _interceptors
diff --git a/litellm/llms/anthropic/experimental_pass_through/messages/interceptors/base.py b/litellm/llms/anthropic/experimental_pass_through/messages/interceptors/base.py
new file mode 100644
index 00000000000..7b0334a3524
--- /dev/null
+++ b/litellm/llms/anthropic/experimental_pass_through/messages/interceptors/base.py
@@ -0,0 +1,41 @@
+from abc import ABC, abstractmethod
+from typing import AsyncIterator, Dict, List, Optional, Union
+
+from litellm.types.llms.anthropic_messages.anthropic_response import (
+    AnthropicMessagesResponse,
+)
+
+
+class MessagesInterceptor(ABC):
+    """
+    Base class for /messages short-circuit interceptors.
+
+    An interceptor can fully replace the normal backend call when it detects
+    a pattern it owns (e.g. advisor orchestration, web-search short-circuit).
+    ``can_handle`` is checked first; if True, ``handle`` is called and its
+    return value is returned directly to the caller.
+
+    See interceptors/README.md for when to add an interceptor vs. a pre-request hook.
+    """
+
+    @abstractmethod
+    def can_handle(
+        self,
+        tools: Optional[List[Dict]],
+        custom_llm_provider: Optional[str],
+    ) -> bool:
+        """Return True if this interceptor should handle the request."""
+
+    @abstractmethod
+    async def handle(
+        self,
+        *,
+        model: str,
+        messages: List[Dict],
+        tools: Optional[List[Dict]],
+        stream: Optional[bool],
+        max_tokens: int,
+        custom_llm_provider: Optional[str],
+        **kwargs,
+    ) -> Union[AnthropicMessagesResponse, AsyncIterator]:
+        """Execute the interception and return the response."""