hiero_sdk/schedule/
schedule_info_query.rs

1// SPDX-License-Identifier: Apache-2.0
2
3use hiero_sdk_proto::services;
4use hiero_sdk_proto::services::schedule_service_client::ScheduleServiceClient;
5use tonic::transport::Channel;
6
7use crate::query::{
8    AnyQueryData,
9    QueryExecute,
10    ToQueryProtobuf,
11};
12use crate::{
13    BoxGrpcFuture,
14    Error,
15    Query,
16    ScheduleId,
17    ScheduleInfo,
18    ToProtobuf,
19    ValidateChecksums,
20};
21
22/// Get all the information about a schedule.
23pub type ScheduleInfoQuery = Query<ScheduleInfoQueryData>;
24
25#[derive(Default, Clone, Debug)]
26pub struct ScheduleInfoQueryData {
27    schedule_id: Option<ScheduleId>,
28}
29
30impl From<ScheduleInfoQueryData> for AnyQueryData {
31    #[inline]
32    fn from(data: ScheduleInfoQueryData) -> Self {
33        Self::ScheduleInfo(data)
34    }
35}
36
37impl ScheduleInfoQuery {
38    /// Returns the schedule ID for which information is requested.
39    #[must_use]
40    pub fn get_schedule_id(&self) -> Option<ScheduleId> {
41        self.data.schedule_id
42    }
43
44    /// Sets the schedule ID for which information is requested.
45    pub fn schedule_id(&mut self, id: impl Into<ScheduleId>) -> &mut Self {
46        self.data.schedule_id = Some(id.into());
47        self
48    }
49}
50
51impl ToQueryProtobuf for ScheduleInfoQueryData {
52    fn to_query_protobuf(&self, header: services::QueryHeader) -> services::Query {
53        let schedule_id = self.schedule_id.to_protobuf();
54
55        services::Query {
56            query: Some(services::query::Query::ScheduleGetInfo(services::ScheduleGetInfoQuery {
57                schedule_id,
58                header: Some(header),
59            })),
60        }
61    }
62}
63
64impl QueryExecute for ScheduleInfoQueryData {
65    type Response = ScheduleInfo;
66
67    fn execute(
68        &self,
69        channel: Channel,
70        request: services::Query,
71    ) -> BoxGrpcFuture<'_, services::Response> {
72        Box::pin(async { ScheduleServiceClient::new(channel).get_schedule_info(request).await })
73    }
74}
75
76impl ValidateChecksums for ScheduleInfoQueryData {
77    fn validate_checksums(&self, ledger_id: &crate::ledger_id::RefLedgerId) -> Result<(), Error> {
78        self.schedule_id.validate_checksums(ledger_id)
79    }
80}
81
82#[cfg(test)]
83mod tests {
84    use expect_test::expect;
85
86    use crate::query::ToQueryProtobuf;
87    use crate::{
88        Hbar,
89        ScheduleId,
90        ScheduleInfoQuery,
91    };
92
93    #[test]
94    fn serialize() {
95        expect![[r#"
96            Query {
97                query: Some(
98                    ScheduleGetInfo(
99                        ScheduleGetInfoQuery {
100                            header: Some(
101                                QueryHeader {
102                                    payment: None,
103                                    response_type: AnswerOnly,
104                                },
105                            ),
106                            schedule_id: Some(
107                                ScheduleId {
108                                    shard_num: 0,
109                                    realm_num: 0,
110                                    schedule_num: 5005,
111                                },
112                            ),
113                        },
114                    ),
115                ),
116            }
117        "#]]
118        .assert_debug_eq(
119            &ScheduleInfoQuery::new()
120                .schedule_id(ScheduleId::new(0, 0, 5005))
121                .max_payment_amount(Hbar::from_tinybars(100_000))
122                .data
123                .to_query_protobuf(Default::default()),
124        )
125    }
126
127    #[test]
128    fn get_set_schedule_id() {
129        let mut query = ScheduleInfoQuery::new();
130        query.schedule_id(ScheduleId::new(0, 0, 5005));
131
132        assert_eq!(query.get_schedule_id(), Some(ScheduleId::new(0, 0, 5005)));
133    }
134}
hiero_sdk/schedule/schedule_info_query.rs

hiero_sdk/schedule/
schedule_info_query.rs
