status-im/go-waku
2
0
Fork 0
mirror of https://github.com/status-im/go-waku.git synced 2025-01-15 00:04:36 +00:00
Code Issues Projects Releases Wiki Activity

fix: lint and unclosed prepared stmt

Browse Source
This commit is contained in:
Richard Ramos 2022-05-27 14:34:13 -04:00
parent 0c989d3d8c
commit 56c8ef705a
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbutils/insert.go
View File

@ -23,8 +23,6 @@ func genRandomTimestamp(now int64, last30d int64) int64 {
return rand.Int63n(last30d) + now return rand.Int63n(last30d) + now
} }
const letterBytes = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
func genRandomContentTopic(n int) string { func genRandomContentTopic(n int) string {
topics := []string{"topic1", "topic2", "topic3", "topic4", "topic5"} topics := []string{"topic1", "topic2", "topic3", "topic4", "topic5"}
i := n % 5 i := n % 5
@ -70,6 +68,10 @@ func main() {
fmt.Println("Inserting ", N, " records in ", dbName) fmt.Println("Inserting ", N, " records in ", dbName)
db, err := newdb(dbName) db, err := newdb(dbName)
if err != nil {
panic(err)
}
query := "INSERT INTO message (id, receiverTimestamp, senderTimestamp, contentTopic, pubsubTopic, payload, version) VALUES (?, ?, ?, ?, ?, ?, ?)" query := "INSERT INTO message (id, receiverTimestamp, senderTimestamp, contentTopic, pubsubTopic, payload, version) VALUES (?, ?, ?, ?, ?, ?, ?)"
err = createTable(db) err = createTable(db)

5
waku/persistence/store.go
View File

@ -158,6 +158,11 @@ func (d *DBStore) Put(cursor *pb.Index, pubsubTopic string, message *pb.WakuMess
return err return err
} }
err = stmt.Close()
if err != nil {
return err
}
return nil return nil
} }