test(db-sync config): Add db-sync test for governance option

cardano_node_tests/tests/test_dbsync_config.py

@@ -45,8 +45,31 @@ class ColumnCondition(str, enum.Enum):
     IS_NULL = "column_condition:IS NULL"
 
 
+GOVERNANCE_TABLES = (
+    db_sync.Table.COMMITTEE_DE_REGISTRATION,
+    db_sync.Table.COMMITTEE_MEMBER,
+    db_sync.Table.COMMITTEE_REGISTRATION,
+    db_sync.Table.COMMITTEE,
+    db_sync.Table.CONSTITUTION,
+    db_sync.Table.DELEGATION_VOTE,
+    db_sync.Table.DREP_DISTR,
+    db_sync.Table.DREP_REGISTRATION,
+    db_sync.Table.EPOCH_STATE,
+    db_sync.Table.GOV_ACTION_PROPOSAL,
+    db_sync.Table.OFF_CHAIN_VOTE_DATA,
+    db_sync.Table.OFF_CHAIN_VOTE_DREP_DATA,
+    db_sync.Table.OFF_CHAIN_VOTE_EXTERNAL_UPDATE,
+    db_sync.Table.OFF_CHAIN_VOTE_FETCH_ERROR,
+    db_sync.Table.OFF_CHAIN_VOTE_GOV_ACTION_DATA,
+    db_sync.Table.OFF_CHAIN_VOTE_REFERENCE,
+    db_sync.Table.VOTING_ANCHOR,
+    db_sync.Table.VOTING_PROCEDURE,
+    db_sync.Table.TREASURY_WITHDRAWAL,
+)
+
+
 def check_dbsync_state(
-    expected_state: dict[tp.Union[str, db_sync.Table], TableCondition | ColumnCondition],
+    expected_state: dict[str | db_sync.Table, TableCondition | ColumnCondition],
 ) -> None:
     """Check the state of db-sync tables and columns against expected conditions.
 
@@ -145,7 +168,6 @@ def basic_tx_out(
             """Test `tx_out` option."""
             db_config = db_sync_manager.get_config_builder()
 
-            # Test tx_out : enable
             db_sync_manager.restart_with_config(
                 custom_config=db_config.with_tx_out(
                     value=db_sync.TxOutMode.ENABLE, force_tx_in=False, use_address_table=False
@@ -160,7 +182,6 @@ def basic_tx_out(
                 }
             )
 
-            # Test tx_out : disable
             db_sync_manager.restart_with_config(
                 custom_config=db_config.with_tx_out(
                     value=db_sync.TxOutMode.DISABLE, force_tx_in=True, use_address_table=True
@@ -179,6 +200,43 @@ def basic_tx_out(
 
         yield basic_tx_out
 
+        def governance(
+            db_sync_manager: db_sync.DBSyncManager,
+        ):
+            """Test `governance` option."""
+            db_config = db_sync_manager.get_config_builder()
+
+            db_sync_manager.restart_with_config(
+                custom_config=db_config.with_governance(value=db_sync.SettingState.ENABLE)
+            )
+
+            # Off-chain data is inserted into the DB a few minutes after the restart of db-sync
+            def _query_func():
+                empty_tables = [
+                    table for table in GOVERNANCE_TABLES if dbsync_utils.table_empty(table=table)
+                ]
+
+                if empty_tables:
+                    msg = f"Following tables are still empty: {empty_tables}"
+                    raise dbsync_utils.DbSyncNoResponseError(msg)
+
+                return True
+
+            dbsync_utils.retry_query(query_func=_query_func, timeout=600)
+
+            check_dbsync_state(
+                expected_state={t: TableCondition.NOT_EMPTY for t in GOVERNANCE_TABLES}  # noqa: C420
+            )
+
+            db_sync_manager.restart_with_config(
+                custom_config=db_config.with_governance(value=db_sync.SettingState.DISABLE)
+            )
+            check_dbsync_state(
+                expected_state={t: TableCondition.EMPTY for t in GOVERNANCE_TABLES}  # noqa: C420
+            )
+
+        yield governance
+
         def tx_cbor_value_enable(
             db_sync_manager: db_sync.DBSyncManager,
         ):

cardano_node_tests/tests/tests_conway/test_committee.py

@@ -550,6 +550,7 @@ def test_update_committee_action(
     @allure.link(helpers.get_vcs_link())
     @pytest.mark.long
     @pytest.mark.dbsync
+    @pytest.mark.dbsync_config
     def test_add_rm_committee_members(  # noqa: C901
         self,
         cluster_lock_governance: governance_utils.GovClusterT,

cardano_node_tests/tests/tests_conway/test_drep.py

@@ -318,6 +318,7 @@ def test_drep_id_is_blake2b_224_of_drep_vkey(
     @submit_utils.PARAM_SUBMIT_METHOD
     @common.PARAM_BUILD_METHOD_NO_EST
     @pytest.mark.dbsync
+    @pytest.mark.dbsync_config
     @pytest.mark.testnets
     @pytest.mark.smoke
     @pytest.mark.parametrize(

cardano_node_tests/tests/tests_conway/test_info.py

@@ -22,10 +22,13 @@
 LOGGER = logging.getLogger(__name__)
 DATA_DIR = pl.Path(__file__).parent.parent / "data"
 
-pytestmark = pytest.mark.skipif(
-    VERSIONS.transaction_era < VERSIONS.CONWAY,
-    reason="runs only with Tx era >= Conway",
-)
+pytestmark = [
+    pytest.mark.skipif(
+        VERSIONS.transaction_era < VERSIONS.CONWAY,
+        reason="runs only with Tx era >= Conway",
+    ),
+    pytest.mark.dbsync_config,
+]
 
 
 @pytest.fixture

cardano_node_tests/tests/tests_conway/test_treasury_withdrawals.py

@@ -93,6 +93,7 @@ class TestTreasuryWithdrawals:
 
     @allure.link(helpers.get_vcs_link())
     @pytest.mark.dbsync
+    @pytest.mark.dbsync_config
     @pytest.mark.long
     @pytest.mark.upgrade_step3
     def test_enact_treasury_withdrawals(

cardano_node_tests/utils/dbsync_service_manager.py

@@ -359,14 +359,12 @@ def recreate_database(self) -> None:
         This is a DESTRUCTIVE operation!
         It will delete existing data and recreate the database from scratch.
         """
-        scripts_dir = cluster_scripts.get_testnet_variant_scriptdir(
-            testnet_variant=configuration.TESTNET_VARIANT
-        )
-        if not scripts_dir:
-            err = f"Testnet variant '{configuration.TESTNET_VARIANT}' scripts directory not found."
+        common_scripts_dir = cluster_scripts.COMMON_DIR
+        if not common_scripts_dir:
+            err = f"Common scripts directory '{common_scripts_dir}' not found."
             raise RuntimeError(err)
 
-        db_script_template = scripts_dir / "postgres-setup.sh"
+        db_script_template = common_scripts_dir / "postgres-setup.sh"
         if not db_script_template.exists() and configuration.BOOTSTRAP_DIR:
             db_script_template = pl.Path(configuration.BOOTSTRAP_DIR) / "postgres-setup.sh"
 

cardano_node_tests/utils/logfiles.py

@@ -50,6 +50,8 @@
     "OffChainPoolFetchError",
     # DB-Sync table name
     "OffChainVoteFetchError",
+    # DB-Sync table name (lowercase)
+    "off_chain_vote_fetch_error",
     # TODO: p2p failures on testnet
     "PeerStatusChangeFailure",
     # TODO: p2p failures on testnet - PeerMonitoringError