@@ -48,11 +48,8 @@ func (r *OpenAIRouter) Process(stream ext_proc.ExternalProcessor_ProcessServer)
4848 return err
4949 }
5050
51- log .Printf ("Processing message type: %T" , req .Request )
52-
5351 switch v := req .Request .(type ) {
5452 case * ext_proc.ProcessingRequest_RequestHeaders :
55- log .Printf ("DEBUG: Processing request headers" )
5653 response , err := r .handleRequestHeaders (v , ctx )
5754 if err != nil {
5855 log .Printf ("ERROR: handleRequestHeaders failed: %v" , err )
@@ -62,10 +59,10 @@ func (r *OpenAIRouter) Process(stream ext_proc.ExternalProcessor_ProcessServer)
6259 log .Printf ("ERROR: sendResponse for headers failed: %v" , err )
6360 return err
6461 }
65- log .Printf ("DEBUG: Request headers processed successfully" )
6662
6763 case * ext_proc.ProcessingRequest_RequestBody :
68- log .Printf ("DEBUG: Processing request body - THIS IS WHERE ROUTING HAPPENS" )
64+ log .Printf ("DEBUG: Processing Request Body - THIS IS WHERE ROUTING HAPPENS" )
65+
6966 response , err := r .handleRequestBody (v , ctx )
7067 if err != nil {
7168 log .Printf ("ERROR: handleRequestBody failed: %v" , err )
@@ -75,7 +72,6 @@ func (r *OpenAIRouter) Process(stream ext_proc.ExternalProcessor_ProcessServer)
7572 log .Printf ("ERROR: sendResponse for body failed: %v" , err )
7673 return err
7774 }
78- log .Printf ("DEBUG: Request body processed successfully" )
7975
8076 case * ext_proc.ProcessingRequest_ResponseHeaders :
8177 response , err := r .handleResponseHeaders (v )
@@ -113,7 +109,5 @@ func (r *OpenAIRouter) Process(stream ext_proc.ExternalProcessor_ProcessServer)
113109 return err
114110 }
115111 }
116-
117- log .Printf ("DEBUG: Finished processing message, continuing to next..." )
118112 }
119113}
0 commit comments