refresh-groups.go

package tag_api

import (
	"bytes"
	"encoding/gob"
	"fmt"

	"github.com/boltdb/bolt"
)

// Refresh data loaded from Bolt Db

func (bs *BoltService) refreshGroups() {
	var err error

	// Refresh images
	err = bs.boltDb.View(func(tx *bolt.Tx) (e error) {
		var bucket *bolt.Bucket
		var v, k []byte

		bucket = tx.Bucket(bs.settings.boltBucket)
		if bucket == nil {
			e = fmt.Errorf("Bolt bucket %s not found", bs.settings.boltBucket)
			return
		}
		k = []byte("groups")

		v = bucket.Get(k)
		if v == nil {
			e = fmt.Errorf("Bolt key %s not found", k)
			return
		}

		b := bytes.NewBuffer(v)
		dec := gob.NewDecoder(b)

		e = dec.Decode(&bs.GroupMap)
		if e != nil {
			e = fmt.Errorf("Parse GroupMap gob from Bolt: %v", e)
			return
		}
		return
	})

	if err != nil {
		Log.Error.Printf("Refresh Groups: %v\n", err)
	}

	Log.Info.Printf("Refresh Groups: %d entries loaded from Bolt\n", len(bs.GroupMap))
}