Method QueryText

model/opencode.go:67–141

(question string, writer io.Writer, history []*RawMessage, prompt string, knowledgeMessages []*RawMessage, toolSession *ToolSession, lang string)

}

func (p *OpenCodeProvider) QueryText(question string, writer io.Writer, history []*RawMessage, prompt string, knowledgeMessages []*RawMessage, toolSession *ToolSession, lang string) (*ModelResult, error) {
	flusher, ok := writer.(http.Flusher)
	if !ok {
		return nil, fmt.Errorf(i18n.Translate(lang, "model:writer does not implement http.Flusher"))
	}

	if strings.HasPrefix(question, "$OpenAgentDryRun$") {
		return &ModelResult{}, nil
	}

	// NOTE: OpenCode is a self-contained agent that executes tools internally
	// on the server side. It does not expose a "function calling" API where
	// the LLM returns tool calls for the client to execute. This means
	// OpenAgent's MCP tools cannot be mapped to OpenCode's execution model.
	// When toolSession is non-nil, tools are silently unavailable and the
	// LLM will produce a text-only response.
	_ = toolSession

	sessionID, err := p.createSession()
	if err != nil {
		return nil, fmt.Errorf("OpenCode: failed to create session at %s: %v.\n\nMake sure 'opencode serve' is running. You can change the server URL in provider settings.", p.serverUrl, err)
	}
	defer p.deleteSession(sessionID)

	var messageText strings.Builder
	for _, msg := range history {
		if msg.Text == "" {
			continue
		}
		switch msg.Author {
		case "AI":
			messageText.WriteString("Assistant: ")
		case "User":
			messageText.WriteString("User: ")
		}
		messageText.WriteString(msg.Text)
		messageText.WriteString("\n")
	}
	if len(knowledgeMessages) > 0 {
		messageText.WriteString("\n--- Context ---\n")
		for _, msg := range knowledgeMessages {
			messageText.WriteString(msg.Text)
			messageText.WriteString("\n")
		}
		messageText.WriteString("--- End Context ---\n\n")
	}
	messageText.WriteString(question)

	// Shared context so SSE goroutine can be cancelled if sendMessageAsync fails
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	type sseResult struct {
		result *ModelResult
		err    error
	}
	resultCh := make(chan sseResult, 1)
	readyCh := make(chan struct{})