Versions

Cargo.toml

@@ -37,10 +37,10 @@ path = "examples/sqlite/src/main.rs"
 required-features = ["examples"]
 
 [dependencies]
-atrium-api = "=0.24.10"
+atrium-api = "=0.25.2"
 dotenv = "0.15.0"
 env_logger = "0.11.5"
-jetstream-oxide = "0.1.1"
+jetstream-oxide = "=0.1.2"
 log = "0.4.22"
 serde = "1.0.215"
 serde_json = "1.0.133"

src/bin/my_did.rs

@@ -1,6 +1,6 @@
 use anyhow::Result;
 use atrium_api::{
-    agent::{store::MemorySessionStore, AtpAgent},
+    agent::atp_agent::{store::MemorySessionStore, AtpAgent},
     types::string::Handle,
 };
 use clap::Parser;

src/bin/publish.rs

@@ -1,6 +1,7 @@
 use atrium_api::com::atproto::repo::put_record::InputData;
+use atrium_api::types::string::RecordKey;
 use atrium_api::{
-    agent::{store::MemorySessionStore, AtpAgent},
+    agent::atp_agent::{store::MemorySessionStore, AtpAgent},
     app::bsky::feed::generator::RecordData,
     types::{
         string::{Datetime, Did, Handle, Nsid},
@@ -50,6 +51,7 @@ async fn main() {
     let handle = args.handle;
     let password = args.app_password;
     let feed_host_name = args.hostname;
+    let record_key = RecordKey::new(args.name.to_owned()).expect("Invalid record key name.");
 
     println!("Logging in...");
 
@@ -122,7 +124,7 @@ async fn main() {
                 repo: atrium_api::types::string::AtIdentifier::Did(
                     publisher_did.to_owned().did.clone(),
                 ),
-                rkey: args.name.to_owned(),
+                rkey: record_key,
                 swap_commit: None,
                 swap_record: None,
                 validate: None,

src/bin/unpublish.rs

@@ -1,7 +1,7 @@
 use anyhow::Result;
 use atrium_api::{
-    agent::{store::MemorySessionStore, AtpAgent},
-    types::string::{Handle, Nsid},
+    agent::atp_agent::{store::MemorySessionStore, AtpAgent},
+    types::string::{Handle, Nsid, RecordKey},
 };
 use clap::Parser;
 
@@ -29,6 +29,8 @@ async fn main() -> Result<()> {
     let handle = args.handle;
     let password = args.app_password;
 
+    let record_key = RecordKey::new(args.name.to_owned()).expect("Invalid record key name.");
+
     println!("Logging in");
 
     let agent = AtpAgent::new(
@@ -62,7 +64,7 @@ async fn main() -> Result<()> {
                 repo: atrium_api::types::string::AtIdentifier::Did(
                     publisher_did.to_owned().did.clone(),
                 ),
-                rkey: args.name.to_owned(),
+                rkey: record_key,
                 swap_commit: None,
                 swap_record: None,
             }

src/feed.rs

@@ -283,7 +283,7 @@ async fn get_feed_skeleton<Handler: FeedHandler>(
         .serve_feed(Request {
             cursor: query.cursor.clone(),
             feed: query.feed.clone(),
-            limit: query.limit,
+            limit: query.limit.map(u8::from),
         })
         .await;
     Ok::<warp::reply::Json, warp::Rejection>(warp::reply::json(&FeedSkeleton {

src/lib.rs

@@ -7,4 +7,7 @@ mod utility_models;
 
 pub use feed::Feed;
 pub use feed_handler::FeedHandler;
-pub use models::*;
+pub use models::{
+    Cid, Did, Embed, ExternalEmbed, FeedResult, ImageEmbed, Label, MediaEmbed, Post, QuoteEmbed,
+    Request, Uri, VideoEmbed,
+};

src/models.rs

@@ -3,7 +3,7 @@ use atrium_api::{
         embed::record_with_media::MainMediaRefs,
         feed::post::{RecordEmbedRefs, RecordLabelsRefs},
     },
-    types::{BlobRef, LimitedNonZeroU8, Object, TypedBlobRef, Union},
+    types::{BlobRef, Object, TypedBlobRef, Union},
 };
 use chrono::{DateTime, Utc};
 use log::trace;
@@ -12,7 +12,7 @@ use log::trace;
 pub struct Request {
     pub cursor: Option<String>,
     pub feed: String,
-    pub limit: Option<LimitedNonZeroU8<100>>,
+    pub limit: Option<u8>,
 }
 
 #[derive(Debug, Clone)]