feat: accept trigger error and run state from endpoint (#3335)

api/triggers.yaml

@@ -33,3 +33,17 @@ components:
               $ref: "./traceid.yaml#/components/schemas/TRACEIDResponse"
             kafka:
               $ref: "./kafka.yaml#/components/schemas/KafkaResponse"
+            error:
+              $ref: "#/components/schemas/TriggerError"
+
+    TriggerError:
+      type: object
+      properties:
+        connectionError:
+          type: boolean
+        runningOnContainer:
+          type: boolean
+        targetsLocalhost:
+          type: boolean
+        message:
+          type: string

server/http/controller.go

@@ -735,6 +735,7 @@ func (c *controller) UpdateTestRun(ctx context.Context, testID string, runID int
 	// Prevents bad data in other fields to override correct data
 	existingRun.TriggerResult = run.TriggerResult
 	existingRun.Trace = traces.MergeTraces(existingRun.Trace, run.Trace)
+	existingRun.State = run.State
 
 	err = c.testRunRepository.UpdateRun(ctx, existingRun)
 	if err != nil {

server/http/mappings/tests.go

@@ -128,10 +128,24 @@ func (m OpenAPI) TriggerResult(in trigger.TriggerResult) openapi.TriggerResult {
 			Grpc:    m.GRPCResponse(in.GRPC),
 			Traceid: m.TraceIDResponse(in.TraceID),
 			Kafka:   m.KafkaResponse(in.Kafka),
+			Error:   m.TriggerError(in.Error),
 		},
 	}
 }
 
+func (m OpenAPI) TriggerError(in *trigger.TriggerError) openapi.TriggerError {
+	if in == nil {
+		return openapi.TriggerError{}
+	}
+
+	return openapi.TriggerError{
+		ConnectionError:    in.ConnectionError,
+		RunningOnContainer: in.RunningOnContainer,
+		TargetsLocalhost:   in.TargetsLocalhost,
+		Message:            in.ErrorMessage,
+	}
+}
+
 func (m OpenAPI) Tests(in []test.Test) []openapi.Test {
 	tests := make([]openapi.Test, len(in))
 	for i, t := range in {
@@ -451,6 +465,20 @@ func (m Model) TriggerResult(in openapi.TriggerResult) trigger.TriggerResult {
 		HTTP:    m.HTTPResponse(in.TriggerResult.Http),
 		GRPC:    m.GRPCResponse(in.TriggerResult.Grpc),
 		TraceID: m.TraceIDResponse(in.TriggerResult.Traceid),
+		Error:   m.TriggerError(in.TriggerResult.Error),
+	}
+}
+
+func (m Model) TriggerError(in openapi.TriggerError) *trigger.TriggerError {
+	if in.Message == "" {
+		return nil
+	}
+
+	return &trigger.TriggerError{
+		ConnectionError:    in.ConnectionError,
+		RunningOnContainer: in.RunningOnContainer,
+		TargetsLocalhost:   in.TargetsLocalhost,
+		ErrorMessage:       in.Message,
 	}
 }
 

server/openapi/model_trigger_error.go

@@ -0,0 +1,37 @@
+/*
+ * TraceTest
+ *
+ * OpenAPI definition for TraceTest endpoint and resources
+ *
+ * API version: 0.2.1
+ * Generated by: OpenAPI Generator (https://openapi-generator.tech)
+ */
+
+package openapi
+
+type TriggerError struct {
+	ConnectionError bool `json:"connectionError,omitempty"`
+
+	RunningOnContainer bool `json:"runningOnContainer,omitempty"`
+
+	TargetsLocalhost bool `json:"targetsLocalhost,omitempty"`
+
+	Message string `json:"message,omitempty"`
+}
+
+// AssertTriggerErrorRequired checks if the required fields are not zero-ed
+func AssertTriggerErrorRequired(obj TriggerError) error {
+	return nil
+}
+
+// AssertRecurseTriggerErrorRequired recursively checks if required fields are not zero-ed in a nested slice.
+// Accepts only nested slice of TriggerError (e.g. [][]TriggerError), otherwise ErrTypeAssertionError is thrown.
+func AssertRecurseTriggerErrorRequired(objSlice interface{}) error {
+	return AssertRecurseInterfaceRequired(objSlice, func(obj interface{}) error {
+		aTriggerError, ok := obj.(TriggerError)
+		if !ok {
+			return ErrTypeAssertionError
+		}
+		return AssertTriggerErrorRequired(aTriggerError)
+	})
+}