stakey/vspd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Serialize record before creating bucket

Browse Source
This commit is contained in:
jholdstock 2020-09-07 09:19:04 +01:00 committed by David Hill
parent 825a717ca7
commit fedd2cd784
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
database/votechange.go
View File

@ -24,10 +24,17 @@ type VoteChangeRecord struct {
// SaveVoteChange will insert the provided vote change record into the database,
// and if this breaches the maximum amount of allowed records, delete the oldest
// one which is currently stored.
// one which is currently stored. Records are stored using a serially increasing
// integer as the key.
func (vdb *VspDatabase) SaveVoteChange(ticketHash string, record VoteChangeRecord) error {
return vdb.db.Update(func(tx *bolt.Tx) error {
// Serialize record for storage in the database.
recordBytes, err := json.Marshal(record)
if err != nil {
return fmt.Errorf("could not marshal vote change record: %v", err)
}
// Create or get a bucket for this ticket.
bkt, err := tx.Bucket(vspBktK).Bucket(voteChangeBktK).
CreateBucketIfNotExists([]byte(ticketHash))
@ -36,14 +43,6 @@ func (vdb *VspDatabase) SaveVoteChange(ticketHash string, record VoteChangeRecor
ticketHash, err)
}
// Serialize record for storage in the database.
recordBytes, err := json.Marshal(record)
if err != nil {
return fmt.Errorf("could not marshal vote change record: %v", err)
}
// Records are stored using a serially increasing integer as the key.
// Loop through the bucket to count the records, as well as finding the
// most recent and the oldest record.
var count int