arnaucube
arnaucube/go-dvotePublic Self-hosted repository
go-dvote/batch/batch.go
batch/batch.goRaw
 1package batch
 2
 3import (
 4	"github.com/syndtr/goleveldb/leveldb"
 5//	"encoding/json"
 6	"fmt"
 7	"github.com/vocdoni/dvote-relay/types"
 8)
 9
10//add (queue for counting)
11func Add(p types.Packet, bdb *leveldb.DB) error {
12	err := bdb.Put([]byte(fmt.Sprintf("%v", p.Nullifier)),[]byte(fmt.Sprintf("%v", p)), nil)
13	if err != nil {
14		return err
15	}
16	return nil
17}
18
19//create (return batch)
20func Create(bdb *leveldb.DB) []byte {
21	var b []byte
22
23	iter := bdb.NewIterator(nil, nil)
24	for iter.Next() {
25		err := iter.Error()
26		if err != nil {
27			panic(err)
28		}
29		//put p in batch
30		//db.Put(iter.Key(), iter.Val(), nil)
31		//bdb.Delete(iter.Key(), nil)
32	}
33	iter.Release()
34	return b
35}