mirror of
https://github.com/MeshCore-Beacon/beacon-server.git
synced 2026-10-25 00:22:24 +00:00
MrAlders0n
5ded8d925f
* feat(db): channel_message_iatas table and indexes * feat(ingest): record channel message sites at insert and on every later hearing * feat(db): channel message site backfill and two-range reconcile * feat(db): serve region and scope message pages from the site read model when trusted * feat: boot repair, periodic reconcile and first-time verification for the message site read model * test(planguard): channel message site statements, diff and storediff cases * feat(background): log when a read-only server trusts the message site read model * test(planguard): storediff vars in query values, and message cases read from the data * fix(ingest): record a stored hearing's channel message site right after the observation insert * fix: bounded message dispatch for filtered all-channel pages, fresher read-only trust, earlier invalidation * fix: record a hearing's site after its path is marked and skip the backstop when the message was found; read-only trust ends at the writer's deadline
12 lines
361 B
Go
12 lines
361 B
Go
// Copyright 2026 Beacon Contributors
|
|
// SPDX-License-Identifier: AGPL-3.0-or-later
|
|
|
|
package ingest
|
|
|
|
import "context"
|
|
|
|
// HandlePacketForTest runs one packet hearing through the worker, for tests in package ingest_test.
|
|
func (w *Worker) HandlePacketForTest(ctx context.Context, iata, pubkeyHex string, raw []byte) {
|
|
w.handlePacket(ctx, iata, pubkeyHex, raw)
|
|
}
|