Convert between int64 (in postgresql) and uint64 (short channel id)

This commit is contained in:
Yaacov Akiba Slama
2022-09-19 20:47:21 +03:00
parent e16541c77d
commit 6594e3de27
2 changed files with 4 additions and 4 deletions

6
db.go
View File

@@ -90,7 +90,7 @@ func insertChannel(chanID uint64, channelPoint string, nodeID []byte, lastUpdate
} }
_, err := pgxPool.Exec(context.Background(), _, err := pgxPool.Exec(context.Background(),
query, chanID, channelPoint, nodeID, lastUpdate) query, int64(chanID), channelPoint, nodeID, lastUpdate)
if err != nil { if err != nil {
return fmt.Errorf("insertChannel(%v, %s, %x) error: %w", return fmt.Errorf("insertChannel(%v, %s, %x) error: %w",
chanID, channelPoint, nodeID, err) chanID, channelPoint, nodeID, err)
@@ -115,14 +115,14 @@ func confirmedChannels(sNodeID string) (map[string]uint64, error) {
chans := make(map[string]uint64) chans := make(map[string]uint64)
for rows.Next() { for rows.Next() {
var ( var (
chanID uint64 chanID int64
channelPoint string channelPoint string
) )
err = rows.Scan(&chanID, &channelPoint) err = rows.Scan(&chanID, &channelPoint)
if err != nil { if err != nil {
return nil, fmt.Errorf("channels(%x) rows.Scan error: %w", nodeID, err) return nil, fmt.Errorf("channels(%x) rows.Scan error: %w", nodeID, err)
} }
chans[channelPoint] = chanID chans[channelPoint] = uint64(chanID)
} }
return chans, rows.Err() return chans, rows.Err()
} }

View File

@@ -28,7 +28,7 @@ func (cfe *copyFromEvents) Values() ([]interface{}, error) {
event := cfe.events[cfe.idx] event := cfe.events[cfe.idx]
values := []interface{}{ values := []interface{}{
event.TimestampNs, event.TimestampNs,
event.ChanIdIn, event.ChanIdOut, int64(event.ChanIdIn), int64(event.ChanIdOut),
event.AmtInMsat, event.AmtOutMsat} event.AmtInMsat, event.AmtOutMsat}
return values, nil return values, nil
} }