core: Re-implement EvalWriteDiff to work with new plan types

plans/changes.go

@@ -55,6 +55,15 @@ func (c *Changes) ResourceInstanceDeposed(addr addrs.AbsResourceInstance, key st
 	return nil
 }
 
+// SyncWrapper returns a wrapper object around the receiver that can be used
+// to make certain changes to the receiver in a concurrency-safe way, as long
+// as all callers share the same wrapper object.
+func (c *Changes) SyncWrapper() *ChangesSync {
+	return &ChangesSync{
+		changes: c,
+	}
+}
+
 // ResourceInstanceChange describes a change to a particular resource instance
 // object.
 type ResourceInstanceChange struct {

plans/changes_src.go

@@ -66,6 +66,38 @@ func (rcs *ResourceInstanceChangeSrc) Decode(ty cty.Type) (*ResourceInstanceChan
 	}, nil
 }
 
+// DeepCopy creates a copy of the receiver where any pointers to nested mutable
+// values are also copied, thus ensuring that future mutations of the receiver
+// will not affect the copy.
+//
+// Some types used within a resource change are immutable by convention even
+// though the Go language allows them to be mutated, such as the types from
+// the addrs package. These are _not_ copied by this method, under the
+// assumption that callers will behave themselves.
+func (rcs *ResourceInstanceChangeSrc) DeepCopy() *ResourceInstanceChangeSrc {
+	if rcs == nil {
+		return nil
+	}
+	ret := *rcs
+
+	if len(ret.RequiredReplace) != 0 {
+		rr := make([]cty.Path, len(ret.RequiredReplace))
+		copy(rr, ret.RequiredReplace)
+		ret.RequiredReplace = rr
+	}
+
+	if len(ret.Private) != 0 {
+		private := make([]byte, len(ret.Private))
+		copy(private, ret.Private)
+		ret.Private = private
+	}
+
+	ret.ChangeSrc.Before = ret.ChangeSrc.Before.Copy()
+	ret.ChangeSrc.After = ret.ChangeSrc.After.Copy()
+
+	return &ret
+}
+
 // OutputChange describes a change to an output value.
 type OutputChangeSrc struct {
 	// ChangeSrc is an embedded description of the not-yet-decoded change.

plans/changes_sync.go

@@ -16,3 +16,20 @@ type ChangesSync struct {
 	lock    sync.Mutex
 	changes *Changes
 }
+
+// AppendResourceInstanceChange records the given resource instance change in
+// the set of planned resource changes.
+//
+// The caller must ensure that there are no concurrent writes to the given
+// change while this method is running, but it is safe to resume mutating
+// it after this method returns without affecting the saved change.
+func (cs *ChangesSync) AppendResourceInstanceChange(changeSrc *ResourceInstanceChangeSrc) {
+	if cs == nil {
+		panic("AppendResourceInstanceChange on nil ChangesSync")
+	}
+	cs.lock.Lock()
+	defer cs.lock.Unlock()
+
+	s := changeSrc.DeepCopy()
+	cs.changes.Resources = append(cs.changes.Resources, s)
+}

plans/dynamic_value.go

@@ -83,3 +83,14 @@ func (v DynamicValue) Decode(ty cty.Type) (cty.Value, error) {
 func (v DynamicValue) ImpliedType() (cty.Type, error) {
 	return ctymsgpack.ImpliedType([]byte(v))
 }
+
+// Copy produces a copy of the receiver with a distinct backing array.
+func (v DynamicValue) Copy() DynamicValue {
+	if len(v) == 0 {
+		return nil
+	}
+
+	ret := make(DynamicValue, len(v))
+	copy(ret, v)
+	return ret
+}

terraform/context.go

@@ -718,6 +718,7 @@ func (c *Context) graphWalker(operation walkOperation) *ContextGraphWalker {
 	return &ContextGraphWalker{
 		Context:            c,
 		State:              c.state.SyncWrapper(),
+		Changes:            c.changes.SyncWrapper(),
 		Operation:          operation,
 		StopContext:        c.runContext,
 		RootVariableValues: c.variables,

terraform/eval_diff.go

@@ -734,39 +734,38 @@ func (n *EvalReadDiff) Eval(ctx EvalContext) (interface{}, error) {
 type EvalWriteDiff struct {
 	Addr           addrs.ResourceInstance
 	DeposedKey     states.DeposedKey
+	ProviderSchema **ProviderSchema
 	Change         **plans.ResourceInstanceChange
 }
 
 // TODO: test
 func (n *EvalWriteDiff) Eval(ctx EvalContext) (interface{}, error) {
-	return nil, fmt.Errorf("EvalWriteDiff not yet updated for new plan types")
+	providerSchema := *n.ProviderSchema
-	/*
+	change := *n.Change
-		diff, lock := ctx.Diff()
 
-		// The diff to write, if its empty it should write nil
+	if change.Addr.String() != n.Addr.String() || change.DeposedKey != n.DeposedKey {
-		var diffVal *InstanceDiff
+		// Should never happen, and indicates a bug in the caller.
-		if n.Diff != nil {
+		panic("inconsistent address and/or deposed key in EvalWriteDiff")
-			diffVal = *n.Diff
-		}
-		if diffVal.Empty() {
-			diffVal = nil
 	}
 
-		// Acquire the lock so that we can do this safely concurrently
+	schema := providerSchema.ResourceTypes[n.Addr.Resource.Type]
-		lock.Lock()
+	if schema == nil {
-		defer lock.Unlock()
+		// Should be caught during validation, so we don't bother with a pretty error here
-
+		return nil, fmt.Errorf("provider does not support resource type %q", n.Addr.Resource.Type)
-		// Write the diff
-		modDiff := diff.ModuleByPath(ctx.Path())
-		if modDiff == nil {
-			modDiff = diff.AddModule(ctx.Path())
 	}
-		if diffVal != nil {
+
-			modDiff.Resources[n.Name] = diffVal
+	csrc, err := change.Encode(schema.ImpliedType())
+	if err != nil {
+		return nil, fmt.Errorf("failed to encode planned changes for %s: %s", n.Addr, err)
+	}
+
+	changes := ctx.Changes()
+	changes.AppendResourceInstanceChange(csrc)
+	if n.DeposedKey == states.NotDeposed {
+		log.Printf("[TRACE] EvalWriteDiff: recorded %s change for %s", change.Action, n.Addr)
 	} else {
-			delete(modDiff.Resources, n.Name)
+		log.Printf("[TRACE] EvalWriteDiff: recorded %s change for %s deposed object %s", change.Action, n.Addr, n.DeposedKey)
 	}
 
 	return nil, nil
-	*/
 }

terraform/node_resource_apply.go

@@ -182,6 +182,7 @@ func (n *NodeApplyableResourceInstance) evalTreeDataResource(addr addrs.AbsResou
 			// later nodes won't see a diff that's now a no-op.
 			&EvalWriteDiff{
 				Addr:           addr.Resource,
+				ProviderSchema: &providerSchema,
 				Change:         nil,
 			},
 
@@ -348,6 +349,7 @@ func (n *NodeApplyableResourceInstance) evalTreeManagedResource(addr addrs.AbsRe
 			// is no longer a diff!
 			&EvalWriteDiff{
 				Addr:           addr.Resource,
+				ProviderSchema: &providerSchema,
 				Change:         nil,
 			},
 

terraform/node_resource_plan_destroy.go

@@ -79,6 +79,7 @@ func (n *NodePlanDestroyableResourceInstance) EvalTree() EvalNode {
 			},
 			&EvalWriteDiff{
 				Addr:           addr.Resource,
+				ProviderSchema: &providerSchema,
 				Change:         &change,
 			},
 		},

terraform/node_resource_plan_instance.go

@@ -100,6 +100,7 @@ func (n *NodePlannableResourceInstance) evalTreeDataResource(addr addrs.AbsResou
 
 			&EvalWriteDiff{
 				Addr:           addr.Resource,
+				ProviderSchema: &providerSchema,
 				Change:         &change,
 			},
 		},
@@ -158,6 +159,7 @@ func (n *NodePlannableResourceInstance) evalTreeManagedResource(addr addrs.AbsRe
 			},
 			&EvalWriteDiff{
 				Addr:           addr.Resource,
+				ProviderSchema: &providerSchema,
 				Change:         &change,
 			},
 		},

terraform/node_resource_plan_orphan.go

@@ -69,6 +69,7 @@ func (n *NodePlannableResourceInstanceOrphan) EvalTree() EvalNode {
 			},
 			&EvalWriteDiff{
 				Addr:           addr.Resource,
+				ProviderSchema: &providerSchema,
 				Change:         &change,
 			},
 			&EvalWriteState{