chore: backend messaging full refactor

MLquery/.env.local

+RABBIT_USER=rabbitmq
+RABBIT_PASSWORD=DevOnlyPass
+RABBIT_HOST=localhost
+RABBIT_PORT=5672
+REDIS_ADDRESS=localhost
+REDIS_PASSWORD=DevOnlyPass
+REDIS_PORT=6379
+QUERY_EXECUTION=neo4j
+LOG_MESSAGES=false
+LOG_LEVEL=-1
+QUERY_CONVERSION_LANGUAGE=cypher
+DEV=true
+AMQP_URL=amqp://localhost:5672?connection_attempts=5&retry_delay=5
\ No newline at end of file

MLquery/Centrality/Dockerfile

@@ -20,6 +20,7 @@ RUN pip install pika
 RUN pip install --upgrade pip enum34
 
 RUN pip install uuid
+RUN pip install python-dotenv
 RUN pip install networkx
 RUN pip install pika
 RUN pip install redis

MLquery/CommunityDetection/Dockerfile

@@ -20,6 +20,7 @@ RUN pip install pika
 RUN pip install --upgrade pip enum34
 
 RUN pip install uuid
+RUN pip install python-dotenv
 RUN pip install networkx
 RUN pip install pika
 RUN pip install redis

MLquery/LinkPrediction/Dockerfile

@@ -20,6 +20,7 @@ RUN pip install pika
 RUN pip install --upgrade pip enum34
 
 RUN pip install uuid
+RUN pip install python-dotenv
 RUN pip install networkx
 RUN pip install pika
 RUN pip install redis

MLquery/MLDriver.py

@@ -10,6 +10,7 @@ import pika
 import json
 import redis
 import os
+from dotenv import load_dotenv
 
 
 ##
@@ -21,6 +22,8 @@ def void(DikkeDraak):
     pass
 
 
+load_dotenv("../.env.dev")
+print(os.getcwd())
 # We often compare against this specific string, so we clearly define it to prevent any typos
 # Python has no constants so we simply give it a very obvious name that implies it is not supposed to be changed
 CONST_MLEXCHANGE = "ml-direct-exchange"
@@ -64,7 +67,9 @@ class MLDriver:
     ##
     def on_request(self, ch, method, props, body):
         sessionID = props.headers["sessionID"]
+        clientID = props.headers["clientID"]
         print("SessionID is: " + sessionID)
+        print("clientID is: " + clientID)
         clientQueueID = r.get("routing " + sessionID)
 
         testing = os.getenv("INTEGRATION_TESTING")

MLquery/ShortestPath/Dockerfile

@@ -20,6 +20,7 @@ RUN pip install pika
 RUN pip install --upgrade pip enum34
 
 RUN pip install uuid
+RUN pip install python-dotenv
 RUN pip install networkx
 RUN pip install pika
 RUN pip install redis