From e6d75cab9f4eb36f74338da6ff31c2e922d9636a Mon Sep 17 00:00:00 2001
From: Chris Baker <1675087+cgbaker@users.noreply.github.com>
Date: Thu, 16 Jan 2020 15:32:00 +0000
Subject: [PATCH] wip: was incorrectly parsing ScalingPolicy

---
 jobspec/parse_group.go | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/jobspec/parse_group.go b/jobspec/parse_group.go
index a5f222fda..44b25185e 100644
--- a/jobspec/parse_group.go
+++ b/jobspec/parse_group.go
@@ -328,6 +328,14 @@ func parseScalingPolicy(out **api.ScalingPolicy, list *ast.ObjectList) error {
 	// Get our resource object
 	o := list.Items[0]
 
+	// We need this later
+	var listVal *ast.ObjectList
+	if ot, ok := o.Val.(*ast.ObjectType); ok {
+		listVal = ot.List
+	} else {
+		return fmt.Errorf("should be an object")
+	}
+
 	valid := []string{
 		"policy",
 		"enabled",
@@ -340,6 +348,7 @@ func parseScalingPolicy(out **api.ScalingPolicy, list *ast.ObjectList) error {
 	if err := hcl.DecodeObject(&m, o.Val); err != nil {
 		return err
 	}
+	delete(m, "policy")
 
 	var result api.ScalingPolicy
 	dec, err := mapstructure.NewDecoder(&mapstructure.DecoderConfig{
@@ -353,6 +362,20 @@ func parseScalingPolicy(out **api.ScalingPolicy, list *ast.ObjectList) error {
 		return err
 	}
 
+	// If we have policy, then parse that
+	if o := listVal.Filter("policy"); len(o.Items) > 0 {
+		for _, o := range o.Elem().Items {
+			var m map[string]interface{}
+			if err := hcl.DecodeObject(&m, o.Val); err != nil {
+				return err
+			}
+
+			if err := mapstructure.WeakDecode(m, &result.Policy); err != nil {
+				return err
+			}
+		}
+	}
+
 	*out = &result
 	return nil
 }