use payjp_client_core::{PayjpClient, BlockingClient, PayjpRequest, RequestBuilder, PayjpMethod};
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
struct ListSubscriptionBuilder {
#[serde(skip_serializing_if = "Option::is_none")]
limit: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
offset: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
since: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
until: Option<i64>,
#[serde(skip_serializing_if = "Option::is_none")]
plan: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
customer: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
status: Option<ListSubscriptionStatus>,
}
impl ListSubscriptionBuilder {
fn new() -> Self {
Self {
limit: None,offset: None,since: None,until: None,plan: None,customer: None,status: None,
}
}
}
#[derive(Copy,Clone,Eq, PartialEq,)]pub enum ListSubscriptionStatus {
Active,
Trial,
Canceled,
Paused,
}
impl ListSubscriptionStatus {
pub fn as_str(self) -> &'static str {
use ListSubscriptionStatus::*;
match self {
Active => "active",
Trial => "trial",
Canceled => "canceled",
Paused => "paused",
}
}
}
impl std::str::FromStr for ListSubscriptionStatus {
type Err = payjp_types::ParseError;
fn from_str(s: &str) -> Result<Self, Self::Err> {
use ListSubscriptionStatus::*;
match s {
"active" => Ok(Active),
"trial" => Ok(Trial),
"canceled" => Ok(Canceled),
"paused" => Ok(Paused),
_ => Err(payjp_types::ParseError)
}
}
}
impl std::fmt::Display for ListSubscriptionStatus {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
f.write_str(self.as_str())
}
}
impl std::fmt::Debug for ListSubscriptionStatus {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
f.write_str(self.as_str())
}
}
impl serde::Serialize for ListSubscriptionStatus {
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where S: serde::Serializer {
serializer.serialize_str(self.as_str())
}
}
#[cfg(feature = "deserialize")]
impl<'de> serde::Deserialize<'de> for ListSubscriptionStatus {
fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
use std::str::FromStr;
let s: std::borrow::Cow<'de, str> = serde::Deserialize::deserialize(deserializer)?;
Self::from_str(&s).map_err(|_| serde::de::Error::custom("Unknown value for ListSubscriptionStatus"))
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct ListSubscription {
inner: ListSubscriptionBuilder,
}
impl ListSubscription {
pub fn new() -> Self {
Self {
inner: ListSubscriptionBuilder::new()
}
}
pub fn limit(mut self, limit: impl Into<i64>) -> Self {
self.inner.limit = Some(limit.into());
self
}
pub fn offset(mut self, offset: impl Into<i64>) -> Self {
self.inner.offset = Some(offset.into());
self
}
pub fn since(mut self, since: impl Into<i64>) -> Self {
self.inner.since = Some(since.into());
self
}
pub fn until(mut self, until: impl Into<i64>) -> Self {
self.inner.until = Some(until.into());
self
}
pub fn plan(mut self, plan: impl Into<String>) -> Self {
self.inner.plan = Some(plan.into());
self
}
pub fn customer(mut self, customer: impl Into<String>) -> Self {
self.inner.customer = Some(customer.into());
self
}
pub fn status(mut self, status: impl Into<ListSubscriptionStatus>) -> Self {
self.inner.status = Some(status.into());
self
}
}
impl Default for ListSubscription {
fn default() -> Self {
Self::new()
}
}impl ListSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
pub fn paginate(&self) -> payjp_client_core::ListPaginator<payjp_types::List<payjp_core::Subscription>> {
payjp_client_core::ListPaginator::new_list("/subscriptions", &self.inner)
}
}
impl PayjpRequest for ListSubscription {
type Output = payjp_types::List<payjp_core::Subscription>;
fn build(&self) -> RequestBuilder {
RequestBuilder::new(PayjpMethod::Get, "/subscriptions").query(&self.inner)
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
struct CreateSubscriptionBuilder {
customer: String,
#[serde(skip_serializing_if = "Option::is_none")]
metadata: Option<payjp_shared::Metadata>,
plan: String,
#[serde(skip_serializing_if = "Option::is_none")]
prorate: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
trial_end: Option<CreateSubscriptionTrialEnd>,
}
impl CreateSubscriptionBuilder {
fn new(customer: impl Into<String>,plan: impl Into<String>,) -> Self {
Self {
customer: customer.into(),metadata: None,plan: plan.into(),prorate: None,trial_end: None,
}
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
#[serde(rename_all = "snake_case")]
pub enum CreateSubscriptionTrialEnd {
#[serde(untagged)]
I64(i64),
#[serde(untagged)]
String(String),
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct CreateSubscription {
inner: CreateSubscriptionBuilder,
}
impl CreateSubscription {
pub fn new(customer:impl Into<String>,plan:impl Into<String>) -> Self {
Self {
inner: CreateSubscriptionBuilder::new(customer.into(),plan.into(),)
}
}
pub fn metadata(mut self, metadata: impl Into<payjp_shared::Metadata>) -> Self {
self.inner.metadata = Some(metadata.into());
self
}
pub fn prorate(mut self, prorate: impl Into<bool>) -> Self {
self.inner.prorate = Some(prorate.into());
self
}
pub fn trial_end(mut self, trial_end: impl Into<CreateSubscriptionTrialEnd>) -> Self {
self.inner.trial_end = Some(trial_end.into());
self
}
}
impl CreateSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
}
impl PayjpRequest for CreateSubscription {
type Output = payjp_core::Subscription;
fn build(&self) -> RequestBuilder {
RequestBuilder::new(PayjpMethod::Post, "/subscriptions").form(&self.inner)
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct RetrieveSubscription {
subscription: String,
}
impl RetrieveSubscription {
pub fn new(subscription:impl Into<String>) -> Self {
Self {
subscription: subscription.into(),
}
}
}
impl RetrieveSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
}
impl PayjpRequest for RetrieveSubscription {
type Output = payjp_core::Subscription;
fn build(&self) -> RequestBuilder {
let subscription = &self.subscription;
RequestBuilder::new(PayjpMethod::Get, format!("/subscriptions/{subscription}"))
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
struct UpdateSubscriptionBuilder {
#[serde(skip_serializing_if = "Option::is_none")]
metadata: Option<payjp_shared::Metadata>,
#[serde(skip_serializing_if = "Option::is_none")]
next_cycle_plan: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
plan: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
prorate: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
trial_end: Option<UpdateSubscriptionTrialEnd>,
}
impl UpdateSubscriptionBuilder {
fn new() -> Self {
Self {
metadata: None,next_cycle_plan: None,plan: None,prorate: None,trial_end: None,
}
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
#[serde(rename_all = "snake_case")]
pub enum UpdateSubscriptionTrialEnd {
#[serde(untagged)]
I64(i64),
#[serde(untagged)]
String(String),
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct UpdateSubscription {
inner: UpdateSubscriptionBuilder,
subscription: String,
}
impl UpdateSubscription {
pub fn new(subscription:impl Into<String>) -> Self {
Self {
subscription: subscription.into(),inner: UpdateSubscriptionBuilder::new()
}
}
pub fn metadata(mut self, metadata: impl Into<payjp_shared::Metadata>) -> Self {
self.inner.metadata = Some(metadata.into());
self
}
pub fn next_cycle_plan(mut self, next_cycle_plan: impl Into<String>) -> Self {
self.inner.next_cycle_plan = Some(next_cycle_plan.into());
self
}
pub fn plan(mut self, plan: impl Into<String>) -> Self {
self.inner.plan = Some(plan.into());
self
}
pub fn prorate(mut self, prorate: impl Into<bool>) -> Self {
self.inner.prorate = Some(prorate.into());
self
}
pub fn trial_end(mut self, trial_end: impl Into<UpdateSubscriptionTrialEnd>) -> Self {
self.inner.trial_end = Some(trial_end.into());
self
}
}
impl UpdateSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
}
impl PayjpRequest for UpdateSubscription {
type Output = payjp_core::Subscription;
fn build(&self) -> RequestBuilder {
let subscription = &self.subscription;
RequestBuilder::new(PayjpMethod::Post, format!("/subscriptions/{subscription}")).form(&self.inner)
}
}
#[derive(Copy,Clone,Debug,)]#[derive(serde::Serialize)]
struct DeleteSubscriptionBuilder {
#[serde(skip_serializing_if = "Option::is_none")]
prorate: Option<bool>,
}
impl DeleteSubscriptionBuilder {
fn new() -> Self {
Self {
prorate: None,
}
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct DeleteSubscription {
inner: DeleteSubscriptionBuilder,
subscription: String,
}
impl DeleteSubscription {
pub fn new(subscription:impl Into<String>) -> Self {
Self {
subscription: subscription.into(),inner: DeleteSubscriptionBuilder::new()
}
}
pub fn prorate(mut self, prorate: impl Into<bool>) -> Self {
self.inner.prorate = Some(prorate.into());
self
}
}
impl DeleteSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
}
impl PayjpRequest for DeleteSubscription {
type Output = payjp_shared::DeleteResponse;
fn build(&self) -> RequestBuilder {
let subscription = &self.subscription;
RequestBuilder::new(PayjpMethod::Delete, format!("/subscriptions/{subscription}")).form(&self.inner)
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct PauseSubscription {
subscription: String,
}
impl PauseSubscription {
pub fn new(subscription:impl Into<String>) -> Self {
Self {
subscription: subscription.into(),
}
}
}
impl PauseSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
}
impl PayjpRequest for PauseSubscription {
type Output = payjp_core::Subscription;
fn build(&self) -> RequestBuilder {
let subscription = &self.subscription;
RequestBuilder::new(PayjpMethod::Post, format!("/subscriptions/{subscription}/pause"))
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
struct ResumeSubscriptionBuilder {
#[serde(skip_serializing_if = "Option::is_none")]
prorate: Option<bool>,
#[serde(skip_serializing_if = "Option::is_none")]
trial_end: Option<ResumeSubscriptionTrialEnd>,
}
impl ResumeSubscriptionBuilder {
fn new() -> Self {
Self {
prorate: None,trial_end: None,
}
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
#[serde(rename_all = "snake_case")]
pub enum ResumeSubscriptionTrialEnd {
#[serde(untagged)]
I64(i64),
#[serde(untagged)]
String(String),
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct ResumeSubscription {
inner: ResumeSubscriptionBuilder,
subscription: String,
}
impl ResumeSubscription {
pub fn new(subscription:impl Into<String>) -> Self {
Self {
subscription: subscription.into(),inner: ResumeSubscriptionBuilder::new()
}
}
pub fn prorate(mut self, prorate: impl Into<bool>) -> Self {
self.inner.prorate = Some(prorate.into());
self
}
pub fn trial_end(mut self, trial_end: impl Into<ResumeSubscriptionTrialEnd>) -> Self {
self.inner.trial_end = Some(trial_end.into());
self
}
}
impl ResumeSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
}
impl PayjpRequest for ResumeSubscription {
type Output = payjp_core::Subscription;
fn build(&self) -> RequestBuilder {
let subscription = &self.subscription;
RequestBuilder::new(PayjpMethod::Post, format!("/subscriptions/{subscription}/resume")).form(&self.inner)
}
}
#[derive(Clone,Debug,)]#[derive(serde::Serialize)]
pub struct CancelSubscription {
subscription: String,
}
impl CancelSubscription {
pub fn new(subscription:impl Into<String>) -> Self {
Self {
subscription: subscription.into(),
}
}
}
impl CancelSubscription {
pub async fn send<C: PayjpClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send(client).await
}
pub fn send_blocking<C: BlockingClient>(&self, client: &C) -> Result<<Self as PayjpRequest>::Output, C::Err> {
self.customize().send_blocking(client)
}
}
impl PayjpRequest for CancelSubscription {
type Output = payjp_core::Subscription;
fn build(&self) -> RequestBuilder {
let subscription = &self.subscription;
RequestBuilder::new(PayjpMethod::Post, format!("/subscriptions/{subscription}/cancel"))
}
}