Implement syslog functionality

.env.example

@@ -36,3 +36,9 @@ MONICA_LABELS_EXCLUDE=
 DATABASE_FILE=data/syncState.db
 GOOGLE_TOKEN_FILE=data/token.pickle
 GOOGLE_CREDENTIALS_FILE=data/credentials.json
+
+# Send messages to a syslog server
+# An alternative to providing target host and port is providing only a target address, for example "/dev/log".
+# In this case, a Unix domain socket is used to send the message to the syslog.
+SYSLOG_TARGET=
+SYSLOG_PORT=

GMSync.py

@@ -1,8 +1,10 @@
 import argparse
 import logging
+import logging.handlers
 import os
 import sys
 from os.path import abspath, join
+from typing import Tuple, Union
 
 from dotenv import dotenv_values, find_dotenv  # type: ignore
 from dotenv.main import set_key  # type: ignore
@@ -14,7 +16,7 @@
 from helpers.MonicaHelper import Monica
 from helpers.SyncHelper import Sync
 
-VERSION = "v4.0.0"
+VERSION = "v4.1.0"
 LOG_FOLDER = "logs"
 LOG_FILENAME = "sync.log"
 DEFAULT_CONFIG_FILEPATH = join("helpers", ".env.default")
@@ -39,6 +41,17 @@ def main(self) -> None:
             # Load config
             self.load_config()
 
+            # Create syslog handler
+            if self.conf.SYSLOG_TARGET:
+                address: Union[Tuple[str, int], str] = (
+                    (self.conf.SYSLOG_TARGET, int(self.conf.SYSLOG_PORT))
+                    if self.conf.SYSLOG_PORT
+                    else self.conf.SYSLOG_TARGET
+                )
+                syslog_handler = logging.handlers.SysLogHandler(address=address)
+                syslog_handler.setFormatter(self.logging_format)
+                self.log.addHandler(syslog_handler)
+
             # Create sync object
             self.create_sync_helper()
 
@@ -94,11 +107,11 @@ def create_logger(self) -> None:
         log = logging.getLogger("GMSync")
         dotenv_log = logging.getLogger("dotenv.main")
         log.setLevel(logging.INFO)
-        logging_format = logging.Formatter("%(asctime)s %(levelname)s %(message)s")
+        self.logging_format = logging.Formatter("%(asctime)s %(levelname)s %(message)s")
         log_filepath = join(LOG_FOLDER, LOG_FILENAME)
         handler = logging.FileHandler(filename=log_filepath, mode="a", encoding="utf8")
         handler.setLevel(logging.INFO)
-        handler.setFormatter(logging_format)
+        handler.setFormatter(self.logging_format)
         log.addHandler(handler)
         dotenv_log.addHandler(handler)
         self.log = log

helpers/.env.default

@@ -31,3 +31,9 @@ MONICA_LABELS_EXCLUDE=
 DATABASE_FILE=data/syncState.db
 GOOGLE_TOKEN_FILE=data/token.pickle
 GOOGLE_CREDENTIALS_FILE=data/credentials.json
+
+# Send messages to a syslog server
+# An alternative to providing target host and port is providing only a target address, for example "/dev/log".
+# In this case, a Unix domain socket is used to send the message to the syslog.
+SYSLOG_TARGET=
+SYSLOG_PORT=

helpers/ConfigHelper.py

@@ -29,6 +29,8 @@ def __init__(self, log: Logger, raw_config: Dict[str, Union[str, None]]) -> None
             self.DATABASE_FILE = abspath(self._values["DATABASE_FILE"])
             self.GOOGLE_TOKEN_FILE = abspath(self._values["GOOGLE_TOKEN_FILE"])
             self.GOOGLE_CREDENTIALS_FILE = abspath(self._values["GOOGLE_CREDENTIALS_FILE"])
+            self.SYSLOG_TARGET = self._values["SYSLOG_TARGET"]
+            self.SYSLOG_PORT = self._values["SYSLOG_PORT"]
         except Exception as e:
             raise ConfigError("Error parsing config, check syntax and required args!") from e
 

test/SetupToken.py

@@ -10,14 +10,15 @@
 
 import requests
 from bs4 import BeautifulSoup  # type: ignore
-from dotenv.main import load_dotenv, set_key  # type: ignore
+from dotenv.main import dotenv_values, set_key  # type: ignore
 from requests import ConnectionError, ConnectTimeout, ReadTimeout
 
 LOG_FOLDER = "logs"
 LOG_FILENAME = "setup.log"
 try:
-    load_dotenv()
-    PROTOCOL, HOST, PORT = re.findall(r"(https?)://(.+?):(\d+)/api/?", os.getenv("BASE_URL", ""))[0]
+    config = dotenv_values(".env")
+    result = re.findall(r"(https?)://(.+?):(\d+)/api/?", str(config.get("BASE_URL", "")))
+    PROTOCOL, HOST, PORT = result[0]
 except IndexError:
     PROTOCOL, HOST, PORT = "http", "localhost", 8080
 ENV_FILE = ".env"