* added createdAt and modifiedAt params to upsert function in apply

Feature #661
kumahq · Apr 15, 2020 · 2701594 · 2701594
1 parent f57aa4f
commit 2701594
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/app/kumactl/cmd/apply/apply.go b/app/kumactl/cmd/apply/apply.go
@@ -110,7 +110,7 @@ func NewApplyCmd(pctx *kumactl_cmd.RootContext) *cobra.Command {
 				return err
 			}
 
-			if err := upsert(rs, res); err != nil {
+			if err := upsert(pctx.Now(), rs, res); err != nil {
 				return err
 			}
 			return nil
@@ -154,23 +154,23 @@ func processConfigTemplate(config string, values map[string]string) ([]byte, err
 	return []byte(data), nil
 }
 
-func upsert(rs store.ResourceStore, res model.Resource) error {
+func upsert(now time.Time, rs store.ResourceStore, res model.Resource) error {
 	newRes, err := registry.Global().NewObject(res.GetType())
 	if err != nil {
 		return err
 	}
 	meta := res.GetMeta()
 	if err := rs.Get(context.Background(), newRes, store.GetByKey(meta.GetName(), meta.GetMesh())); err != nil {
 		if store.IsResourceNotFound(err) {
-			return rs.Create(context.Background(), res, store.CreateByKey(meta.GetName(), meta.GetMesh()))
+			return rs.Create(context.Background(), res, store.CreateByKey(meta.GetName(), meta.GetMesh()), store.CreatedAt(now))
 		} else {
 			return err
 		}
 	}
 	if err := newRes.SetSpec(res.GetSpec()); err != nil {
 		return err
 	}
-	return rs.Update(context.Background(), newRes)
+	return rs.Update(context.Background(), newRes, store.ModifiedAt(now))
 }
 
 func parseResource(bytes []byte) (model.Resource, error) {