mirror of
https://github.com/Vateron-Media/XC_VM.git
synced 2026-10-31 11:03:22 +01:00
Claude
1055f699e7
Bus heartbeats now belong to the enrolment that sent them. cl:hb carries the node's gen, RECORD_LUA keeps root_ready and the pending document only within the same gen, and a flush writes cluster_nodes and servers.status only while the row's gen matches. Re-enrolment and revocation drop the node's cl:hb, cl:hb_flushed and cl:tel:<sid> (HeartbeatService::forget). A stale beat can no longer set root_ready, last_seen_at or status 1 on a re-enrolled row. After a root_ready change the flush reads the column back, so a beat that hello overtook is not recorded as written, and the next heartbeat is flushed at once instead of 5 s later. A node that is flushed and forgotten in the same pass no longer leaves its cl:hb_flushed record behind. When a pass reads nothing from the bus (bus lost, or restarted empty), LivenessService uses the heard times it last read from that bus for up to FLUSH_EVERY_MS. MySQL alone could then be up to 12 s behind a live node and turn it suspect. Tests cover each guard the review found untested: the authority gate, a refused servers write, telemetry judged on heard time, the forget guards and cleanup, a future flusher stamp, the lock token, carried root_ready and telemetry, re-enrolment and revocation, and bus loss. Beats no longer depend on wall-clock time. QueryLogDb is loaded from the test bootstrap. ADR 0004 now states the agent contract precisely: a cadence of 3 s at most, root_ready timing, and the size rule for MAIN's own encoding. It also covers cl:tel under volatile-ttl and the bus-loss liveness bound. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01TQHeypQpfAXTdCysmi7b6a
109 lines
3.3 KiB
PHP
109 lines
3.3 KiB
PHP
<?php
|
|
|
|
$projectRoot = dirname(__DIR__);
|
|
$srcRoot = $projectRoot . '/src';
|
|
$flatRoot = $projectRoot;
|
|
|
|
if (file_exists($srcRoot . '/vendor/autoload.php')) {
|
|
$appRoot = $srcRoot;
|
|
} elseif (file_exists($flatRoot . '/vendor/autoload.php')) {
|
|
$appRoot = $flatRoot;
|
|
} else {
|
|
throw new RuntimeException('Unable to locate vendor/autoload.php in expected project paths.');
|
|
}
|
|
|
|
// Silence error_log() diagnostics emitted by exercised code paths (ModuleLoader
|
|
// dependency skips, GitHubReleases version warnings, …) so the test run stays clean.
|
|
// No test asserts on this output; production behaviour is unchanged.
|
|
ini_set('error_log', '/dev/null');
|
|
|
|
$tmpRoot = __DIR__ . '/.tmp';
|
|
$binRoot = $tmpRoot . '/bin';
|
|
|
|
if (!is_dir($tmpRoot)) {
|
|
mkdir($tmpRoot, 0775, true);
|
|
}
|
|
if (!is_dir($binRoot)) {
|
|
mkdir($binRoot, 0775, true);
|
|
}
|
|
|
|
$fakeBinary = $binRoot . '/fake_bin.sh';
|
|
if (!file_exists($fakeBinary)) {
|
|
file_put_contents($fakeBinary, "#!/bin/sh\nexit 0\n");
|
|
chmod($fakeBinary, 0755);
|
|
}
|
|
|
|
if (!defined('MAIN_HOME')) {
|
|
define('MAIN_HOME', $appRoot . '/');
|
|
}
|
|
|
|
if (!defined('PHP_BIN')) {
|
|
define('PHP_BIN', PHP_BINARY);
|
|
}
|
|
// Extra OpenSSL entropy/seed used by Encryption (real value in AppConfig.php).
|
|
// Any stable value works for tests that round-trip encrypt/decrypt.
|
|
if (!defined('OPENSSL_EXTRA')) {
|
|
define('OPENSSL_EXTRA', 'test-openssl-extra');
|
|
}
|
|
// FfmpegPaths::binary() builds paths under BIN_PATH . 'ffmpeg_bin/<ver>/'. No such
|
|
// fixtures exist here, so lookups miss and the code falls back to FFMPEG_BIN_40.
|
|
if (!defined('BIN_PATH')) {
|
|
define('BIN_PATH', $binRoot . '/');
|
|
}
|
|
if (!defined('VOD_PATH')) {
|
|
define('VOD_PATH', $tmpRoot . '/vod/');
|
|
}
|
|
if (!is_dir(VOD_PATH)) {
|
|
mkdir(VOD_PATH, 0775, true);
|
|
}
|
|
|
|
foreach (array('40', '71', '80') as $version) {
|
|
$ffmpegConst = 'FFMPEG_BIN_' . $version;
|
|
$ffprobeConst = 'FFPROBE_BIN_' . $version;
|
|
if (!defined($ffmpegConst)) {
|
|
define($ffmpegConst, $fakeBinary);
|
|
}
|
|
if (!defined($ffprobeConst)) {
|
|
define($ffprobeConst, $fakeBinary);
|
|
}
|
|
}
|
|
|
|
if (!isset($_FILES)) {
|
|
$_FILES = array();
|
|
}
|
|
|
|
if (!function_exists('igbinary_serialize')) {
|
|
function igbinary_serialize($value) {
|
|
return serialize($value);
|
|
}
|
|
}
|
|
if (!function_exists('igbinary_unserialize')) {
|
|
function igbinary_unserialize($value) {
|
|
return unserialize($value);
|
|
}
|
|
}
|
|
|
|
require_once MAIN_HOME . 'vendor/autoload.php';
|
|
require_once __DIR__ . '/Unit/M3uParser/ExtCustomTag.php';
|
|
|
|
// Test support: in-memory SQLite harness for DB-touching repositories/services.
|
|
require_once __DIR__ . '/Support/TestDb.php';
|
|
require_once __DIR__ . '/Support/ClusterReference.php';
|
|
require_once __DIR__ . '/Support/FakeClusterCrypto.php';
|
|
require_once __DIR__ . '/Support/FakeSshFleet.php';
|
|
require_once __DIR__ . '/Support/BusServer.php';
|
|
require_once __DIR__ . '/Support/QueryLogDb.php';
|
|
|
|
// EventIngest's lane locks are real flock files. Without this they would land
|
|
// in the shared TMP_PATH or system temp dir, where suite runs from other
|
|
// checkouts contend on the same files: give each test process its own
|
|
// directory under tests/.tmp, removed when the process ends.
|
|
$ingestLockDir = $tmpRoot . '/cluster_ingest/' . getmypid() . '/';
|
|
\XcVm\Domain\Cluster\EventIngest::useLockDir($ingestLockDir);
|
|
register_shutdown_function(static function () use ($ingestLockDir): void {
|
|
foreach (glob($ingestLockDir . '*') ?: array() as $lockFile) {
|
|
@unlink($lockFile);
|
|
}
|
|
@rmdir($ingestLockDir);
|
|
});
|