use std::borrow::Cow;
use crate::Endpoint;
use crate::api::triggers::InboundRuleTriggerId;
use crate::api::{DEFAULT_PAGE_COUNT, DEFAULT_PAGE_OFFSET, endpoint_with_query};
use serde::{Deserialize, Serialize};
use typed_builder::TypedBuilder;
use url::form_urlencoded::Serializer;
#[derive(Debug, Clone, PartialEq, Serialize, TypedBuilder)]
#[serde(rename_all = "PascalCase")]
pub struct ListInboundRuleTriggersRequest {
#[serde(skip)]
#[builder(default = DEFAULT_PAGE_COUNT)]
pub count: i64,
#[serde(skip)]
#[builder(default = DEFAULT_PAGE_OFFSET)]
pub offset: i64,
}
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct InboundRule {
#[serde(rename = "ID")]
pub trigger_id: InboundRuleTriggerId,
pub rule: String,
}
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct ListInboundRuleTriggersResponse {
pub total_count: i64,
pub inbound_rules: Vec<InboundRule>,
}
impl Endpoint for ListInboundRuleTriggersRequest {
type Request = ListInboundRuleTriggersRequest;
type Response = ListInboundRuleTriggersResponse;
fn endpoint(&self) -> Cow<'static, str> {
let mut serializer = Serializer::new(String::new());
serializer.append_pair("count", &self.count.to_string());
serializer.append_pair("offset", &self.offset.to_string());
endpoint_with_query("/triggers/inboundrules", serializer.finish())
}
fn body(&self) -> &Self::Request {
self
}
fn method(&self) -> http::Method {
http::Method::GET
}
}
#[cfg(test)]
mod tests {
use httptest::matchers::request;
use httptest::{Expectation, Server, responders::*};
use serde_json::json;
use crate::Query;
use crate::reqwest::PostmarkClient;
use super::*;
#[tokio::test]
async fn list_inbound_rule_triggers() {
let server = Server::run();
server.expect(
Expectation::matching(request::method_path("GET", "/triggers/inboundrules"))
.respond_with(json_encoded(json!({
"TotalCount": 1,
"InboundRules": [{"ID": 3, "Rule": "someone@example.com"}]
}))),
);
let client = PostmarkClient::builder()
.base_url(server.url("/").to_string())
.build();
let req = ListInboundRuleTriggersRequest::builder()
.count(50)
.offset(0)
.build();
let resp = req.execute(&client).await.expect("json decode");
assert_eq!(resp.total_count, 1);
}
#[test]
fn list_inbound_rule_triggers_uses_default_pagination() {
let req = ListInboundRuleTriggersRequest::builder().build();
assert_eq!(req.endpoint(), "/triggers/inboundrules?count=100&offset=0");
}
}