feat: working target history

internal/server/activities/add_target_history.go

@@ -0,0 +1,28 @@
+package activities
+
+import (
+	"context"
+
+	"github.com/mentos1386/zdravko/database/models"
+	"github.com/mentos1386/zdravko/internal/server/services"
+	"github.com/mentos1386/zdravko/internal/temporal"
+)
+
+func (a *Activities) AddTargetHistory(ctx context.Context, param temporal.ActivityAddTargetHistoryParam) (*temporal.ActivityAddTargetHistoryResult, error) {
+
+	status := models.TargetStatusUnknown
+	if param.Status == temporal.AddTargetHistoryStatusSuccess {
+		status = models.TargetStatusSuccess
+	}
+	if param.Status == temporal.AddTargetHistoryStatusFailure {
+		status = models.TargetStatusFailure
+	}
+
+	err := services.AddHistoryForTarget(ctx, a.db, &models.TargetHistory{
+		TargetId: param.Target.Id,
+		Status:   status,
+		Note:     param.Note,
+	})
+
+	return &temporal.ActivityAddTargetHistoryResult{}, err
+}

internal/server/activities/targets_filter.go

@@ -37,10 +37,12 @@ func (a *Activities) TargetsFilter(ctx context.Context, param temporal.ActivityT
 		a.logger.Info("TargetsFilter", "target", target)
 
 		targetWithMedatada := &struct {
+			Id       string
 			Name     string
 			Group    string
 			Metadata map[string]interface{}
 		}{
+			Id:       target.Id,
 			Name:     target.Name,
 			Group:    target.Group,
 			Metadata: metadata,
@@ -57,6 +59,7 @@ func (a *Activities) TargetsFilter(ctx context.Context, param temporal.ActivityT
 		}
 		if value.Export().(bool) {
 			filteredTargets = append(filteredTargets, &temporal.Target{
+				Id:       target.Id,
 				Name:     target.Name,
 				Group:    target.Group,
 				Metadata: target.Metadata,

internal/server/handlers/examples.yaml

@@ -85,7 +85,7 @@ filter: |
 
 target: |
   kind: Http
-  tags:
+  labels:
     production: "true"
   spec:
     url: "https://test.k6.io"

internal/server/workflows/check.go

@@ -6,53 +6,71 @@ import (
 	"time"
 
 	"github.com/mentos1386/zdravko/internal/temporal"
-	"github.com/mentos1386/zdravko/pkg/api"
 	"go.temporal.io/sdk/workflow"
 )
 
-func (w *Workflows) CheckWorkflowDefinition(ctx workflow.Context, param temporal.WorkflowCheckParam) (api.CheckStatus, error) {
+func (w *Workflows) CheckWorkflowDefinition(ctx workflow.Context, param temporal.WorkflowCheckParam) error {
 	workerGroupIds := param.WorkerGroupIds
 	sort.Strings(workerGroupIds)
 
-	ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
-		StartToCloseTimeout: 60 * time.Second,
-		TaskQueue:           temporal.TEMPORAL_SERVER_QUEUE,
-	})
-	targetsFilterParam := temporal.ActivityTargetsFilterParam{
-		Filter: param.Filter,
-	}
 	targetsFilterResult := temporal.ActivityTargetsFilterResult{}
-	err := workflow.ExecuteActivity(ctx, temporal.ActivityTargetsFilterName, targetsFilterParam).Get(ctx, &targetsFilterResult)
+	err := workflow.ExecuteActivity(
+		workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
+			StartToCloseTimeout: 60 * time.Second,
+			TaskQueue:           temporal.TEMPORAL_SERVER_QUEUE,
+		}),
+		temporal.ActivityTargetsFilterName,
+		temporal.ActivityTargetsFilterParam{
+			Filter: param.Filter,
+		},
+	).Get(ctx, &targetsFilterResult)
 	if err != nil {
-		return api.CheckStatusUnknown, err
+		return err
 	}
 
 	for _, target := range targetsFilterResult.Targets {
 		for _, workerGroupId := range workerGroupIds {
-			ctx = workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
-				StartToCloseTimeout: 60 * time.Second,
-				TaskQueue:           workerGroupId,
-			})
-
-			heatlcheckParam := temporal.ActivityCheckParam{
-				Script: param.Script,
-				Target: target,
-			}
-
 			var checkResult *temporal.ActivityCheckResult
-			err := workflow.ExecuteActivity(ctx, temporal.ActivityCheckName, heatlcheckParam).Get(ctx, &checkResult)
+			err := workflow.ExecuteActivity(
+				workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
+					StartToCloseTimeout: 60 * time.Second,
+					TaskQueue:           workerGroupId,
+				}),
+				temporal.ActivityCheckName,
+				temporal.ActivityCheckParam{
+					Script: param.Script,
+					Target: target,
+				},
+			).Get(ctx, &checkResult)
 			if err != nil {
-				return api.CheckStatusUnknown, err
+				return err
 			}
 
-			status := api.CheckStatusFailure
+			status := temporal.AddTargetHistoryStatusFailure
 			if checkResult.Success {
-				status = api.CheckStatusSuccess
+				status = temporal.AddTargetHistoryStatusSuccess
+			}
+
+			var addTargetHistoryResult *temporal.ActivityAddTargetHistoryResult
+			err = workflow.ExecuteActivity(
+				workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
+					StartToCloseTimeout: 60 * time.Second,
+					TaskQueue:           temporal.TEMPORAL_SERVER_QUEUE,
+				}),
+				temporal.ActivityAddTargetHistoryName,
+				&temporal.ActivityAddTargetHistoryParam{
+					Target: target,
+					Status: status,
+					Note:   checkResult.Note,
+				},
+			).Get(ctx, &addTargetHistoryResult)
+			if err != nil {
+				return err
 			}
 
 			slog.Info("Check %s status: %s", param.CheckId, status)
 		}
 	}
 
