feat(env_group): add upstream test type: local, remote, mirror

Author: 0xJacky

.air.toml

@@ -15,7 +15,7 @@ full_bin = "APP_ENV=dev APP_USER=air ./tmp/main"
 # Watch these filename extensions.
 include_ext = ["go", "tpl", "tmpl", "html", "toml", "po", "conf"]
 # Ignore these filename extensions or directories.
-exclude_dir = ["assets", "tmp", "vendor", "app/node_modules", "upload", "docs", "resources", ".idea", "cmd"]
+exclude_dir = ["assets", "tmp", "vendor", "app/node_modules", "upload", "docs", "resources", ".idea", "cmd", ".go"]
 # Watch these directories if you specified.
 include_dir = []
 # Exclude files.

.devcontainer/docker-compose.yml

@@ -5,7 +5,7 @@ services:
     container_name: nginx-ui
     volumes:
       - ../..:/workspaces:cached
-      - ./go-path:/root/go
+      - ../.go:/root/go
       - ./data/nginx:/etc/nginx
       - /var/run/docker.sock:/var/run/docker.sock
     command: sleep infinity

.gitignore

@@ -19,3 +19,4 @@ internal/**/*.gen.go
 .devcontainer/data
 .devcontainer/casdoor.pem
 .vscode/.i18n-gettext.secret
+.go/

api/analytic/nodes.go

@@ -107,7 +107,7 @@ func GetNodesAnalytic(c *gin.Context) {
 	defer ws.Close()
 
 	for {
-		// write
+		// Send NodeMap data to client
 		err = ws.WriteJSON(analytic.NodeMap)
 		if err != nil {
 			if helper.IsUnexpectedWebsocketError(err) {

api/cluster/group.go

@@ -110,19 +110,21 @@ func RestartNginx(c *gin.Context) {
 func AddGroup(c *gin.Context) {
 	cosy.Core[model.EnvGroup](c).
 		SetValidRules(gin.H{
-			"name":             "required",
-			"sync_node_ids":    "omitempty",
-			"post_sync_action": "omitempty,oneof=" + model.PostSyncActionNone + " " + model.PostSyncActionReloadNginx,
+			"name":               "required",
+			"sync_node_ids":      "omitempty",
+			"post_sync_action":   "omitempty,oneof=" + model.PostSyncActionNone + " " + model.PostSyncActionReloadNginx,
+			"upstream_test_type": "omitempty,oneof=" + model.UpstreamTestLocal + " " + model.UpstreamTestRemote + " " + model.UpstreamTestMirror,
 		}).
 		Create()
 }
 
 func ModifyGroup(c *gin.Context) {
 	cosy.Core[model.EnvGroup](c).
 		SetValidRules(gin.H{
-			"name":             "required",
-			"sync_node_ids":    "omitempty",
-			"post_sync_action": "omitempty,oneof=" + model.PostSyncActionNone + " " + model.PostSyncActionReloadNginx,
+			"name":               "required",
+			"sync_node_ids":      "omitempty",
+			"post_sync_action":   "omitempty,oneof=" + model.PostSyncActionNone + " " + model.PostSyncActionReloadNginx,
+			"upstream_test_type": "omitempty,oneof=" + model.UpstreamTestLocal + " " + model.UpstreamTestRemote + " " + model.UpstreamTestMirror,
 		}).
 		Modify()
 }

app/src/api/env_group.ts

@@ -7,10 +7,18 @@ export const PostSyncAction = {
   ReloadNginx: 'reload_nginx',
 }
 
+// Upstream test types
+export const UpstreamTestType = {
+  Local: 'local',
+  Remote: 'remote',
+  Mirror: 'mirror',
+}
+
 export interface EnvGroup extends ModelBase {
   name: string
   sync_node_ids: number[]
   post_sync_action?: string
+  upstream_test_type?: string
 }
 
 const baseUrl = '/env_groups'