From d1130364143e01e11bbc97ef1855fa39bdf86f13 Mon Sep 17 00:00:00 2001
From: MrAlders0n <MrAlders0n@smal.ca>
Date: Wed, 15 Jul 2026 21:02:12 -0400
Subject: [PATCH] feat(beacon): route ingest through the presence coalescer

---
 cmd/beacon/main.go | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/cmd/beacon/main.go b/cmd/beacon/main.go
index c9bd9c4..a2a500d 100644
--- a/cmd/beacon/main.go
+++ b/cmd/beacon/main.go
@@ -26,6 +26,7 @@ import (
 	"github.com/MeshCore-Beacon/beacon-server/internal/iatadb"
 	"github.com/MeshCore-Beacon/beacon-server/internal/ingest"
 	"github.com/MeshCore-Beacon/beacon-server/internal/keystore"
+	"github.com/MeshCore-Beacon/beacon-server/internal/presence"
 	"github.com/MeshCore-Beacon/beacon-server/internal/scopestore"
 
 	"github.com/jackc/pgx/v5/pgxpool"
@@ -111,6 +112,11 @@ func main() {
 
 	store := db.New(pool)
 
+	// ── Presence write coalescing ────────────────────────────────────────────
+	// Ingest writes go through the coalescer; reads keep using the store.
+	coalescer := presence.New(store, resolved.PresenceFlushInterval, resolved.PresencePacketTTL)
+	go coalescer.Run(ctx)
+
 	// ── Redis cache layer ────────────────────────────────────────────────────
 	var reader api.Reader = store
 	if redisAddr := os.Getenv("REDIS_ADDR"); redisAddr != "" {
@@ -209,7 +215,7 @@ func main() {
 			TelemetryResolution: resolved.TelemetryResolution,
 			AllowedIATAs:        allowedIATAs,
 		},
-		store,
+		coalescer,
 		h,
 		keys,
 		scopes,
@@ -224,7 +230,7 @@ func main() {
 			TelemetryResolution: resolved.TelemetryResolution,
 			AllowedIATAs:        allowedIATAs,
 		},
-		store,
+		coalescer,
 		h,
 		keys,
 		scopes,
@@ -272,6 +278,7 @@ func main() {
 	if err := srv.Shutdown(shutdownCtx); err != nil {
 		log.Printf("server shutdown error: %v", err)
 	}
+	coalescer.Flush(shutdownCtx)
 }
 
 // getEnv returns the value of an env var and logs a warning if it is unset.