diff --git a/tests/__ini__.py b/dashboard/__init__.py similarity index 100% rename from tests/__ini__.py rename to dashboard/__init__.py diff --git a/dashboard/libs/flux/__init__.py b/dashboard/libs/flux/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/dashboard/libs/fs_schema.py b/dashboard/libs/fs_schema.py deleted file mode 100644 index 4836858..0000000 --- a/dashboard/libs/fs_schema.py +++ /dev/null @@ -1,35 +0,0 @@ -from .schema import AbstractSchema -from pathlib import Path - -class FSSchema(AbstractSchema): - def __init__(self, basepath, metadata_engine=None): - self.basepath = basepath - self._metadata_engine = metadata_engine - - def ls(self, dir, only_files=True): - dirpath = Path(dir) - if only_files: - return [f for f in dirpath.iterdir() if f.is_dir()] - return [f for f in dirpath.iterdir()] - - def tables(self, dir, only_files=True): - dirpath = Path(dir) - if only_files: - return [f for f in dirpath.iterdir() if f.is_dir()] - return [f for f in dirpath.iterdir()] - - def info(self, path): - path = Path(path) - pass - - def read(self, path): - path = Path(path) - pass - - def write(self, path, content): - path = Path(path) - pass - - def delete(self, path): - path = Path(path) - pass diff --git a/dashboard/libs/repository/fs_repository.py b/dashboard/libs/repository/fs_repository.py index 3c4eee8..c74ac51 100644 --- a/dashboard/libs/repository/fs_repository.py +++ b/dashboard/libs/repository/fs_repository.py @@ -55,7 +55,7 @@ class FSRepository(AbstractRepository): raise ValueError("Can't open the table") - def write(self, table:str, content, schema:str='.'): + def write(self, content, table:str, schema:str='.'): table_path = self.build_table_path(table, schema) pass diff --git a/dashboard/libs/repository/repository.py b/dashboard/libs/repository/repository.py index 3605de7..031e510 100644 --- a/dashboard/libs/repository/repository.py +++ b/dashboard/libs/repository/repository.py @@ -1,4 +1,5 @@ import abc + from .metadata import AbstractMetadataEngine @@ -6,31 +7,31 @@ class AbstractRepository(abc.ABC): metadata_engine = AbstractMetadataEngine @abc.abstractmethod - def schemas(): - """ List schemas """ + def schemas(self) -> list[str]: + """List schemas""" raise NotImplementedError @abc.abstractmethod - def tables(schema): - """ List table in schema""" + def tables(self, schema) -> list[str]: + """List table in schema""" raise NotImplementedError @abc.abstractmethod - def info(self, path): - """ Get infos about a file""" + def infos(self, table: str, schema: str) -> dict[str, str]: + """Get infos about the table""" raise NotImplementedError @abc.abstractmethod - def read(self, path): - """ Get content of a file""" + def read(self, table: str, schema: str): + """Get content of the table""" raise NotImplementedError @abc.abstractmethod - def write(self, path, content): - """ Write content into the file""" + def write(self, content, table: str, schema: str): + """Write content into the table""" raise NotImplementedError @abc.abstractmethod - def delete(self, path): - """ Delete the file """ + def delete_table(self, table: str, schema: str): + """Delete the table""" raise NotImplementedError diff --git a/tests/__init__.py b/tests/__init__.py new file mode 100644 index 0000000..e69de29