From 6594e3de273c32a603ba347b2945d003e4435e49 Mon Sep 17 00:00:00 2001 From: Yaacov Akiba Slama Date: Mon, 19 Sep 2022 20:47:21 +0300 Subject: [PATCH] Convert between int64 (in postgresql) and uint64 (short channel id) --- db.go | 6 +++--- forwarding_history.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/db.go b/db.go index 131a019..b4b8ea6 100644 --- a/db.go +++ b/db.go @@ -90,7 +90,7 @@ func insertChannel(chanID uint64, channelPoint string, nodeID []byte, lastUpdate } _, err := pgxPool.Exec(context.Background(), - query, chanID, channelPoint, nodeID, lastUpdate) + query, int64(chanID), channelPoint, nodeID, lastUpdate) if err != nil { return fmt.Errorf("insertChannel(%v, %s, %x) error: %w", chanID, channelPoint, nodeID, err) @@ -115,14 +115,14 @@ func confirmedChannels(sNodeID string) (map[string]uint64, error) { chans := make(map[string]uint64) for rows.Next() { var ( - chanID uint64 + chanID int64 channelPoint string ) err = rows.Scan(&chanID, &channelPoint) if err != nil { return nil, fmt.Errorf("channels(%x) rows.Scan error: %w", nodeID, err) } - chans[channelPoint] = chanID + chans[channelPoint] = uint64(chanID) } return chans, rows.Err() } diff --git a/forwarding_history.go b/forwarding_history.go index 4a98caa..9ad9066 100644 --- a/forwarding_history.go +++ b/forwarding_history.go @@ -28,7 +28,7 @@ func (cfe *copyFromEvents) Values() ([]interface{}, error) { event := cfe.events[cfe.idx] values := []interface{}{ event.TimestampNs, - event.ChanIdIn, event.ChanIdOut, + int64(event.ChanIdIn), int64(event.ChanIdOut), event.AmtInMsat, event.AmtOutMsat} return values, nil }