dsc-rs 0.10.15

Discourse CLI tool for managing multiple Discourse forums: track installs, run upgrades over SSH, manage emojis, sync topics and categories as Markdown, and more.
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

use super::client::DiscourseClient;
use super::error::http_error;
use anyhow::{Context, Result};
use serde::{Deserialize, Serialize};

/// One row from /user_actions.json. Distilled — Discourse returns more
/// fields than most callers need.
#[derive(Debug, Deserialize, Serialize, Clone)]
pub struct UserAction {
    pub action_type: u32,
    pub created_at: String,
    #[serde(default)]
    pub title: Option<String>,
    #[serde(default)]
    pub slug: Option<String>,
    pub topic_id: u64,
    #[serde(default)]
    pub post_id: Option<u64>,
    #[serde(default)]
    pub post_number: Option<u64>,
    #[serde(default)]
    pub username: Option<String>,
    #[serde(default)]
    pub excerpt: Option<String>,
}

#[derive(Debug, Deserialize)]
struct UserActionsResponse {
    #[serde(default)]
    user_actions: Vec<UserAction>,
}

impl DiscourseClient {
    /// Fetch a page of a user's activity. `filter_types` is a slice of
    /// Discourse's numeric action-type filters (e.g. 4 = new_topic, 5 = reply);
    /// they're joined with commas. `offset` paginates — Discourse returns
    /// ~10 items per page.
    pub fn fetch_user_actions(
        &self,
        username: &str,
        filter_types: &[u32],
        offset: u32,
    ) -> Result<Vec<UserAction>> {
        let types_csv = filter_types
            .iter()
            .map(|n| n.to_string())
            .collect::<Vec<_>>()
            .join(",");
        let path = format!(
            "/user_actions.json?username={}&filter={}&offset={}",
            username, types_csv, offset
        );
        let response = self.get(&path)?;
        let status = response.status();
        let text = response.text().context("reading user actions response")?;
        if !status.is_success() {
            return Err(http_error("user actions request", status, &text));
        }
        let body: UserActionsResponse =
            serde_json::from_str(&text).context("parsing user actions response")?;
        Ok(body.user_actions)
    }
}