manifest & model etag

pkg/bdb/migrate/mig003/migrate.go

@@ -3,8 +3,10 @@ package mig003
 import (
 	"bytes"
 	"context"
+	"hash/fnv"
 	"os"
 	"path/filepath"
+	"strconv"
 
 	"github.com/aserto-dev/azm/migrate"
 	v3 "github.com/aserto-dev/azm/v3"
@@ -91,8 +93,13 @@ func createModel() func(*zerolog.Logger, *bolt.DB, *bolt.DB) error {
 			return err
 		}
 
+		h := fnv.New64a()
+		h.Reset()
+		_, _ = h.Write(manifestBuf.Bytes())
+
 		md := &dsm3.Metadata{
 			UpdatedAt: timestamppb.Now(),
+			Etag:      strconv.FormatUint(h.Sum64(), 10),
 		}
 		if err := rwDB.Update(func(tx *bolt.Tx) error {
 			if err := ds.Manifest(md).Set(ctx, tx, manifestBuf); err != nil {

pkg/ds/manifest.go

@@ -84,6 +84,12 @@ func (m *manifest) Set(ctx context.Context, tx *bolt.Tx, buf *bytes.Buffer) erro
 // SetModel, persists the model cache in the _manifest bucket
 // _metadata/{name}/{version}/model.
 func (m *manifest) SetModel(ctx context.Context, tx *bolt.Tx, mod *model.Model) error {
+	if mod.Metadata == nil {
+		mod.Metadata = &model.Metadata{}
+	}
+	mod.Metadata.ETag = m.Metadata.Etag
+	mod.Metadata.UpdatedAt = m.Metadata.UpdatedAt.AsTime()
+
 	if _, err := bdb.SetAny[model.Model](ctx, tx, bdb.ManifestPath, bdb.ModelKey, mod); err != nil {
 		return err
 	}