services/syncbase/server/store_util.go

// Copyright 2015 The Vanadium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package server

import (
	"strconv"

	"v.io/v23/rpc"
	"v.io/v23/verror"
	"v.io/v23/vom"

	"v.io/syncbase/x/ref/services/syncbase/store"
)

func getObject(st store.Store, k string, v interface{}) error {
	bytes, err := st.Get(k)
	if err != nil {
		return err
	}
	return vom.Decode(bytes, v)
}

func putObject(st store.Store, k string, v interface{}) error {
	bytes, err := vom.Encode(v)
	if err != nil {
		return err
	}
	return st.Put(k, bytes)
}

func formatVersion(version uint64) string {
	return strconv.FormatUint(version, 10)
}

func checkVersion(call rpc.ServerCall, presented string, actual uint64) error {
	if presented != "" && presented != formatVersion(actual) {
		return verror.NewErrBadVersion(call.Context())
	}
	return nil
}