pickcat-api-collection 0.1.7

PickcatAPI合集
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

//! 阅读会话章节：阅读埋点上报。
//!
//! 参见 <https://pickcat-docs.xiaole6324.fun/reading-session.html>。

use crate::dto::reading_session::{ReadingBatchDTO, ReadingBatchResponseDTO, VisiblePostDTO};
use crate::{Error, PickcatAccound};

/// 阅读埋点，来自文档的「阅读会话」章节
/// (<https://pickcat-docs.xiaole6324.fun/reading-session.html>)。
pub trait ReadingSessionBehavior {
    /// `PUT /api/v1/reading-sessions/{sessionId}/batches/{batchNo}` —— 需要会话。
    ///
    /// `session_id` 由调用方生成；`batch_no` 为批次序号。成功返回 `201`。
    /// `visible_posts` 至少要有 1 项，否则服务端返回 `400 VALIDATION_FAILED`。
    fn report_reading_batch(
        &self,
        session_id: &str,
        batch_no: u32,
        topic_id: &str,
        elapsed_ms: u64,
        visible_posts: Vec<VisiblePostDTO>,
    ) -> impl std::future::Future<Output = Result<ReadingBatchResponseDTO, Error>> + Send;
}

impl ReadingSessionBehavior for PickcatAccound {
    async fn report_reading_batch(
        &self,
        session_id: &str,
        batch_no: u32,
        topic_id: &str,
        elapsed_ms: u64,
        visible_posts: Vec<VisiblePostDTO>,
    ) -> Result<ReadingBatchResponseDTO, Error> {
        let dto = ReadingBatchDTO {
            topic_id: topic_id.to_string(),
            elapsed_ms,
            visible_posts,
        };
        Ok(self
            .client
            .put(format!(
                "{}/api/v1/reading-sessions/{}/batches/{}",
                self.base_url, session_id, batch_no
            ))
            .json(&dto)
            .send()
            .await?
            .json::<ReadingBatchResponseDTO>()
            .await?)
    }
}