wip on manual step integration

Author: RabbITCybErSeC

backend/soarca/helper.go

@@ -1,6 +1,7 @@
 package soarca
 
 import (
+	"bytes"
 	"context"
 	"encoding/json"
 	"fmt"
@@ -14,7 +15,6 @@ const (
 )
 
 func fetchToJson(client *http.Client, url string, target interface{}) error {
-
 	ctx, cancel := context.WithTimeout(context.Background(), timeout*time.Millisecond)
 	defer cancel()
 
@@ -58,3 +58,37 @@ func fetch(ctx context.Context, client *http.Client, url string) ([]byte, error)
 
 	return body, nil
 }
+
+func postJson(client *http.Client, url string, payload interface{}) error {
+	ctx, cancel := context.WithTimeout(context.Background(), timeout*time.Millisecond)
+	defer cancel()
+
+	return postJsonWithContext(ctx, client, url, payload)
+}
+
+func postJsonWithContext(ctx context.Context, client *http.Client, url string, payload interface{}) error {
+	jsonData, err := json.Marshal(payload)
+	if err != nil {
+		return fmt.Errorf("failed to marshal payload: %w", err)
+	}
+
+	req, err := http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewBuffer(jsonData))
+	if err != nil {
+		return fmt.Errorf("failed to create request: %w", err)
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+
+	response, err := client.Do(req)
+	if err != nil {
+		return fmt.Errorf("failed to make POST request: %w", err)
+	}
+	defer response.Body.Close()
+
+	if response.StatusCode != http.StatusOK {
+		body, _ := io.ReadAll(response.Body)
+		return fmt.Errorf("unexpected status code: %d, body: %s", response.StatusCode, string(body))
+	}
+
+	return nil
+}

backend/soarca/manual.go

@@ -0,0 +1,61 @@
+package soarca
+
+import (
+	"encoding/json"
+	"fmt"
+	"net/http"
+	models "soarca-gui/models/manual"
+)
+
+const (
+	manualPath = "/manual"
+)
+
+type Manual struct {
+	Host   string
+	client *http.Client
+}
+
+func NewManual(host string, client *http.Client) *Manual {
+	return &Manual{Host: host, client: client}
+}
+
+func (m *Manual) GetManualActions() ([]models.ManualAction, error) {
+	url := fmt.Sprintf("%s%s", m.Host, manualPath)
+	var actions []models.ManualAction
+	err := fetchToJson(m.client, url, &actions)
+	if err != nil {
+		return nil, fmt.Errorf("failed to fetch manual actions: %w", err)
+	}
+	return actions, nil
+}
+
+func (m *Manual) GetManualActionByIDs(executionID, stepID string) (*models.ManualAction, error) {
+	url := fmt.Sprintf("%s%s/%s/%s", m.Host, manualPath, executionID, stepID)
+	var action models.ManualAction
+	err := fetchToJson(m.client, url, &action)
+	if err != nil {
+		return nil, fmt.Errorf("failed to fetch manual action: %w", err)
+	}
+	return &action, nil
+}
+
+func (m *Manual) ContinueManualAction(request models.ManualContinueRequest) error {
+	url := fmt.Sprintf("%s%s/continue", m.Host, manualPath)
+
+	jsonData, err := json.Marshal(request)
+	if err != nil {
+		return fmt.Errorf("failed to marshal continue request: %w", err)
+	}
+
+	err = postJson(url, &request)
+	if err != nil {
+		return nil, fmt.Errorf("failed to fetch manual action: %w", err)
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		return fmt.Errorf("unexpected status code: %d", resp.StatusCode)
+	}
+
+	return nil
+}

handlers/reporting.go

@@ -3,7 +3,6 @@ package handlers
 import (
 	"errors"
 	"net/http"
-
 	"soarca-gui/backend"
 	"soarca-gui/models/reporter"
 	"soarca-gui/utils"
@@ -28,14 +27,12 @@ func (r *reportingHandler) ReportingIndexHandler(context *gin.Context) {
 }
 
 func (r *reportingHandler) ReportingCardSectionHandler(context *gin.Context) {
-
 	reports, err := r.reporter.GetReports()
-
 	if err != nil {
 		metrics := []cards.ReportingCardData{
-			cards.ReportingCardData{Type: cards.Unkown},
-			cards.ReportingCardData{Type: cards.Unkown},
-			cards.ReportingCardData{Type: cards.Unkown},
+			{Type: cards.Unkown},
+			{Type: cards.Unkown},
+			{Type: cards.Unkown},
 		}
 		render := utils.NewTempl(context, http.StatusOK, cards.ReportingMetricCards(metrics))
 		context.Render(http.StatusInternalServerError, render)
@@ -46,9 +43,9 @@ func (r *reportingHandler) ReportingCardSectionHandler(context *gin.Context) {
 	failedCount := countStatusType("failed", reports)
 
 	metrics := []cards.ReportingCardData{
-		cards.ReportingCardData{Type: cards.Succes, Value: succesCount},
-		cards.ReportingCardData{Type: cards.Ongoing, Value: ongoingCount},
-		cards.ReportingCardData{Type: cards.Failed, Value: failedCount},
+		{Type: cards.Succes, Value: succesCount},
+		{Type: cards.Ongoing, Value: ongoingCount},
+		{Type: cards.Failed, Value: failedCount},
 	}
 	render := utils.NewTempl(context, http.StatusOK, cards.ReportingMetricCards(metrics))
 	context.Render(http.StatusOK, render)

models/manual/manual.go

@@ -0,0 +1,22 @@
+package manual
+
+type ManualAction struct {
+	ExecutionStatus string                 `json:"execution-status"`
+	ExecutionID     string                 `json:"execution_id"`
+	PlaybookID      string                 `json:"playbook_id"`
+	StepID          string                 `json:"step_id"`
+	Description     string                 `json:"description"`
+	Command         string                 `json:"command"`
+	CommandIsBase64 bool                   `json:"command_is_base64"`
+	Targets         map[string]interface{} `json:"targets"`
+	OutArgs         map[string]interface{} `json:"out_args"`
+}
+
+type ManualContinueRequest struct {
+	ExecutionStatus string                 `json:"execution-status"`
+	ExecutionID     string                 `json:"execution_id"`
+	PlaybookID      string                 `json:"playbook_id"`
+	StepID          string                 `json:"step_id"`
+	ResponseStatus  string                 `json:"response_status"`
+	ResponseOutArgs map[string]interface{} `json:"response_out_args"`
+}