codeperl
diff --git a/‎localstack/services/plugins.py
Lines changed: 0 additions & 77 deletions b/‎localstack/services/plugins.py
Lines changed: 0 additions & 77 deletions
@@ -8,8 +8,6 @@
 from typing import Callable, Dict, List, Optional, Protocol, Tuple
 
 from plugin import Plugin, PluginLifecycleListener, PluginManager, PluginSpec
-from readerwriterlock import rwlock
-from werkzeug import Request
 
 from localstack import config
 from localstack.aws.skeleton import DispatchTable
@@ -29,81 +27,6 @@
 _default = object()  # sentinel object indicating a default value
 
 
-# ---------------------------
-# STATE SERIALIZER INTERFACE
-# ---------------------------
-
-
-class PersistenceContext:
-    state_dir: str
-    lock: rwlock.RWLockable
-
-    def __init__(self, state_dir: str = None, lock: rwlock.RWLockable = None):
-        # state dir (within DATA_DIR) of currently processed API in local file system
-        self.state_dir = state_dir
-        # read-write lock for concurrency control of incoming requests
-        self.lock = lock
-
-
-class StateSerializer(abc.ABC):
-    """A state serializer encapsulates the logic of persisting and loading service state to/from disk."""
-
-    @abc.abstractmethod
-    def restore_state(self, context: PersistenceContext):
-        """Restore state from the underlying persistence file"""
-        pass
-
-    @abc.abstractmethod
-    def update_state(self, context: PersistenceContext, request: Request):
-        """Update persistence state based on the incoming request"""
-        pass
-
-    @abc.abstractmethod
-    def is_write_request(self, request: Request) -> bool:
-        """Returns whether the given request is a write request that should trigger serialization"""
-        return False
-
-    def get_lock_for_request(self, request: Request) -> Optional[rwlock.Lockable]:
-        """Returns a lock (or None) that should be used to guard the given request, for concurrency control"""
-        return None
-
-    def get_context(self) -> PersistenceContext:
-        """Returns the current persistence context"""
-        return None
-
-
-class StateSerializerComposite(StateSerializer):
-    """Composite state serializer that delegates the requests to a list of underlying concrete serializers"""
-
-    def __init__(self, serializers: List[StateSerializer] = None):
-        self.serializers: List[StateSerializer] = serializers or []
-
-    def restore_state(self, context: PersistenceContext):
-        for serializer in self.serializers:
-            serializer.restore_state(context)
-
-    def update_state(self, context: PersistenceContext, request: Request):
-        for serializer in self.serializers:
-            serializer.update_state(context, request)
-
-    def is_write_request(self, request: Request) -> bool:
-        return any(ser.is_write_request(request) for ser in self.serializers)
-
-    def get_lock_for_request(self, request: Request) -> Optional[rwlock.Lockable]:
-        if self.serializers:
-            return self.serializers[0].get_lock_for_request(
-                request
-            )  # return lock from first serializer
-
-    def get_context(self) -> PersistenceContext:
-        if self.serializers:
-            return self.serializers[0].get_context()  # return context from first serializer
-
-
-# maps service names to serializers (TODO: to be encapsulated in ServicePlugin instances)
-SERIALIZERS: Dict[str, StateSerializer] = {}
-
-
 # -----------------
 # PLUGIN UTILITIES
 # -----------------