diff options
| author | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-10 12:34:28 +0000 |
|---|---|---|
| committer | DanConwayDev <DanConwayDev@protonmail.com> | 2025-12-10 12:34:28 +0000 |
| commit | b32772848f7325d4b3e1e15b05c5163df0b9671b (patch) | |
| tree | 50a47f996b0b60ba191eee1ea4faeb1b1b83ecaf /src/sync/relay_connection.rs | |
| parent | 5f9d3ca0db4ffc9088be0b9ac9558efe1a4da810 (diff) | |
sync: implement filter consolidation system
Diffstat (limited to 'src/sync/relay_connection.rs')
| -rw-r--r-- | src/sync/relay_connection.rs | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/sync/relay_connection.rs b/src/sync/relay_connection.rs index 6499c27..b0765e8 100644 --- a/src/sync/relay_connection.rs +++ b/src/sync/relay_connection.rs | |||
| @@ -213,4 +213,14 @@ impl RelayConnection { | |||
| 213 | self.client.disconnect().await; | 213 | self.client.disconnect().await; |
| 214 | tracing::debug!(relay = %self.url, "Disconnected from relay"); | 214 | tracing::debug!(relay = %self.url, "Disconnected from relay"); |
| 215 | } | 215 | } |
| 216 | |||
| 217 | /// Unsubscribe from all active subscriptions | ||
| 218 | /// | ||
| 219 | /// Used during consolidation to reset all subscriptions before rebuilding | ||
| 220 | /// with consolidated filters. This sends CLOSE messages for all active | ||
| 221 | /// subscriptions on the relay. | ||
| 222 | pub async fn unsubscribe_all(&self) { | ||
| 223 | self.client.unsubscribe_all().await; | ||
| 224 | tracing::debug!(relay = %self.url, "Unsubscribed from all subscriptions"); | ||
| 225 | } | ||
| 216 | } \ No newline at end of file | 226 | } \ No newline at end of file |