mirror of
https://github.com/MeshCore-Beacon/beacon-server.git
synced 2026-10-24 18:32:30 +00:00
MrAlders0n
8c89b62691
* Run the channel message backfill in the background after startup * Finish each backfilled packet; mark packets whose message exists; log a shutdown stop * Cap each backfilled packet's statements at 30 s
82 lines
2.6 KiB
Go
82 lines
2.6 KiB
Go
// Copyright 2026 Beacon Contributors
|
|
// SPDX-License-Identifier: AGPL-3.0-or-later
|
|
|
|
package ingest
|
|
|
|
import (
|
|
"context"
|
|
"encoding/binary"
|
|
"encoding/json"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/MeshCore-Beacon/beacon-server/internal/borders"
|
|
"github.com/MeshCore-Beacon/beacon-server/internal/hub"
|
|
"github.com/meshcore-go/meshcore-go"
|
|
"github.com/paulmach/orb"
|
|
)
|
|
|
|
func TestForeignNodeUpdates(t *testing.T) {
|
|
local, err := borders.New([]orb.Polygon{{{{10, 10}, {20, 10}, {20, 20}, {10, 20}, {10, 10}}}})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
w, _ := newTestWorker()
|
|
go w.hub.Run()
|
|
client := w.hub.NewClient()
|
|
defer w.hub.Remove(client)
|
|
w.hub.AddScope(client, "foreign", hub.Scope{Events: []hub.EventType{hub.EventNodeUpdate, hub.EventObserverStatus}})
|
|
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
|
defer cancel()
|
|
waitForSummarySubscriber(t, ctx, w.hub, client)
|
|
for _, tc := range []struct {
|
|
name string
|
|
enabled, position bool
|
|
role byte
|
|
lat, lng int32
|
|
present bool
|
|
want any
|
|
}{
|
|
{"disabled", false, true, 2, 25000000, 25000000, false, nil},
|
|
{"inside", true, true, 2, 15000000, 15000000, true, false},
|
|
{"outside", true, true, 2, 25000000, 25000000, true, true},
|
|
{"omitted retains old position", true, false, 2, 0, 0, false, nil},
|
|
{"explicit reset clears flag", true, true, 2, 0, 0, true, nil},
|
|
{"invalid position clears flag", true, true, 2, 91000000, 25000000, true, nil},
|
|
{"role change clears flag", true, false, meshcore.AdvertTypeChat, 0, 0, true, nil},
|
|
} {
|
|
t.Run(tc.name, func(t *testing.T) {
|
|
w.cfg.LocalBorders = nil
|
|
if tc.enabled {
|
|
w.cfg.LocalBorders = borders.NewLive(local)
|
|
}
|
|
data := []byte{tc.role}
|
|
if tc.position {
|
|
data[0] |= meshcore.AdvertLatLonMask
|
|
data = binary.LittleEndian.AppendUint32(data, uint32(tc.lat))
|
|
data = binary.LittleEndian.AppendUint32(data, uint32(tc.lng))
|
|
}
|
|
w.handlePayloadTypeSideEffects(ctx, buildAdvertPacketWithData(t, data, false), "AAA", []byte{1}, RadioSettings{}, nil, nil, nil, 0, false, false)
|
|
for {
|
|
select {
|
|
case event := <-client.Send:
|
|
if event.Type != hub.EventNodeUpdate {
|
|
continue
|
|
}
|
|
var payload map[string]any
|
|
if err := json.Unmarshal(event.Payload, &payload); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
got, present := payload["possiblyForeign"]
|
|
if present != tc.present || got != tc.want {
|
|
t.Fatalf("flag = %v (present=%v); want %v (present=%v)", got, present, tc.want, tc.present)
|
|
}
|
|
return
|
|
case <-ctx.Done():
|
|
t.Fatal("node update not received")
|
|
}
|
|
}
|
|
})
|
|
}
|
|
}
|