Merge pull request #389 from helium/madninja/unique_entropy

Use the solana block hash as source of data

poc_entropy/Cargo.toml

@@ -14,7 +14,7 @@ thiserror = {workspace = true}
 serde =  {workspace = true}
 serde_json = {workspace = true}
 base64 = {workspace = true}
-sha2 = {workspace = true}
+blake3 = {workspace = true}
 http = {workspace = true}
 tonic = {workspace = true}
 hyper = "0"

poc_entropy/src/entropy_generator.rs

@@ -151,18 +151,25 @@ impl EntropyGenerator {
         &mut self,
         file_sink: &file_sink::FileSinkClient,
     ) -> anyhow::Result<()> {
-        match Self::get_entropy(&self.client).await {
-            Ok(data) => self.sender.send_modify(|entry| {
-                entry.timestamp = Utc::now().timestamp();
-                entry.data = data;
-                entry.version = ENTROPY_VERSION;
-            }),
+        let source_data = match Self::get_entropy(&self.client).await {
+            Ok(data) => data,
             Err(err) => {
                 tracing::warn!("failed to get entropy: {err:?}");
-                self.sender
-                    .send_modify(|entry| entry.timestamp = Utc::now().timestamp());
+                (*self.receiver.borrow().data).to_vec()
             }
-        }
+        };
+        let timestamp = Utc::now().timestamp();
+
+        let mut hasher = blake3::Hasher::new();
+        hasher.update(&timestamp.to_le_bytes());
+        hasher.update(&source_data);
+        let data = hasher.finalize().as_bytes().to_vec();
+
+        self.sender.send_modify(|entry| {
+            entry.timestamp = timestamp;
+            entry.data = data;
+        });
+
         let entropy = &*self.receiver.borrow();
         tracing::info!(
             "using entropy: {} at: {}",