Fixed regression on secrets step for Anthropic.

Author: blkt

src/codegate/pipeline/secrets/secrets.py

@@ -498,6 +498,17 @@ async def process_chunk(
             "",
         )
 
+        # If the chunk has no content, we do not touch it, as it is
+        # likely to break the communication protocol. As of the time
+        # of this writing, this is probably only valid for Anthropic,
+        # and we might want to abstract this away in the interface by
+        # answering a question like "is this chunk modifiable?"
+        if next(chunk.get_content(), None) is None:
+            return [chunk]
+        for content in chunk.get_content():
+            if content.get_text() is None or content.get_text() == "":
+                return [chunk]
+
         # Check if this is the first chunk (delta role will be present, others will not)
         redacted_count = input_context.metadata["redacted_secrets_count"]
         secret_text = "secret" if redacted_count == 1 else "secrets"

tests/types/openai/streaming_messages.txt

@@ -5,3 +5,4 @@ data: {"id":"chatcmpl-B0szUPll9BiFva49CokSsI1pVPjA6","choices":[{"index":0,"delt
 data: {"id":"chatcmpl-B0szUPll9BiFva49CokSsI1pVPjA6","choices":[],"created":1739551084,"model":"gpt-4o-2024-08-06","service_tier":"default","system_fingerprint":"fp_523b9b6e5f","object":"chat.completion.chunk","usage":{"completion_tokens":394,"prompt_tokens":15675,"total_tokens":16069,"completion_tokens_details":{"accepted_prediction_tokens":0,"audio_tokens":0,"reasoning_tokens":0,"rejected_prediction_tokens":0},"prompt_tokens_details":{"audio_tokens":0,"cached_tokens":4352}}}
 
 data: [DONE]
+