quelch 0.5.0

Ingest data from Jira, Confluence, and more directly into Azure AI Search
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

//! Confluence-specific mutation calls.

use anyhow::Result;
use rand::Rng;
use rand::rngs::StdRng;

pub async fn mutate(client: &reqwest::Client, base: &str, rng: &mut StdRng) -> Result<()> {
    let space = if rng.r#gen::<f32>() < 0.7 {
        "QUELCH"
    } else {
        "INFRA"
    };
    // 85% update / 15% create
    if rng.r#gen::<f32>() < 0.15 {
        create_page(client, base, space, rng).await
    } else {
        update_random_page(client, base, space, rng).await
    }
}

async fn create_page(
    client: &reqwest::Client,
    base: &str,
    space: &str,
    rng: &mut StdRng,
) -> Result<()> {
    let id: u32 = rng.gen_range(1_000_000..9_999_999);
    let title = format!("New page {id}");
    let body = format!("<h1>{title}</h1><p>Created by sim.</p>");
    client
        .post(format!("{base}/_sim/confluence/upsert_page"))
        .json(&serde_json::json!({
            "space": space,
            "id": id.to_string(),
            "title": title,
            "body": body,
        }))
        .send()
        .await?
        .error_for_status()?;
    Ok(())
}

async fn update_random_page(
    client: &reqwest::Client,
    base: &str,
    space: &str,
    rng: &mut StdRng,
) -> Result<()> {
    let search = client
        .get(format!("{base}/confluence/rest/api/content/search"))
        .header("authorization", format!("Bearer {}", crate::sim::MOCK_PAT))
        .query(&[
            ("cql", format!("space = {space}").as_str()),
            ("limit", "100"),
        ])
        .send()
        .await?
        .error_for_status()?
        .json::<serde_json::Value>()
        .await?;
    let pages = search
        .get("results")
        .and_then(|v| v.as_array())
        .cloned()
        .unwrap_or_default();
    if pages.is_empty() {
        return create_page(client, base, space, rng).await;
    }
    let idx = rng.gen_range(0..pages.len());
    let chosen = &pages[idx];
    let id = chosen
        .get("id")
        .and_then(|k| k.as_str())
        .unwrap_or("")
        .to_string();
    let title = chosen
        .get("title")
        .and_then(|t| t.as_str())
        .unwrap_or("untitled")
        .to_string();
    client
        .post(format!("{base}/_sim/confluence/upsert_page"))
        .json(&serde_json::json!({
            "space": space,
            "id": id,
            "title": format!("{title} (v+1)"),
            "body": "<p>Updated by sim.</p>",
        }))
        .send()
        .await?
        .error_for_status()?;
    Ok(())
}