oppi.li / pdsfs

mount an atproto PDS repository as a FUSE filesystem oppi.li/posts/mounting_the_atmosphere/

fork atom

Watch live changes from the firehose #11

closed opened by

danabra.mov 3 months ago targeting main from danabra.mov/pdsfs: firehose

Vibecoded by Claude. I don't know Rust.

I think it works.

This includes https://tangled.org/@oppi.li/pdsfs/pulls/8 and https://tangled.org/@oppi.li/pdsfs/pulls/10, I guess I should've used stacks.

Labels

None yet.

Participants 1

AT URI

at://did:plc:fpruhuo22xkm5o7ttr2ktxdo/sh.tangled.repo.pull/3m34e5c724p22

+1 -1

1 changed file

Diff round #1

expand all

unified split

src

fs.rs

+1 -1

src/fs.rs

··· 473 let mut repos = self.repos.lock().unwrap(); 474 let repo = &mut repos[&did]; 475 if let Ok(Some(val)) = self.rt.block_on(repo.get_raw::<ipld_core::ipld::Ipld>(&key)) { 476 - reply.data(&serde_json::to_string(&val).unwrap().as_bytes()[offset as usize..]); 477 return; 478 } 479 } else {

··· 473 let mut repos = self.repos.lock().unwrap(); 474 let repo = &mut repos[&did]; 475 if let Ok(Some(val)) = self.rt.block_on(repo.get_raw::<ipld_core::ipld::Ipld>(&key)) { 476 + reply.data(&serde_json::to_string_pretty(&val).unwrap().as_bytes()[offset as usize..]); 477 return; 478 } 479 } else {

Submissions

danabra.mov submitted #1 3mo

interdiff

1 commit

expand

a31d79ef

pretty print json

danabra.mov 3 months ago

fml this is too hard

danabra.mov 3 months ago

let me just resubmit everything as a stack

closed without merging

danabra.mov submitted #0 3mo

diff

4 commits

expand

4bb72e43

show files as .json

e7ba090f

initialize tokio once

c9898260

disable cache

15b22fe2

watch firehose

danabra.mov 3 months ago

i guess "firehose" is inaccurate, the code just watches the pds. but whatever