// @generated by jacquard-lexicon. DO NOT EDIT. // // Lexicon: sh.weaver.collab.session // // This file was automatically generated from Lexicon schemas. // Any manual changes will be overwritten on the next regeneration. /// Active real-time collaboration session. Published when joining a collaborative editing session, deleted on disconnect. #[jacquard_derive::lexicon] #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic )] #[serde(rename_all = "camelCase")] pub struct Session<'a> { pub created_at: jacquard_common::types::string::Datetime, /// Session TTL. Should be refreshed periodically while active. #[serde(skip_serializing_if = "std::option::Option::is_none")] pub expires_at: std::option::Option, /// iroh NodeId in z-base32 encoding for P2P connection. #[serde(borrow)] pub node_id: jacquard_common::CowStr<'a>, /// DERP relay URL if using relay-only mode (browser clients). #[serde(skip_serializing_if = "std::option::Option::is_none")] #[serde(borrow)] pub relay_url: std::option::Option>, /// The resource being collaboratively edited. #[serde(borrow)] pub resource: crate::com_atproto::repo::strong_ref::StrongRef<'a>, } pub mod session_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 CreatedAt; type Resource; type NodeId; } /// Empty state - all required fields are unset pub struct Empty(()); impl sealed::Sealed for Empty {} impl State for Empty { type CreatedAt = Unset; type Resource = Unset; type NodeId = Unset; } ///State transition - sets the `created_at` field to Set pub struct SetCreatedAt(PhantomData S>); impl sealed::Sealed for SetCreatedAt {} impl State for SetCreatedAt { type CreatedAt = Set; type Resource = S::Resource; type NodeId = S::NodeId; } ///State transition - sets the `resource` field to Set pub struct SetResource(PhantomData S>); impl sealed::Sealed for SetResource {} impl State for SetResource { type CreatedAt = S::CreatedAt; type Resource = Set; type NodeId = S::NodeId; } ///State transition - sets the `node_id` field to Set pub struct SetNodeId(PhantomData S>); impl sealed::Sealed for SetNodeId {} impl State for SetNodeId { type CreatedAt = S::CreatedAt; type Resource = S::Resource; type NodeId = Set; } /// Marker types for field names #[allow(non_camel_case_types)] pub mod members { ///Marker type for the `created_at` field pub struct created_at(()); ///Marker type for the `resource` field pub struct resource(()); ///Marker type for the `node_id` field pub struct node_id(()); } } /// Builder for constructing an instance of this type pub struct SessionBuilder<'a, S: session_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>, ), _phantom: ::core::marker::PhantomData<&'a ()>, } impl<'a> Session<'a> { /// Create a new builder for this type pub fn new() -> SessionBuilder<'a, session_state::Empty> { SessionBuilder::new() } } impl<'a> SessionBuilder<'a, session_state::Empty> { /// Create a new builder with all fields unset pub fn new() -> Self { SessionBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: (None, None, None, None, None), _phantom: ::core::marker::PhantomData, } } } impl<'a, S> SessionBuilder<'a, S> where S: session_state::State, S::CreatedAt: session_state::IsUnset, { /// Set the `createdAt` field (required) pub fn created_at( mut self, value: impl Into, ) -> SessionBuilder<'a, session_state::SetCreatedAt> { self.__unsafe_private_named.0 = ::core::option::Option::Some(value.into()); SessionBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: self.__unsafe_private_named, _phantom: ::core::marker::PhantomData, } } } impl<'a, S: session_state::State> SessionBuilder<'a, S> { /// Set the `expiresAt` field (optional) pub fn expires_at( mut self, value: impl Into>, ) -> Self { self.__unsafe_private_named.1 = value.into(); self } /// Set the `expiresAt` field to an Option value (optional) pub fn maybe_expires_at( mut self, value: Option, ) -> Self { self.__unsafe_private_named.1 = value; self } } impl<'a, S> SessionBuilder<'a, S> where S: session_state::State, S::NodeId: session_state::IsUnset, { /// Set the `nodeId` field (required) pub fn node_id( mut self, value: impl Into>, ) -> SessionBuilder<'a, session_state::SetNodeId> { self.__unsafe_private_named.2 = ::core::option::Option::Some(value.into()); SessionBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: self.__unsafe_private_named, _phantom: ::core::marker::PhantomData, } } } impl<'a, S: session_state::State> SessionBuilder<'a, S> { /// Set the `relayUrl` field (optional) pub fn relay_url( mut self, value: impl Into>>, ) -> Self { self.__unsafe_private_named.3 = value.into(); self } /// Set the `relayUrl` field to an Option value (optional) pub fn maybe_relay_url( mut self, value: Option>, ) -> Self { self.__unsafe_private_named.3 = value; self } } impl<'a, S> SessionBuilder<'a, S> where S: session_state::State, S::Resource: session_state::IsUnset, { /// Set the `resource` field (required) pub fn resource( mut self, value: impl Into>, ) -> SessionBuilder<'a, session_state::SetResource> { self.__unsafe_private_named.4 = ::core::option::Option::Some(value.into()); SessionBuilder { _phantom_state: ::core::marker::PhantomData, __unsafe_private_named: self.__unsafe_private_named, _phantom: ::core::marker::PhantomData, } } } impl<'a, S> SessionBuilder<'a, S> where S: session_state::State, S::CreatedAt: session_state::IsSet, S::Resource: session_state::IsSet, S::NodeId: session_state::IsSet, { /// Build the final struct pub fn build(self) -> Session<'a> { Session { created_at: self.__unsafe_private_named.0.unwrap(), expires_at: self.__unsafe_private_named.1, node_id: self.__unsafe_private_named.2.unwrap(), relay_url: self.__unsafe_private_named.3, resource: self.__unsafe_private_named.4.unwrap(), 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>, >, ) -> Session<'a> { Session { created_at: self.__unsafe_private_named.0.unwrap(), expires_at: self.__unsafe_private_named.1, node_id: self.__unsafe_private_named.2.unwrap(), relay_url: self.__unsafe_private_named.3, resource: self.__unsafe_private_named.4.unwrap(), extra_data: Some(extra_data), } } } impl<'a> Session<'a> { pub fn uri( uri: impl Into>, ) -> Result< jacquard_common::types::uri::RecordUri<'a, SessionRecord>, jacquard_common::types::uri::UriError, > { jacquard_common::types::uri::RecordUri::try_from_uri( jacquard_common::types::string::AtUri::new_cow(uri.into())?, ) } } /// Typed wrapper for GetRecord response with this collection's record type. #[derive( serde::Serialize, serde::Deserialize, Debug, Clone, PartialEq, Eq, jacquard_derive::IntoStatic )] #[serde(rename_all = "camelCase")] pub struct SessionGetRecordOutput<'a> { #[serde(skip_serializing_if = "std::option::Option::is_none")] #[serde(borrow)] pub cid: std::option::Option>, #[serde(borrow)] pub uri: jacquard_common::types::string::AtUri<'a>, #[serde(borrow)] pub value: Session<'a>, } impl From> for Session<'_> { fn from(output: SessionGetRecordOutput<'_>) -> Self { use jacquard_common::IntoStatic; output.value.into_static() } } impl jacquard_common::types::collection::Collection for Session<'_> { const NSID: &'static str = "sh.weaver.collab.session"; type Record = SessionRecord; } /// Marker type for deserializing records from this collection. #[derive(Debug, serde::Serialize, serde::Deserialize)] pub struct SessionRecord; impl jacquard_common::xrpc::XrpcResp for SessionRecord { const NSID: &'static str = "sh.weaver.collab.session"; const ENCODING: &'static str = "application/json"; type Output<'de> = SessionGetRecordOutput<'de>; type Err<'de> = jacquard_common::types::collection::RecordError<'de>; } impl jacquard_common::types::collection::Collection for SessionRecord { const NSID: &'static str = "sh.weaver.collab.session"; type Record = SessionRecord; } impl<'a> ::jacquard_lexicon::schema::LexiconSchema for Session<'a> { fn nsid() -> &'static str { "sh.weaver.collab.session" } fn def_name() -> &'static str { "main" } fn lexicon_doc() -> ::jacquard_lexicon::lexicon::LexiconDoc<'static> { lexicon_doc_sh_weaver_collab_session() } fn validate( &self, ) -> ::core::result::Result<(), ::jacquard_lexicon::validation::ConstraintError> { Ok(()) } } fn lexicon_doc_sh_weaver_collab_session() -> ::jacquard_lexicon::lexicon::LexiconDoc< 'static, > { ::jacquard_lexicon::lexicon::LexiconDoc { lexicon: ::jacquard_lexicon::lexicon::Lexicon::Lexicon1, id: ::jacquard_common::CowStr::new_static("sh.weaver.collab.session"), revision: None, description: None, defs: { let mut map = ::alloc::collections::BTreeMap::new(); map.insert( ::jacquard_common::smol_str::SmolStr::new_static("main"), ::jacquard_lexicon::lexicon::LexUserType::Record(::jacquard_lexicon::lexicon::LexRecord { description: Some( ::jacquard_common::CowStr::new_static( "Active real-time collaboration session. Published when joining a collaborative editing session, deleted on disconnect.", ), ), key: Some(::jacquard_common::CowStr::new_static("tid")), record: ::jacquard_lexicon::lexicon::LexRecordRecord::Object(::jacquard_lexicon::lexicon::LexObject { description: None, required: Some( vec![ ::jacquard_common::smol_str::SmolStr::new_static("resource"), ::jacquard_common::smol_str::SmolStr::new_static("nodeId"), ::jacquard_common::smol_str::SmolStr::new_static("createdAt") ], ), nullable: None, properties: { #[allow(unused_mut)] let mut map = ::alloc::collections::BTreeMap::new(); map.insert( ::jacquard_common::smol_str::SmolStr::new_static( "createdAt", ), ::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString { description: None, format: Some( ::jacquard_lexicon::lexicon::LexStringFormat::Datetime, ), default: None, min_length: None, max_length: None, min_graphemes: None, max_graphemes: None, r#enum: None, r#const: None, known_values: None, }), ); map.insert( ::jacquard_common::smol_str::SmolStr::new_static( "expiresAt", ), ::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString { description: Some( ::jacquard_common::CowStr::new_static( "Session TTL. Should be refreshed periodically while active.", ), ), format: Some( ::jacquard_lexicon::lexicon::LexStringFormat::Datetime, ), default: None, min_length: None, max_length: None, min_graphemes: None, max_graphemes: None, r#enum: None, r#const: None, known_values: None, }), ); map.insert( ::jacquard_common::smol_str::SmolStr::new_static("nodeId"), ::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString { description: Some( ::jacquard_common::CowStr::new_static( "iroh NodeId in z-base32 encoding for P2P connection.", ), ), format: None, default: None, min_length: None, max_length: None, min_graphemes: None, max_graphemes: None, r#enum: None, r#const: None, known_values: None, }), ); map.insert( ::jacquard_common::smol_str::SmolStr::new_static( "relayUrl", ), ::jacquard_lexicon::lexicon::LexObjectProperty::String(::jacquard_lexicon::lexicon::LexString { description: Some( ::jacquard_common::CowStr::new_static( "DERP relay URL if using relay-only mode (browser clients).", ), ), format: Some( ::jacquard_lexicon::lexicon::LexStringFormat::Uri, ), default: None, min_length: None, max_length: None, min_graphemes: None, max_graphemes: None, r#enum: None, r#const: None, known_values: None, }), ); map.insert( ::jacquard_common::smol_str::SmolStr::new_static( "resource", ), ::jacquard_lexicon::lexicon::LexObjectProperty::Ref(::jacquard_lexicon::lexicon::LexRef { description: None, r#ref: ::jacquard_common::CowStr::new_static( "com.atproto.repo.strongRef", ), }), ); map }, }), }), ); map }, } }