|
4 | 4 | import structlog |
5 | 5 | from litellm import ChatCompletionRequest |
6 | 6 |
|
| 7 | +from codegate.clients.clients import ClientType |
7 | 8 | from codegate.pipeline.base import ( |
8 | 9 | AlertSeverity, |
9 | 10 | PipelineContext, |
|
13 | 14 | from codegate.pipeline.extract_snippets.extract_snippets import extract_snippets |
14 | 15 | from codegate.storage.storage_engine import StorageEngine |
15 | 16 | from codegate.utils.package_extractor import PackageExtractor |
16 | | -from codegate.utils.utils import generate_vector_string, get_tool_name_from_messages |
| 17 | +from codegate.utils.utils import generate_vector_string |
17 | 18 |
|
18 | 19 | logger = structlog.get_logger("codegate") |
19 | 20 |
|
@@ -128,14 +129,13 @@ async def process( # noqa: C901 |
128 | 129 | new_request = request.copy() |
129 | 130 |
|
130 | 131 | # perform replacement in all the messages starting from this index |
131 | | - base_tool = get_tool_name_from_messages(request) |
132 | | - if base_tool != "open interpreter": |
| 132 | + if context.client != ClientType.OPEN_INTERPRETER: |
133 | 133 | for i in range(last_user_idx, len(new_request["messages"])): |
134 | 134 | message = new_request["messages"][i] |
135 | 135 | message_str = str(message["content"]) # type: ignore |
136 | 136 | context_msg = message_str |
137 | 137 | # Add the context to the last user message |
138 | | - if base_tool in ["cline", "kodu"]: |
| 138 | + if context.client in [ClientType.CLINE, ClientType.KODU]: |
139 | 139 | match = re.search(r"<task>\s*(.*?)\s*</task>(.*)", message_str, re.DOTALL) |
140 | 140 | if match: |
141 | 141 | task_content = match.group(1) # Content within <task>...</task> |
|
0 commit comments