Struct HashiverseClient 

pub struct HashiverseClient { /* private fields */ }

The top-level client API for participating in a hashiverse network.

HashiverseClient is what every external consumer — the server binary’s cache role, the WASM browser client, the Python wrapper, integration tests — builds on top of. It orchestrates all the subsystems the client side needs:

• a PeerTracker for Kademlia-style peer discovery and gossip,
• a LivePostBundleManager / LivePostBundleFeedbackManager pair for fetching post bundles and their feedback from the network (with on-disk caching),
• a SingleTimeline / MultipleTimeline pair for recursive bucket traversal when reading a feed,
• a MetaPostManager for the user’s profile / follow list / settings,
• a RecentPostsPen so freshly-authored posts appear in the user’s own timelines immediately,
• a ClientId / KeyLocker pair for the signed identity used on every outbound action.

All external dependencies — clock, network, PoW — are carried through a single RuntimeServices, which is what makes the same code run inside the in-memory integration test harness, on a native server, and in a browser Web Worker without touching any of the high-level logic above.

Construct one via HashiverseClient::new and keep a single instance per logged-in account; the struct is cheap to share (Arc<Self>) and its internal state uses RwLocks for concurrent access.

Implementations

impl HashiverseClient

pub async fn new( runtime_services: Arc<RuntimeServices>, client_storage: Arc<dyn ClientStorage>, key_locker: Arc<dyn KeyLocker>, _args: Args, ) -> Result<Self>

pub fn client_id(&self) -> &ClientId

pub async fn client_storage_reset(&self) -> Result<()>

pub async fn submit_post( &self, post: &str, ) -> Result<(Vec<SubmitPostCommitTokenV1>, (EncodedPostV1, Bytes)), Error>

pub fn meta_post_manager(&self) -> &MetaPostManager

pub async fn submit_meta_post(&self) -> Result<()>

pub async fn ensure_meta_post_in_current_bucket(&self) -> Result<()>

pub async fn submit_feedback( &self, bucket_location: BucketLocation, post_id: Id, feedback_type: u8, ) -> Result<()>

pub async fn get_post( &self, bucket_location: BucketLocation, post_id: &Id, ) -> Result<(BucketLocation, EncodedPostV1, Bytes)>

pub async fn get_post_feedbacks( &self, bucket_location: BucketLocation, post_id: Id, ) -> Result<[u64; 256]>

pub async fn single_timeline_reset(&self) -> Result<()>

pub async fn single_timeline_lock( &self, bucket_type: BucketType, base_id: &Id, ) -> Result<RwLockWriteGuard<'_, Option<SingleTimeline>>>

pub async fn single_timeline_get_more( &self, bucket_type: BucketType, base_id: &Id, ) -> Result<(Vec<(BucketLocation, EncodedPostV1, Bytes)>, TimeMillis)>

pub async fn multiple_timeline_reset(&self) -> Result<()>

pub async fn multiple_timeline_lock( &self, bucket_type: BucketType, base_ids: &Vec<Id>, ) -> Result<RwLockWriteGuard<'_, Option<MultipleTimeline>>>

pub async fn multiple_timeline_get_more( &self, bucket_type: BucketType, base_ids: &Vec<Id>, ) -> Result<(Vec<(BucketLocation, EncodedPostV1, Bytes)>, TimeMillis)>

pub async fn fetch_url_preview( &self, url: &str, ) -> Result<FetchUrlPreviewResponseV1>

pub async fn fetch_trending_hashtags( &self, limit: u16, ) -> Result<TrendingHashtagsFetchResponseV1>

pub async fn dispatch_command(&self, command: &String) -> Result<(), Error>