Method create_comment_task

crates/store/src/comments_store.rs:289–328

(
        &self,
        input: NewCommentTaskInput,
    )

    }

    pub async fn create_comment_task(
        &self,
        input: NewCommentTaskInput,
    ) -> Result<CommentTaskRecord> {
        let now = now_ms();
        let record = CommentTaskRecord {
            task_id: input.task_id,
            article_id: input.article_id,
            entry_type: input.entry_type,
            status: COMMENT_STATUS_PENDING.to_string(),
            comment_text: input.comment_text,
            selected_text: normalize_optional_text(input.selected_text),
            anchor_block_id: normalize_optional_text(input.anchor_block_id),
            anchor_context_before: normalize_optional_text(input.anchor_context_before),
            anchor_context_after: normalize_optional_text(input.anchor_context_after),
            reply_to_comment_id: normalize_optional_text(input.reply_to_comment_id),
            reply_to_comment_text: normalize_optional_text(input.reply_to_comment_text),
            reply_to_ai_reply_markdown: normalize_optional_text(input.reply_to_ai_reply_markdown),
            client_ip: input.client_ip,
            ip_region: input.ip_region,
            fingerprint: input.fingerprint,
            ua: normalize_optional_text(input.ua),
            language: normalize_optional_text(input.language),
            platform: normalize_optional_text(input.platform),
            timezone: normalize_optional_text(input.timezone),
            viewport: normalize_optional_text(input.viewport),
            referrer: normalize_optional_text(input.referrer),
            admin_note: None,
            failure_reason: None,
            attempt_count: 0,
            created_at: now,
            updated_at: now,
            approved_at: None,
            completed_at: None,
        };

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

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