Random keying

TicketsBot · Oct 26, 2024 · 771cfff · 771cfff
1 parent 9419818
commit 771cfff
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/event-stream/src/publisher.rs b/event-stream/src/publisher.rs
@@ -44,13 +44,11 @@ impl Publisher {
         })
     }
 
-    pub fn send(&self, ev: &event_forwarding::Event, guild_id: u64) -> Result<()> {
+    pub fn send(&self, ev: &event_forwarding::Event, _guild_id: u64) -> Result<()> {
         let marshalled = serde_json::to_vec(ev)?;
 
-        let key = guild_id.to_string();
-        let record = BaseRecord::to(&self.topic.as_str())
-            .payload(&marshalled)
-            .key(key.as_str());
+        let record: BaseRecord<'_, String, Vec<u8>> = BaseRecord::to(&self.topic.as_str())
+            .payload(&marshalled);
 
         let should_poll = self.since_last_poll.compare_exchange(POLL_INTERVAL, 0, Ordering::Relaxed, Ordering::Relaxed).is_ok();
         self.since_last_poll.fetch_add(1, Ordering::Relaxed);