added db connection to auth server and added usermanagement code

Auth Server/.env

@@ -1,3 +1,7 @@
 HOST="127.0.0.1"
-PORT=54321
+PORT=54322
-ENV="DEV"
+ENV="DEV"
+DBHOST=""
+DBUNAME=""
+DBPASSWORD=""
+DBNAME=""

Auth Server/database.py

@@ -0,0 +1,20 @@
+import psycopg2
+
+class Database:
+    __conn:psycopg2.connect
+    __cursor:psycopg2.cursor
+
+    def __init__(self, database:str, host:str, user:str, password:str, port:str):
+        self.__conn = psycopg2.connect(database=database, host=host, user=user, password=password, port=port)
+        self.__cursor = self.__conn.cursor()
+
+    def getConnection(self) -> psycopg2.connect:
+        return self.__conn
+    
+    def fetchall(self, query:str):
+        self.__cursor.execute(query)
+        return self.__cursor.fetchall()
+    
+    def fetchall(self, query:str):
+        self.__cursor.execute(query)
+        return self.__cursor.fetchone()

Auth Server/index.py

@@ -29,20 +29,41 @@ def handle_connection(socket:socket, address):
         # decide which event should be performed
         if message_json["event"]  == "login":
             # encode message and respond to client
-            # TODO: Handle login
+            # TODO: connect to databasse
+            # TODO: request user data
+            # TODO: validate user data
+            # TODO: create session
+            # TODO: return session to client
             response = f"<place_holder_message>"
             socket.sendall(response.encode())
         elif message_json["event"]  == "register":
             # encode message and respond to client
-            # TODO: Handle registration
+            # TODO: connect to databasse
+            # TODO: request user data
+            # TODO: validate user data
+            # TODO: create session
+            # TODO: return session to client
             response = f"<place_holder_message>"
             socket.sendall(response.encode())
         elif message_json["event"]  == "logout":
             # encode message and respond to client
-            # TODO: Handle registration
+            # TODO: connect to databasse
+            # TODO: request user data
+            # TODO: validate user data
+            # TODO: create session
+            # TODO: return session to client
             response = f"<place_holder_message>"
             socket.sendall(response.encode())
-    
+        elif message_json["event"]  == "sessionrefresh":
+            # encode message and respond to client
+            # TODO: connect to databasse
+            # TODO: request user data
+            # TODO: validate user data
+            # TODO: create session
+            # TODO: return session to client
+            response = f"<place_holder_message>"
+            socket.sendall(response.encode())
+
     # connection is not required anymore and gets closed
     socket.close()
     print(f"connection closed for {address}")

User Management/.env

@@ -0,0 +1,3 @@
+HOST="127.0.0.1"
+PORT=54321
+ENV="DEV"

User Management/index.py

@@ -0,0 +1,70 @@
+import socket
+import threading
+import os
+import json
+from dotenv import load_dotenv
+
+load_dotenv()
+
+# retrieves host data from environment
+HOST = os.getenv("HOST")
+PORT = os.getenv("PORT")
+
+# TODO: setup tcp service for authorization
+def handle_connection(socket:socket, address):
+    # states that a connection has been established
+    print(f"Connected with {address}")
+
+    # Communication with client
+    while True:
+        data = socket.recv(1024)
+        if not data:
+            break
+
+        # decode message for handling
+        message = data.decode()
+        message_json = json.loads(message)
+        print(f"received message from {address}: {message}")
+
+        # decide which event should be performed
+        if message_json["event"]  == "login":
+            # encode message and respond to client
+            # TODO: Handle login
+                # TODO: request user information based on input
+                # TODO: validate informateion given is valid
+                # TODO: create session id for user
+                # TODO: send session information to user
+            response = f"<place_holder_message>"
+            socket.sendall(response.encode())
+        elif message_json["event"]  == "register":
+            # encode message and respond to client
+            # TODO: Handle registration
+            response = f"<place_holder_message>"
+            socket.sendall(response.encode())
+        elif message_json["event"]  == "logout":
+            # encode message and respond to client
+            # TODO: Handle registration
+            response = f"<place_holder_message>"
+            socket.sendall(response.encode())
+    
+    # connection is not required anymore and gets closed
+    socket.close()
+    print(f"connection closed for {address}")
+
+# create tcp socket
+server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+
+# make socket bind connection info and listen for connections
+socket.bind(HOST, PORT)
+socket.listen()
+print(f"authorization server online on {HOST}:{PORT}")
+
+# server loop forwards connection to handle_connection
+while True:
+    # accept incomming connection
+    # TODO: validate this connection is a valid game connection
+    client_socket, client_address = server_socket.accept()
+
+    # create network thread for connection
+    client_thread = threading.Thread(target=handle_connection, args=(client_socket, client_address))
+    client_thread.start()