polyte-cli 0.4.0

CLI tool for querying Polymarket Gamma API
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
95

use clap::{Args, Subcommand, ValueEnum};
use color_eyre::eyre::Result;
use polyte_data::{api::builders::TimePeriod, DataApi};

#[derive(Subcommand)]
pub enum BuildersCommand {
    /// Get aggregated builder leaderboard
    Leaderboard(LeaderboardCommand),
    /// Get daily builder volume time series
    Volume(VolumeCommand),
}

impl BuildersCommand {
    pub async fn run(self, data: &DataApi) -> Result<()> {
        match self {
            Self::Leaderboard(cmd) => cmd.run(data).await,
            Self::Volume(cmd) => cmd.run(data).await,
        }
    }
}

/// Get aggregated builder leaderboard
#[derive(Args)]
pub struct LeaderboardCommand {
    /// Time period for aggregation
    #[arg(short, long, default_value = "day")]
    pub time_period: CliTimePeriod,
    /// Maximum number of results (0-50)
    #[arg(short, long, default_value = "25")]
    pub limit: u32,
    /// Pagination offset (0-1000)
    #[arg(short, long, default_value = "0")]
    pub offset: u32,
}

impl LeaderboardCommand {
    pub async fn run(self, data: &DataApi) -> Result<()> {
        let rankings = data
            .builders()
            .leaderboard()
            .time_period(self.time_period.into())
            .limit(self.limit)
            .offset(self.offset)
            .send()
            .await?;
        println!("{}", serde_json::to_string_pretty(&rankings)?);
        Ok(())
    }
}

/// Get daily builder volume time series
#[derive(Args)]
pub struct VolumeCommand {
    /// Time period filter
    #[arg(short, long, default_value = "day")]
    pub time_period: CliTimePeriod,
}

impl VolumeCommand {
    pub async fn run(self, data: &DataApi) -> Result<()> {
        let volumes = data
            .builders()
            .volume()
            .time_period(self.time_period.into())
            .send()
            .await?;
        println!("{}", serde_json::to_string_pretty(&volumes)?);
        Ok(())
    }
}

/// Time period for aggregation
#[derive(Debug, Clone, Copy, ValueEnum, Default)]
pub enum CliTimePeriod {
    /// Daily aggregation
    #[default]
    Day,
    /// Weekly aggregation
    Week,
    /// Monthly aggregation
    Month,
    /// All time aggregation
    All,
}

impl From<CliTimePeriod> for TimePeriod {
    fn from(period: CliTimePeriod) -> Self {
        match period {
            CliTimePeriod::Day => TimePeriod::Day,
            CliTimePeriod::Week => TimePeriod::Week,
            CliTimePeriod::Month => TimePeriod::Month,
            CliTimePeriod::All => TimePeriod::All,
        }
    }
}