update

Author: steiler

pkg/datastore/datastore_rpc.go

@@ -275,7 +275,7 @@ func (d *Datastore) Sync(ctx context.Context) {
 }
 
 func (d *Datastore) writeToSyncTreeCandidate(ctx context.Context, updates []*sdcpb.Update, ts int64) error {
-	upds, err := treetypes.ExpandAndConvertIntent(ctx, d.schemaClient, tree.RunningIntentName, tree.RunningValuesPrio, updates)
+	upds, err := treetypes.ExpandAndConvertIntent(ctx, d.schemaClient, tree.RunningIntentName, tree.RunningValuesPrio, updates, ts)
 	if err != nil {
 		return err
 	}

pkg/datastore/transaction_rpc.go

@@ -40,7 +40,7 @@ func (d *Datastore) SdcpbTransactionIntentToInternalTI(ctx context.Context, req
 	}
 
 	// convert the sdcpb.updates to tree.UpdateSlice
-	Updates, err := treetypes.ExpandAndConvertIntent(ctx, d.schemaClient, req.GetIntent(), req.GetPriority(), req.GetUpdate())
+	Updates, err := treetypes.ExpandAndConvertIntent(ctx, d.schemaClient, req.GetIntent(), req.GetPriority(), req.GetUpdate(), time.Now().Unix())
 	if err != nil {
 		return nil, err
 	}

pkg/tree/types/update.go

@@ -95,7 +95,7 @@ func (u *Update) GetPathSlice() PathSlice {
 }
 
 // ExpandAndConvertIntent takes a slice of Updates ([]*sdcpb.Update) and converts it into a tree.UpdateSlice, that contains *treetypes.Updates.
-func ExpandAndConvertIntent(ctx context.Context, scb utils.SchemaClientBound, intentName string, priority int32, upds []*sdcpb.Update) (UpdateSlice, error) {
+func ExpandAndConvertIntent(ctx context.Context, scb utils.SchemaClientBound, intentName string, priority int32, upds []*sdcpb.Update, ts int64) (UpdateSlice, error) {
 	converter := utils.NewConverter(scb)
 
 	// list of updates to be added to the cache
@@ -115,7 +115,7 @@ func ExpandAndConvertIntent(ctx context.Context, scb utils.SchemaClientBound, in
 		}
 
 		// construct the cache.Update
-		newCacheUpdates = append(newCacheUpdates, NewUpdate(pathslice, u.GetValue(), priority, intentName, 0))
+		newCacheUpdates = append(newCacheUpdates, NewUpdate(pathslice, u.GetValue(), priority, intentName, ts))
 	}
 	return newCacheUpdates, nil
 }