Method stream_from_input

crates/opencode-session/src/llm.rs:810–952

Internal: build the request and start streaming.

(
        input: &StreamInput,
        provider: Arc<dyn Provider>,
    )

    /// Internal: build the request and start streaming.
    async fn stream_from_input(
        input: &StreamInput,
        provider: Arc<dyn Provider>,
    ) -> anyhow::Result<StreamOutput> {
        let session_id = input.session_id.clone();
        let model_id = input.model.model_id.clone();
        let provider_id = input.model.provider_id.clone();
        let agent_name = input.agent.name.clone();

        tracing::info!(
            session_id = %session_id,
            model_id = %model_id,
            provider_id = %provider_id,
            agent = %agent_name,
            "Starting LLM stream"
        );

        let mut system_prompt = build_system_prompt(input);
        let system_header_before_hooks = system_prompt.first().cloned().unwrap_or_default();

        // Plugin hook: chat.system.transform — let plugins modify the system prompt
        let system_hook_outputs = opencode_plugin::trigger_collect(
            HookContext::new(HookEvent::ChatSystemTransform)
                .with_session(&session_id)
                .with_data("model_id", serde_json::json!(&model_id))
                .with_data("provider_id", serde_json::json!(&provider_id))
                .with_data("system", serde_json::json!(&system_prompt)),
        )
        .await;
        apply_chat_system_hook_outputs(&mut system_prompt, system_hook_outputs);
        rejoin_system_prompt_if_needed(&mut system_prompt, &system_header_before_hooks);

        let mut tools = resolve_tools(input.tools.clone(), &input.agent);
        // Inject LiteLLM dummy tool if needed
        inject_litellm_dummy_tool(&mut tools, &input.messages, &input.model.provider_id);

        let mut max_tokens = if input.small {
            Some(1024u64)
        } else {
            Some(input.agent.max_tokens.unwrap_or(OUTPUT_TOKEN_MAX))
        };

        let mut temperature = if input.small {
            Some(0.5f32)
        } else {
            input.agent.temperature
        };
        let mut top_p = input.agent.top_p;
        let mut provider_options: HashMap<String, serde_json::Value> = HashMap::new();

        let (tx, rx) = tokio::sync::mpsc::channel(100);

        // Plugin hook: chat.params — let plugins modify LLM request parameters
        let params_hook_outputs = opencode_plugin::trigger_collect(
            HookContext::new(HookEvent::ChatParams)
                .with_session(&session_id)
                .with_data("model_id", serde_json::json!(&model_id))
                .with_data("provider_id", serde_json::json!(&provider_id))