fix: added custom PubSub and TimedCache

Author: nkhaldi

.flake8

@@ -3,4 +3,6 @@
 exclude =
     migrations
 
-max-line-length = 120
+max-line-length = 120
+
+ignore = D

multifilter.py

@@ -0,0 +1,67 @@
+"""Cunsom PubSub implementation."""
+
+
+class PubSub:
+    """Custom PubSub class."""
+
+    def __init__(self):
+        """Initialize subscribers dictionary."""
+        self.subscribers = {}
+
+    def subscribe(self, event_name):
+        """Subscribe to event_name."""
+
+        def decorator(func):
+            """Add function to subscribers list."""
+            if event_name not in self.subscribers:
+                self.subscribers[event_name] = []
+            self.subscribers[event_name].append(func)
+
+            return func
+
+        return decorator
+
+    def emit(self, event_name, data):
+        """Emit event_name with data."""
+        if event_name in self.subscribers:
+            for func in self.subscribers[event_name]:
+                func(data)
+
+    def off(self, event_name, func):
+        """Unsubscribe from event_name."""
+        if event_name in self.subscribers:
+            self.subscribers[event_name] = [f for f in self.subscribers[event_name] if f != func]
+
+
+# Пример использования
+pubSub = PubSub()
+
+
+@pubSub.subscribe("event1")
+def log1(data):
+    """Test function 1."""
+    print("event1", data)
+
+
+@pubSub.subscribe("event2")
+def log2(data):
+    """Test function 2."""
+    print("event2", data)
+
+
+@pubSub.subscribe("event1")
+def log3(data):
+    """Test function 3."""
+    print("event1-1111", data)
+
+
+# Эмитим событие до отписки
+pubSub.emit("event1", "hello")
+pubSub.emit("event2", "hello")
+
+# Отписываем log3 от event1
+pubSub.off("event1", log3)
+
+# Эмитим событие после отписки
+pubSub.emit("event1", "hello again")
+pubSub.emit("event2", "hello again")

my_PubSub.py

@@ -0,0 +1,64 @@
+"""Custom implementation of a timed cache."""
+
+import threading
+import time
+
+
+class TimedCache:
+    """Timed cache class."""
+
+    def __init__(self):
+        """Initialize cache and lock."""
+        self.cache = {}
+        self.lock = threading.Lock()
+
+    def set(self, key, value, ttl):
+        """Set value with TTL."""
+        expiration_time = time.time() + ttl
+        with self.lock:
+            self.cache[key] = (value, expiration_time)
+        # Запускаем поток для удаления элемента по истечении времени
+        threading.Thread(target=self._remove_after_ttl, args=(key, ttl)).start()
+
+    def get(self, key):
+        """Get value by key."""
+        with self.lock:
+            if key in self.cache:
+                value, expiration_time = self.cache[key]
+                if time.time() < expiration_time:
+                    return value
+                else:
+                    del self.cache[key]
+                    return None
+            return None
+
+    def _remove_after_ttl(self, key, ttl):
+        """Remove key after TTL."""
+        time.sleep(ttl)
+        with self.lock:
+            if key in self.cache:
+                value, expiration_time = self.cache[key]
+                if time.time() >= expiration_time:
+                    del self.cache[key]
+
+    def __contains__(self, key):
+        """Check if key is in cache and not expired."""
+        with self.lock:
+            if key in self.cache:
+                _, expiration_time = self.cache[key]
+                if time.time() < expiration_time:
+                    return True
+                else:
+                    del self.cache[key]
+            return False
+
+
+# Пример использования
+cache = TimedCache()
+cache.set("foo", "bar", 5)  # Устанавливаем значение с TTL 5 секунд
+
+print(cache.get("foo"))  # Вывод: bar
+
+time.sleep(6)
+
+print(cache.get("foo"))  # Вывод: None (значение истекло)