WIP

Signed-off-by: Martin Weise <martin.weise@tuwien.ac.at>

dbrepo-auth-service/init/Pipfile

@@ -12,6 +12,8 @@ coverage = "*"
 pytest = "*"
 testcontainers-mysql = "*"
 requests-mock = "*"
+logging = "*"
+dbrepo = {path = "./lib/dbrepo-1.9.0.tar.gz"}
 
 [requires]
 python_version = "3.11"

dbrepo-auth-service/init/app.py

@@ -3,6 +3,47 @@ import os
 import mariadb
 from requests import post, get
 
+logging.addLevelName(level=logging.NOTSET, levelName='TRACE')
+logging.basicConfig(level=logging.DEBUG)
+
+from logging.config import dictConfig
+
+# logging configuration
+dictConfig({
+    'version': 1,
+    'formatters': {
+        'default': {
+            'format': '[%(asctime)s] %(levelname)s in %(module)s: %(message)s',
+        },
+        'simple': {
+            'format': '[%(asctime)s] [%(levelname)s] %(message)s',
+        },
+        'ecs': {
+            'format': '{"@timestamp": "%(asctime)s", "log.level": "%(levelname)s", "log.logger": "%(module)s", "message": "%(message)s", "service_name": "analyse-service", "service_version": "1.9.0"}',
+            'datefmt': '%Y-%m-%dT%H:%M:%S'
+        },
+    },
+    'handlers': {
+        'wsgi': {
+            'class': 'logging.StreamHandler',
+            'stream': 'ext://flask.logging.wsgi_errors_stream',
+            'formatter': 'simple'
+        },
+        'file': {
+            'class': 'logging.handlers.TimedRotatingFileHandler',
+            'formatter': 'ecs',
+            'filename': '/var/log/app/service/analyse/app.log',
+            'when': 'm',
+            'interval': 1,
+            'backupCount': 5,
+            'encoding': 'utf8'
+        },
+    },
+    'root': {
+        'level': 'DEBUG',
+        'handlers': ['wsgi', 'file']
+    }
+})
 
 def fetch_keycloak_master_access_token() -> str:
     """

dbrepo-data-service/init/debug.py

@@ -8,6 +8,8 @@ rest_client = RestClient("http://127.0.0.1", "admin", "admin")
 
 database_client = DatabaseClient(username='root', password='dbrepo')
 
+auth_client = AuthClient
+
 for db in rest_client.get_databases():
     database = rest_client.get_database(db.id)
     # create query store if necessary
@@ -24,3 +26,5 @@ for db in rest_client.get_databases():
             pass
         print(f'update permission {access.type} for user {access.user.username} in database: {database.internal_name}')
         rest_client.update_database_access(database.id, access.user.id, access.type)
+    for user in rest_client.get_users():
+        print(f'====> user {user.username}')
\ No newline at end of file