dandri/meshcore-analyzer
1
0
Fork 0
mirror of https://github.com/Kpa-clawbot/meshcore-analyzer.git synced 2026-05-14 20:25:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: InsertTransmission 2-return in db_test.go (13 call sites)

Browse Source 
Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
This commit is contained in:
Kpa-clawbot
2026-03-27 23:01:54 -07:00
parent 573bc011f9
commit 28bb6c5daf
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/ingestor/db_test.go
+13 -13
View File
@@ -83,7 +83,7 @@ func TestInsertTransmission(t *testing.T) {
RSSI: &rssi,
}
if err := s.InsertTransmission(data); err != nil {
if _, err := s.InsertTransmission(data); err != nil {
t.Fatal(err)
}
@@ -101,7 +101,7 @@ func TestInsertTransmission(t *testing.T) {
}
// Verify hash dedup: same hash should not create new transmission
if err := s.InsertTransmission(data); err != nil {
if _, err := s.InsertTransmission(data); err != nil {
t.Fatal(err)
}
s.db.QueryRow("SELECT COUNT(*) FROM transmissions").Scan(&count)
@@ -192,7 +192,7 @@ func TestInsertTransmissionWithObserver(t *testing.T) {
PathJSON: "[]",
DecodedJSON: `{"type":"TXT_MSG"}`,
}
if err := s.InsertTransmission(data); err != nil {
if _, err := s.InsertTransmission(data); err != nil {
t.Fatal(err)
}
@@ -223,7 +223,7 @@ func TestEndToEndIngest(t *testing.T) {
Raw: rawHex,
}
pktData := BuildPacketData(msg, decoded, "obs1", "SJC")
if err := s.InsertTransmission(pktData); err != nil {
if _, err := s.InsertTransmission(pktData); err != nil {
t.Fatal(err)
}
@@ -262,7 +262,7 @@ func TestInsertTransmissionEmptyHash(t *testing.T) {
Timestamp: "2026-03-25T00:00:00Z",
Hash: "", // empty hash → should return nil
}
err = s.InsertTransmission(data)
_, err = s.InsertTransmission(data)
if err != nil {
t.Errorf("empty hash should return nil, got %v", err)
}
@@ -287,7 +287,7 @@ func TestInsertTransmissionEmptyTimestamp(t *testing.T) {
Hash: "emptyts123456789",
RouteType: 2,
}
err = s.InsertTransmission(data)
_, err = s.InsertTransmission(data)
if err != nil {
t.Fatal(err)
}
@@ -313,7 +313,7 @@ func TestInsertTransmissionEarlierFirstSeen(t *testing.T) {
Hash: "firstseen12345678",
RouteType: 2,
}
if err := s.InsertTransmission(data); err != nil {
if _, err := s.InsertTransmission(data); err != nil {
t.Fatal(err)
}
@@ -324,7 +324,7 @@ func TestInsertTransmissionEarlierFirstSeen(t *testing.T) {
Hash: "firstseen12345678", // same hash
RouteType: 2,
}
if err := s.InsertTransmission(data2); err != nil {
if _, err := s.InsertTransmission(data2); err != nil {
t.Fatal(err)
}
@@ -348,7 +348,7 @@ func TestInsertTransmissionLaterFirstSeenNotUpdated(t *testing.T) {
Hash: "notupdated1234567",
RouteType: 2,
}
if err := s.InsertTransmission(data); err != nil {
if _, err := s.InsertTransmission(data); err != nil {
t.Fatal(err)
}
@@ -359,7 +359,7 @@ func TestInsertTransmissionLaterFirstSeenNotUpdated(t *testing.T) {
Hash: "notupdated1234567",
RouteType: 2,
}
if err := s.InsertTransmission(data2); err != nil {
if _, err := s.InsertTransmission(data2); err != nil {
t.Fatal(err)
}
@@ -385,7 +385,7 @@ func TestInsertTransmissionNilSNRRSSI(t *testing.T) {
SNR: nil,
RSSI: nil,
}
err = s.InsertTransmission(data)
_, err = s.InsertTransmission(data)
if err != nil {
t.Fatal(err)
}
@@ -544,13 +544,13 @@ func TestInsertTransmissionDedupObservation(t *testing.T) {
RouteType: 2,
PathJSON: "[]",
}
if err := s.InsertTransmission(data); err != nil {
if _, err := s.InsertTransmission(data); err != nil {
t.Fatal(err)
}
// Insert same hash again with same observer (no observerID) —
// the UNIQUE constraint on observations dedup should handle it
if err := s.InsertTransmission(data); err != nil {
if _, err := s.InsertTransmission(data); err != nil {
t.Fatal(err)
}