@@ -78,9 +78,9 @@ func (h *defaultCompletionHandler) ToParam(_ context.Context, _ logging.Logger,
7878 return message .ToParam ()
7979}
8080
81- // openAIV3Provider is an OpenAI-compatible provider implementation using
82- // OpenAI's official Go SDK v3.
83- type openAIV3Provider struct {
81+ // openAICompletionsProvider is an OpenAI-compatible Chat Completions API
82+ // provider implementation using OpenAI's official Go SDK v3.
83+ type openAICompletionsProvider struct {
8484 client openai.Client
8585 availableTools []config.ToolConfig
8686
@@ -90,7 +90,7 @@ type openAIV3Provider struct {
9090 NewCompletionHandler func () CompletionHandler
9191}
9292
93- // openAIV3ModelParams is an internal model configuration used by openAIV3Provider .
93+ // openAIV3ModelParams is an internal model configuration used by OpenAI implementations .
9494// It is not user-facing; provider wrappers translate their user-facing model params
9595// into this struct.
9696type openAIV3ModelParams struct {
@@ -144,18 +144,18 @@ func (r ResponseFormat) Ptr() *ResponseFormat {
144144 return utils .Ptr (r )
145145}
146146
147- func newOpenAIV3Provider (availableTools []config.ToolConfig , opts ... option.RequestOption ) * openAIV3Provider {
147+ func newOpenAICompletionsProvider (availableTools []config.ToolConfig , opts ... option.RequestOption ) * openAICompletionsProvider {
148148 clientOpts := append ([]option.RequestOption {
149149 option .WithMaxRetries (0 ), // disable SDK retries since MindTrial has its own retry policy
150150 }, opts ... )
151151
152- return & openAIV3Provider {
152+ return & openAICompletionsProvider {
153153 client : openai .NewClient (clientOpts ... ),
154154 availableTools : availableTools ,
155155 }
156156}
157157
158- func (o * openAIV3Provider ) Run (ctx context.Context , logger logging.Logger , cfg config.RunConfig , task config.Task ) (result Result , err error ) {
158+ func (o * openAICompletionsProvider ) Run (ctx context.Context , logger logging.Logger , cfg config.RunConfig , task config.Task ) (result Result , err error ) {
159159 request := openai.ChatCompletionNewParams {
160160 Model : openai .ChatModel (cfg .Model ),
161161 Messages : []openai.ChatCompletionMessageParamUnion {},
@@ -370,7 +370,7 @@ func (o *openAIV3Provider) Run(ctx context.Context, logger logging.Logger, cfg c
370370 } // move to the next conversation turn
371371}
372372
373- func (o * openAIV3Provider ) createPromptMessage (ctx context.Context , logger logging.Logger , promptText string , files []config.TaskFile , result * Result ) (message openai.ChatCompletionMessageParamUnion , err error ) {
373+ func (o * openAICompletionsProvider ) createPromptMessage (ctx context.Context , logger logging.Logger , promptText string , files []config.TaskFile , result * Result ) (message openai.ChatCompletionMessageParamUnion , err error ) {
374374 if len (files ) > 0 {
375375 parts := make ([]openai.ChatCompletionContentPartUnionParam , 0 , (len (files )* 2 )+ 1 )
376376 for _ , file := range files {
@@ -403,7 +403,7 @@ func (o *openAIV3Provider) createPromptMessage(ctx context.Context, logger loggi
403403// to "high" (nearest higher) to avoid artificially reducing image fidelity during evaluations.
404404// A nil or unrecognised value maps to "auto" (OpenAI's default behavior); a warning is logged
405405// for unrecognised values so the operator is aware of the fallback.
406- func (o * openAIV3Provider ) mapImageDetailToOpenAI (ctx context.Context , logger logging.Logger , detail * config.ImageDetail ) string {
406+ func (o * openAICompletionsProvider ) mapImageDetailToOpenAI (ctx context.Context , logger logging.Logger , detail * config.ImageDetail ) string {
407407 if detail != nil {
408408 switch * detail {
409409 case config .ImageDetailAuto :
@@ -421,7 +421,7 @@ func (o *openAIV3Provider) mapImageDetailToOpenAI(ctx context.Context, logger lo
421421 return "auto"
422422}
423423
424- func (o * openAIV3Provider ) isTransientResponse (err error ) bool {
424+ func (o * openAICompletionsProvider ) isTransientResponse (err error ) bool {
425425 return isOpenAITransientResponse (err )
426426}
427427
@@ -444,15 +444,15 @@ func isOpenAITransientResponse(err error) bool {
444444
445445// newCompletionHandler returns a fresh CompletionHandler for the current API call.
446446// If a custom factory is set, it is used; otherwise, the defaultCompletionHandler is returned.
447- func (o * openAIV3Provider ) newCompletionHandler () CompletionHandler {
447+ func (o * openAICompletionsProvider ) newCompletionHandler () CompletionHandler {
448448 if o .NewCompletionHandler != nil {
449449 return o .NewCompletionHandler ()
450450 }
451451 return & defaultCompletionHandler {}
452452}
453453
454454// handleRequest dispatches the request to the appropriate handler based on streaming mode.
455- func (o * openAIV3Provider ) handleRequest (ctx context.Context , logger logging.Logger , request openai.ChatCompletionNewParams , acc CompletionAccumulator ) (* openai.ChatCompletion , error ) {
455+ func (o * openAICompletionsProvider ) handleRequest (ctx context.Context , logger logging.Logger , request openai.ChatCompletionNewParams , acc CompletionAccumulator ) (* openai.ChatCompletion , error ) {
456456 if request .StreamOptions .IncludeUsage .Value {
457457 return o .handleStreamingRequest (ctx , logger , request , acc )
458458 }
@@ -461,7 +461,7 @@ func (o *openAIV3Provider) handleRequest(ctx context.Context, logger logging.Log
461461
462462// handleStreamingRequest executes a streaming chat completion request,
463463// delegating chunk accumulation to the provided CompletionAccumulator.
464- func (o * openAIV3Provider ) handleStreamingRequest (ctx context.Context , logger logging.Logger , request openai.ChatCompletionNewParams , acc CompletionAccumulator ) (resp * openai.ChatCompletion , err error ) {
464+ func (o * openAICompletionsProvider ) handleStreamingRequest (ctx context.Context , logger logging.Logger , request openai.ChatCompletionNewParams , acc CompletionAccumulator ) (resp * openai.ChatCompletion , err error ) {
465465 stream := o .client .Chat .Completions .NewStreaming (ctx , request )
466466 defer stream .Close ()
467467
@@ -476,6 +476,6 @@ func (o *openAIV3Provider) handleStreamingRequest(ctx context.Context, logger lo
476476 return acc .Result (), nil
477477}
478478
479- func (o * openAIV3Provider ) Close (ctx context.Context ) error {
479+ func (o * openAICompletionsProvider ) Close (ctx context.Context ) error {
480480 return nil
481481}
0 commit comments