Compare commits
2 Commits
0.3.0.post
...
0.3.0.post
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7e6aacc82f | ||
|
|
cb4872d057 |
@@ -17,7 +17,7 @@ import sys
|
||||
from tap import Tap
|
||||
from loguru import logger
|
||||
|
||||
from . import __Summuary__, __Name__,__version__
|
||||
from . import __Summuary__, __Name__, __version__
|
||||
from . import datasync
|
||||
from . import exceptions
|
||||
from . import compressors
|
||||
@@ -37,7 +37,10 @@ class dabdatasync_args_service_abstract(Tap):
|
||||
service: Optional[str] = None
|
||||
|
||||
def configure(self) -> None:
|
||||
self.add_argument("--service",help=f"specify the service to use (availables: {datasync.DataSync_Factory.get_list()}, first found in priority if not set)")
|
||||
self.add_argument(
|
||||
"--service",
|
||||
help=f"specify the service to use (availables: {datasync.DataSync_Factory.get_list()}, first found in priority if not set)",
|
||||
)
|
||||
|
||||
|
||||
class dabdatasync_args_service_compress_abstract(dabdatasync_args_service_abstract):
|
||||
@@ -47,7 +50,10 @@ class dabdatasync_args_service_compress_abstract(dabdatasync_args_service_abstra
|
||||
|
||||
def configure(self) -> None:
|
||||
super().configure()
|
||||
self.add_argument("--compressor",help=f"specify the compressor method (availables: {compressors.DataSync_Compressors.get_list()}, .tar.gz if not set)")
|
||||
self.add_argument(
|
||||
"--compressor",
|
||||
help=f"specify the compressor method (availables: {compressors.DataSync_Compressors.get_list()}, .tar.gz if not set)",
|
||||
)
|
||||
|
||||
|
||||
class dabdatasync_args_PullData(dabdatasync_args_service_compress_abstract):
|
||||
@@ -65,14 +71,14 @@ class dabdatasync_args_WipeRemoteData(dabdatasync_args_service_abstract):
|
||||
class dabdatasync_args(Tap):
|
||||
"""Main CLI arg parser"""
|
||||
|
||||
verbosity: int = 0
|
||||
help: bool = False
|
||||
version: bool = False
|
||||
|
||||
verbosity: int = 0
|
||||
help: bool = False
|
||||
version: bool = False
|
||||
|
||||
def configure(self) -> None:
|
||||
self.add_argument("--version", action="store_true", help="show version string")
|
||||
self.add_argument("-h", "--help", action="store_true", help="full help")
|
||||
self.add_argument("-v", "--verbosity", action="count", help="increase output verbosity")
|
||||
self.add_argument("--version", action="store_true", help="show version string")
|
||||
self.add_argument("-h", "--help", action="store_true", help="full help")
|
||||
self.add_argument("-v", "--verbosity", action="count", help="increase output verbosity")
|
||||
|
||||
self.add_subparsers(dest="command", help="command type")
|
||||
self.add_subparser("GetServices", dabdatasync_args_GetServices, help="Get registered services list")
|
||||
@@ -91,21 +97,21 @@ def fct_main(i_args: list[str]) -> None: # pylint: disable=too-many-branches,to
|
||||
parser: dabdatasync_args = dabdatasync_args(prog=__Name__, description=__Summuary__)
|
||||
|
||||
args: dabdatasync_args = parser.parse_args(i_args)
|
||||
|
||||
|
||||
if args.help or args.version:
|
||||
print(f"{__Name__} version {__version__}")
|
||||
|
||||
|
||||
if args.help:
|
||||
print(parser.format_help())
|
||||
|
||||
for name, subparser in parser._subparsers.choices.items(): # type: ignore[union-attr]
|
||||
|
||||
for name, subparser in parser._subparsers.choices.items(): # type: ignore[union-attr]
|
||||
print("=========================")
|
||||
print(f"Subparser {{{name}}}")
|
||||
print(subparser.format_help())
|
||||
|
||||
|
||||
if args.help or args.version:
|
||||
exit(0)
|
||||
|
||||
|
||||
logger.remove()
|
||||
if args.verbosity:
|
||||
if args.verbosity == 1:
|
||||
|
||||
@@ -15,7 +15,7 @@ import warnings
|
||||
|
||||
try: # pragma: no cover
|
||||
__version__ = version("dabdatasync")
|
||||
except PackageNotFoundError: # pragma: no cover
|
||||
except PackageNotFoundError: # pragma: no cover
|
||||
warnings.warn("can not read __version__, assuming local test context, setting it to ?.?.?")
|
||||
__version__ = "?.?.?"
|
||||
|
||||
|
||||
@@ -75,11 +75,12 @@ class DataSync_Compressors:
|
||||
if len(found) == 1:
|
||||
return found[0]
|
||||
raise DataSyncException_TooManyCompressorFound()
|
||||
|
||||
|
||||
@classmethod
|
||||
def get_list(cls) -> list[str]:
|
||||
"""return the available compressor name list"""
|
||||
return [ _.compressor_name for _ in cls._availables]
|
||||
return [_.compressor_name for _ in cls._availables]
|
||||
|
||||
|
||||
@DataSync_Compressors.register
|
||||
class DataSync_Compressor__tar_gz(A_DataSync_Compressor):
|
||||
|
||||
@@ -183,4 +183,4 @@ class DataSync_Factory:
|
||||
@classmethod
|
||||
def get_list(cls) -> list[str]:
|
||||
"""return the available DataSync concrete class name list"""
|
||||
return [ _.service_name for _ in cls.ar_cls_DataSync]
|
||||
return [_.service_name for _ in cls.ar_cls_DataSync]
|
||||
|
||||
@@ -4,4 +4,4 @@
|
||||
# Creative Commons Attribution-NonCommercial-ShareAlike 4.0 International Unported License.
|
||||
#
|
||||
# You should have received a copy of the license along with this
|
||||
# work. If not, see <https://creativecommons.org/licenses/by-nc-sa/4.0/>.
|
||||
# work. If not, see <https://creativecommons.org/licenses/by-nc-sa/4.0/>.
|
||||
|
||||
@@ -35,32 +35,46 @@ class TestDabDataSync(unittest.TestCase):
|
||||
shutil.rmtree(testdir_path / "test_data2", ignore_errors=True)
|
||||
shutil.copytree(testdir_path / "test_data_origin", testdir_path / "test_data")
|
||||
shutil.copytree(testdir_path / "test_data_origin", testdir_path / "test_data2")
|
||||
|
||||
nextcloud_pwd=""
|
||||
if 'nextcloud_pwd' in os.environ:
|
||||
|
||||
nextcloud_pwd = ""
|
||||
if "nextcloud_pwd" in os.environ:
|
||||
nextcloud_pwd = os.environ.get("nextcloud_pwd")
|
||||
elif os.path.isfile(testdir_path / "nextcloud_pwd.mdp"):
|
||||
with open(testdir_path / "nextcloud_pwd.mdp","rt",encoding="utf-8") as pwd_file:
|
||||
nextcloud_pwd=pwd_file.read()
|
||||
with open(testdir_path / "nextcloud_pwd.mdp", "rt", encoding="utf-8") as pwd_file:
|
||||
nextcloud_pwd = pwd_file.read()
|
||||
else:
|
||||
raise RuntimeError("NextCloud pwd file not found")
|
||||
|
||||
files = glob.glob(str(testdir_path / "*.json"))
|
||||
files += glob.glob(str(testdir_path /"*.json"))
|
||||
files += glob.glob(str(testdir_path / "*.json"))
|
||||
for file in files:
|
||||
with open(file) as f:
|
||||
data = json.load(f)
|
||||
data = json.load(f)
|
||||
try:
|
||||
data["Args"]["FSSync_NextCloud_Password"]["value"] = nextcloud_pwd
|
||||
except Exception:
|
||||
pass
|
||||
os.remove(file)
|
||||
with open(file, 'w') as f:
|
||||
with open(file, "w") as f:
|
||||
json.dump(data, f, sort_keys=True, indent=4)
|
||||
|
||||
|
||||
def tearDown(self) -> None:
|
||||
shutil.rmtree(testdir_path / "test_data", ignore_errors=True)
|
||||
shutil.rmtree(testdir_path / "test_data2", ignore_errors=True)
|
||||
|
||||
files = glob.glob(str(testdir_path / "*.json"))
|
||||
files += glob.glob(str(testdir_path / "*.json"))
|
||||
for file in files:
|
||||
with open(file) as f:
|
||||
data = json.load(f)
|
||||
try:
|
||||
data["Args"]["FSSync_NextCloud_Password"]["value"] = ""
|
||||
except Exception:
|
||||
pass
|
||||
os.remove(file)
|
||||
with open(file, "w") as f:
|
||||
json.dump(data, f, sort_keys=True, indent=4)
|
||||
|
||||
def test_version(self):
|
||||
self.assertNotEqual(dabdatasync.__version__, "?.?.?")
|
||||
|
||||
|
||||
@@ -239,7 +239,7 @@
|
||||
},
|
||||
"FSSync_NextCloud_Password": {
|
||||
"type": "STRING",
|
||||
"value": "F3P8m-nQHik-NSmb2-mnFEF-s85RE"
|
||||
"value": ""
|
||||
},
|
||||
"FSSync_NextCloud_Path": {
|
||||
"type": "STRING",
|
||||
|
||||
@@ -11,7 +11,7 @@
|
||||
},
|
||||
"FSSync_NextCloud_Password": {
|
||||
"type": "STRING",
|
||||
"value": "F3P8m-nQHik-NSmb2-mnFEF-s85RE"
|
||||
"value": ""
|
||||
},
|
||||
"FSSync_NextCloud_Path": {
|
||||
"type": "STRING",
|
||||
|
||||
Reference in New Issue
Block a user