fix: create new querypublisher for each message

Every user was using the same global queryPublisher, with the risk of one users message setting headers
that were then used for another users response.

src/readers/queryService.ts

@@ -78,8 +78,6 @@ export const queryServiceReader = async (frontendPublisher: RabbitMqBroker, mlPu
   }
   log.info('Starting query reader for', type);
 
-  const publisher = new QueryPublisher(frontendPublisher, mlPublisher);
-
   const queryServiceConsumer = await new RabbitMqBroker(
     rabbitMq,
     'requests-exchange',
@@ -90,6 +88,8 @@ export const queryServiceReader = async (frontendPublisher: RabbitMqBroker, mlPu
   log.info('Connected to RabbitMQ ST!');
 
   await queryServiceConsumer.startConsuming<QueryRequest>('query-service', async (message, headers) => {
+    const publisher = new QueryPublisher(frontendPublisher, mlPublisher, headers);
+
     const startTime = Date.now();
     const ss = await ums.getUserSaveState(headers.message.sessionData.userID, message.saveStateID);
 
@@ -107,7 +107,6 @@ export const queryServiceReader = async (frontendPublisher: RabbitMqBroker, mlPu
       return;
     }
 
-    publisher.withHeaders(headers).withRoutingKey(headers.routingKey).withQueryID(headers.callID);
     publisher.publishStatusToFrontend('Received');
 
     if (ss == null || ss.dbConnections == null || ss.dbConnections[0] == null || ss.dbConnections.length === 0) {

src/utils/queryPublisher.ts

@@ -10,24 +10,12 @@ export class QueryPublisher {
   private headers?: BackendMessageHeader;
   private queryID?: string;
 
-  constructor(frontendPublisher: RabbitMqBroker, mlPublisher: RabbitMqBroker) {
+  constructor(frontendPublisher: RabbitMqBroker, mlPublisher: RabbitMqBroker, headers: BackendMessageHeader) {
     this.frontendPublisher = frontendPublisher;
     this.mlPublisher = mlPublisher;
-  }
-
-  withHeaders(headers?: BackendMessageHeader) {
     this.headers = headers;
-    return this;
-  }
-
-  withRoutingKey(routingKey?: string) {
-    this.routingKey = routingKey;
-    return this;
-  }
-
-  withQueryID(queryID?: string) {
-    this.queryID = queryID;
-    return this;
+    this.routingKey = headers.routingKey;
+    this.queryID = headers.callID; // FIXME: WTF?
   }
 
   publishStatusToFrontend(status: string) {