Method transition_comment_task

crates/store/src/comments_store.rs:432–475

(
        &self,
        task_id: &str,
        next_status: &str,
        admin_note: Option<String>,
        failure_reason: Option<String>,
        bump_attempt: bool,
    )

    }

    pub async fn transition_comment_task(
        &self,
        task_id: &str,
        next_status: &str,
        admin_note: Option<String>,
        failure_reason: Option<String>,
        bump_attempt: bool,
    ) -> Result<Option<CommentTaskRecord>> {
        let mut record = match self.get_comment_task(task_id).await? {
            Some(record) => record,
            None => return Ok(None),
        };

        validate_transition(&record.status, next_status)?;

        let now = now_ms();
        record.status = next_status.to_string();
        record.updated_at = now;
        if let Some(note) = admin_note {
            record.admin_note = normalize_optional_text(Some(note));
        }
        if let Some(reason) = failure_reason {
            record.failure_reason = normalize_optional_text(Some(reason));
        }
        if bump_attempt {
            record.attempt_count = record.attempt_count.saturating_add(1);
        }
        if (next_status == COMMENT_STATUS_APPROVED || next_status == COMMENT_STATUS_RUNNING)
            && record.approved_at.is_none()
        {
            record.approved_at = Some(now);
        }
        if next_status == COMMENT_STATUS_DONE || next_status == COMMENT_STATUS_REJECTED {
            record.completed_at = Some(now);
        }
        if next_status == COMMENT_STATUS_RUNNING {
            record.failure_reason = None;
            record.completed_at = None;
        }

        let table = self.tasks_table().await?;
        upsert_comment_task_record(&table, &record).await?;
        Ok(Some(record))
    }

    pub async fn delete_comment_task(&self, task_id: &str) -> Result<()> {
        let tasks_table = self.tasks_table().await?;