📌 ISSUE-#35: Updated settings

Author: FernandoCelmer

.gitignore

@@ -175,6 +175,5 @@ cython_debug/
 
 
 # Dotflow
-.xpto
 .storage
-tests.py
+.dotflow-io

dotflow/__init__.py

@@ -3,7 +3,7 @@
 __version__ = "0.7.0"
 __description__ = "🎲 Dotflow turns an idea into flow!"
 
-from .config import Config
+from .core.config import Config
 from .core.action import Action as action
 from .core.context import Context
 from .core.dotflow import DotFlow

dotflow/cli/setup.py

@@ -4,7 +4,7 @@
 
 from dotflow import __version__, __description__
 from dotflow.log import logger
-from dotflow.config import Config
+from dotflow.settings import Settings as settings
 from dotflow.core.utils.basic_functions import basic_callback
 from dotflow.core.exception import (
     MissingActionDecorator,
@@ -50,7 +50,7 @@ def setup_start(self):
         self.cmd_start.add_argument("-c", "--callback", default=basic_callback)
         self.cmd_start.add_argument("-i", "--initial-context")
         self.cmd_start.add_argument("-o", "--output", default=False, action='store_true')
-        self.cmd_start.add_argument("-p", "--path", default=Config.PATH)
+        self.cmd_start.add_argument("-p", "--path", default=settings.INITIAL_PATH)
 
         self.cmd_start.set_defaults(exec=StartCommand)
 

dotflow/cli/validators/start.py

@@ -4,7 +4,7 @@
 
 from pydantic import BaseModel, Field  # type: ignore
 
-from dotflow import Config
+from dotflow.settings import Settings as settings
 
 
 class StartValidator(BaseModel):
@@ -13,4 +13,4 @@ class StartValidator(BaseModel):
     callable: Optional[str] = Field(default=None)
     initial_context: Optional[str] = Field(default=None)
     output: Optional[bool] = Field(default=True)
-    path: Optional[str] = Field(default=Config.PATH)
+    path: Optional[str] = Field(default=settings.INITIAL_PATH)

dotflow/config.py

@@ -0,0 +1,18 @@
+"""Config module"""
+
+from dotflow.core.utils import make_dir
+from dotflow.settings import Settings as settings
+
+
+class Config:
+
+    def __init__(
+            self,
+            path: str = settings.INITIAL_PATH,
+            output: bool = False
+    ) -> None:
+        self.path = path
+        self.log_path = f"{path}/{settings.LOG_FILE}"
+        self.output = output
+
+        make_dir(path=self.path, show_log=True)

dotflow/core/config.py

@@ -3,7 +3,7 @@
 from uuid import uuid4
 from functools import partial
 
-from dotflow.config import Config
+from dotflow.core.config import Config
 from dotflow.core.workflow import Workflow
 from dotflow.core.task import TaskBuilder
 

dotflow/core/dotflow.py

@@ -4,26 +4,19 @@
 from typing import Any, Callable, List
 
 from dotflow.log import logger
-from dotflow.config import Config
+from dotflow.core.config import Config
 from dotflow.core.action import Action
 from dotflow.core.context import Context
 from dotflow.core.module import Module
 from dotflow.core.exception import MissingActionDecorator
 from dotflow.core.models.status import TaskStatus
-from dotflow.core.utils import (
-    basic_callback,
-    traceback_error,
-    message_error
-)
+from dotflow.settings import Settings as settings
+from dotflow.core.utils import basic_callback, traceback_error, message_error, copy_file
 
 
 class TaskInstance:
 
-    def __init__(
-            self,
-            *args,
-            **kwargs
-    ) -> None:
+    def __init__(self, *args, **kwargs) -> None:
         self.task_id = None
         self.workflow_id = None
         self.step = None
@@ -45,15 +38,9 @@ def __init__(
         callback: Callable = basic_callback,
         initial_context: Any = None,
         workflow_id: UUID = None,
-        config: Config = None
+        config: Config = None,
     ) -> None:
-        super().__init__(
-            task_id,
-            step,
-            callback,
-            initial_context,
-            workflow_id
-        )
+        super().__init__(task_id, step, callback, initial_context, workflow_id)
         self.config = config
         self.task_id = task_id
         self.workflow_id = workflow_id
@@ -72,10 +59,7 @@ def status(self):
     def status(self, value: TaskStatus) -> None:
         self._status = value
 
-        logger.info(
-            "ID %s - %s - %s",
-            self.workflow_id, self.task_id, value
-        )
+        logger.info("ID %s - %s - %s", self.workflow_id, self.task_id, value)
 
     @property
     def error(self):
@@ -90,8 +74,10 @@ def error(self, value: Exception) -> None:
 
         logger.error(
             "ID %s - %s - %s \n %s",
-            self.workflow_id, self.task_id,
-            self.status, task_error.traceback
+            self.workflow_id,
+            self.task_id,
+            self.status,
+            task_error.traceback,
         )
 
     @property
@@ -117,10 +103,12 @@ def current_context(self, value: Context):
         if self.config.output:
             logger.info(
                 "ID %s - %s - Current Context -> %s",
-                self.workflow_id, self.task_id, str(value.storage)
+                self.workflow_id,
+                self.task_id,
+                str(value.storage),
             )
 
-        self.config._log_transfer()
+        copy_file(source=settings.LOG_PATH, destination=self.config.log_path)
 
     @property
     def initial_context(self):
@@ -135,10 +123,12 @@ def initial_context(self, value: Context):
         if self.config.output:
             logger.info(
                 "ID %s - %s - Initial Context -> %s",
-                self.workflow_id, self.task_id, str(value)
+                self.workflow_id,
+                self.task_id,
+                str(value),
             )
 
-        self.config._log_transfer()
+        copy_file(source=settings.LOG_PATH, destination=self.config.log_path)
 
     @property
     def config(self):
@@ -167,11 +157,7 @@ def __init__(self, error: Exception = None) -> None:
 
 class TaskBuilder:
 
-    def __init__(
-            self,
-            config: Config,
-            workflow_id: UUID = None
-    ) -> None:
+    def __init__(self, config: Config, workflow_id: UUID = None) -> None:
         self.queu: List[Task] = []
         self.workflow_id = workflow_id
         self.config = config
@@ -180,7 +166,7 @@ def add(
         self,
         step: Callable,
         callback: Callable = basic_callback,
-        initial_context: Any = None
+        initial_context: Any = None,
     ) -> None:
         step = Module(value=step)
 
@@ -194,7 +180,7 @@ def add(
                 callback=Module(value=callback),
                 initial_context=initial_context,
                 workflow_id=self.workflow_id,
-                config=self.config
+                config=self.config,
             )
         )
 

dotflow/core/task.py

@@ -2,11 +2,14 @@
 
 from dotflow.core.utils.error_handler import traceback_error, message_error
 from dotflow.core.utils.basic_functions import basic_function, basic_callback
+from dotflow.core.utils.tools import make_dir, copy_file
 
 
 __all__ = [
     "traceback_error",
     "message_error",
     "basic_function",
-    "basic_callback"
+    "basic_callback",
+    "make_dir",
+    "copy_file"
 ]

dotflow/core/utils/__init__.py

@@ -0,0 +1,26 @@
+"""Tools"""
+
+import logging
+
+from os import makedirs
+from shutil import copy
+
+
+def make_dir(path: str, show_log: bool = False):
+    try:
+        makedirs(name=path, exist_ok=True)
+    except Exception as err:
+        if show_log:
+            logging.error(err)
+
+
+def copy_file(
+        source: str,
+        destination: str,
+        show_log: bool = False
+) -> None:
+    try:
+        copy(src=source, dst=destination)
+    except Exception as err:
+        if show_log:
+            logging.error(err)