1 files changed, 142 insertions, 1 deletions
diff --git a/src/hydrilla/proxy/store.py b/src/hydrilla/proxy/store.py
index 72852d8..4978b65 100644
--- a/src/hydrilla/proxy/store.py
+++ b/src/hydrilla/proxy/store.py
@@ -29,12 +29,153 @@
 # Enable using with Python 3.7.
 from __future__ import annotations
 
+import threading
 import dataclasses as dc
+import typing as t
 
 from pathlib import Path
+from enum import Enum
+
+from immutables import Map
+
+from .. url_patterns import parse_pattern
+from .. import versions
+from . import state
+
+
+@dc.dataclass(frozen=True, eq=False)
+class StoredItemRef(state.ItemRef):
+    item_id: int
+
+    def __eq__(self, other: object) -> bool:
+        return isinstance(other, StoredItemRef) and \
+            self.item_id == other.item_id
+
+    def __hash__(self) -> int:
+        return hash(self.item_id)
+
+    def _id(self) -> str:
+        return str(self.item_id)
+
+
+@dc.dataclass(frozen=True, eq=False)
+class StoredPayloadRef(state.PayloadRef):
+    payload_id: int
+
+    def __eq__(self, other: object) -> bool:
+        return isinstance(other, StoredPayloadRef) and \
+            self.payload_id == other.payload_id
+
+    def __hash__(self) -> int:
+        return hash(self.payload_id)
+
+    def _id(self) -> str:
+        return str(self.payload_id)
+
+
+# class ItemStoredData:
+#     """...."""
+#     def __init__(
+#             self,
+#             item_id:       int
+#             ty#pe:          ItemType
+#             repository_id: int
+#             version:       str
+#             identifier:    str
+#             orphan:        bool
+#             installed:     bool
+#             enabled:       EnabledStatus
+#     ) -> None:
+#         """...."""
+#         self.item_id       = item_id
+#         self.type          = ItemType(type)
+#         self.repository_id = repository_id
+#         self.version       = parse
+#             identifier:    str
+#             orphan:        bool
+#             installed:     bool
+#             enabled:       EnabledStatus
+
 
 @dc.dataclass
 class HaketiloStore:
     """...."""
     store_dir: Path
-    # TODO: implement
+
+    lock: threading.RLock = dc.field(default_factory=threading.RLock)
+
+    # def load_all_resources(self) -> t.Sequence[item_infos.ResourceInfo]:
+    #     """...."""
+    #     # TODO: implement
+    #     with self.lock:
+    #         return []
+
+    def load_installed_mappings_data(self) \
+        -> t.Mapping[state.MappingRef, state.EnabledStatus]:
+        """...."""
+        # TODO: implement
+        with self.lock:
+            dummy_item_ref = StoredItemRef(
+                item_id    = 47,
+                identifier = 'somemapping',
+                version    = versions.parse_normalize_version('1.2.3'),
+                repository = 'somerepo',
+                orphan     = False
+            )
+
+            return Map({
+                state.MappingRef(dummy_item_ref): state.EnabledStatus.ENABLED
+            })
+
+    def load_payloads_data(self) \
+        -> t.Mapping[state.MappingRef, t.Iterable[state.PayloadRef]]:
+        """...."""
+        # TODO: implement
+        with self.lock:
+            dummy_item_ref = StoredItemRef(
+                item_id    = 47,
+                identifier = 'somemapping',
+                version    = versions.parse_normalize_version('1.2.3'),
+                repository = 'somerepo',
+                orphan     = False
+            )
+
+            dummy_mapping_ref = state.MappingRef(dummy_item_ref)
+
+            payload_refs = []
+            for parsed_pattern in parse_pattern('http*://example.com/a/***'):
+                dummy_payload_ref = StoredPayloadRef(
+                    payload_id  = 22,
+                    mapping_ref = dummy_mapping_ref,
+                    pattern     = parsed_pattern
+                )
+
+                payload_refs.append(dummy_payload_ref)
+
+            return Map({dummy_mapping_ref: payload_refs})
+
+    def load_file_data(
+            self,
+            payload_ref:         state.PayloadRef,
+            resource_identifier: str,
+            file_path:           t.Sequence[str]
+    ) -> t.Optional[state.FileData]:
+        # TODO: implement
+        with self.lock:
+            return None
+
+    def load_global_settings(self) -> state.HaketiloGlobalSettings:
+        """...."""
+        # TODO: implement
+        with self.lock:
+            return state.HaketiloGlobalSettings(
+                state.MappingApplicationMode.WHEN_ENABLED,
+                False
+            )
+
+    def write_global_settings(self, settings: state.HaketiloGlobalSettings) \
+        -> None:
+        """...."""
+        # TODO: implement
+        with self.lock:
+            pass