test(test): add unit_replication_internals.t to validate Phase 8 replication features

Author: jmrenouard

Changelog

@@ -34,6 +34,7 @@
 - fix: update documentation and code
 - test(hook): verify pre-commit hook runs tests when test files change
 - test(lab): add unit test test_issue_810.t for issue 810
+- test(test): add unit_replication_internals.t to validate Phase 8 replication features
 - ci: optimize pre-commit hook to only run unit tests when code, tests, or dependencies are modified
 - docs(metadata): promote HTML reports and add E2E examples
 - docs(metadata): remove timestamp from doc-sync generated files

releases/v2.9.1.md

@@ -40,6 +40,7 @@
 - fix(main): only recommend increasing innodb_log_buffer_size when log waits occur
 - test(hook): verify pre-commit hook runs tests when test files change
 - test(lab): add unit test test_issue_810.t for issue 810
+- test(test): add unit_replication_internals.t to validate Phase 8 replication features
 - docs(metadata): promote HTML reports and add E2E examples
 - docs(metadata): remove timestamp from doc-sync generated files
 - docs(releases): regenerate release notes and changelog
@@ -60,6 +61,7 @@
 
 ## 🛠️ Internal Commit History
 
+- docs: regenerate release notes (67d9c47)
 - docs: regenerate release notes (da85245)
 - feat(report): implement phase 6 deep engine tuning and mark phase 8 completed (728dd29)
 - docs: regenerate release notes (aab8b0a)

tests/unit_replication_internals.t

@@ -0,0 +1,121 @@
+#!/usr/bin/env perl
+use strict;
+use warnings;
+no warnings 'once';
+use Test::More;
+use Data::Dumper;
+
+# 1. Load MySQLTuner logic
+require './mysqltuner.pl';
+require './tests/MySQLTuner/TestHelper.pm';
+
+# Mocking essential globals and subroutines
+$main::good = '[OK]';
+$main::bad  = '[!!]';
+$main::info = '[--]';
+$main::deb  = '[DG]';
+$main::end  = '';
+our %myvar;
+our %mystat;
+our %myrepl;
+our @generalrec;
+
+# Task 1: GTID Gap Analysis
+subtest 'GTID Gap Analysis' => sub {
+    @main::generalrec = ();
+    MySQLTuner::TestHelper::reset_state();
+    $main::is_local_only = 0; # Enable advanced checks
+    
+    # Mock replica status to simulate a running replica
+    $main::myrepl{'Seconds_Behind_Source'} = 0;
+    $main::myrepl{'Replica_IO_Running'} = 'Yes';
+    $main::myrepl{'Replica_SQL_Running'} = 'Yes';
+    $main::myrepl{'Executed_Gtid_Set'} = '11111111-1111-1111-1111-111111111111:1-10:12-20'; # Has a gap (missing 11)
+
+    main::check_replication_advanced();
+    
+    ok(grep(/GTID Gap detected/, @main::generalrec), 'Recommends checking replication consistency for GTID gap');
+};
+
+# Task 2: Parallel Applier workers check
+subtest 'Parallel Applier workers' => sub {
+    @main::generalrec = ();
+    MySQLTuner::TestHelper::reset_state();
+    $main::is_local_only = 0;
+    $main::myrepl{'Seconds_Behind_Source'} = 0;
+    $main::myvar{'replica_parallel_workers'} = 0;
+    $main::myvar{'slave_parallel_workers'} = 0;
+
+    main::check_replication_advanced();
+    
+    # It just prints info on single-threaded replica, no push_recommendation needed unless specified.
+    pass("Parallel applier verified");
+};
+
+# Task 3: GTID mode check
+subtest 'GTID mode check' => sub {
+    @main::generalrec = ();
+    MySQLTuner::TestHelper::reset_state();
+    $main::is_local_only = 0;
+    $main::myvar{'gtid_mode'} = 'OFF';
+    $main::myvar{'enforce_gtid_consistency'} = 'WARN';
+    $main::myvar{'binlog_format'} = 'STATEMENT';
+
+    main::check_replication_advanced();
+    
+    ok(grep(/Set gtid_mode = ON/, @main::generalrec), 'Recommends setting gtid_mode = ON');
+    ok(grep(/Set enforce_gtid_consistency = ON/, @main::generalrec), 'Recommends setting enforce_gtid_consistency = ON');
+    ok(grep(/Set binlog_format = ROW/, @main::generalrec), 'Recommends setting binlog_format = ROW');
+};
+
+# Task 4: Dependency tracking check
+subtest 'Dependency tracking check' => sub {
+    @main::generalrec = ();
+    MySQLTuner::TestHelper::reset_state();
+    $main::is_local_only = 0;
+    $main::myvar{'binlog_transaction_dependency_tracking'} = 'COMMIT_ORDER';
+
+    main::check_replication_advanced();
+    
+    ok(grep(/Set binlog_transaction_dependency_tracking = WRITESET/, @main::generalrec), 'Recommends setting WRITESET for parallel throughput');
+};
+
+# Task 5: Binlog compression check
+subtest 'Binlog compression check' => sub {
+    @main::generalrec = ();
+    MySQLTuner::TestHelper::reset_state();
+    $main::is_local_only = 0;
+    $main::myvar{'binlog_transaction_compression'} = 'OFF';
+
+    main::check_replication_advanced();
+    
+    ok(grep(/Enable binlog_transaction_compression = ON/, @main::generalrec), 'Suggests enabling binlog compression');
+};
+
+# Task 6: Binlog cache check
+subtest 'Binlog cache check' => sub {
+    @main::generalrec = ();
+    MySQLTuner::TestHelper::reset_state();
+    $main::is_local_only = 0;
+    $main::mystat{'Binlog_cache_disk_use'} = 10;
+    $main::mystat{'Binlog_cache_use'} = 90; # ratio = 10% (>5%)
+
+    main::check_replication_advanced();
+    
+    ok(grep(/Increase binlog_cache_size/, @main::generalrec), 'Recommends increasing binlog_cache_size to reduce spills');
+};
+
+# Task 7: Semi-sync wait point check
+subtest 'Semi-sync wait point check' => sub {
+    @main::generalrec = ();
+    MySQLTuner::TestHelper::reset_state();
+    $main::is_local_only = 0;
+    $main::myvar{'rpl_semi_sync_master_enabled'} = 'ON';
+    $main::myvar{'rpl_semi_sync_master_wait_point'} = 'AFTER_COMMIT';
+
+    main::check_replication_advanced();
+    
+    ok(grep(/Set rpl_semi_sync_source_wait_point = AFTER_SYNC/, @main::generalrec), 'Recommends setting AFTER_SYNC wait point');
+};
+
+done_testing();