commit 33aa0836f2606644c416ca7d2d908722716f8844
parent 86e1f8f763e85b6678de9ccea13d502f0df95496
Author: Carlosokumu <carlosokumu254@gmail.com>
Date: Wed, 5 Nov 2025 21:45:29 +0300
chore: rename name to key for clarity
Diffstat:
3 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/ungana/store/base_store.py b/ungana/store/base_store.py
@@ -4,9 +4,9 @@ from typing import Union
class UnganaBaseStore(ABC):
@abstractmethod
- def put(self, base_uri: str, name: str, data: Union[bytes, str]) -> str:
+ def put(self, base_uri: str, key: str, data: Union[bytes, str]) -> str:
pass
@abstractmethod
- def get(self, base_uri: str, name: str) -> bytes:
+ def get(self, base_uri: str, key: str) -> bytes:
pass
diff --git a/ungana/store/fs_store.py b/ungana/store/fs_store.py
@@ -9,17 +9,17 @@ class UnganaFSStore(UnganaBaseStore):
path = parsed.path if parsed.scheme else uri
return Path(path).expanduser().resolve()
- def put(self, base_uri: str, name: str, data: bytes) -> str:
+ def put(self, base_uri: str, key: str, data: bytes) -> str:
base_path = self._resolve_base_path(base_uri)
- target = base_path.joinpath(name)
+ target = base_path.joinpath(key)
target.parent.mkdir(parents=True, exist_ok=True)
with open(target, "wb") as f:
f.write(data)
return f"file://{target}"
- def get(self, base_uri: str, name: str) -> bytes:
+ def get(self, base_uri: str, key: str) -> bytes:
base_path = self._resolve_base_path(base_uri)
- target = base_path.joinpath(name)
+ target = base_path.joinpath(key)
if not target.exists():
raise FileNotFoundError(f"{target} does not exist")
return target.read_bytes()
diff --git a/ungana/store/wala_store.py b/ungana/store/wala_store.py
@@ -7,7 +7,7 @@ from .base_store import UnganaBaseStore
class UnganaWalaStore(UnganaBaseStore):
- def put(self, base_url: str, name: str, data: bytes) -> str:
+ def put(self, base_url: str, key: str, data: bytes) -> str:
parsed = urlparse(base_url)
if not parsed.scheme.startswith("http"):
raise ValueError(f"Invalid Wala URL: {base_url}")
@@ -16,11 +16,11 @@ class UnganaWalaStore(UnganaBaseStore):
digest = resp.text.strip()
return urljoin(base_url.rstrip("/") + "/", digest)
- def get(self, base_url: str, name: str) -> bytes:
+ def get(self, base_url: str, key: str) -> bytes:
parsed = urlparse(base_url)
if not parsed.scheme.startswith("http"):
raise ValueError(f"Invalid Wala URL: {base_url}")
- target_url = urljoin(base_url.rstrip("/") + "/", name)
+ target_url = urljoin(base_url.rstrip("/") + "/", key)
resp = requests.get(target_url, timeout=10)
resp.raise_for_status()
return resp.content