|
5 | 5 | from litellm.types.utils import Delta, StreamingChoices
|
6 | 6 |
|
7 | 7 | from codegate.llm_utils.extractor import PackageExtractor
|
8 |
| -from codegate.pipeline.base import CodeSnippet, PipelineContext, PipelineSensitiveData |
| 8 | +from codegate.pipeline.base import CodeSnippet, PipelineContext |
9 | 9 | from codegate.pipeline.extract_snippets.extract_snippets import extract_snippets
|
10 | 10 | from codegate.pipeline.output import OutputPipelineContext, OutputPipelineStep
|
11 | 11 | from codegate.storage import StorageEngine
|
@@ -39,14 +39,15 @@ def _create_chunk(self, original_chunk: ModelResponse, content: str) -> ModelRes
|
39 | 39 | object="chat.completion.chunk",
|
40 | 40 | )
|
41 | 41 |
|
42 |
| - async def _snippet_comment(self, snippet: CodeSnippet, secrets: PipelineSensitiveData) -> str: |
| 42 | + async def _snippet_comment(self, snippet: CodeSnippet, context: PipelineContext) -> str: |
43 | 43 | """Create a comment for a snippet"""
|
44 | 44 | snippet.libraries = await PackageExtractor.extract_packages(
|
45 | 45 | content=snippet.code,
|
46 |
| - provider=secrets.provider, |
47 |
| - model=secrets.model, |
48 |
| - api_key=secrets.api_key, |
49 |
| - base_url=secrets.api_base, |
| 46 | + provider=context.sensitive.provider if context.sensitive else None, |
| 47 | + model=context.sensitive.model if context.sensitive else None, |
| 48 | + api_key=context.sensitive.api_key if context.sensitive else None, |
| 49 | + base_url=context.sensitive.api_base if context.sensitive else None, |
| 50 | + extra_headers=context.metadata.get("extra_headers", None), |
50 | 51 | )
|
51 | 52 | # Check if any of the snippet libraries is a bad package
|
52 | 53 | storage_engine = StorageEngine()
|
@@ -126,7 +127,7 @@ async def process_chunk(
|
126 | 127 | chunks.append(self._create_chunk(chunk, before))
|
127 | 128 | complete_comment += before
|
128 | 129 |
|
129 |
| - comment = await self._snippet_comment(last_snippet, input_context.sensitive) |
| 130 | + comment = await self._snippet_comment(last_snippet, input_context) |
130 | 131 | complete_comment += comment
|
131 | 132 | chunks.append(
|
132 | 133 | self._create_chunk(
|
|
0 commit comments