From c202f90ab918bf35c9fec50f7c8e44384e8030a3 Mon Sep 17 00:00:00 2001 From: dawn <90008@klbr.net> Date: Sat, 27 Jun 2026 21:35:05 +0000 Subject: [PATCH] [db] include port in firehose cursor key to avoid collisions --- src/db/keys/v1.rs | 8 +++++++- 1 file(s) changed, 7 insertion(s)(+), 1 deletion(s)(-) diff --git a/src/db/keys/v1.rs b/src/db/keys/v1.rs --- a/src/db/keys/v1.rs +++ b/src/db/keys/v1.rs @@ -10,5 +10,11 @@ } pub fn firehose_cursor_key_from_url(url: &Url) -> Vec { - firehose_cursor_key(url.host_str().unwrap_or("")) + let host = url.host_str().unwrap_or(""); + let key = if let Some(port) = url.port() { + format!("{host}:{port}") + } else { + host.to_string() + }; + firehose_cursor_key(&key) } -- tangled.sh