mirror of
https://github.com/vicliu624/trail-mate.git
synced 2026-10-26 06:52:36 +00:00
32 lines
3.3 KiB
JavaScript
32 lines
3.3 KiB
JavaScript
import test from 'node:test';
|
|
import assert from 'node:assert/strict';
|
|
import {spawn} from 'node:child_process';
|
|
import {createInterface} from 'node:readline';
|
|
import path from 'node:path';
|
|
import {Identity} from '../../site/node_modules/@reticulum/core/src/index.js';
|
|
import {createTrackDirectoryReadSession} from '../../site/tracks/src/directory-read-session.js';
|
|
import {querySharedTrackPage} from '../../site/tracks/src/shared-track-query.js';
|
|
import {createTrackRegionClient} from '../../site/tracks/src/region-client.js';
|
|
import {readSharedTrack} from '../../site/tracks/src/shared-track-read.js';
|
|
import {trackId} from '../../site/tracks/src/shared-id.js';
|
|
test('metadata map/region queries use actual Python directory state and signed LXMF replies',async()=>{
|
|
const python=process.env.TRAIL_MATE_TRACK_PYTHON??path.resolve('.codex-build/reticulum-directory/venv',process.platform==='win32'?'Scripts/python.exe':'bin/python');
|
|
const peer=spawn(python,['-m','tools.tracks.read_interop_fixture'],{stdio:['pipe','pipe','pipe'],windowsHide:true});let stderr='';peer.stderr.on('data',bytes=>stderr+=bytes.toString());
|
|
const exit=new Promise((resolve,reject)=>{peer.once('exit',resolve);peer.once('error',reject);}),reader=createInterface({input:peer.stdout})[Symbol.asyncIterator]();
|
|
const next=async()=>{const line=await reader.next();if(line.done)throw Error('Fixture ended: '+stderr);return JSON.parse(line.value);};
|
|
const local=await Identity.generate(),tags=['山脊','trail, ridge'],regions={type:'FeatureCollection',features:[{type:'Feature',id:'r',properties:{name:'Region'},geometry:{type:'Polygon',coordinates:[[[119,29],[122,29],[122,32],[119,32],[119,29]]]}}]};
|
|
peer.stdin.write(JSON.stringify({local_public:Buffer.from(await local.getPublicKey()).toString('hex'),metadata:[3,tags,0,1,0,0,0,null],regions})+'\n');let session;
|
|
try{
|
|
const fixture=await next(),bin=hex=>new Uint8Array(Buffer.from(hex,'hex'));
|
|
session=await createTrackDirectoryReadSession({metadataQueries:true,directoryPublicKey:bin(fixture.directory_public),directoryDelivery:bin(fixture.directory_delivery),localDelivery:bin(fixture.local_delivery),exchange:async call=>{peer.stdin.write(JSON.stringify({payload:Buffer.from(call.fields.get(0xfc)).toString('hex')})+'\n');return bin((await next()).wire);}});
|
|
assert.ok(session.capabilities.metadataSupported&&session.capabilities.metadataRegionSupported);
|
|
const options={box:[1190000000,290000000,1220000000,320000000],activity:3,tags};
|
|
const map=await querySharedTrackPage(session.request,options);assert.deepEqual(map.items[0].objectId,bin(fixture.id));assert.deepEqual(map.items[0].tags,tags);
|
|
assert.equal((await querySharedTrackPage(session.request,{...options,activity:1})).items.length,0);
|
|
const client=await createTrackRegionClient(session.request,{metadataSupported:true}),root=await client.children(),selected=await client.region(root.items[0].id),page=await client.query(selected,{activity:3,tags});
|
|
assert.deepEqual(page.items[0].objectId,map.items[0].objectId);assert.deepEqual(page.items[0].tags,tags);
|
|
const signed=await readSharedTrack(session.request,trackId(page.items[0].objectId));assert.deepEqual(signed.record[14].slice(0,2),[3,tags]);
|
|
assert.equal((await querySharedTrackPage(session.request,{box:options.box})).items[0].activity,undefined);
|
|
}finally{session?.close();peer.stdin.end();assert.equal(await exit,0,stderr);}
|
|
});
|