hashiverse-lib 1.0.8

Core protocol library for Hashiverse — your open-source decentralized X/Twitter replacement.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112

//! # Test stub [`PostBundleFeedbackManager`]
//!
//! A do-nothing implementation of
//! [`crate::client::post_bundle::post_bundle_feedback_manager::PostBundleFeedbackManager`]
//! that always returns a "not implemented" error. Used by test scenarios that exercise
//! timeline or posting logic without caring about feedback, so those tests don't need to
//! stand up a full live feedback stack.

use crate::client::post_bundle::post_bundle_feedback_manager::PostBundleFeedbackManager;
use crate::protocol::posting::encoded_post_bundle_feedback::EncodedPostBundleFeedbackV1;
use crate::tools::buckets::BucketLocation;
use crate::tools::time::TimeMillis;

#[derive(Default)]
pub struct StubPostBundleFeedbackManager {
}


#[cfg_attr(target_arch = "wasm32", async_trait::async_trait(?Send))]
#[cfg_attr(not(target_arch = "wasm32"), async_trait::async_trait)]
impl PostBundleFeedbackManager for StubPostBundleFeedbackManager {
    async fn get_post_bundle_feedback(&self, _bucket_location: BucketLocation, _time_millis: TimeMillis) -> anyhow::Result<EncodedPostBundleFeedbackV1> {
        anyhow::bail!("Not implemented");
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use bytes::{Bytes, BytesMut};
    use crate::protocol::posting::encoded_post_feedback::{EncodedPostFeedbackV1, EncodedPostFeedbackViewV1};
    use crate::tools::buckets::{BucketLocation, BucketType, BUCKET_DURATIONS};
    use crate::tools::time::TimeMillis;
    use crate::tools::types::{Id, Pow, Salt};

    fn make_bucket_location() -> BucketLocation {
        BucketLocation::new(BucketType::User, Id::random(), BUCKET_DURATIONS[0], TimeMillis(1_000_000)).unwrap()
    }

    #[tokio::test]
    async fn stub_always_returns_error() {
        let stub = StubPostBundleFeedbackManager::default();
        let result = stub.get_post_bundle_feedback(make_bucket_location(), TimeMillis(1_000_000)).await;
        assert!(result.is_err(), "stub should always return an error");
        assert!(result.unwrap_err().to_string().contains("Not implemented"));
    }

    #[test]
    fn feedback_roundtrip_encoding() {
        let post_id = Id::random();
        let feedback = EncodedPostFeedbackV1 {
            post_id,
            feedback_type: 1,
            salt: Salt::random(),
            pow: Pow(42),
        };

        let mut buf = BytesMut::new();
        feedback.append_encode_to_bytes(&mut buf).unwrap();
        let bytes = buf.freeze();

        let view = EncodedPostFeedbackViewV1::iter(&bytes)
            .next()
            .expect("should yield one entry")
            .expect("entry should decode without error");

        assert_eq!(view.post_id_bytes(), post_id.as_ref());
        assert_eq!(view.feedback_type(), 1);
        assert_eq!(view.pow(), Pow(42));
    }

    #[test]
    fn feedback_view_iter_multiple_entries() {
        let post_ids: Vec<Id> = (0..3).map(|_| Id::random()).collect();
        let mut combined = BytesMut::new();
        for (i, &post_id) in post_ids.iter().enumerate() {
            let feedback = EncodedPostFeedbackV1 {
                post_id,
                feedback_type: (i as u8) + 1,
                salt: Salt::random(),
                pow: Pow((i as u8) * 10),
            };
            feedback.append_encode_to_bytes(&mut combined).unwrap();
        }
        let bytes: Bytes = combined.freeze();

        let views: Vec<_> = EncodedPostFeedbackViewV1::iter(&bytes)
            .collect::<Result<Vec<_>, _>>()
            .expect("all entries should decode");

        assert_eq!(views.len(), 3);
        for (i, view) in views.iter().enumerate() {
            assert_eq!(view.post_id_bytes(), post_ids[i].as_ref());
            assert_eq!(view.feedback_type(), (i as u8) + 1);
            assert_eq!(view.pow(), Pow((i as u8) * 10));
        }
    }

    #[test]
    fn feedback_pow_comparison() {
        // Feedback merge rule: for a given (post_id, feedback_type), keep the highest PoW.
        // Verify the Pow type supports the comparisons needed for that rule.
        assert!(Pow(10) > Pow(5));
        assert!(Pow(0) < Pow(1));
        assert_eq!(Pow(7), Pow(7));

        // Verify that the "keep max" logic works with standard iterator helpers
        let pows = vec![Pow(3), Pow(15), Pow(7)];
        let strongest = pows.into_iter().max().unwrap();
        assert_eq!(strongest, Pow(15));
    }
}