#[allow(unused_imports)]
use alloc::collections::BTreeMap;
#[allow(unused_imports)]
use core::marker::PhantomData;
use jacquard_common::deps::smol_str::SmolStr;
use jacquard_common::types::string::AtUri;
use jacquard_common::types::value::Data;
use jacquard_common::{BosStr, CowStr, DefaultStr, FromStaticStr};
use jacquard_derive::IntoStatic;
use serde::{Deserialize, Serialize};
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(
rename_all = "camelCase",
bound(deserialize = "S: Deserialize<'de> + BosStr")
)]
pub struct CancelPipeline<S: BosStr = DefaultStr> {
pub pipeline: AtUri<S>,
pub repo: AtUri<S>,
pub workflow: S,
#[serde(flatten, default, skip_serializing_if = "Option::is_none")]
pub extra_data: Option<BTreeMap<SmolStr, Data<S>>>,
}
pub struct CancelPipelineResponse;
impl jacquard_common::xrpc::XrpcResp for CancelPipelineResponse {
const NSID: &'static str = "sh.tangled.pipeline.cancelPipeline";
const ENCODING: &'static str = "application/json";
type Output<S: BosStr> = ();
type Err = jacquard_common::xrpc::GenericError;
}
impl<S: BosStr> jacquard_common::xrpc::XrpcRequest for CancelPipeline<S> {
const NSID: &'static str = "sh.tangled.pipeline.cancelPipeline";
const METHOD: jacquard_common::xrpc::XrpcMethod =
jacquard_common::xrpc::XrpcMethod::Procedure("application/json");
type Response = CancelPipelineResponse;
}
pub struct CancelPipelineRequest;
impl jacquard_common::xrpc::XrpcEndpoint for CancelPipelineRequest {
const PATH: &'static str = "/xrpc/sh.tangled.pipeline.cancelPipeline";
const METHOD: jacquard_common::xrpc::XrpcMethod =
jacquard_common::xrpc::XrpcMethod::Procedure("application/json");
type Request<S: BosStr> = CancelPipeline<S>;
type Response = CancelPipelineResponse;
}
pub mod cancel_pipeline_state {
pub use crate::builder_types::{IsSet, IsUnset, Set, Unset};
#[allow(unused)]
use ::core::marker::PhantomData;
mod sealed {
pub trait Sealed {}
}
pub trait State: sealed::Sealed {
type Repo;
type Pipeline;
type Workflow;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type Repo = Unset;
type Pipeline = Unset;
type Workflow = Unset;
}
pub struct SetRepo<St: State = Empty>(PhantomData<fn() -> St>);
impl<St: State> sealed::Sealed for SetRepo<St> {}
impl<St: State> State for SetRepo<St> {
type Repo = Set<members::repo>;
type Pipeline = St::Pipeline;
type Workflow = St::Workflow;
}
pub struct SetPipeline<St: State = Empty>(PhantomData<fn() -> St>);
impl<St: State> sealed::Sealed for SetPipeline<St> {}
impl<St: State> State for SetPipeline<St> {
type Repo = St::Repo;
type Pipeline = Set<members::pipeline>;
type Workflow = St::Workflow;
}
pub struct SetWorkflow<St: State = Empty>(PhantomData<fn() -> St>);
impl<St: State> sealed::Sealed for SetWorkflow<St> {}
impl<St: State> State for SetWorkflow<St> {
type Repo = St::Repo;
type Pipeline = St::Pipeline;
type Workflow = Set<members::workflow>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct repo(());
pub struct pipeline(());
pub struct workflow(());
}
}
pub struct CancelPipelineBuilder<S: BosStr, St: cancel_pipeline_state::State> {
_state: PhantomData<fn() -> St>,
_fields: (Option<AtUri<S>>, Option<AtUri<S>>, Option<S>),
_type: PhantomData<fn() -> S>,
}
impl<S: BosStr> CancelPipeline<S> {
pub fn new() -> CancelPipelineBuilder<S, cancel_pipeline_state::Empty> {
CancelPipelineBuilder::new()
}
}
impl<S: BosStr> CancelPipelineBuilder<S, cancel_pipeline_state::Empty> {
pub fn new() -> Self {
CancelPipelineBuilder {
_state: PhantomData,
_fields: (None, None, None),
_type: PhantomData,
}
}
}
impl<S: BosStr, St> CancelPipelineBuilder<S, St>
where
St: cancel_pipeline_state::State,
St::Pipeline: cancel_pipeline_state::IsUnset,
{
pub fn pipeline(
mut self,
value: impl Into<AtUri<S>>,
) -> CancelPipelineBuilder<S, cancel_pipeline_state::SetPipeline<St>> {
self._fields.0 = Option::Some(value.into());
CancelPipelineBuilder {
_state: PhantomData,
_fields: self._fields,
_type: PhantomData,
}
}
}
impl<S: BosStr, St> CancelPipelineBuilder<S, St>
where
St: cancel_pipeline_state::State,
St::Repo: cancel_pipeline_state::IsUnset,
{
pub fn repo(
mut self,
value: impl Into<AtUri<S>>,
) -> CancelPipelineBuilder<S, cancel_pipeline_state::SetRepo<St>> {
self._fields.1 = Option::Some(value.into());
CancelPipelineBuilder {
_state: PhantomData,
_fields: self._fields,
_type: PhantomData,
}
}
}
impl<S: BosStr, St> CancelPipelineBuilder<S, St>
where
St: cancel_pipeline_state::State,
St::Workflow: cancel_pipeline_state::IsUnset,
{
pub fn workflow(
mut self,
value: impl Into<S>,
) -> CancelPipelineBuilder<S, cancel_pipeline_state::SetWorkflow<St>> {
self._fields.2 = Option::Some(value.into());
CancelPipelineBuilder {
_state: PhantomData,
_fields: self._fields,
_type: PhantomData,
}
}
}
impl<S: BosStr, St> CancelPipelineBuilder<S, St>
where
St: cancel_pipeline_state::State,
St::Repo: cancel_pipeline_state::IsSet,
St::Pipeline: cancel_pipeline_state::IsSet,
St::Workflow: cancel_pipeline_state::IsSet,
{
pub fn build(self) -> CancelPipeline<S> {
CancelPipeline {
pipeline: self._fields.0.unwrap(),
repo: self._fields.1.unwrap(),
workflow: self._fields.2.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(self, extra_data: BTreeMap<SmolStr, Data<S>>) -> CancelPipeline<S> {
CancelPipeline {
pipeline: self._fields.0.unwrap(),
repo: self._fields.1.unwrap(),
workflow: self._fields.2.unwrap(),
extra_data: Some(extra_data),
}
}
}