Merge pull request #353 from flanksource/feat/custom-properties

feat: transform properties

api/v1/common.go

@@ -161,8 +161,14 @@ type BaseScraper struct {
 
 	// DeleteFields is a JSONPath expression used to identify the deleted time of the config.
 	// If multiple fields are specified, the first non-empty value will be used.
-	DeleteFields []string      `json:"deleteFields,omitempty"`
-	Tags         JSONStringMap `json:"tags,omitempty"`
+	DeleteFields []string `json:"deleteFields,omitempty"`
+
+	// Tags allow you to set custom tags on the scraped config items.
+	Tags JSONStringMap `json:"tags,omitempty"`
+
+	// Properties are custom templatable properties for the scraped config items
+	// grouped by the config type.
+	Properties map[string]types.Properties `json:"properties,omitempty" template:"true"`
 }
 
 func (base BaseScraper) String() string {

api/v1/interface.go

@@ -8,6 +8,7 @@ import (
 
 	"github.com/flanksource/commons/logger"
 	"github.com/flanksource/duty/models"
+	"github.com/flanksource/duty/types"
 )
 
 // Analyzer ...
@@ -230,6 +231,23 @@ type ScrapeResult struct {
 	Action              string              `json:",omitempty"`
 	ParentExternalID    string              `json:"-"`
 	ParentType          string              `json:"-"`
+	Properties          types.Properties    `json:"properties,omitempty"`
+}
+
+func (s ScrapeResult) AsMap() map[string]any {
+	output := make(map[string]any)
+
+	b, err := json.Marshal(s)
+	if err != nil {
+		logger.Errorf("failed to marshal change result: %v", err)
+		return output
+	}
+
+	if err := json.Unmarshal(b, &output); err != nil {
+		logger.Errorf("failed to unmarshal change result: %v", err)
+	}
+
+	return output
 }
 
 func NewScrapeResult(base BaseScraper) *ScrapeResult {