Preprod to main for feature release v1.6.3

.circleci/config.yml

@@ -4,7 +4,7 @@ version: 2.1
 parameters:
   golang-tag:
     type: string
-    default: "1.21"
+    default: "1.22"
   nodejs-ver:
     type: integer
     default: 16

Makefile

@@ -1,6 +1,6 @@
 SHELL:= /bin/bash
 DEBUG_FLAG?=false
-GO_VERSION=1.21
+GO_VERSION=1.22
 
 ifeq ($(DEBUG), "true")
 	BINDATA_OPTS="-debug"
@@ -159,7 +159,8 @@ fmt:
 
 .PHONY: test
 test: generate
-	go test $(COVERAGE_OPTS)  ./main/... ./sys/... ./storage/... ./service/...
+	go test $(COVERAGE_OPTS)  ./main/... ./sys/... ./storage/... ./service/...; ret=$$?; \
+		echo $$ret
 
 .PHONY: test-integration
 test-integration:

go.mod

@@ -1,6 +1,8 @@
 module github.com/ProxeusApp/proxeus-core
 
-go 1.20
+go 1.21
+
+toolchain go1.22.0
 
 require (
 	github.com/SparkPost/gosparkpost v0.2.0
@@ -20,7 +22,7 @@ require (
 	github.com/h2non/filetype v1.1.3
 	github.com/imkira/go-interpol v1.1.0 // indirect
 	github.com/labstack/gommon v0.4.2
-	github.com/onsi/gomega v1.31.1
+	github.com/onsi/gomega v1.32.0
 	github.com/patrickmn/go-cache v2.1.0+incompatible
 	github.com/pkg/errors v0.9.1
 	github.com/robertkrimen/otto v0.3.0
@@ -30,8 +32,8 @@ require (
 	github.com/xeipuuv/gojsonpointer v0.0.0-20190905194746-02993c407bfb // indirect
 	github.com/xeipuuv/gojsonschema v1.2.0 // indirect
 	go.etcd.io/bbolt v1.3.8 // indirect
-	golang.org/x/crypto v0.20.0
-	golang.org/x/net v0.21.0
+	golang.org/x/crypto v0.21.0
+	golang.org/x/net v0.22.0
 	gopkg.in/gavv/httpexpect.v2 v2.16.0
 )
 
@@ -43,7 +45,7 @@ require (
 	github.com/gorilla/context v1.1.2 // indirect
 	github.com/gorilla/websocket v1.5.1 // indirect
 	github.com/klauspost/compress v1.17.3 // indirect
-	github.com/labstack/echo-contrib v0.15.0
+	github.com/labstack/echo-contrib v0.16.0
 	github.com/mattn/go-colorable v0.1.13 // indirect
 	github.com/sergi/go-diff v1.3.1 // indirect
 	github.com/shirou/gopsutil v3.21.11+incompatible // indirect
@@ -54,7 +56,7 @@ require (
 	github.com/yusufpapurcu/wmi v1.2.3 // indirect
 	golang.org/x/image v0.14.0 // indirect
 	google.golang.org/appengine v1.6.8 // indirect
-	google.golang.org/protobuf v1.31.0 // indirect
+	google.golang.org/protobuf v1.33.0 // indirect
 )
 
 require (
@@ -78,7 +80,7 @@ require (
 	github.com/go-ole/go-ole v1.3.0 // indirect
 	github.com/go-sourcemap/sourcemap v2.1.3+incompatible // indirect
 	github.com/golang-jwt/jwt v3.2.2+incompatible // indirect
-	github.com/golang/protobuf v1.5.3 // indirect
+	github.com/golang/protobuf v1.5.4 // indirect
 	github.com/golang/snappy v0.0.5-0.20220116011046-fa5810519dcb // indirect
 	github.com/google/go-cmp v0.6.0 // indirect
 	github.com/google/pprof v0.0.0-20231101202521-4ca4178f5c7a // indirect
@@ -102,7 +104,7 @@ require (
 	golang.org/x/exp v0.0.0-20231110203233-9a3e6036ecaa // indirect
 	golang.org/x/mod v0.14.0 // indirect
 	golang.org/x/sync v0.5.0 // indirect
-	golang.org/x/sys v0.17.0 // indirect
+	golang.org/x/sys v0.18.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
 	golang.org/x/time v0.5.0 // indirect
 	golang.org/x/tools v0.16.1 // indirect

main/www/security.go

@@ -54,7 +54,7 @@ func redirectToLogin(c echo.Context) error {
 	if isAjax {
 		return echo.ErrUnauthorized
 	}
-	return c.Redirect(http.StatusTemporaryRedirect, "/login")
+	return c.Redirect(http.StatusTemporaryRedirect, "/login?redirect="+req.URL.Path)
 }
 
 func getURI(host, url string) string {

service/document.go

@@ -87,7 +87,7 @@ func (me *DefaultDocumentService) Edit(auth model.Auth, userId string, formInput
 	if !ok {
 		return ErrUnableToEdit
 	}
-	if len(fName) >= 80 || !filenameRegex.MatchString(fName) {
+	if len(fName) > 80 || !filenameRegex.MatchString(fName) {
 		return ErrUnableToEdit
 	}
 	usrDataItem, err := userDataDB().Get(auth, userId)

sys/workflow/engine.go

@@ -304,8 +304,9 @@ func (me *Engine) setupNodes(ctx *context) error {
 	if len(me.nodeImpls) == 0 {
 		return ErrNodeImplementationNotProvided
 	}
+
 	for _, item := range ctx.flow.Nodes {
-		item.internalNode = item.isCondition() || item.isWorkflow()
+		item.internalNode = item.isCondition() || item.isWorkflow() || item.isPlaceholder()
 		if !item.internalNode {
 			if s, ok := me.nodeImpls[item.Type]; ok && s.InitImplFunc != nil {
 				item.new = s.InitImplFunc
@@ -319,6 +320,62 @@ func (me *Engine) setupNodes(ctx *context) error {
 	return nil
 }
 
+func (me *Engine) removeUselessNodes(ctx *context) error {
+	uselessConnections := make(map[string]*Connection, 0)
+
+	for name, item := range ctx.flow.Nodes {
+		if !item.isPlaceholder() {
+			continue
+		}
+
+		for _, conn := range item.Connections {
+			correctConnection := conn
+			currentNode := ctx.flow.Nodes[correctConnection.NodeID]
+
+			for currentNode.isPlaceholder() {
+				if len(currentNode.Connections) > 0 {
+					correctConnection = currentNode.Connections[0]
+					currentNode = ctx.flow.Nodes[correctConnection.NodeID]
+				} else {
+					break
+				}
+			}
+
+			uselessConnections[name] = correctConnection
+		}
+	}
+
+	for _, item := range ctx.flow.Nodes {
+		if item.isPlaceholder() {
+			continue
+		}
+
+		for i := 0; i < len(item.Connections); i++ {
+			conn := item.Connections[i]
+
+			if val, ok := uselessConnections[conn.NodeID]; ok {
+				item.Connections[i] = val
+			}
+		}
+	}
+
+	if val, ok := uselessConnections[ctx.flow.Start.NodeID]; ok {
+		ctx.flow.Start.NodeID = val.NodeID
+	}
+
+	filteredNodes := make(map[string]*Node, 0)
+
+	for name, item := range ctx.flow.Nodes {
+		if !item.isPlaceholder() {
+			filteredNodes[name] = item
+		}
+	}
+
+	ctx.flow.Nodes = filteredNodes
+
+	return nil
+}
+
 func (me *Engine) execute(nn *Node, considerSteps bool) (proceed bool, err error) {
 	nn.focus()
 	if nn.internalNode {

sys/workflow/node.go

@@ -71,6 +71,10 @@ func (n *Node) isWorkflow() bool {
 	return n.Type == "workflow"
 }
 
+func (n *Node) isPlaceholder() bool {
+	return n.Type == "placeholder"
+}
+
 func (me *Node) getImpl() (NodeIF, error) {
 	//instance is still valid for reuse
 	if me.impl != nil {

sys/workflow/workflow.go

@@ -73,9 +73,11 @@ func newWorkflow(wf *Workflow, engine *Engine, parent *context) (*context, error
 	if wf == nil {
 		return nil, ErrWorkflowMissing
 	}
+
 	if wf.Flow == nil || wf.Flow.Start == nil || wf.Flow.Start.NodeID == "" {
 		return nil, ErrStartNodeMissing
 	}
+
 	me := context{
 		id:      "root",
 		flow:    wf.Flow,
@@ -84,11 +86,18 @@ func newWorkflow(wf *Workflow, engine *Engine, parent *context) (*context, error
 		engine:  engine,
 	}
 
-	err := engine.setupNodes(&me)
+	err := engine.removeUselessNodes(&me)
 	if err != nil {
 		return nil, err
 	}
+
+	err = engine.setupNodes(&me)
+	if err != nil {
+		return nil, err
+	}
+
 	me.start()
+
 	return &me, nil
 }
 
@@ -122,6 +131,8 @@ func (me *context) resolve(n *Node) error {
 					return err
 				}
 				return me.resolve(nn)
+			} else if n.isPlaceholder() {
+				return nil
 			} else if n.isWorkflow() {
 				return me.stepIntoWorkflow(n)
 			}

test/e2e/cypress/integration/0_powerup.js

@@ -17,6 +17,10 @@ describe(`Power up on ${url}`, () => {
 
   it('should bring to home page after saving with default values', () => {
     cy.get('button.btn-primary').eq(2).click()
+
+    cy.location('pathname', {
+      timeout: 60000
+    }).should('eq', '/');
   })
 
-})
+})

test/e2e/cypress/integration/1_user.js

@@ -177,7 +177,7 @@ describe(`User signup & login at ${url}`, () => {
 
       it('should remove account and logout when clicking again', () => {
         cy.get('.btn-danger').click()
-        cy.url().should('eq', `${url}/login`)
+        cy.url().should('eq', `${url}/login?redirect=%2Fadmin%2Fworkflow`)
       })
     })
   })

ui/core/package.json

@@ -18,7 +18,7 @@
     "@proxeus/wallet": "1.0.0",
     "ajv": "^6.5.2",
     "async": "^3.2.5",
-    "axios": "^1.6.7",
+    "axios": "^1.6.8",
     "babel-runtime": "^6.26.0",
     "bootstrap": "^4.1.2",
     "bootstrap-vue": "2.0.0-rc.12",
@@ -32,13 +32,13 @@
     "he": "^1.2.0",
     "html-svg-connect": "^2.0.0",
     "human-standard-token-abi": "^2.0.0",
-    "interactjs": "1.10.26",
+    "interactjs": "1.10.27",
     "jquery": "^3.5.0",
     "jquery-ui": "^1.13.2",
     "js-sha3": "^0.9.3",
     "moment": "^2.30.1",
     "popper.js": "^1.14.4",
-    "sass": "^1.71.1",
+    "sass": "^1.72.0",
     "sortablejs": "^1.15.2",
     "tippy.js": "^6.3.7",
     "underscore": "^1.8.3",
@@ -56,7 +56,7 @@
     "vue-draggable": "^2.0.6",
     "vue-dynamic": "0.2.1",
     "vue-error-page": "^1.1.5",
-    "vue-flatpickr-component": "^11.0.4",
+    "vue-flatpickr-component": "^11.0.5",
     "vue-headful": "^2.0.1",
     "vue-moment": "^4.0.0",
     "vue-multiselect": "^2.1.9",
@@ -92,7 +92,7 @@
     "eslint-plugin-node": "^11.1.0",
     "eslint-plugin-promise": "^4.2.1",
     "eslint-plugin-standard": "^5.0.0",
-    "eslint-plugin-vue": "^9.22.0",
+    "eslint-plugin-vue": "^9.24.0",
     "file-loader": "^3.0.1",
     "less": "^3.8.1",
     "less-loader": "^4.1.0",

ui/core/src/App.vue

@@ -50,6 +50,10 @@ export default {
     window.$root = this.$root
     this.$root.$on('service-on', this.onServiceOn)
     this.$root.$on('service-off', this.onServiceOff)
+
+    if (!this.app.checkUserHasSession()) {
+      this.app.redirectToLogin(window.location.pathname)
+    }
   },
   beforeDestroy () {
     this.$root.$off('service-on', this.onServiceOn)

ui/core/src/DocumentApp.vue

@@ -24,6 +24,10 @@ export default {
   created () {
     this.$root.$on('service-on', this.onServiceOn)
     this.$root.$on('service-off', this.onServiceOff)
+
+    if (!this.app.checkUserHasSession()) {
+      this.app.redirectToLogin(window.location.pathname)
+    }
   },
   beforeDestroy () {
     this.$root.$off('service-on', this.onServiceOn)
@@ -107,13 +111,19 @@ export default {
     color: $primary;
   }
 
+  body {
+    overflow: hidden;
+  }
+
   .navbar h1 {
     margin-bottom: 0;
   }
 
   .app-main {
-    @media (max-width: 767px) {
-      max-width: 100% !important;
+    max-width: calc(100% - 265px);
+
+    @media (max-width: 979px) {
+      max-width: calc(100% - 80px);
     }
   }