mirror of
https://github.com/koala73/worldmonitor.git
synced 2026-04-25 17:14:57 +02:00
3702463321
* feat(thermal): add thermal escalation seeded service Cherry-picked from codex/thermal-escalation-phase1 and retargeted to main. Includes thermal escalation seed script, RPC handler, proto definitions, bootstrap/health/seed-health wiring, gateway cache tier, client service, and tests. * fix(thermal): wire data-loader, fix typing, recalculate summary Wire fetchThermalEscalations into data-loader.ts with panel forwarding, freshness tracking, and variant gating. Fix seed-health intervalMin from 90 to 180 to match 3h TTL. Replace 8 as-any casts with typed interface. Recalculate summary counts after maxItems slice. * fix(thermal): enforce maxItems on hydrated data + fix bootstrap keys Codex P2: hydration branch now slices clusters to maxItems before mapping, matching the RPC fallback behavior. Also add thermalEscalation to bootstrap.js BOOTSTRAP_CACHE_KEYS and SLOW_KEYS (was lost during conflict resolution). * fix(thermal): recalculate summary on sliced hydrated clusters When maxItems truncates the cluster array from bootstrap hydration, the summary was still using the original full-set counts. Now recalculates clusterCount, elevatedCount, spikeCount, etc. on the sliced array, matching the handler's behavior.
79 lines
2.8 KiB
JavaScript
79 lines
2.8 KiB
JavaScript
import { describe, it } from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
|
|
import {
|
|
clusterDetections,
|
|
computeThermalEscalationWatch,
|
|
emptyThermalEscalationWatch,
|
|
} from '../scripts/lib/thermal-escalation.mjs';
|
|
|
|
function makeDetection(id, lat, lon, detectedAt, overrides = {}) {
|
|
return {
|
|
id,
|
|
location: { latitude: lat, longitude: lon },
|
|
brightness: overrides.brightness ?? 360,
|
|
frp: overrides.frp ?? 30,
|
|
satellite: overrides.satellite ?? 'VIIRS_SNPP_NRT',
|
|
detectedAt,
|
|
region: overrides.region ?? 'Ukraine',
|
|
dayNight: overrides.dayNight ?? 'N',
|
|
};
|
|
}
|
|
|
|
describe('thermal escalation model', () => {
|
|
it('clusters nearby detections together by region', () => {
|
|
const clusters = clusterDetections([
|
|
makeDetection('a', 50.45, 30.52, 1),
|
|
makeDetection('b', 50.46, 30.54, 2),
|
|
makeDetection('c', 41.0, 29.0, 3, { region: 'Turkey' }),
|
|
]);
|
|
|
|
assert.equal(clusters.length, 2);
|
|
assert.equal(clusters[0].detections.length, 2);
|
|
assert.equal(clusters[1].detections.length, 1);
|
|
});
|
|
|
|
it('builds an elevated or stronger conflict-adjacent cluster from raw detections', () => {
|
|
const nowMs = Date.UTC(2026, 2, 17, 12, 0, 0);
|
|
const detections = [
|
|
makeDetection('a', 50.45, 30.52, nowMs - 90 * 60 * 1000, { frp: 35 }),
|
|
makeDetection('b', 50.46, 30.53, nowMs - 80 * 60 * 1000, { frp: 42, satellite: 'VIIRS_NOAA20_NRT' }),
|
|
makeDetection('c', 50.47, 30.55, nowMs - 70 * 60 * 1000, { frp: 38 }),
|
|
makeDetection('d', 50.45, 30.56, nowMs - 60 * 60 * 1000, { frp: 44 }),
|
|
makeDetection('e', 50.44, 30.57, nowMs - 50 * 60 * 1000, { frp: 48 }),
|
|
];
|
|
|
|
const previousHistory = {
|
|
cells: {
|
|
'50.5:30.5': {
|
|
entries: [
|
|
{ observedAt: '2026-03-16T12:00:00.000Z', observationCount: 1, totalFrp: 10, status: 'THERMAL_STATUS_NORMAL' },
|
|
{ observedAt: '2026-03-15T12:00:00.000Z', observationCount: 1, totalFrp: 12, status: 'THERMAL_STATUS_NORMAL' },
|
|
],
|
|
},
|
|
},
|
|
};
|
|
|
|
const result = computeThermalEscalationWatch(detections, previousHistory, { nowMs });
|
|
assert.equal(result.watch.clusters.length, 1);
|
|
const cluster = result.watch.clusters[0];
|
|
assert.equal(cluster.countryCode, 'UA');
|
|
assert.equal(cluster.context, 'THERMAL_CONTEXT_CONFLICT_ADJACENT');
|
|
assert.ok(['THERMAL_STATUS_ELEVATED', 'THERMAL_STATUS_SPIKE', 'THERMAL_STATUS_PERSISTENT'].includes(cluster.status));
|
|
assert.ok(cluster.totalFrp > cluster.baselineExpectedFrp);
|
|
});
|
|
|
|
it('returns an empty watch shape when no data exists', () => {
|
|
const empty = emptyThermalEscalationWatch();
|
|
assert.deepEqual(empty.summary, {
|
|
clusterCount: 0,
|
|
elevatedCount: 0,
|
|
spikeCount: 0,
|
|
persistentCount: 0,
|
|
conflictAdjacentCount: 0,
|
|
highRelevanceCount: 0,
|
|
});
|
|
assert.equal(empty.clusters.length, 0);
|
|
});
|
|
});
|