diff --git a/synapse/storage/databases/main/cache.py b/synapse/storage/databases/main/cache.py
index 18905e07b6..2fbd389c71 100644
--- a/synapse/storage/databases/main/cache.py
+++ b/synapse/storage/databases/main/cache.py
@@ -584,19 +584,6 @@ class CacheInvalidationWorkerStore(SQLBaseStore):
else:
return 0
- async def stream_introspection_token_invalidation(
- self, key: Tuple[Optional[str]]
- ) -> None:
- """
- Stream an invalidation request for the introspection token cache to workers
-
- Args:
- key: token_id of the introspection token to remove from the cache
- """
- await self.send_invalidation_to_replication(
- "introspection_token_invalidation", key
- )
-
@wrap_as_background_process("clean_up_old_cache_invalidations")
async def _clean_up_cache_invalidation_wrapper(self) -> None:
"""
diff --git a/synapse/storage/databases/main/devices.py b/synapse/storage/databases/main/devices.py
index 7208fc8b33..324fdfa892 100644
--- a/synapse/storage/databases/main/devices.py
+++ b/synapse/storage/databases/main/devices.py
@@ -33,7 +33,6 @@ from typing_extensions import Literal
from synapse.api.constants import EduTypes
from synapse.api.errors import Codes, StoreError
-from synapse.config.homeserver import HomeServerConfig
from synapse.logging.opentracing import (
get_active_span_text_map,
set_tag,
@@ -1664,7 +1663,6 @@ class DeviceStore(DeviceWorkerStore, DeviceBackgroundUpdateStore):
self.device_id_exists_cache: LruCache[
Tuple[str, str], Literal[True]
] = LruCache(cache_name="device_id_exists", max_size=10000)
- self.config: HomeServerConfig = hs.config
async def store_device(
self,
@@ -1778,13 +1776,6 @@ class DeviceStore(DeviceWorkerStore, DeviceBackgroundUpdateStore):
for device_id in device_ids:
self.device_id_exists_cache.invalidate((user_id, device_id))
- # TODO: don't nuke the entire cache once there is a way to associate
- # device_id -> introspection_token
- if self.config.experimental.msc3861.enabled:
- # mypy ignore - the token cache is defined on MSC3861DelegatedAuth
- self.auth._token_cache.invalidate_all() # type: ignore[attr-defined]
- await self.stream_introspection_token_invalidation((None,))
-
async def update_device(
self, user_id: str, device_id: str, new_display_name: Optional[str] = None
) -> None:
|
