Allow setting the file mode of the SQLite database

Author: vkarak

docs/config_reference.rst

@@ -1651,6 +1651,16 @@ Result storage configuration
 
    The SQLite database file to use.
 
+.. py:attribute:: storage.sqlite_db_file_mode
+
+   :required: No
+   :default: ``"644"``
+
+   The permissions of the SQLite database file in octal form.
+
+   The mode will only taken into account upon creation of the DB file.
+   Permissions of an existing DB file have to be changed manually.
+
 
 General Configuration
 =====================

docs/manpage.rst

@@ -2038,6 +2038,21 @@ Whenever an environment variable is associated with a configuration option, its
    .. versionadded:: 4.7
 
 
+.. envvar:: RFM_SQLITE_DB_FILE_MODE
+
+   The permissions of the SQLite database file in octal form.
+
+   .. table::
+      :align: left
+
+      ================================== ==================
+      Associated command line option     N/A
+      Associated configuration parameter :attr:`~config.storage.sqlite_db_file_mode`
+      ================================== ==================
+
+   .. versionadded:: 4.7
+
+
 .. envvar:: RFM_SYSLOG_ADDRESS
 
    The address of the Syslog server to send performance logs.

reframe/frontend/cli.py

@@ -3,6 +3,7 @@
 #
 # SPDX-License-Identifier: BSD-3-Clause
 
+import functools
 import inspect
 import itertools
 import json
@@ -777,6 +778,13 @@ def main():
         configvar='storage/sqlite_db_file',
         help='DB file where the results database resides (SQLite backend)'
     )
+    argparser.add_argument(
+        dest='sqlite_db_file_mode',
+        envvar='RFM_SQLITE_DB_FILE_MODE',
+        configvar='storage/sqlite_db_file_mode',
+        help='DB file permissions (SQLite backend)',
+        type=functools.partial(int, base=8)
+    )
     argparser.add_argument(
         dest='syslog_address',
         envvar='RFM_SYSLOG_ADDRESS',

reframe/frontend/reporting/storage.py

@@ -52,6 +52,9 @@ def __init__(self):
         self.__db_file = os.path.join(
             osext.expandvars(runtime().get_option('storage/0/sqlite_db_file'))
         )
+        self.__db_file_mode = runtime().get_option(
+            'storage/0/sqlite_db_file_mode'
+        )
 
     def _db_file(self):
         prefix = os.path.dirname(self.__db_file)
@@ -78,6 +81,11 @@ def _db_connect(self, *args, **kwargs):
         with getprofiler().time_region('sqlite connect'):
             return sqlite3.connect(*args, **kwargs)
 
+    def _db_lock(self):
+        prefix = os.path.dirname(self.__db_file)
+        return FileLock(os.path.join(prefix, '.db.lock'),
+                        mode=self.__db_file_mode)
+
     def _db_create(self):
         clsname = type(self).__name__
         getlogger().debug(
@@ -104,6 +112,8 @@ def _db_create(self):
                          'on testcases(job_completion_time_unix)')
             conn.execute('CREATE TABLE IF NOT EXISTS metadata('
                          'schema_version TEXT)')
+        # Update DB file mode
+        os.chmod(self.__db_file, self.__db_file_mode)
 
     def _db_schema_check(self):
         with self._db_connect(self.__db_file) as conn:
@@ -164,9 +174,8 @@ def _db_store_report(self, conn, report, report_file_path):
         return session_uuid
 
     def store(self, report, report_file=None):
-        prefix = os.path.dirname(self.__db_file)
         with self._db_connect(self._db_file()) as conn:
-            with FileLock(os.path.join(prefix, '.db.lock')):
+            with self._db_lock():
                 return self._db_store_report(conn, report, report_file)
 
     @time_function
@@ -298,8 +307,7 @@ def fetch_session_json(self, uuid):
         return jsonext.loads(results[0][0]) if results else {}
 
     def _do_remove(self, uuid):
-        prefix = os.path.dirname(self.__db_file)
-        with FileLock(os.path.join(prefix, '.db.lock')):
+        with self._db_lock():
             with self._db_connect(self._db_file()) as conn:
                 # Enable foreign keys for delete action to have cascade effect
                 conn.execute('PRAGMA foreign_keys = ON')
@@ -316,8 +324,7 @@ def _do_remove(self, uuid):
 
     def _do_remove2(self, uuid):
         '''Remove a session using the RETURNING keyword'''
-        prefix = os.path.dirname(self.__db_file)
-        with FileLock(os.path.join(prefix, '.db.lock')):
+        with self._db_lock():
             with self._db_connect(self._db_file()) as conn:
                 # Enable foreign keys for delete action to have cascade effect
                 conn.execute('PRAGMA foreign_keys = ON')

reframe/schemas/config.json

@@ -544,7 +544,8 @@
                 "properties": {
                     "backend": {"type": "string"},
                     "sqlite_conn_timeout": {"type": "number"},
-                    "sqlite_db_file": {"type": "string"}
+                    "sqlite_db_file": {"type": "string"},
+                    "sqlite_db_file_mode": {"type": "string"}
                 }
             }
         }
@@ -627,6 +628,7 @@
         "storage/backend": "sqlite",
         "storage/sqlite_conn_timeout": 60,
         "storage/sqlite_db_file": "${HOME}/.reframe/reports/results.db",
+        "storage/sqlite_db_file_mode": "644",
         "systems/descr": "",
         "systems/max_local_jobs": 8,
         "systems/modules_system": "nomod",