DA-202: filesNode graphql endpoint is in.

app/mainapp/graphql/private/gqlgen.yml

@@ -41,6 +41,8 @@ models:
    model: dataplane/mainapp/database/models.PipelineRuns
  LogsWorkers:
    model: dataplane/mainapp/database/models.LogsWorkers
+ CodeFolders:
+   model: dataplane/mainapp/database/models.CodeFolders
 
 resolver:
   layout: follow-schema

app/mainapp/graphql/private/resolvers/aa_platform.resolvers.go

@@ -5,7 +5,7 @@ package privateresolvers
 
 import (
 	"context"
-	permissions "dataplane/mainapp/auth_permissions"
+	"dataplane/mainapp/auth_permissions"
 	"dataplane/mainapp/config"
 	"dataplane/mainapp/database"
 	"dataplane/mainapp/database/models"

app/mainapp/graphql/private/resolvers/code_editor.graphqls

@@ -0,0 +1,37 @@
+type CodeFolders {
+    folderID: String!
+    parentID: String!
+	folderName: String!
+	level: String!
+	fType: String!
+	active: Boolean!
+}
+
+input FilesNodeInput {
+	folderID: String!
+    parentID: String!
+	environmentID: String!
+	pipelineID: String!
+	nodeID: String!
+	folderName: String!
+	fType: String!
+	active: Boolean!
+}
+
+extend type Query {
+  """
+	Get a node's file structure.
+	+ **Route**: Private
+    + **Permissions**: admin_platform, platform_environment, specific_pipeline[write]
+	"""
+  filesNode(environmentID: String!, nodeID: String!, pipelineID: String!): [CodeFolders]!
+}
+
+extend type Mutation {
+  """
+	Update a node's file structure.
+	+ **Route**: Private
+    + **Permissions**: admin_platform, platform_environment, specific_pipeline[write]
+	"""
+  updateFilesNode(input:[FilesNodeInput]!): String!
+}

app/mainapp/graphql/private/resolvers/code_editor.resolvers.go

@@ -0,0 +1,97 @@
+package privateresolvers
+
+// This file will be automatically regenerated based on the schema, any resolver implementations
+// will be copied through when generating and any unknown code will be moved to the end.
+
+import (
+	"context"
+	permissions "dataplane/mainapp/auth_permissions"
+	"dataplane/mainapp/database"
+	"dataplane/mainapp/database/models"
+	privategraphql "dataplane/mainapp/graphql/private"
+	"dataplane/mainapp/logging"
+	"errors"
+	"os"
+
+	"gorm.io/gorm/clause"
+)
+
+func (r *mutationResolver) UpdateFilesNode(ctx context.Context, input []*privategraphql.FilesNodeInput) (string, error) {
+	currentUser := ctx.Value("currentUser").(string)
+	platformID := ctx.Value("platformID").(string)
+
+	// ----- Permissions
+	perms := []models.Permissions{
+		{Subject: "user", SubjectID: currentUser, Resource: "admin_platform", ResourceID: platformID, Access: "write", EnvironmentID: "d_platform"},
+		{Subject: "user", SubjectID: currentUser, Resource: "platform_environment", ResourceID: platformID, Access: "write", EnvironmentID: input[0].EnvironmentID},
+		{Subject: "user", SubjectID: currentUser, Resource: "environment_edit_all_pipelines", ResourceID: platformID, Access: "write", EnvironmentID: input[0].EnvironmentID},
+		{Subject: "user", SubjectID: currentUser, Resource: "specific_pipeline", ResourceID: input[0].PipelineID, Access: "write", EnvironmentID: input[0].EnvironmentID},
+	}
+
+	permOutcome, _, _, _ := permissions.MultiplePermissionChecks(perms)
+
+	if permOutcome == "denied" {
+		return "", errors.New("Requires permissions.")
+	}
+
+	// ----- Add node files to database
+
+	for _, p := range input {
+
+		f := &models.CodeFolders{
+			EnvironmentID: p.EnvironmentID,
+			PipelineID:    p.PipelineID,
+			NodeID:        p.NodeID,
+			FolderID:      p.FolderID,
+			ParentID:      p.ParentID,
+			FolderName:    p.FolderName,
+			FType:         p.FType,
+			Level:         "node",
+			Active:        p.Active,
+		}
+
+		err := database.DBConn.Clauses(clause.OnConflict{UpdateAll: true}).Where("folder_id = ?", p.FolderID).
+			Create(&f).Error
+
+		if err != nil {
+			if os.Getenv("debug") == "true" {
+				logging.PrintSecretsRedact(err)
+			}
+			return "", errors.New("update files node database error.")
+		}
+
+	}
+
+	return "Success", nil
+}
+
+func (r *queryResolver) FilesNode(ctx context.Context, environmentID string, nodeID string, pipelineID string) ([]*models.CodeFolders, error) {
+	currentUser := ctx.Value("currentUser").(string)
+	platformID := ctx.Value("platformID").(string)
+
+	// ----- Permissions
+	perms := []models.Permissions{
+		{Subject: "user", SubjectID: currentUser, Resource: "admin_platform", ResourceID: platformID, Access: "write", EnvironmentID: "d_platform"},
+		{Subject: "user", SubjectID: currentUser, Resource: "platform_environment", ResourceID: platformID, Access: "write", EnvironmentID: environmentID},
+		{Subject: "user", SubjectID: currentUser, Resource: "environment_edit_all_pipelines", ResourceID: platformID, Access: "write", EnvironmentID: environmentID},
+		{Subject: "user", SubjectID: currentUser, Resource: "specific_pipeline", ResourceID: pipelineID, Access: "write", EnvironmentID: environmentID},
+	}
+
+	permOutcome, _, _, _ := permissions.MultiplePermissionChecks(perms)
+
+	if permOutcome == "denied" {
+		return nil, errors.New("Requires permissions.")
+	}
+
+	f := []*models.CodeFolders{}
+
+	err := database.DBConn.Where("node_id = ?", nodeID).Find(&f).Error
+	if err != nil {
+		if os.Getenv("debug") == "true" {
+			logging.PrintSecretsRedact(err)
+		}
+		return nil, errors.New("Retrive user database error.")
+	}
+
+	return f, nil
+}

app/mainapp/graphql/private/resolvers/pipelines.resolvers.go

@@ -5,7 +5,7 @@ package privateresolvers
 
 import (
 	"context"
-	permissions "dataplane/mainapp/auth_permissions"
+	"dataplane/mainapp/auth_permissions"
 	"dataplane/mainapp/config"
 	"dataplane/mainapp/database"
 	"dataplane/mainapp/database/models"
@@ -20,8 +20,7 @@ import (
 	"strings"
 	"time"
 
-	"github.com/go-git/go-git/v5"
-
+	git "github.com/go-git/go-git/v5"
 	"github.com/google/uuid"
 	jsoniter "github.com/json-iterator/go"
 	"gorm.io/gorm"

frontend/src/components/CustomNodesContent/BashNode/index.jsx

@@ -86,7 +86,7 @@ const BashNode = (props) => {
 
                 <Box mt={0}>
                     <MoreInfoMenu iconHorizontal iconColor="#0073C6" iconColorDark="#0073C6" iconSize={19} noPadding>
-                        {isEditorPage ? <ProcessTypeEditorModeItem /> : <ProcessTypeNodeItem />}
+                        {isEditorPage ? <ProcessTypeEditorModeItem /> : <ProcessTypeNodeItem nodeId={props.id} />}
                     </MoreInfoMenu>
                 </Box>
             </Grid>

frontend/src/components/CustomNodesContent/PythonNode/index.jsx

@@ -86,7 +86,7 @@ const PythonNode = (props) => {
 
                 <Box mt={0}>
                     <MoreInfoMenu iconHorizontal iconColor="#0073C6" iconColorDark="#0073C6" iconSize={19} noPadding>
-                        {isEditorPage ? <ProcessTypeEditorModeItem /> : <ProcessTypeNodeItem />}
+                        {isEditorPage ? <ProcessTypeEditorModeItem /> : <ProcessTypeNodeItem nodeId={props.id} />}
                     </MoreInfoMenu>
                 </Box>
             </Grid>