-	return api.CheckStatusSuccess, nil
+	return nil
 }

internal/temporal/activity_add_target_history.go

@@ -0,0 +1,20 @@
+package temporal
+
+type AddTargetHistoryStatus string
+
+const (
+	AddTargetHistoryStatusSuccess AddTargetHistoryStatus = "SUCCESS"
+	AddTargetHistoryStatusFailure AddTargetHistoryStatus = "FAILURE"
+	AddTargetHistoryStatusUnknown AddTargetHistoryStatus = "UNKNOWN"
+)
+
+type ActivityAddTargetHistoryParam struct {
+	Target *Target
+	Status AddTargetHistoryStatus
+	Note   string
+}
+
+type ActivityAddTargetHistoryResult struct {
+}
+
+const ActivityAddTargetHistoryName = "ADD_TARGET_HISTORY"

internal/temporal/temporal.go

@@ -13,6 +13,7 @@ import (
 )
 
 type Target struct {
+	Id       string
 	Name     string
 	Group    string
 	Metadata string

pkg/api/checks.go

@@ -1,15 +1 @@
 package api
-
-type CheckStatus string
-
-const (
-	CheckStatusSuccess CheckStatus = "SUCCESS"
-	CheckStatusFailure CheckStatus = "FAILURE"
-	CheckStatusUnknown CheckStatus = "UNKNOWN"
-)
-
-type ApiV1ChecksHistoryPOSTBody struct {
-	Status        CheckStatus `json:"status"`
-	Note          string      `json:"note"`
-	WorkerGroupId string      `json:"worker_group"`
-}

pkg/server/worker.go

@@ -31,7 +31,7 @@ func NewWorker(temporalClient client.Client, cfg *config.ServerConfig, logger *s
 
 	// Register Activities
 	worker.RegisterActivityWithOptions(a.TargetsFilter, activity.RegisterOptions{Name: temporal.ActivityTargetsFilterName})
-	worker.RegisterActivityWithOptions(a.ProcessCheckOutcome, activity.RegisterOptions{Name: temporal.ActivityProcessCheckOutcomeName})
+	worker.RegisterActivityWithOptions(a.AddTargetHistory, activity.RegisterOptions{Name: temporal.ActivityAddTargetHistoryName})
 
 	return &Worker{
 		worker: worker,

web/static/css/tailwind.css

@@ -1798,6 +1798,10 @@ code {
 }
 
 @media (min-width: 640px) {
+  .sm\:col-span-2 {
+    grid-column: span 2 / span 2;
+  }
+
   .sm\:w-auto {
     width: auto;
   }

web/templates/pages/settings_checks_create.tmpl

@@ -35,26 +35,26 @@
         <code>@yearly</code>.
       </p>
       <label for="filter">Filter</label>
-      <textarea required id="filter" name="filter" class="h-12">
+      <textarea required id="filter" name="filter" class="sm:col-span-2 h-12">
 {{ ScriptUnescapeString .ExampleFilter }}</textarea
       >
       <div
         id="editor-filter"
-        class="hidden block w-full h-12 rounded-lg border border-gray-300 overflow-hidden"
+        class="hidden sm:col-span-2 block w-full h-12 rounded-lg border border-gray-300 overflow-hidden"
       ></div>
-      <p>
+      <p class="sm:col-span-2">
         With filter we specify what targets the check will run on. The must be a
         javascript expression that returns a boolean.
       </p>
       <label for="script">Script</label>
-      <textarea required id="script" name="script" class="h-96">
+      <textarea required id="script" name="script" class="sm:col-span-2 h-96">
 {{ ScriptUnescapeString .ExampleScript }}</textarea
       >
       <div
         id="editor-script"
-        class="hidden block w-full h-96 rounded-lg border border-gray-300 overflow-hidden"
+        class="hidden sm:col-span-2 block w-full h-96 rounded-lg border border-gray-300 overflow-hidden"
       ></div>
-      <p>
+      <p class="sm:col-span-2">
         Script is what determines the status of a service. You can read more
         about it on
         <a target="_blank" href="https://k6.io/docs/using-k6/http-requests/"
@@ -68,7 +68,13 @@
   <script src="/static/monaco/vs/loader.js"></script>
   <script>
     const items = [
-      { name: "filter", language: "javascript" },
+      {
+        name: "filter",
+        language: "javascript",
+        options: {
+          quickSuggestions: false,
+        },
+      },
       { name: "script", language: "javascript" },
     ];
 
@@ -80,7 +86,7 @@
     }
 
     window.editors = {};
-    for (const { name, language } of items) {
+    for (const { name, language, options = {} } of items) {
       const textarea = document.getElementById(name);
       const editor = document.getElementById("editor-" + name);
 
@@ -96,6 +102,8 @@
           codeLens: false,
           contextmenu: false,
           scrollBeyondLastLine: false,
+          wordWrap: "on",
+          ...options,
         });
 
         const resizeObserver = new ResizeObserver((entries) => {

web/templates/pages/settings_checks_describe.tmpl

@@ -29,26 +29,26 @@
         <code>@yearly</code>.
       </p>
       <label for="filter">Filter</label>
-      <textarea required id="filter" name="filter" class="h-12">
+      <textarea required id="filter" name="filter" class="sm:col-span-2 h-12">
 {{ ScriptUnescapeString .Check.Filter }}</textarea
       >
       <div
         id="editor-filter"
-        class="hidden block w-full h-12 rounded-lg border border-gray-300 overflow-hidden"
+        class="hidden sm:col-span-2 block w-full h-12 rounded-lg border border-gray-300 overflow-hidden"
       ></div>
-      <p>
+      <p class="sm:col-span-2">
         With filter we specify what targets the check will run on. The must be a
         javascript expression that returns a boolean.
       </p>
       <label for="script">Script</label>
-      <textarea required id="script" name="script" class="h-96">
+      <textarea required id="script" name="script" class="sm:col-span-2 h-96">
 {{ ScriptUnescapeString .Check.Script }}</textarea
       >
       <div
         id="editor-script"
-        class="block w-full h-96 rounded-lg border border-gray-300 overflow-hidden hidden"
+        class="hidden sm:col-span-2 block w-full h-96 rounded-lg border border-gray-300 overflow-hidden"
       ></div>
-      <p>
+      <p class="sm:col-span-2">
         Script is what determines the status of a service. You can read more
         about it on
         <a target="_blank" href="https://k6.io/docs/using-k6/http-requests/"
@@ -184,7 +184,13 @@
   <script src="/static/monaco/vs/loader.js"></script>
   <script>
     const items = [
-      { name: "filter", language: "javascript" },
+      {
+        name: "filter",
+        language: "javascript",
+        options: {
+          quickSuggestions: false,
+        },
+      },
       { name: "script", language: "javascript" },
     ];
 
@@ -196,7 +202,7 @@
     }
 
     window.editors = {};
-    for (const { name, language } of items) {
+    for (const { name, language, options = {} } of items) {
       const textarea = document.getElementById(name);
       const editor = document.getElementById("editor-" + name);
 
@@ -212,6 +218,8 @@
           codeLens: false,
           contextmenu: false,
           scrollBeyondLastLine: false,
+          wordWrap: "on",
+          ...options,
         });
 
         const resizeObserver = new ResizeObserver((entries) => {