From f636fc3f7e338b6e1a031a23d83a7a56c70beee7 Mon Sep 17 00:00:00 2001 From: Kpa-clawbot <259247574+Kpa-clawbot@users.noreply.github.com> Date: Fri, 27 Mar 2026 22:58:11 -0700 Subject: [PATCH] =?UTF-8?q?fix:=20InsertTransmission=20returns=202=20value?= =?UTF-8?q?s=20=E2=80=94=20handle=20isNew=20at=20all=20call=20sites?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com> --- cmd/ingestor/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/ingestor/main.go b/cmd/ingestor/main.go index dc2a32e..60c1c94 100644 --- a/cmd/ingestor/main.go +++ b/cmd/ingestor/main.go @@ -332,7 +332,7 @@ func handleMessage(store *Store, tag string, source MQTTSource, m mqtt.Message, DecodedJSON: string(decodedJSON), } - if err := store.InsertTransmission(pktData); err != nil { + if _, err := store.InsertTransmission(pktData); err != nil { log.Printf("MQTT [%s] channel insert error: %v", tag, err) } @@ -409,7 +409,7 @@ func handleMessage(store *Store, tag string, source MQTTSource, m mqtt.Message, DecodedJSON: string(decodedJSON), } - if err := store.InsertTransmission(pktData); err != nil { + if _, err := store.InsertTransmission(pktData); err != nil { log.Printf("MQTT [%s] DM insert error: %v", tag, err) }