// @generated by jacquard-lexicon. DO NOT EDIT. // // Lexicon: tools.ozone.moderation.emitEvent // // This file was automatically generated from Lexicon schemas. // Any manual changes will be overwritten on the next regeneration. #[jacquard_derive::lexicon] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic )] #[serde(rename_all = "camelCase")] pub struct EmitEvent<'a> { #[serde(borrow)] pub created_by: jacquard_common::types::string::Did<'a>, #[serde(borrow)] pub event: EmitEventEvent<'a>, /// An optional external ID for the event, used to deduplicate events from external systems. Fails when an event of same type with the same external ID exists for the same subject. #[serde(skip_serializing_if = "std::option::Option::is_none")] #[serde(borrow)] pub external_id: std::option::Option>, #[serde(skip_serializing_if = "std::option::Option::is_none")] #[serde(borrow)] pub mod_tool: std::option::Option>, #[serde(borrow)] pub subject: EmitEventSubject<'a>, #[serde(skip_serializing_if = "std::option::Option::is_none")] #[serde(borrow)] pub subject_blob_cids: std::option::Option< Vec>, >, } pub mod emit_event_state { pub use crate::builder_types::{Set, Unset, IsSet, IsUnset}; #[allow(unused)] use ::core::marker::PhantomData; mod sealed { pub trait Sealed {} } /// State trait tracking which required fields have been set pub trait State: sealed::Sealed { type CreatedBy; type Event; type Subject; } /// Empty state - all required fields are unset pub struct Empty(()); impl sealed::Sealed for Empty {} impl State for Empty { type CreatedBy = Unset; type Event = Unset; type Subject = Unset; } ///State transition - sets the `created_by` field to Set pub struct SetCreatedBy(PhantomData S>); impl sealed::Sealed for SetCreatedBy {} impl State for SetCreatedBy { type CreatedBy = Set; type Event = S::Event; type Subject = S::Subject; } ///State transition - sets the `event` field to Set pub struct SetEvent(PhantomData S>); impl sealed::Sealed for SetEvent {} impl State for SetEvent { type CreatedBy = S::CreatedBy; type Event = Set; type Subject = S::Subject; } ///State transition - sets the `subject` field to Set pub struct SetSubject(PhantomData S>); impl sealed::Sealed for SetSubject {} impl State for SetSubject { type CreatedBy = S::CreatedBy; type Event = S::Event; type Subject = Set; } /// Marker types for field names #[allow(non_camel_case_types)] pub mod members { ///Marker type for the `created_by` field pub struct created_by(()); ///Marker type for the `event` field pub struct event(()); ///Marker type for the `subject` field pub struct subject(()); } } /// Builder for constructing an instance of this type pub struct EmitEventBuilder<'a, S: emit_event_state::State> { _phantom_state: ::core::marker::PhantomData S>, __unsafe_private_named: ( ::core::option::Option>, ::core::option::Option>, ::core::option::Option>, ::core::option::Option>, ::core::option::Option>, ::core::option::Option>>, ), _phantom: ::core::marker::PhantomData<&'a ()>, } impl<'a> EmitEvent<'a> { /// Create a new builder for this type pub fn new() -> EmitEventBuilder<'a, emit_event_state::Empty> { EmitEventBuilder::new() } } impl<'a> EmitEventBuilder<'a, emit_event_state::Empty> { /// Create a new builder with all fields unset pub fn new() -> Self { EmitEventBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: (None, None, None, None, None, None), _phantom: ::core::marker::PhantomData, } } } impl<'a, S> EmitEventBuilder<'a, S> where S: emit_event_state::State, S::CreatedBy: emit_event_state::IsUnset, { /// Set the `createdBy` field (required) pub fn created_by( mut self, value: impl Into>, ) -> EmitEventBuilder<'a, emit_event_state::SetCreatedBy> { self.__unsafe_private_named.0 = ::core::option::Option::Some(value.into()); EmitEventBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: self.__unsafe_private_named, _phantom: ::core::marker::PhantomData, } } } impl<'a, S> EmitEventBuilder<'a, S> where S: emit_event_state::State, S::Event: emit_event_state::IsUnset, { /// Set the `event` field (required) pub fn event( mut self, value: impl Into>, ) -> EmitEventBuilder<'a, emit_event_state::SetEvent> { self.__unsafe_private_named.1 = ::core::option::Option::Some(value.into()); EmitEventBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: self.__unsafe_private_named, _phantom: ::core::marker::PhantomData, } } } impl<'a, S: emit_event_state::State> EmitEventBuilder<'a, S> { /// Set the `externalId` field (optional) pub fn external_id( mut self, value: impl Into>>, ) -> Self { self.__unsafe_private_named.2 = value.into(); self } /// Set the `externalId` field to an Option value (optional) pub fn maybe_external_id( mut self, value: Option>, ) -> Self { self.__unsafe_private_named.2 = value; self } } impl<'a, S: emit_event_state::State> EmitEventBuilder<'a, S> { /// Set the `modTool` field (optional) pub fn mod_tool( mut self, value: impl Into>>, ) -> Self { self.__unsafe_private_named.3 = value.into(); self } /// Set the `modTool` field to an Option value (optional) pub fn maybe_mod_tool( mut self, value: Option>, ) -> Self { self.__unsafe_private_named.3 = value; self } } impl<'a, S> EmitEventBuilder<'a, S> where S: emit_event_state::State, S::Subject: emit_event_state::IsUnset, { /// Set the `subject` field (required) pub fn subject( mut self, value: impl Into>, ) -> EmitEventBuilder<'a, emit_event_state::SetSubject> { self.__unsafe_private_named.4 = ::core::option::Option::Some(value.into()); EmitEventBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: self.__unsafe_private_named, _phantom: ::core::marker::PhantomData, } } } impl<'a, S: emit_event_state::State> EmitEventBuilder<'a, S> { /// Set the `subjectBlobCids` field (optional) pub fn subject_blob_cids( mut self, value: impl Into>>>, ) -> Self { self.__unsafe_private_named.5 = value.into(); self } /// Set the `subjectBlobCids` field to an Option value (optional) pub fn maybe_subject_blob_cids( mut self, value: Option>>, ) -> Self { self.__unsafe_private_named.5 = value; self } } impl<'a, S> EmitEventBuilder<'a, S> where S: emit_event_state::State, S::CreatedBy: emit_event_state::IsSet, S::Event: emit_event_state::IsSet, S::Subject: emit_event_state::IsSet, { /// Build the final struct pub fn build(self) -> EmitEvent<'a> { EmitEvent { created_by: self.__unsafe_private_named.0.unwrap(), event: self.__unsafe_private_named.1.unwrap(), external_id: self.__unsafe_private_named.2, mod_tool: self.__unsafe_private_named.3, subject: self.__unsafe_private_named.4.unwrap(), subject_blob_cids: self.__unsafe_private_named.5, extra_data: Default::default(), } } /// Build the final struct with custom extra_data pub fn build_with_data( self, extra_data: std::collections::BTreeMap< jacquard_common::smol_str::SmolStr, jacquard_common::types::value::Data<'a>, >, ) -> EmitEvent<'a> { EmitEvent { created_by: self.__unsafe_private_named.0.unwrap(), event: self.__unsafe_private_named.1.unwrap(), external_id: self.__unsafe_private_named.2, mod_tool: self.__unsafe_private_named.3, subject: self.__unsafe_private_named.4.unwrap(), subject_blob_cids: self.__unsafe_private_named.5, extra_data: Some(extra_data), } } } #[jacquard_derive::open_union] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic )] #[serde(tag = "$type")] #[serde(bound(deserialize = "'de: 'a"))] pub enum EmitEventEvent<'a> { #[serde(rename = "tools.ozone.moderation.defs#modEventTakedown")] ModEventTakedown(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventAcknowledge")] ModEventAcknowledge(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventEscalate")] ModEventEscalate(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventComment")] ModEventComment(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventLabel")] ModEventLabel(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventReport")] ModEventReport(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventMute")] ModEventMute(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventUnmute")] ModEventUnmute(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventMuteReporter")] ModEventMuteReporter(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventUnmuteReporter")] ModEventUnmuteReporter( Box>, ), #[serde(rename = "tools.ozone.moderation.defs#modEventReverseTakedown")] ModEventReverseTakedown( Box>, ), #[serde(rename = "tools.ozone.moderation.defs#modEventResolveAppeal")] ModEventResolveAppeal( Box>, ), #[serde(rename = "tools.ozone.moderation.defs#modEventEmail")] ModEventEmail(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventDivert")] ModEventDivert(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventTag")] ModEventTag(Box>), #[serde(rename = "tools.ozone.moderation.defs#accountEvent")] AccountEvent(Box>), #[serde(rename = "tools.ozone.moderation.defs#identityEvent")] IdentityEvent(Box>), #[serde(rename = "tools.ozone.moderation.defs#recordEvent")] RecordEvent(Box>), #[serde(rename = "tools.ozone.moderation.defs#modEventPriorityScore")] ModEventPriorityScore( Box>, ), #[serde(rename = "tools.ozone.moderation.defs#ageAssuranceEvent")] AgeAssuranceEvent(Box>), #[serde(rename = "tools.ozone.moderation.defs#ageAssuranceOverrideEvent")] AgeAssuranceOverrideEvent( Box>, ), #[serde(rename = "tools.ozone.moderation.defs#revokeAccountCredentialsEvent")] RevokeAccountCredentialsEvent( Box>, ), #[serde(rename = "tools.ozone.moderation.defs#scheduleTakedownEvent")] ScheduleTakedownEvent( Box>, ), #[serde(rename = "tools.ozone.moderation.defs#cancelScheduledTakedownEvent")] CancelScheduledTakedownEvent( Box>, ), } #[jacquard_derive::open_union] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic )] #[serde(tag = "$type")] #[serde(bound(deserialize = "'de: 'a"))] pub enum EmitEventSubject<'a> { #[serde(rename = "com.atproto.admin.defs#repoRef")] RepoRef(Box>), #[serde(rename = "com.atproto.repo.strongRef")] StrongRef(Box>), } #[jacquard_derive::lexicon] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic )] #[serde(rename_all = "camelCase")] pub struct EmitEventOutput<'a> { #[serde(flatten)] #[serde(borrow)] pub value: crate::tools_ozone::moderation::ModEventView<'a>, } #[jacquard_derive::open_union] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, thiserror::Error, miette::Diagnostic, jacquard_derive::IntoStatic )] #[serde(tag = "error", content = "message")] #[serde(bound(deserialize = "'de: 'a"))] pub enum EmitEventError<'a> { #[serde(rename = "SubjectHasAction")] SubjectHasAction(std::option::Option>), /// An event with the same external ID already exists for the subject. #[serde(rename = "DuplicateExternalId")] DuplicateExternalId(std::option::Option>), } impl core::fmt::Display for EmitEventError<'_> { fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result { match self { Self::SubjectHasAction(msg) => { write!(f, "SubjectHasAction")?; if let Some(msg) = msg { write!(f, ": {}", msg)?; } Ok(()) } Self::DuplicateExternalId(msg) => { write!(f, "DuplicateExternalId")?; if let Some(msg) = msg { write!(f, ": {}", msg)?; } Ok(()) } Self::Unknown(err) => write!(f, "Unknown error: {:?}", err), } } } /// Response type for ///tools.ozone.moderation.emitEvent pub struct EmitEventResponse; impl jacquard_common::xrpc::XrpcResp for EmitEventResponse { const NSID: &'static str = "tools.ozone.moderation.emitEvent"; const ENCODING: &'static str = "application/json"; type Output<'de> = EmitEventOutput<'de>; type Err<'de> = EmitEventError<'de>; } impl<'a> jacquard_common::xrpc::XrpcRequest for EmitEvent<'a> { const NSID: &'static str = "tools.ozone.moderation.emitEvent"; const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure( "application/json", ); type Response = EmitEventResponse; } /// Endpoint type for ///tools.ozone.moderation.emitEvent pub struct EmitEventRequest; impl jacquard_common::xrpc::XrpcEndpoint for EmitEventRequest { const PATH: &'static str = "/xrpc/tools.ozone.moderation.emitEvent"; const METHOD: jacquard_common::xrpc::XrpcMethod = jacquard_common::xrpc::XrpcMethod::Procedure( "application/json", ); type Request<'de> = EmitEvent<'de>; type Response = EmitEventResponse; }