pub mod decrypt_by_cid;
pub mod delete_stored;
pub mod encrypt;
pub mod get_post;
pub mod store;
#[allow(unused_imports)]
use alloc::collections::BTreeMap;
#[allow(unused_imports)]
use core::marker::PhantomData;
use jacquard_common::CowStr;
#[allow(unused_imports)]
use jacquard_common::deps::codegen::unicode_segmentation::UnicodeSegmentation;
use jacquard_common::types::blob::BlobRef;
use jacquard_common::types::collection::{Collection, RecordError};
use jacquard_common::types::string::{AtUri, Cid, Datetime};
use jacquard_common::types::uri::{RecordUri, UriError};
use jacquard_common::xrpc::XrpcResp;
use jacquard_derive::{IntoStatic, lexicon};
use jacquard_lexicon::lexicon::LexiconDoc;
use jacquard_lexicon::schema::LexiconSchema;
#[allow(unused_imports)]
use jacquard_lexicon::validation::{ConstraintError, ValidationPath};
use serde::{Serialize, Deserialize};
#[lexicon]
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(rename_all = "camelCase")]
pub struct Post<'a> {
#[serde(skip_serializing_if = "Option::is_none")]
#[serde(borrow)]
pub additional: Option<CowStr<'a>>,
pub created_at: Datetime,
#[serde(skip_serializing_if = "Option::is_none")]
#[serde(borrow)]
pub encrypt_body: Option<BlobRef<'a>>,
#[serde(borrow)]
pub text: CowStr<'a>,
#[serde(borrow)]
pub uri: AtUri<'a>,
#[serde(borrow)]
pub visibility: CowStr<'a>,
}
#[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq, IntoStatic)]
#[serde(rename_all = "camelCase")]
pub struct PostGetRecordOutput<'a> {
#[serde(skip_serializing_if = "Option::is_none")]
#[serde(borrow)]
pub cid: Option<Cid<'a>>,
#[serde(borrow)]
pub uri: AtUri<'a>,
#[serde(borrow)]
pub value: Post<'a>,
}
impl<'a> Post<'a> {
pub fn uri(
uri: impl Into<CowStr<'a>>,
) -> Result<RecordUri<'a, PostRecord>, UriError> {
RecordUri::try_from_uri(AtUri::new_cow(uri.into())?)
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct PostRecord;
impl XrpcResp for PostRecord {
const NSID: &'static str = "uk.skyblur.post";
const ENCODING: &'static str = "application/json";
type Output<'de> = PostGetRecordOutput<'de>;
type Err<'de> = RecordError<'de>;
}
impl From<PostGetRecordOutput<'_>> for Post<'_> {
fn from(output: PostGetRecordOutput<'_>) -> Self {
use jacquard_common::IntoStatic;
output.value.into_static()
}
}
impl Collection for Post<'_> {
const NSID: &'static str = "uk.skyblur.post";
type Record = PostRecord;
}
impl Collection for PostRecord {
const NSID: &'static str = "uk.skyblur.post";
type Record = PostRecord;
}
impl<'a> LexiconSchema for Post<'a> {
fn nsid() -> &'static str {
"uk.skyblur.post"
}
fn def_name() -> &'static str {
"main"
}
fn lexicon_doc() -> LexiconDoc<'static> {
lexicon_doc_uk_skyblur_post()
}
fn validate(&self) -> Result<(), ConstraintError> {
if let Some(ref value) = self.additional {
#[allow(unused_comparisons)]
if <str>::len(value.as_ref()) > 100000usize {
return Err(ConstraintError::MaxLength {
path: ValidationPath::from_field("additional"),
max: 100000usize,
actual: <str>::len(value.as_ref()),
});
}
}
if let Some(ref value) = self.additional {
{
let count = UnicodeSegmentation::graphemes(value.as_ref(), true).count();
if count > 10000usize {
return Err(ConstraintError::MaxGraphemes {
path: ValidationPath::from_field("additional"),
max: 10000usize,
actual: count,
});
}
}
}
{
let value = &self.text;
#[allow(unused_comparisons)]
if <str>::len(value.as_ref()) > 3000usize {
return Err(ConstraintError::MaxLength {
path: ValidationPath::from_field("text"),
max: 3000usize,
actual: <str>::len(value.as_ref()),
});
}
}
{
let value = &self.text;
{
let count = UnicodeSegmentation::graphemes(value.as_ref(), true).count();
if count > 300usize {
return Err(ConstraintError::MaxGraphemes {
path: ValidationPath::from_field("text"),
max: 300usize,
actual: count,
});
}
}
}
{
let value = &self.visibility;
#[allow(unused_comparisons)]
if <str>::len(value.as_ref()) > 100usize {
return Err(ConstraintError::MaxLength {
path: ValidationPath::from_field("visibility"),
max: 100usize,
actual: <str>::len(value.as_ref()),
});
}
}
{
let value = &self.visibility;
{
let count = UnicodeSegmentation::graphemes(value.as_ref(), true).count();
if count > 10usize {
return Err(ConstraintError::MaxGraphemes {
path: ValidationPath::from_field("visibility"),
max: 10usize,
actual: count,
});
}
}
}
Ok(())
}
}
pub mod post_state {
pub use crate::builder_types::{Set, Unset, IsSet, IsUnset};
#[allow(unused)]
use ::core::marker::PhantomData;
mod sealed {
pub trait Sealed {}
}
pub trait State: sealed::Sealed {
type Visibility;
type CreatedAt;
type Text;
type Uri;
}
pub struct Empty(());
impl sealed::Sealed for Empty {}
impl State for Empty {
type Visibility = Unset;
type CreatedAt = Unset;
type Text = Unset;
type Uri = Unset;
}
pub struct SetVisibility<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetVisibility<S> {}
impl<S: State> State for SetVisibility<S> {
type Visibility = Set<members::visibility>;
type CreatedAt = S::CreatedAt;
type Text = S::Text;
type Uri = S::Uri;
}
pub struct SetCreatedAt<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetCreatedAt<S> {}
impl<S: State> State for SetCreatedAt<S> {
type Visibility = S::Visibility;
type CreatedAt = Set<members::created_at>;
type Text = S::Text;
type Uri = S::Uri;
}
pub struct SetText<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetText<S> {}
impl<S: State> State for SetText<S> {
type Visibility = S::Visibility;
type CreatedAt = S::CreatedAt;
type Text = Set<members::text>;
type Uri = S::Uri;
}
pub struct SetUri<S: State = Empty>(PhantomData<fn() -> S>);
impl<S: State> sealed::Sealed for SetUri<S> {}
impl<S: State> State for SetUri<S> {
type Visibility = S::Visibility;
type CreatedAt = S::CreatedAt;
type Text = S::Text;
type Uri = Set<members::uri>;
}
#[allow(non_camel_case_types)]
pub mod members {
pub struct visibility(());
pub struct created_at(());
pub struct text(());
pub struct uri(());
}
}
pub struct PostBuilder<'a, S: post_state::State> {
_state: PhantomData<fn() -> S>,
_fields: (
Option<CowStr<'a>>,
Option<Datetime>,
Option<BlobRef<'a>>,
Option<CowStr<'a>>,
Option<AtUri<'a>>,
Option<CowStr<'a>>,
),
_lifetime: PhantomData<&'a ()>,
}
impl<'a> Post<'a> {
pub fn new() -> PostBuilder<'a, post_state::Empty> {
PostBuilder::new()
}
}
impl<'a> PostBuilder<'a, post_state::Empty> {
pub fn new() -> Self {
PostBuilder {
_state: PhantomData,
_fields: (None, None, None, None, None, None),
_lifetime: PhantomData,
}
}
}
impl<'a, S: post_state::State> PostBuilder<'a, S> {
pub fn additional(mut self, value: impl Into<Option<CowStr<'a>>>) -> Self {
self._fields.0 = value.into();
self
}
pub fn maybe_additional(mut self, value: Option<CowStr<'a>>) -> Self {
self._fields.0 = value;
self
}
}
impl<'a, S> PostBuilder<'a, S>
where
S: post_state::State,
S::CreatedAt: post_state::IsUnset,
{
pub fn created_at(
mut self,
value: impl Into<Datetime>,
) -> PostBuilder<'a, post_state::SetCreatedAt<S>> {
self._fields.1 = Option::Some(value.into());
PostBuilder {
_state: PhantomData,
_fields: self._fields,
_lifetime: PhantomData,
}
}
}
impl<'a, S: post_state::State> PostBuilder<'a, S> {
pub fn encrypt_body(mut self, value: impl Into<Option<BlobRef<'a>>>) -> Self {
self._fields.2 = value.into();
self
}
pub fn maybe_encrypt_body(mut self, value: Option<BlobRef<'a>>) -> Self {
self._fields.2 = value;
self
}
}
impl<'a, S> PostBuilder<'a, S>
where
S: post_state::State,
S::Text: post_state::IsUnset,
{
pub fn text(
mut self,
value: impl Into<CowStr<'a>>,
) -> PostBuilder<'a, post_state::SetText<S>> {
self._fields.3 = Option::Some(value.into());
PostBuilder {
_state: PhantomData,
_fields: self._fields,
_lifetime: PhantomData,
}
}
}
impl<'a, S> PostBuilder<'a, S>
where
S: post_state::State,
S::Uri: post_state::IsUnset,
{
pub fn uri(
mut self,
value: impl Into<AtUri<'a>>,
) -> PostBuilder<'a, post_state::SetUri<S>> {
self._fields.4 = Option::Some(value.into());
PostBuilder {
_state: PhantomData,
_fields: self._fields,
_lifetime: PhantomData,
}
}
}
impl<'a, S> PostBuilder<'a, S>
where
S: post_state::State,
S::Visibility: post_state::IsUnset,
{
pub fn visibility(
mut self,
value: impl Into<CowStr<'a>>,
) -> PostBuilder<'a, post_state::SetVisibility<S>> {
self._fields.5 = Option::Some(value.into());
PostBuilder {
_state: PhantomData,
_fields: self._fields,
_lifetime: PhantomData,
}
}
}
impl<'a, S> PostBuilder<'a, S>
where
S: post_state::State,
S::Visibility: post_state::IsSet,
S::CreatedAt: post_state::IsSet,
S::Text: post_state::IsSet,
S::Uri: post_state::IsSet,
{
pub fn build(self) -> Post<'a> {
Post {
additional: self._fields.0,
created_at: self._fields.1.unwrap(),
encrypt_body: self._fields.2,
text: self._fields.3.unwrap(),
uri: self._fields.4.unwrap(),
visibility: self._fields.5.unwrap(),
extra_data: Default::default(),
}
}
pub fn build_with_data(
self,
extra_data: BTreeMap<
jacquard_common::deps::smol_str::SmolStr,
jacquard_common::types::value::Data<'a>,
>,
) -> Post<'a> {
Post {
additional: self._fields.0,
created_at: self._fields.1.unwrap(),
encrypt_body: self._fields.2,
text: self._fields.3.unwrap(),
uri: self._fields.4.unwrap(),
visibility: self._fields.5.unwrap(),
extra_data: Some(extra_data),
}
}
}
fn lexicon_doc_uk_skyblur_post() -> LexiconDoc<'static> {
#[allow(unused_imports)]
use jacquard_common::{CowStr, deps::smol_str::SmolStr, types::blob::MimeType};
use jacquard_lexicon::lexicon::*;
use alloc::collections::BTreeMap;
LexiconDoc {
lexicon: Lexicon::Lexicon1,
id: CowStr::new_static("uk.skyblur.post"),
defs: {
let mut map = BTreeMap::new();
map.insert(
SmolStr::new_static("main"),
LexUserType::Record(LexRecord {
description: Some(
CowStr::new_static("Record containing a Skyblur post."),
),
key: Some(CowStr::new_static("tid")),
record: LexRecordRecord::Object(LexObject {
required: Some(
vec![
SmolStr::new_static("text"),
SmolStr::new_static("createdAt"),
SmolStr::new_static("uri"),
SmolStr::new_static("visibility")
],
),
properties: {
#[allow(unused_mut)]
let mut map = BTreeMap::new();
map.insert(
SmolStr::new_static("additional"),
LexObjectProperty::String(LexString {
description: Some(
CowStr::new_static("The post additional contents."),
),
max_length: Some(100000usize),
max_graphemes: Some(10000usize),
..Default::default()
}),
);
map.insert(
SmolStr::new_static("createdAt"),
LexObjectProperty::String(LexString {
description: Some(
CowStr::new_static("Created date assigned by client"),
),
format: Some(LexStringFormat::Datetime),
..Default::default()
}),
);
map.insert(
SmolStr::new_static("encryptBody"),
LexObjectProperty::Blob(LexBlob { ..Default::default() }),
);
map.insert(
SmolStr::new_static("text"),
LexObjectProperty::String(LexString {
description: Some(
CowStr::new_static(
"The post main contents. Blurred text must be enclosed in brackets [].",
),
),
max_length: Some(3000usize),
max_graphemes: Some(300usize),
..Default::default()
}),
);
map.insert(
SmolStr::new_static("uri"),
LexObjectProperty::String(LexString {
format: Some(LexStringFormat::AtUri),
..Default::default()
}),
);
map.insert(
SmolStr::new_static("visibility"),
LexObjectProperty::String(LexString {
description: Some(
CowStr::new_static(
"For 'login', the post requires login to view (Bluesky account required). For 'password', the text only contains blurred text, and additional is always empty. The unblurred text and additional are included in the encryptBody. 'followers' restricted to author's followers. 'following' restricted to users author follows. 'mutual' restricted to mutual followers.",
),
),
max_length: Some(100usize),
max_graphemes: Some(10usize),
..Default::default()
}),
);
map
},
..Default::default()
}),
..Default::default()
}),
);
map
},
..Default::default()
}
}