CTX-6230: coretex node logs command implementation based on criteria …

coretex/cli/commands/node.py

@@ -16,6 +16,7 @@
 #     along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
 from typing import Optional
+from pathlib import Path
 
 import click
 
@@ -26,7 +27,7 @@
 from ..modules.utils import onBeforeCommandExecute, checkEnvironment
 from ..modules.update import activateAutoUpdate, getNodeStatus
 from ...utils import docker
-from ...configuration import UserConfiguration, NodeConfiguration, InvalidConfiguration, ConfigurationNotFound
+from ...configuration import NodeConfiguration, InvalidConfiguration, ConfigurationNotFound
 
 
 @click.command()
@@ -179,6 +180,23 @@ def config(advanced: bool) -> None:
     activateAutoUpdate()
 
 
+@click.command()
+@click.option("--tail", "-n", type = int, help = "Shows N last logs.")
+@click.option("--follow", "-f", is_flag = True, help = "Displays logs realtime.")
+@click.option("--timestamps", "-t", is_flag = True, help = "Displays timestamps for logs.")
+@click.option("--verbose", "-v", is_flag = True, help = "Displays debug logs.")
+def logs(tail: Optional[int], follow: bool, timestamps: bool, verbose: bool) -> None:
+    nodeConfig = NodeConfiguration.load()
+    if getNodeStatus() in [NodeStatus.inactive, NodeStatus.deleted]:
+        ui.errorEcho("There is no currently running Node on the machine.")
+
+    if not verbose:
+        node_module.showLogs(tail, follow, timestamps)
+        return
+
+    node_module.showDebugLogs(Path(nodeConfig.storagePath).joinpath("logs", "node"))
+
+
 @click.group()
 @onBeforeCommandExecute(docker.isDockerAvailable)
 @onBeforeCommandExecute(initializeUserSession)
@@ -192,3 +210,4 @@ def node() -> None:
 node.add_command(stop, "stop")
 node.add_command(update, "update")
 node.add_command(config, "config")
+node.add_command(logs, "logs")

coretex/cli/modules/node.py

@@ -198,6 +198,23 @@ def shouldUpdate(image: str) -> bool:
     return True
 
 
+def showLogs(tail: Optional[int], follow: bool, timestamps: bool) -> None:
+    docker.getLogs(config_defaults.DOCKER_CONTAINER_NAME, tail, follow, timestamps)
+
+
+def showDebugLogs(nodeLogsPath: Path) -> None:
+    logFiles = list(nodeLogsPath.glob('*'))
+
+    if not logFiles:
+        ui.errorEcho("No log files found in the directory.")
+        return
+
+    latestLogFile = max(logFiles, key = lambda file: file.stat().st_ctime)
+
+    with latestLogFile.open("r") as nodeLogsFile:
+        ui.stdEcho(nodeLogsFile.read())
+
+
 def registerNode(
     name: str,
     nodeMode: NodeMode,

coretex/configuration/user.py

@@ -117,7 +117,7 @@ def isTokenValid(self, tokenName: str) -> bool:
             return False
 
         try:
-            return datetime.now(timezone.utc) > decodeDate(tokenExpirationDate)
+            return datetime.now(timezone.utc) < decodeDate(tokenExpirationDate)
         except ValueError:
             return False
 

coretex/utils/docker.py

@@ -184,3 +184,17 @@ def getDockerSwapLimit() -> int:
         return getTotalSwapMemory()
 
     return int(swapLimit / 1024)
+
+
+def getLogs(name: str, tail: Optional[int], follow: bool, timestamps: bool) -> None:
+    runCommand = ["docker", "logs", name]
+    if isinstance(tail, int):
+        runCommand.extend(["--tail", str(tail)])
+
+    if timestamps:
+        runCommand.append("-t")
+
+    if follow:
+        runCommand.append("-f")
+
+    command(runCommand)