Method loop_inner

crates/opencode-session/src/prompt.rs:937–1366

(
        session_id: String,
        token: CancellationToken,
        provider: Arc<dyn Provider>,
        model_id: String,
        provider_id: String,
        session: &mut Session,
        agent

    }

    async fn loop_inner(
        session_id: String,
        token: CancellationToken,
        provider: Arc<dyn Provider>,
        model_id: String,
        provider_id: String,
        session: &mut Session,
        agent_name: Option<&str>,
        system_prompt: Option<String>,
        tools: Vec<ToolDefinition>,
        agent_params: &AgentParams,
        update_hook: Option<SessionUpdateHook>,
    ) -> anyhow::Result<()> {
        let mut step = 0u32;
        let provider_type = ProviderType::from_provider_id(&provider_id);
        let mut post_first_step_ran = false;

        loop {
            if token.is_cancelled() {
                tracing::info!("Prompt loop cancelled for session {}", session_id);
                break;
            }

            let mut filtered_messages = Self::filter_compacted_messages(&session.messages);

            let last_user = filtered_messages
                .iter()
                .rev()
                .find(|m| matches!(m.role, MessageRole::User));

            let last_assistant = filtered_messages
                .iter()
                .rev()
                .find(|m| matches!(m.role, MessageRole::Assistant));

            let last_user = match last_user {
                Some(m) => m,
                None => return Err(anyhow::anyhow!("No user message found")),
            };

            if Self::process_pending_subtasks(session, provider.clone(), &model_id, &provider_id)
                .await?
            {
                tracing::info!("Processed pending subtask parts for session {}", session_id);
                continue;
            }

            if let Some(ref assistant) = last_assistant {
                let has_finish = assistant.parts.iter().any(|p| match &p.part_type {
                    PartType::Text { text, .. } => !text.is_empty(),
                    _ => false,
                });

                if has_finish && last_user.id < assistant.id {
                    tracing::info!("Prompt loop complete for session {}", session_id);
                    break;
                }
            }