Function query_requests

crates/store/src/article_request_store.rs:711–802

(
    table: &Table,
    filter: Option<&str>,
    limit: Option<usize>,
    offset: Option<usize>,
)

}

async fn query_requests(
    table: &Table,
    filter: Option<&str>,
    limit: Option<usize>,
    offset: Option<usize>,
) -> Result<Vec<ArticleRequestRecord>> {
    let mut query = table.query();
    if let Some(f) = filter {
        query = query.only_if(f);
    }
    if let Some(o) = offset {
        query = query.offset(o);
    }
    if let Some(l) = limit {
        query = query.limit(l.max(1));
    }
    let cols = &[
        "request_id",
        "article_url",
        "title_hint",
        "request_message",
        "nickname",
        "requester_email",
        "frontend_page_url",
        "status",
        "fingerprint",
        "client_ip",
        "ip_region",
        "admin_note",
        "failure_reason",
        "ingested_article_id",
        "attempt_count",
        "created_at",
        "updated_at",
        "ai_reply",
        "parent_request_id",
    ];
    let batches = query
        .select(Select::columns(cols))
        .execute()
        .await?
        .try_collect::<Vec<_>>()
        .await?;

    let mut rows = Vec::new();
    for batch in batches {
        let c_request_id = string_col(&batch, "request_id")?;
        let c_article_url = string_col(&batch, "article_url")?;
        let c_title_hint = string_col(&batch, "title_hint")?;
        let c_request_message = string_col(&batch, "request_message")?;
        let c_nickname = string_col(&batch, "nickname")?;
        let c_requester_email = string_col(&batch, "requester_email")?;
        let c_frontend_page_url = string_col(&batch, "frontend_page_url")?;
        let c_status = string_col(&batch, "status")?;
        let c_fingerprint = string_col(&batch, "fingerprint")?;
        let c_client_ip = string_col(&batch, "client_ip")?;
        let c_ip_region = string_col(&batch, "ip_region")?;
        let c_admin_note = string_col(&batch, "admin_note")?;