fix(openai): merge custom-provider system prompts

Signed-off-by: pandego <7780875+pandego@users.noreply.github.com>

Author: pandego

pkg/model/provider/openai/client.go

@@ -173,10 +173,16 @@ func (c *Client) Close() {
 	}
 }
 
-// convertMessages converts chat.Message to openai.ChatCompletionMessageParamUnion
-// using the shared oaistream implementation.
-func convertMessages(messages []chat.Message) []openai.ChatCompletionMessageParamUnion {
-	return oaistream.ConvertMessages(messages)
+// convertMessages converts chat.Message to OpenAI chat-completions message params.
+// Custom OpenAI-compatible providers may target local model runners that reject
+// consecutive system or user messages, so we normalize those prompts to match
+// the DMR provider behavior.
+func convertMessages(cfg *latest.ModelConfig, messages []chat.Message) []openai.ChatCompletionMessageParamUnion {
+	openaiMessages := oaistream.ConvertMessages(messages)
+	if isCustomProvider(cfg) {
+		return oaistream.MergeConsecutiveMessages(openaiMessages)
+	}
+	return openaiMessages
 }
 
 // CreateChatCompletionStream creates a streaming chat completion request
@@ -220,7 +226,7 @@ func (c *Client) CreateChatCompletionStream(
 
 	params := openai.ChatCompletionNewParams{
 		Model:    c.ModelConfig.Model,
-		Messages: convertMessages(messages),
+		Messages: convertMessages(&c.ModelConfig, messages),
 		StreamOptions: openai.ChatCompletionStreamOptionsParam{
 			IncludeUsage: openai.Bool(trackUsage),
 		},

pkg/model/provider/openai/client_test.go

@@ -7,6 +7,7 @@ import (
 	"github.com/stretchr/testify/require"
 
 	"github.com/docker/docker-agent/pkg/chat"
+	"github.com/docker/docker-agent/pkg/config/latest"
 	"github.com/docker/docker-agent/pkg/tools"
 )
 
@@ -47,7 +48,7 @@ func TestConvertMessagesToResponseInput_OrphanedFunctionCall(t *testing.T) {
 }
 
 func TestConvertMessagesToResponseInput_NoOrphans(t *testing.T) {
-	// All tool calls have matching results — no placeholder needed.
+	// All tool calls have matching results - no placeholder needed.
 	messages := []chat.Message{
 		{Role: chat.MessageRoleUser, Content: "hello"},
 		{
@@ -69,3 +70,37 @@ func TestConvertMessagesToResponseInput_NoOrphans(t *testing.T) {
 	}
 	assert.Equal(t, 1, outputCount, "should not inject extra outputs when all calls have results")
 }
+
+func TestConvertMessages_MergesConsecutiveSystemMessagesForCustomProviders(t *testing.T) {
+	cfg := &latest.ModelConfig{
+		ProviderOpts: map[string]any{"api_type": "openai_chatcompletions"},
+	}
+	messages := []chat.Message{
+		{Role: chat.MessageRoleSystem, Content: "You are Bob, a coding expert"},
+		{Role: chat.MessageRoleSystem, Content: "## Custom Shell Tools\n\n### execute_command"},
+		{Role: chat.MessageRoleSystem, Content: "<available_skills>\n  <skill>what-time-is-it</skill>\n</available_skills>"},
+		{Role: chat.MessageRoleUser, Content: "what is your favourite colour?"},
+	}
+
+	result := convertMessages(cfg, messages)
+	require.Len(t, result, 2)
+	require.NotNil(t, result[0].OfSystem)
+	assert.Contains(t, result[0].OfSystem.Content.OfString.Value, "You are Bob, a coding expert")
+	assert.Contains(t, result[0].OfSystem.Content.OfString.Value, "Custom Shell Tools")
+	assert.Contains(t, result[0].OfSystem.Content.OfString.Value, "available_skills")
+	assert.NotNil(t, result[1].OfUser)
+}
+
+func TestConvertMessages_PreservesConsecutiveSystemMessagesForOpenAIProvider(t *testing.T) {
+	messages := []chat.Message{
+		{Role: chat.MessageRoleSystem, Content: "System 1"},
+		{Role: chat.MessageRoleSystem, Content: "System 2"},
+		{Role: chat.MessageRoleUser, Content: "hello"},
+	}
+
+	result := convertMessages(&latest.ModelConfig{}, messages)
+	require.Len(t, result, 3)
+	assert.NotNil(t, result[0].OfSystem)
+	assert.NotNil(t, result[1].OfSystem)
+	assert.NotNil(t, result[2].OfUser)
+}