[WIP] Remote triggering a pipeline

handlers/user.go

@@ -1,6 +1,7 @@
 package handlers
 
 import (
+	"crypto/rand"
 	"crypto/rsa"
 	"net/http"
 	"time"
@@ -158,8 +159,12 @@ func UserResetTriggerToken(c echo.Context) error {
 	if user == nil {
 		return c.String(http.StatusBadRequest, "Error retrieving user")
 	}
+
 	nsUUID := uuid.NewV4()
-	triggerToken := uuid.NewV5(nsUUID, "autoTriggerToken")
+	token := make([]byte, 32)
+	rand.Read(token)
+	namespace := string(token)
+	triggerToken := uuid.NewV5(nsUUID, namespace)
 	user.TriggerToken = triggerToken.String()
 	err = ss.UserPut(user, true)
 	if err != nil {

store/store.go

@@ -1,6 +1,7 @@
 package store
 
 import (
+	"crypto/rand"
 	"encoding/binary"
 	"fmt"
 	"path/filepath"
@@ -167,7 +168,10 @@ func (s *BoltStore) setupDatabase() error {
 
 	if u == nil {
 		nsUUID := uuid.NewV4()
-		triggerToken := uuid.NewV5(nsUUID, "autoTriggerToken")
+		token := make([]byte, 32)
+		rand.Read(token)
+		namespace := string(token)
+		triggerToken := uuid.NewV5(nsUUID, namespace)
 		auto := gaia.User{
 			DisplayName:  "Auto User",
 			JwtExpiry:    0,

workers/pipeline/create_pipeline.go

@@ -1,6 +1,7 @@
 package pipeline
 
 import (
+	"crypto/rand"
 	"errors"
 	"fmt"
 	"strings"
@@ -124,7 +125,11 @@ func CreatePipeline(p *gaia.CreatePipeline) {
 	}
 
 	nsUUID := uuid.NewV4()
-	p.Pipeline.TriggerToken = uuid.NewV5(nsUUID, "pipelineTriggerToken").String()
+	token := make([]byte, 32)
+	rand.Read(token)
+	namespace := string(token)
+	p.Pipeline.TriggerToken = uuid.NewV5(nsUUID, namespace).String()
+
 	// Save the generated pipeline data
 	err = bP.SavePipeline(&p.Pipeline)
 	if err != nil {