fix formatting and bugs

Author: Zvonimir

src/modules/triple-store/implementation/ot-blazegraph/ot-blazegraph.js

@@ -178,7 +178,7 @@ class OtBlazegraph extends OtTripleStore {
 
     async queryVoid(repository, query, timeout) {
         try {
-            return axios.post(this.repositories[repository].sparqlEndpoint, query, {
+            return await axios.post(this.repositories[repository].sparqlEndpoint, query, {
                 headers: {
                     'Content-Type': 'application/sparql-update; charset=UTF-8',
                     'X-BIGDATA-MAX-QUERY-MILLIS': timeout,
@@ -187,13 +187,11 @@ class OtBlazegraph extends OtTripleStore {
         } catch (error) {
             const status = error?.response?.status;
             const dataSnippet =
-                typeof error?.response?.data === 'string'
-                    ? error.response.data.slice(0, 200)
-                    : '';
+                typeof error?.response?.data === 'string' ? error.response.data.slice(0, 200) : '';
             this.logger.error(
-                `[OtBlazegraph.queryVoid] Update failed for ${repository} (status: ${status}): ${error.message}${
-                    dataSnippet ? ` | data: ${dataSnippet}` : ''
-                } | query: ${snippet || '<empty>'}`,
+                `[OtBlazegraph.queryVoid] Update failed for ${repository} (status: ${status}): ${
+                    error.message
+                }${dataSnippet ? ` | data: ${dataSnippet}` : ''}`,
             );
             throw error;
         }

src/service/publish-service.js

@@ -69,16 +69,15 @@ class PublishService extends OperationService {
         // }
 
         // 2. Check if all responses have been received
-            // 2.1 If minimum replication is reached, mark the operation as completed
+        // 2.1 If minimum replication is reached, mark the operation as completed
 
         const record = await this.operationIdService.getOperationIdRecord(operationId);
         if (record?.minAcksReached) return;
 
-        
         if (completedNumber >= minAckResponses) {
             this.logger.info(
                 `[PUBLISH] Minimum replication reached for operationId: ${operationId}, ` +
-                `datasetRoot: ${datasetRoot}, completed: ${completedNumber}/${minAckResponses}`,
+                    `datasetRoot: ${datasetRoot}, completed: ${completedNumber}/${minAckResponses}`,
             );
             await this.markOperationAsCompleted(
                 operationId,
@@ -89,11 +88,11 @@ class PublishService extends OperationService {
             await this.repositoryModuleManager.updateMinAcksReached(operationId, true);
             this.logResponsesSummary(completedNumber, failedNumber);
         }
-            // 2.2 Otherwise, mark as failed
-        else if (totalResponses === numberOfFoundNodes)  {
+        // 2.2 Otherwise, mark as failed
+        else if (totalResponses === numberOfFoundNodes) {
             this.logger.warn(
                 `[PUBLISH] Failed for operationId: ${operationId}, ` +
-                `only ${completedNumber}/${minAckResponses} nodes responded successfully`,
+                    `only ${completedNumber}/${minAckResponses} nodes responded successfully`,
             );
             await this.markOperationAsFailed(
                 operationId,