forked from
pds.dad/rusty-statusphere
Learn how to use Rust to build ATProto powered applications
Updated to latest version of rocketman and only list 10 statuses
+6
-4
+3
-2
Cargo.lock
+3
-2
Cargo.lock
···
2716
2716
2717
2717
[[package]]
2718
2718
name = "rocketman"
2719
-
version = "0.1.1"
2719
+
version = "0.2.0"
2720
2720
source = "registry+https://github.com/rust-lang/crates.io-index"
2721
-
checksum = "72eca7751d4341e1ec6227b2300aed5c86c48b58cdae4a6e41e5c3ad7522ec2c"
2721
+
checksum = "4a3aae946adbfdcf80cad8793e02d8eb94be06c925331aa56aeb446795893361"
2722
2722
dependencies = [
2723
2723
"anyhow",
2724
2724
"async-trait",
···
2735
2735
"tracing",
2736
2736
"tracing-subscriber",
2737
2737
"url",
2738
+
"zstd",
2738
2739
]
2739
2740
2740
2741
[[package]]
+1
-1
Cargo.toml
+1
-1
Cargo.toml
···
19
19
log = "0.4.27"
20
20
serde = { version = "1.0.219", features = ["derive"] }
21
21
serde_json = "1.0.140"
22
-
rocketman = "0.1.1" # pyt the latest version here
22
+
rocketman = "0.2.0"
23
23
tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
24
24
dotenv = "0.15.0"
25
25
thiserror = "1.0.69"
+2
-1
src/db.rs
+2
-1
src/db.rs
···
177
177
) -> Result<Vec<Self>, async_sqlite::Error> {
178
178
Ok(pool
179
179
.conn(move |conn| {
180
-
let mut stmt = conn.prepare("SELECT * FROM status ORDER BY indexedAt DESC")?;
180
+
let mut stmt =
181
+
conn.prepare("SELECT * FROM status ORDER BY indexedAt DESC LIMIT 10")?;
181
182
let status_iter = stmt
182
183
.query_map([], |row| Ok(Self::map_from_row(row).unwrap()))
183
184
.unwrap();