mirror of
https://github.com/Kpa-clawbot/meshcore-analyzer.git
synced 2026-09-01 22:29:12 +00:00
test: 101 server route tests via supertest — 76% coverage
server.js now exportable via require.main guard. Tests every API endpoint: stats, nodes, packets, channels, observers, traces, analytics, config, health, perf, resolve-hops. Covers: params, pagination, error paths, region filtering.
This commit is contained in:
you
@@ -17,6 +17,7 @@ node test-aging.js
|
||||
node test-frontend-helpers.js
|
||||
node test-regional-filter.js
|
||||
node test-server-helpers.js
|
||||
node test-server-routes.js
|
||||
node test-db.js
|
||||
|
||||
# Integration tests (spin up temp servers)
|
||||
@@ -29,3 +30,4 @@ echo ""
|
||||
echo "═══════════════════════════════════════"
|
||||
echo " All tests passed"
|
||||
echo "═══════════════════════════════════════"
|
||||
node test-server-routes.js
|
||||
|
||||
@@ -0,0 +1,609 @@
|
||||
#!/usr/bin/env node
|
||||
'use strict';
|
||||
|
||||
// Server route integration tests via supertest
|
||||
process.env.NODE_ENV = 'test';
|
||||
process.env.SEED_DB = 'true'; // Seed test data
|
||||
|
||||
const request = require('supertest');
|
||||
const { app, pktStore, db, cache } = require('./server');
|
||||
|
||||
let passed = 0, failed = 0;
|
||||
|
||||
async function t(name, fn) {
|
||||
try {
|
||||
await fn();
|
||||
passed++;
|
||||
} catch (e) {
|
||||
failed++;
|
||||
console.error(`FAIL: ${name} — ${e.message}`);
|
||||
}
|
||||
}
|
||||
|
||||
function assert(cond, msg) { if (!cond) throw new Error(msg || 'assertion failed'); }
|
||||
|
||||
// Seed additional test data for branch coverage
|
||||
function seedTestData() {
|
||||
const now = new Date().toISOString();
|
||||
const yesterday = new Date(Date.now() - 86400000).toISOString();
|
||||
|
||||
// Add nodes with various roles and locations
|
||||
const nodes = [
|
||||
{ public_key: 'aabb' + '0'.repeat(60), name: 'TestRepeater1', role: 'repeater', lat: 37.7749, lon: -122.4194, last_seen: now, first_seen: yesterday },
|
||||
{ public_key: 'ccdd' + '0'.repeat(60), name: 'TestRoom1', role: 'room', lat: 40.7128, lon: -74.0060, last_seen: now, first_seen: yesterday },
|
||||
{ public_key: 'eeff' + '0'.repeat(60), name: 'TestCompanion1', role: 'companion', lat: 0, lon: 0, last_seen: yesterday, first_seen: yesterday },
|
||||
{ public_key: '1122' + '0'.repeat(60), name: 'TestSensor1', role: 'sensor', lat: 51.5074, lon: -0.1278, last_seen: now, first_seen: yesterday },
|
||||
// Node with same 2-char prefix as TestRepeater1 to test ambiguous resolution
|
||||
{ public_key: 'aabb' + '1'.repeat(60), name: 'TestRepeater2', role: 'repeater', lat: 34.0522, lon: -118.2437, last_seen: now, first_seen: yesterday },
|
||||
];
|
||||
for (const n of nodes) {
|
||||
try { db.upsertNode(n); } catch {}
|
||||
}
|
||||
|
||||
// Add observer
|
||||
try { db.upsertObserver({ id: 'test-obs-1', name: 'TestObs', iata: 'SFO', last_seen: now, first_seen: yesterday }); } catch {}
|
||||
try { db.upsertObserver({ id: 'test-obs-2', name: 'TestObs2', iata: 'NYC', last_seen: now, first_seen: yesterday }); } catch {}
|
||||
|
||||
// Add packets with paths and decoded data
|
||||
const packets = [
|
||||
{
|
||||
raw_hex: '11451000D818206D3AAC152C8A91F89957E6D30CA51F36E28790228971C473B755F244F718754CF5EE4A2FD58D944466E42CDED140C66D0CC590183E32BAF40F112BE8F3F2BDF6012B4B2793C52F1D36F69EE054D9A05593286F78453E56C0EC4A3EB95DDA2A7543FCCC00B939CACC009278603902FC12BCF84B706120526F6F6620536F6C6172',
|
||||
timestamp: now, observer_id: 'test-obs-1', snr: 10.5, rssi: -85,
|
||||
hash: 'test-hash-001', route_type: 1, payload_type: 4, payload_version: 1,
|
||||
path_json: JSON.stringify(['aabb', 'ccdd']),
|
||||
decoded_json: JSON.stringify({ type: 'ADVERT', name: 'TestRepeater1', pubKey: 'aabb' + '0'.repeat(60), role: 'repeater', lat: 37.7749, lon: -122.4194, flags: { repeater: true } }),
|
||||
},
|
||||
{
|
||||
raw_hex: '2233445566778899AABBCCDD',
|
||||
timestamp: yesterday, observer_id: 'test-obs-1', snr: -5, rssi: -110,
|
||||
hash: 'test-hash-002', route_type: 0, payload_type: 5, payload_version: 1,
|
||||
path_json: JSON.stringify(['aabb', 'ccdd', 'eeff']),
|
||||
decoded_json: JSON.stringify({ type: 'TXT_MSG', text: 'Hello test', channelHash: 'ch01', channel_hash: 'ch01', srcName: 'TestCompanion1' }),
|
||||
},
|
||||
{
|
||||
raw_hex: 'AABBCCDD00112233',
|
||||
timestamp: now, observer_id: 'test-obs-2', snr: 8, rssi: -70,
|
||||
hash: 'test-hash-003', route_type: 3, payload_type: 4, payload_version: 1,
|
||||
path_json: JSON.stringify(['1122', 'aabb']),
|
||||
decoded_json: JSON.stringify({ type: 'ADVERT', name: 'TestSensor1', pubKey: '1122' + '0'.repeat(60), role: 'sensor', lat: 51.5074, lon: -0.1278, flags: { sensor: true } }),
|
||||
},
|
||||
{
|
||||
raw_hex: 'FF00FF00FF00FF00',
|
||||
timestamp: now, observer_id: 'test-obs-1', snr: 15, rssi: -60,
|
||||
hash: 'test-hash-001', route_type: 1, payload_type: 4, payload_version: 1,
|
||||
path_json: JSON.stringify(['aabb', 'ccdd']),
|
||||
decoded_json: JSON.stringify({ type: 'ADVERT', name: 'TestRepeater1', pubKey: 'aabb' + '0'.repeat(60) }),
|
||||
},
|
||||
{
|
||||
raw_hex: '5566778899AABB00',
|
||||
timestamp: now, observer_id: 'test-obs-2', snr: 3, rssi: -90,
|
||||
hash: 'test-hash-004', route_type: 0, payload_type: 5, payload_version: 1,
|
||||
path_json: JSON.stringify(['eeff', 'aabb', 'ccdd', '1122']),
|
||||
decoded_json: JSON.stringify({ type: 'TXT_MSG', text: 'Another msg', channelHash: 'ch02', srcName: 'TestRoom1' }),
|
||||
},
|
||||
];
|
||||
|
||||
for (const pkt of packets) {
|
||||
try { pktStore.insert(pkt); } catch {}
|
||||
try { db.insertTransmission(pkt); } catch {}
|
||||
}
|
||||
|
||||
// Seed another packet with CHAN type for channel messages
|
||||
const chanPkt = {
|
||||
raw_hex: 'AA00BB00CC00DD00',
|
||||
timestamp: now, observer_id: 'test-obs-1', observer_name: 'TestObs', snr: 5, rssi: -80,
|
||||
hash: 'test-hash-005', route_type: 0, payload_type: 5, payload_version: 1,
|
||||
path_json: JSON.stringify(['aabb', 'ccdd']),
|
||||
decoded_json: JSON.stringify({ type: 'CHAN', channel: 'ch01', text: 'UserA: Hello world', sender: 'UserA', sender_timestamp: now, SNR: 5 }),
|
||||
};
|
||||
try { pktStore.insert(chanPkt); } catch {}
|
||||
try { db.insertTransmission(chanPkt); } catch {}
|
||||
|
||||
// Duplicate of same message from different observer (for dedup/repeats coverage)
|
||||
const chanPkt2 = {
|
||||
raw_hex: 'AA00BB00CC00DD00',
|
||||
timestamp: now, observer_id: 'test-obs-2', observer_name: 'TestObs2', snr: 3, rssi: -90,
|
||||
hash: 'test-hash-005', route_type: 0, payload_type: 5, payload_version: 1,
|
||||
path_json: JSON.stringify(['aabb', 'ccdd']),
|
||||
decoded_json: JSON.stringify({ type: 'CHAN', channel: 'ch01', text: 'UserA: Hello world', sender: 'UserA' }),
|
||||
};
|
||||
try { pktStore.insert(chanPkt2); } catch {}
|
||||
try { db.insertTransmission(chanPkt2); } catch {}
|
||||
|
||||
// Clear cache so fresh data is picked up
|
||||
cache.clear();
|
||||
}
|
||||
|
||||
seedTestData();
|
||||
|
||||
(async () => {
|
||||
console.log('── Server Route Tests ──');
|
||||
|
||||
// --- Config routes ---
|
||||
await t('GET /api/config/cache', async () => {
|
||||
const r = await request(app).get('/api/config/cache').expect(200);
|
||||
assert(r.body && typeof r.body === 'object', 'should return object');
|
||||
});
|
||||
|
||||
await t('GET /api/config/client', async () => {
|
||||
const r = await request(app).get('/api/config/client').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return config');
|
||||
});
|
||||
|
||||
await t('GET /api/config/regions', async () => {
|
||||
const r = await request(app).get('/api/config/regions').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return regions');
|
||||
});
|
||||
|
||||
await t('GET /api/config/theme', async () => {
|
||||
const r = await request(app).get('/api/config/theme').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return theme object');
|
||||
});
|
||||
|
||||
await t('GET /api/config/map', async () => {
|
||||
const r = await request(app).get('/api/config/map').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return map config');
|
||||
});
|
||||
|
||||
// --- Health ---
|
||||
await t('GET /api/health', async () => {
|
||||
const r = await request(app).get('/api/health').expect(200);
|
||||
assert(r.body.status, 'should have status');
|
||||
});
|
||||
|
||||
// --- Stats ---
|
||||
await t('GET /api/stats', async () => {
|
||||
const r = await request(app).get('/api/stats').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return stats');
|
||||
});
|
||||
|
||||
// --- Perf ---
|
||||
await t('GET /api/perf', async () => {
|
||||
const r = await request(app).get('/api/perf').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return perf data');
|
||||
});
|
||||
|
||||
await t('POST /api/perf/reset', async () => {
|
||||
const r = await request(app).post('/api/perf/reset');
|
||||
assert(r.status === 200 || r.status === 403, 'should return 200 or 403');
|
||||
});
|
||||
|
||||
// --- Nodes ---
|
||||
await t('GET /api/nodes default', async () => {
|
||||
const r = await request(app).get('/api/nodes').expect(200);
|
||||
assert(Array.isArray(r.body) || r.body.nodes, 'should return nodes');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with limit', async () => {
|
||||
await request(app).get('/api/nodes?limit=5').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with offset', async () => {
|
||||
await request(app).get('/api/nodes?limit=2&offset=1').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with role=repeater', async () => {
|
||||
await request(app).get('/api/nodes?role=repeater').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with role=room', async () => {
|
||||
await request(app).get('/api/nodes?role=room').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with region=SFO', async () => {
|
||||
await request(app).get('/api/nodes?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with search', async () => {
|
||||
await request(app).get('/api/nodes?search=Test').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with lastHeard', async () => {
|
||||
await request(app).get('/api/nodes?lastHeard=86400').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with sortBy=name', async () => {
|
||||
await request(app).get('/api/nodes?sortBy=name').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with sortBy=role', async () => {
|
||||
await request(app).get('/api/nodes?sortBy=role').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with before cursor', async () => {
|
||||
await request(app).get('/api/nodes?before=2099-01-01T00:00:00Z').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes with large limit', async () => {
|
||||
await request(app).get('/api/nodes?limit=10000&lastHeard=259200').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/search with q', async () => {
|
||||
const r = await request(app).get('/api/nodes/search?q=Test').expect(200);
|
||||
assert(Array.isArray(r.body) || typeof r.body === 'object', 'should return results');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/search without q', async () => {
|
||||
await request(app).get('/api/nodes/search').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/bulk-health', async () => {
|
||||
const r = await request(app).get('/api/nodes/bulk-health').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return bulk health');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/network-status', async () => {
|
||||
const r = await request(app).get('/api/nodes/network-status').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return network status');
|
||||
});
|
||||
|
||||
cache.clear(); // Clear to avoid cache hits for regional queries
|
||||
await t('GET /api/nodes/network-status with region', async () => {
|
||||
await request(app).get('/api/nodes/network-status?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
cache.clear();
|
||||
await t('GET /api/nodes/bulk-health with region', async () => {
|
||||
await request(app).get('/api/nodes/bulk-health?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
// Test with real node pubkey
|
||||
const testPubkey = 'aabb' + '0'.repeat(60);
|
||||
|
||||
await t('GET /api/nodes/:pubkey — existing', async () => {
|
||||
const r = await request(app).get(`/api/nodes/${testPubkey}`);
|
||||
assert(r.status === 200 || r.status === 404, 'should find or not find');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey — nonexistent', async () => {
|
||||
await request(app).get('/api/nodes/' + '0'.repeat(64)).expect(404);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/health — existing', async () => {
|
||||
const r = await request(app).get(`/api/nodes/${testPubkey}/health`);
|
||||
assert(r.status === 200 || r.status === 404, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/health — nonexistent', async () => {
|
||||
const r = await request(app).get('/api/nodes/nonexistent/health');
|
||||
assert(r.status === 404 || r.status === 200, 'should handle missing node');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/paths — existing', async () => {
|
||||
const r = await request(app).get(`/api/nodes/${testPubkey}/paths`);
|
||||
assert(r.status === 200 || r.status === 404, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/paths — nonexistent', async () => {
|
||||
const r = await request(app).get('/api/nodes/nonexistent/paths');
|
||||
assert(r.status === 404 || r.status === 200, 'should handle missing');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/paths with days param', async () => {
|
||||
await request(app).get(`/api/nodes/${testPubkey}/paths?days=7`);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/analytics — existing', async () => {
|
||||
const r = await request(app).get(`/api/nodes/${testPubkey}/analytics`);
|
||||
assert(r.status === 200 || r.status === 404, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/analytics with days', async () => {
|
||||
await request(app).get(`/api/nodes/${testPubkey}/analytics?days=7`);
|
||||
});
|
||||
|
||||
await t('GET /api/nodes/:pubkey/analytics — nonexistent', async () => {
|
||||
const r = await request(app).get('/api/nodes/nonexistent/analytics');
|
||||
assert(r.status === 404 || r.status === 200, 'should handle missing');
|
||||
});
|
||||
|
||||
// --- Packets ---
|
||||
await t('GET /api/packets default', async () => {
|
||||
const r = await request(app).get('/api/packets').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return packets');
|
||||
});
|
||||
|
||||
await t('GET /api/packets with limit', async () => {
|
||||
await request(app).get('/api/packets?limit=5').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with offset', async () => {
|
||||
await request(app).get('/api/packets?limit=5&offset=0').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with type', async () => {
|
||||
await request(app).get('/api/packets?type=ADVERT').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with route', async () => {
|
||||
await request(app).get('/api/packets?route=1').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with observer', async () => {
|
||||
await request(app).get('/api/packets?observer=test-obs-1').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with region', async () => {
|
||||
await request(app).get('/api/packets?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with hash', async () => {
|
||||
await request(app).get('/api/packets?hash=test-hash-001').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with since/until', async () => {
|
||||
await request(app).get('/api/packets?since=2020-01-01T00:00:00Z&until=2099-01-01T00:00:00Z').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with groupByHash', async () => {
|
||||
await request(app).get('/api/packets?groupByHash=true').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with node filter', async () => {
|
||||
await request(app).get(`/api/packets?node=${testPubkey}`).expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with nodes (multi)', async () => {
|
||||
await request(app).get(`/api/packets?nodes=${testPubkey},ccdd${'0'.repeat(60)}`).expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets with order asc', async () => {
|
||||
await request(app).get('/api/packets?order=asc').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/packets/timestamps without since', async () => {
|
||||
await request(app).get('/api/packets/timestamps').expect(400);
|
||||
});
|
||||
|
||||
await t('GET /api/packets/timestamps with since', async () => {
|
||||
const r = await request(app).get('/api/packets/timestamps?since=2020-01-01T00:00:00Z').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return timestamps');
|
||||
});
|
||||
|
||||
await t('GET /api/packets/:id — id 1', async () => {
|
||||
const r = await request(app).get('/api/packets/1');
|
||||
assert(r.status === 200 || r.status === 404, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/packets/:id — nonexistent', async () => {
|
||||
const r = await request(app).get('/api/packets/999999');
|
||||
assert(r.status === 404 || r.status === 200, 'should handle missing packet');
|
||||
});
|
||||
|
||||
// --- POST /api/decode ---
|
||||
await t('POST /api/decode without hex', async () => {
|
||||
await request(app).post('/api/decode').send({}).expect(400);
|
||||
});
|
||||
|
||||
await t('POST /api/decode with invalid hex', async () => {
|
||||
await request(app).post('/api/decode').send({ hex: 'zzzz' }).expect(400);
|
||||
});
|
||||
|
||||
await t('POST /api/decode with valid hex', async () => {
|
||||
const r = await request(app).post('/api/decode')
|
||||
.send({ hex: '11451000D818206D3AAC152C8A91F89957E6D30CA51F36E28790228971C473B755F244F718754CF5EE4A2FD58D944466E42CDED140C66D0CC590183E32BAF40F112BE8F3F2BDF6012B4B2793C52F1D36F69EE054D9A05593286F78453E56C0EC4A3EB95DDA2A7543FCCC00B939CACC009278603902FC12BCF84B706120526F6F6620536F6C6172' });
|
||||
assert(r.status === 200 || r.status === 400, 'should not crash');
|
||||
});
|
||||
|
||||
// --- POST /api/packets ---
|
||||
await t('POST /api/packets without hex', async () => {
|
||||
await request(app).post('/api/packets').send({}).expect(400);
|
||||
});
|
||||
|
||||
await t('POST /api/packets with hex (no api key configured)', async () => {
|
||||
const r = await request(app).post('/api/packets')
|
||||
.send({ hex: '11451000D818206D3AAC152C8A91F89957E6D30CA51F36E28790228971C473B755F244F718754CF5EE4A2FD58D944466E42CDED140C66D0CC590183E32BAF40F112BE8F3F2BDF6012B4B2793C52F1D36F69EE054D9A05593286F78453E56C0EC4A3EB95DDA2A7543FCCC00B939CACC009278603902FC12BCF84B706120526F6F6620536F6C6172', observer: 'test-obs-1', region: 'SFO' });
|
||||
assert(r.status === 200 || r.status === 400 || r.status === 403, 'should handle');
|
||||
});
|
||||
|
||||
await t('POST /api/packets with invalid hex', async () => {
|
||||
const r = await request(app).post('/api/packets').send({ hex: 'zzzz' });
|
||||
assert(r.status === 400, 'should reject invalid hex');
|
||||
});
|
||||
|
||||
// --- Channels (clear cache first to ensure fresh data) ---
|
||||
cache.clear();
|
||||
await t('GET /api/channels', async () => {
|
||||
const r = await request(app).get('/api/channels').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return channels');
|
||||
});
|
||||
|
||||
await t('GET /api/channels with region', async () => {
|
||||
await request(app).get('/api/channels?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/channels/:hash/messages', async () => {
|
||||
const r = await request(app).get('/api/channels/ch01/messages').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return messages');
|
||||
});
|
||||
|
||||
await t('GET /api/channels/:hash/messages with params', async () => {
|
||||
await request(app).get('/api/channels/ch01/messages?limit=5&offset=0').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/channels/:hash/messages with region', async () => {
|
||||
await request(app).get('/api/channels/ch01/messages?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/channels/:hash/messages nonexistent', async () => {
|
||||
await request(app).get('/api/channels/nonexistent/messages').expect(200);
|
||||
});
|
||||
|
||||
// --- Observers ---
|
||||
await t('GET /api/observers', async () => {
|
||||
const r = await request(app).get('/api/observers').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return observers');
|
||||
});
|
||||
|
||||
await t('GET /api/observers/:id — existing', async () => {
|
||||
const r = await request(app).get('/api/observers/test-obs-1');
|
||||
assert(r.status === 200 || r.status === 404, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/observers/:id — nonexistent', async () => {
|
||||
const r = await request(app).get('/api/observers/nonexistent');
|
||||
assert(r.status === 404 || r.status === 200, 'should handle missing observer');
|
||||
});
|
||||
|
||||
await t('GET /api/observers/:id/analytics — existing', async () => {
|
||||
const r = await request(app).get('/api/observers/test-obs-1/analytics');
|
||||
assert(r.status === 200 || r.status === 404, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/observers/:id/analytics — nonexistent', async () => {
|
||||
const r = await request(app).get('/api/observers/nonexistent/analytics');
|
||||
assert(r.status === 404 || r.status === 200, 'should handle');
|
||||
});
|
||||
|
||||
// --- Traces ---
|
||||
await t('GET /api/traces/:hash — existing', async () => {
|
||||
const r = await request(app).get('/api/traces/test-hash-001');
|
||||
assert(r.status === 200 || r.status === 404, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/traces/:hash — nonexistent', async () => {
|
||||
const r = await request(app).get('/api/traces/nonexistent');
|
||||
assert(r.status === 200 || r.status === 404, 'should handle trace lookup');
|
||||
});
|
||||
|
||||
// --- Analytics (clear cache before regional tests) ---
|
||||
cache.clear();
|
||||
await t('GET /api/analytics/rf', async () => {
|
||||
const r = await request(app).get('/api/analytics/rf').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return RF analytics');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/rf with region', async () => {
|
||||
await request(app).get('/api/analytics/rf?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/rf with region NYC', async () => {
|
||||
await request(app).get('/api/analytics/rf?region=NYC').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/topology', async () => {
|
||||
const r = await request(app).get('/api/analytics/topology').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return topology');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/topology with region', async () => {
|
||||
await request(app).get('/api/analytics/topology?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/channels', async () => {
|
||||
const r = await request(app).get('/api/analytics/channels').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return channel analytics');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/channels with region', async () => {
|
||||
await request(app).get('/api/analytics/channels?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/hash-sizes', async () => {
|
||||
const r = await request(app).get('/api/analytics/hash-sizes').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return hash sizes');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/hash-sizes with region', async () => {
|
||||
await request(app).get('/api/analytics/hash-sizes?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/subpaths', async () => {
|
||||
const r = await request(app).get('/api/analytics/subpaths').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return subpaths');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/subpaths with params', async () => {
|
||||
await request(app).get('/api/analytics/subpaths?minLen=2&maxLen=3&limit=10').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/subpaths with region', async () => {
|
||||
await request(app).get('/api/analytics/subpaths?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/subpath-detail with hops', async () => {
|
||||
const r = await request(app).get('/api/analytics/subpath-detail?hops=aabb,ccdd');
|
||||
assert(r.status === 200 || r.status === 400, 'should handle');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/subpath-detail without hops', async () => {
|
||||
const r = await request(app).get('/api/analytics/subpath-detail');
|
||||
assert(r.status === 200 || r.status === 400, 'should handle missing hops');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/distance', async () => {
|
||||
const r = await request(app).get('/api/analytics/distance').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return distance analytics');
|
||||
});
|
||||
|
||||
await t('GET /api/analytics/distance with region', async () => {
|
||||
await request(app).get('/api/analytics/distance?region=SFO').expect(200);
|
||||
});
|
||||
|
||||
// --- Resolve hops ---
|
||||
await t('GET /api/resolve-hops with hops', async () => {
|
||||
const r = await request(app).get('/api/resolve-hops?hops=aabb,ccdd').expect(200);
|
||||
assert(typeof r.body === 'object', 'should return resolved hops');
|
||||
});
|
||||
|
||||
await t('GET /api/resolve-hops without hops', async () => {
|
||||
await request(app).get('/api/resolve-hops').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/resolve-hops with region and observer', async () => {
|
||||
await request(app).get('/api/resolve-hops?hops=aabb,ccdd®ion=SFO&observer=test-obs-1').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/resolve-hops with prefixes (legacy)', async () => {
|
||||
await request(app).get('/api/resolve-hops?prefixes=aabb,ccdd').expect(200);
|
||||
});
|
||||
|
||||
await t('GET /api/resolve-hops ambiguous prefix', async () => {
|
||||
// 'aabb' matches both TestRepeater1 and TestRepeater2
|
||||
const r = await request(app).get('/api/resolve-hops?hops=aabb,ccdd,1122®ion=SFO&observer=test-obs-1').expect(200);
|
||||
assert(typeof r.body === 'object', 'should resolve hops');
|
||||
});
|
||||
|
||||
await t('GET /api/resolve-hops with packet context', async () => {
|
||||
await request(app).get('/api/resolve-hops?hops=aabb,eeff,ccdd®ion=SFO&observer=test-obs-1&packetHash=test-hash-001').expect(200);
|
||||
});
|
||||
|
||||
// --- IATA coords ---
|
||||
await t('GET /api/iata-coords', async () => {
|
||||
const r = await request(app).get('/api/iata-coords').expect(200);
|
||||
assert(r.body && 'coords' in r.body, 'should have coords key');
|
||||
});
|
||||
|
||||
// --- Audio lab ---
|
||||
await t('GET /api/audio-lab/buckets', async () => {
|
||||
const r = await request(app).get('/api/audio-lab/buckets').expect(200);
|
||||
assert(r.body && 'buckets' in r.body, 'should have buckets key');
|
||||
});
|
||||
|
||||
// --- SPA fallback ---
|
||||
await t('GET /nodes SPA fallback', async () => {
|
||||
const r = await request(app).get('/nodes');
|
||||
assert([200, 304, 404].includes(r.status), 'should not crash');
|
||||
});
|
||||
|
||||
// --- Cache behavior: hit same endpoint twice ---
|
||||
await t('Cache hit: /api/nodes/bulk-health twice', async () => {
|
||||
await request(app).get('/api/nodes/bulk-health').expect(200);
|
||||
await request(app).get('/api/nodes/bulk-health').expect(200);
|
||||
});
|
||||
|
||||
await t('Cache hit: /api/analytics/rf twice', async () => {
|
||||
await request(app).get('/api/analytics/rf').expect(200);
|
||||
await request(app).get('/api/analytics/rf').expect(200);
|
||||
});
|
||||
|
||||
await t('Cache hit: /api/analytics/topology twice', async () => {
|
||||
await request(app).get('/api/analytics/topology').expect(200);
|
||||
await request(app).get('/api/analytics/topology').expect(200);
|
||||
});
|
||||
|
||||
// ── Summary ──
|
||||
console.log(`\n═══ Server Route Tests: ${passed} passed, ${failed} failed ═══`);
|
||||
if (failed > 0) process.exit(1);
|
||||
process.exit(0);
|
||||
})();
|
||||
Reference in New Issue
Block a user