Add action_response field into .fleet-actions-results (#796)

elastic · Oct 21, 2021 · 730835d · 730835d
1 parent 5c1d81f
commit 730835d
Show file tree

Hide file tree

Showing 5 changed files with 46 additions and 21 deletions.
diff --git a/cmd/fleet/handleAck.go b/cmd/fleet/handleAck.go
@@ -163,13 +163,14 @@ func (ack *AckT) handleAckEvents(ctx context.Context, agent *model.Agent, events
 		}
 
 		acr := model.ActionResult{
-			ActionId:    ev.ActionId,
-			AgentId:     agent.Id,
-			StartedAt:   ev.StartedAt,
-			CompletedAt: ev.CompletedAt,
-			ActionData:  ev.ActionData,
-			Data:        ev.Data,
-			Error:       ev.Error,
+			ActionId:       ev.ActionId,
+			AgentId:        agent.Id,
+			StartedAt:      ev.StartedAt,
+			CompletedAt:    ev.CompletedAt,
+			ActionData:     ev.ActionData,
+			ActionResponse: ev.ActionResponse,
+			Data:           ev.Data,
+			Error:          ev.Error,
 		}
 		if _, err := dl.CreateActionResult(ctx, ack.bulk, acr); err != nil {
 			return errors.Wrap(err, "create action result")

diff --git a/cmd/fleet/schema.go b/cmd/fleet/schema.go
@@ -102,20 +102,21 @@ type ActionResp struct {
 }
 
 type Event struct {
-	Type        string          `json:"type"`
-	SubType     string          `json:"subtype"`
-	AgentId     string          `json:"agent_id"`
-	ActionId    string          `json:"action_id"`
-	PolicyId    string          `json:"policy_id"`
-	StreamId    string          `json:"stream_id"`
-	Timestamp   string          `json:"timestamp"`
-	Message     string          `json:"message"`
-	Payload     json.RawMessage `json:"payload,omitempty"`
-	StartedAt   string          `json:"started_at"`
-	CompletedAt string          `json:"completed_at"`
-	ActionData  json.RawMessage `json:"action_data,omitempty"`
-	Data        json.RawMessage `json:"data,omitempty"`
-	Error       string          `json:"error,omitempty"`
+	Type           string          `json:"type"`
+	SubType        string          `json:"subtype"`
+	AgentId        string          `json:"agent_id"`
+	ActionId       string          `json:"action_id"`
+	PolicyId       string          `json:"policy_id"`
+	StreamId       string          `json:"stream_id"`
+	Timestamp      string          `json:"timestamp"`
+	Message        string          `json:"message"`
+	Payload        json.RawMessage `json:"payload,omitempty"`
+	StartedAt      string          `json:"started_at"`
+	CompletedAt    string          `json:"completed_at"`
+	ActionData     json.RawMessage `json:"action_data,omitempty"`
+	ActionResponse json.RawMessage `json:"action_response,omitempty"`
+	Data           json.RawMessage `json:"data,omitempty"`
+	Error          string          `json:"error,omitempty"`
 }
 
 type StatusResponse struct {

diff --git a/internal/pkg/es/mapping.go b/internal/pkg/es/mapping.go
diff --git a/internal/pkg/model/schema.go b/internal/pkg/model/schema.go
diff --git a/model/schema.json b/model/schema.json
@@ -97,6 +97,11 @@
           "type": "object",
           "format": "raw"
         },
+        "action_response": {
+          "description": "The custom action response payload.",
+          "type": "object",
+          "format": "raw"
+        },
         "error": {
           "description": "The action error message.",
           "type": "string"