71 lines
1.7 KiB
Go
71 lines
1.7 KiB
Go
package json
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
|
|
ctyjson "github.com/zclconf/go-cty/cty/json"
|
|
|
|
"github.com/hashicorp/terraform/internal/plans"
|
|
"github.com/hashicorp/terraform/internal/states"
|
|
"github.com/hashicorp/terraform/internal/tfdiags"
|
|
)
|
|
|
|
type Output struct {
|
|
Sensitive bool `json:"sensitive"`
|
|
Type json.RawMessage `json:"type,omitempty"`
|
|
Value json.RawMessage `json:"value,omitempty"`
|
|
Action ChangeAction `json:"action,omitempty"`
|
|
}
|
|
|
|
type Outputs map[string]Output
|
|
|
|
func OutputsFromMap(outputValues map[string]*states.OutputValue) (Outputs, tfdiags.Diagnostics) {
|
|
var diags tfdiags.Diagnostics
|
|
|
|
outputs := make(map[string]Output, len(outputValues))
|
|
|
|
for name, ov := range outputValues {
|
|
unmarked, _ := ov.Value.UnmarkDeep()
|
|
value, err := ctyjson.Marshal(unmarked, unmarked.Type())
|
|
if err != nil {
|
|
diags = diags.Append(tfdiags.Sourceless(
|
|
tfdiags.Error,
|
|
fmt.Sprintf("Error serializing output %q", name),
|
|
fmt.Sprintf("Error: %s", err),
|
|
))
|
|
return nil, diags
|
|
}
|
|
valueType, err := ctyjson.MarshalType(unmarked.Type())
|
|
if err != nil {
|
|
diags = diags.Append(err)
|
|
return nil, diags
|
|
}
|
|
|
|
outputs[name] = Output{
|
|
Sensitive: ov.Sensitive,
|
|
Type: json.RawMessage(valueType),
|
|
Value: json.RawMessage(value),
|
|
}
|
|
}
|
|
|
|
return outputs, nil
|
|
}
|
|
|
|
func OutputsFromChanges(changes []*plans.OutputChangeSrc) Outputs {
|
|
outputs := make(map[string]Output, len(changes))
|
|
|
|
for _, change := range changes {
|
|
outputs[change.Addr.OutputValue.Name] = Output{
|
|
Sensitive: change.Sensitive,
|
|
Action: changeAction(change.Action),
|
|
}
|
|
}
|
|
|
|
return outputs
|
|
}
|
|
|
|
func (o Outputs) String() string {
|
|
return fmt.Sprintf("Outputs: %d", len(o))
|
|
}
|