From 6ab4ee4968f9ecd3b4e81450eb83c8f7e9d2a259 Mon Sep 17 00:00:00 2001
From: Artem Niehrieiev <r.tem@tuta.io>
Date: Tue, 29 Jul 2025 09:23:59 +0000
Subject: [PATCH] enhance Cassandra client configuration: add query options for
 consistency settings

---
 .../test/ava-tests/saas-tests/table-cassandra.e2e.test.ts | 8 ++++----
 .../data-access-objects/data-access-object-cassandra.ts   | 3 +++
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/backend/test/ava-tests/saas-tests/table-cassandra.e2e.test.ts b/backend/test/ava-tests/saas-tests/table-cassandra.e2e.test.ts
index d79fdfd79..df7951acc 100644
--- a/backend/test/ava-tests/saas-tests/table-cassandra.e2e.test.ts
+++ b/backend/test/ava-tests/saas-tests/table-cassandra.e2e.test.ts
@@ -362,7 +362,7 @@ test.serial(`${currentTest} should return page of all rows with pagination page=
     t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('column_name'), true);
     t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('data_type'), true);
     t.is(getTableRowsRO.primaryColumns[0].column_name, 'id');
-    t.is(getTableRowsRO.primaryColumns[0].data_type, 'text');
+    t.is(getTableRowsRO.primaryColumns[0].data_type, 'uuid');
 
     t.is(getTableRowsRO.pagination.total, 42);
     t.is(getTableRowsRO.pagination.lastPage, 21);
@@ -436,7 +436,7 @@ test.serial(`${currentTest} should return page of all rows with pagination page=
     t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('column_name'), true);
     t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('data_type'), true);
     t.is(getTableRowsRO.primaryColumns[0].column_name, 'id');
-    t.is(getTableRowsRO.primaryColumns[0].data_type, 'text');
+    t.is(getTableRowsRO.primaryColumns[0].data_type, 'uuid');
 
     t.is(getTableRowsRO.pagination.total, 42);
     t.is(getTableRowsRO.pagination.lastPage, 21);
@@ -513,7 +513,7 @@ should return all found rows with pagination page=1 perPage=2`,
       t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('column_name'), true);
       t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('data_type'), true);
       t.is(getTableRowsRO.primaryColumns[0].column_name, 'id');
-      t.is(getTableRowsRO.primaryColumns[0].data_type, 'text');
+      t.is(getTableRowsRO.primaryColumns[0].data_type, 'uuid');
 
       t.is(getTableRowsRO.pagination.total, 3);
       t.is(getTableRowsRO.pagination.lastPage, 2);
@@ -591,7 +591,7 @@ should return all found rows with pagination page=1 perPage=3`,
       t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('column_name'), true);
       t.is(getTableRowsRO.primaryColumns[0].hasOwnProperty('data_type'), true);
       t.is(getTableRowsRO.primaryColumns[0].column_name, 'id');
-      t.is(getTableRowsRO.primaryColumns[0].data_type, 'text');
+      t.is(getTableRowsRO.primaryColumns[0].data_type, 'uuid');
 
       t.is(getTableRowsRO.pagination.total, 3);
       t.is(getTableRowsRO.pagination.lastPage, 2);
diff --git a/shared-code/src/data-access-layer/data-access-objects/data-access-object-cassandra.ts b/shared-code/src/data-access-layer/data-access-objects/data-access-object-cassandra.ts
index 31dc8f219..aaa71c0fc 100644
--- a/shared-code/src/data-access-layer/data-access-objects/data-access-object-cassandra.ts
+++ b/shared-code/src/data-access-layer/data-access-objects/data-access-object-cassandra.ts
@@ -857,6 +857,9 @@ export class DataAccessObjectCassandra extends BasicDataAccessObject implements
         protocolOptions: {
           port,
         },
+        queryOptions: {
+          consistency: cassandra.types.consistencies.localQuorum,
+        },
       };
       if (this.connection.ssl) {
         clientOptions.sslOptions = {