+1

Cargo.lock

reviewed

··· 2656 2656 "async-recursion", 2657 2657 "axum", 2658 2658 "axum-extra", 2659 2659 + "base64 0.22.1", 2659 2660 "chrono", 2660 2661 "dataloader", 2661 2662 "deadpool",

+1 -1

lexica/src/com_atproto/label.rs

reviewed

··· 145 145 #[serde(skip_serializing_if = "Option::is_none")] 146 146 pub exp: Option<NaiveDateTime>, 147 147 #[serde(skip_serializing_if = "Option::is_none")] 148 148 - pub sig: Option<Vec<u8>>, 148 148 + pub sig: Option<crate::JsonBytes>, 149 149 }

+8

lexica/src/lib.rs

reviewed

··· 1 1 + use serde::Serialize; 2 2 + 1 3 pub mod app_bsky; 2 4 pub mod com_atproto; 5 5 + 6 6 + #[derive(Clone, Debug, Serialize)] 7 7 + pub struct JsonBytes { 8 8 + #[serde(rename = "$bytes")] 9 9 + pub bytes: String, 10 10 + }

+1

parakeet/Cargo.toml

reviewed

··· 7 7 async-recursion = "1.1.1" 8 8 axum = { version = "0.8", features = ["json"] } 9 9 axum-extra = { version = "0.10.0", features = ["query", "typed-header"] } 10 10 + base64 = "0.22" 10 11 chrono = { version = "0.4.39", features = ["serde"] } 11 12 dataloader = { path = "../dataloader-rs", default-features = false, features = ["runtime-tokio"] } 12 13 deadpool = { version = "0.12.1", features = ["managed"] }

+6 -1

parakeet/src/hydration/mod.rs

reviewed

··· 3 3 use crate::loaders::Dataloaders; 4 4 use crate::xrpc::cdn::BskyCdn; 5 5 use crate::xrpc::extract::LabelConfigItem; 6 6 + use base64::{prelude::BASE64_STANDARD, Engine}; 6 7 use std::collections::HashMap; 7 8 use std::sync::Arc; 8 9 ··· 17 18 pub use profile::*; 18 19 19 20 fn db_to_atp_label(input: parakeet_db::models::Label) -> lexica::com_atproto::label::Label { 21 21 + let sig = input.sig.map(|sig| lexica::JsonBytes { 22 22 + bytes: BASE64_STANDARD.encode(&sig), 23 23 + }); 24 24 + 20 25 lexica::com_atproto::label::Label { 21 26 ver: 1, 22 27 src: input.labeler, ··· 25 30 val: input.label, 26 31 cts: input.created_at, 27 32 exp: input.expires, 28 28 - sig: input.sig, 33 33 + sig, 29 34 } 30 35 } 31 36