logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-03 22:53:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: insert peerID

Browse Source
This commit is contained in:
Richard Ramos 2024-05-28 16:15:23 -04:00
parent dc03b2b911
commit 255a6b2010
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/persistence/database.go
View File

@ -9,6 +9,7 @@ import (
"github.com/libp2p/go-libp2p/core/peer" "github.com/libp2p/go-libp2p/core/peer"
"github.com/waku-org/go-waku/waku/v2/protocol/pb" "github.com/waku-org/go-waku/waku/v2/protocol/pb"
"github.com/waku-org/go-waku/waku/v2/timesource" "github.com/waku-org/go-waku/waku/v2/timesource"
"github.com/waku-org/go-waku/waku/v2/utils"
"go.uber.org/zap" "go.uber.org/zap"
) )
@ -260,7 +261,7 @@ func (d *DBStore) RecordMessage(uuid string, tx *sql.Tx, msgHash pb.MessageHash,
now := time.Now().UnixNano() now := time.Now().UnixNano()
for _, s := range storenodes { for _, s := range storenodes {
_, err := stmt.Exec(uuid, clusterID, topic, msgHash.String(), timestamp, s.Addrs[0].String(), status, now) _, err := stmt.Exec(uuid, clusterID, topic, msgHash.String(), timestamp, utils.EncapsulatePeerID(s.ID, s.Addrs[0])[0].String(), status, now)
if err != nil { if err != nil {
return err return err
} }
@ -277,7 +278,7 @@ func (d *DBStore) RecordStorenodeUnavailable(uuid string, storenode peer.AddrInf
defer stmt.Close() defer stmt.Close()
now := time.Now().UnixNano() now := time.Now().UnixNano()
_, err = stmt.Exec(uuid, storenode.Addrs[0].String(), now) _, err = stmt.Exec(uuid, utils.EncapsulatePeerID(storenode.ID, storenode.Addrs[0])[0].String(), now)
if err != nil { if err != nil {
return err return err
} }