Merge pull request #149 from Tenderly/dgp/invocation-type-support

[PIPE-670] - Parallel Execution Support
Tenderly · Jun 5, 2023 · 10a7ff1 · 10a7ff1
2 parents 806ef39 + 6e7d1ab
commit 10a7ff1
Show file tree

Hide file tree

Showing 4 changed files with 227 additions and 97 deletions.
diff --git a/commands/actions/init.go b/commands/actions/init.go
@@ -57,15 +57,24 @@ module.exports = { blockHelloWorldFn };
 var initDescription = "This is just an example, but you can publish this action."
 
 var initAction = &actionsModel.ActionSpec{
-	Description: &initDescription,
-	Function:    "example:blockHelloWorldFn",
-	Trigger:     actionsModel.TriggerUnparsed{Type: "block"},
+	Description:   &initDescription,
+	Function:      "example:blockHelloWorldFn",
+	Trigger:       actionsModel.TriggerUnparsed{Type: "block"},
+	ExecutionType: "sequential",
 }
 
 func init() {
-	initCmd.PersistentFlags().StringVar(&actionsSourcesDir, "sources", "", "The path where the actions will be created.")
-	initCmd.PersistentFlags().StringVar(&actionsLanguage, "language", "typescript", "Initialize actions for this language. Supported {javascript, typescript}")
-	initCmd.PersistentFlags().StringVar(&actionsTemplateName, "template", "", "Initialize actions from this template, see Tenderly/tenderly-actions.")
+	initCmd.PersistentFlags().StringVar(
+		&actionsSourcesDir, "sources", "", "The path where the actions will be created.",
+	)
+	initCmd.PersistentFlags().StringVar(
+		&actionsLanguage, "language", "typescript",
+		"Initialize actions for this language. Supported {javascript, typescript}",
+	)
+	initCmd.PersistentFlags().StringVar(
+		&actionsTemplateName, "template", "",
+		"Initialize actions from this template, see Tenderly/tenderly-actions.",
+	)
 
 	actionsCmd.AddCommand(initCmd)
 }
@@ -88,11 +97,13 @@ var initCmd = &cobra.Command{
 				"Actions for project are already initialized",
 				userError.NewUserError(
 					fmt.Errorf("actions initialized"),
-					commands.Colorizer.Sprintf("Actions for project %s are already initialized, see %s",
+					commands.Colorizer.Sprintf(
+						"Actions for project %s are already initialized, see %s",
 						commands.Colorizer.Bold(commands.Colorizer.Green(projectSlug)),
 						commands.Colorizer.Bold(commands.Colorizer.Green("tenderly.yaml")),
 					),
-				))
+				),
+			)
 			os.Exit(0)
 		}
 
@@ -106,7 +117,10 @@ var initCmd = &cobra.Command{
 			if err != nil {
 				userError.LogErrorf(
 					"failed to load template",
-					userError.NewUserError(err, fmt.Sprintf("Failed to load template %s", actionsTemplateName)))
+					userError.NewUserError(
+						err, fmt.Sprintf("Failed to load template %s", actionsTemplateName),
+					),
+				)
 				os.Exit(1)
 			}
 
@@ -127,28 +141,36 @@ var initCmd = &cobra.Command{
 			if err != nil {
 				userError.LogErrorf(
 					"failed to load template specs",
-					userError.NewUserError(err, fmt.Sprintf("Failed to load specs for template %s", actionsTemplateName)))
+					userError.NewUserError(
+						err, fmt.Sprintf("Failed to load specs for template %s", actionsTemplateName),
+					),
+				)
 				os.Exit(1)
 			}
 		}
 
-		config.MustWriteActionsInit(projectSlug, &actionsModel.ProjectActions{
-			Runtime:      actionsModel.RuntimeV2,
-			Sources:      sources,
-			Dependencies: nil,
-			Specs:        specs,
-		})
+		config.MustWriteActionsInit(
+			projectSlug, &actionsModel.ProjectActions{
+				Runtime:      actionsModel.RuntimeV2,
+				Sources:      sources,
+				Dependencies: nil,
+				Specs:        specs,
+			},
+		)
 
 		if actionsLanguage == LanguageJavaScript {
 			filePath := filepath.Join(sources, "example.js")
 			content := initActionJavascript
 
 			util.CreateFileWithContent(filePath, content)
 
-			logrus.Info(commands.Colorizer.Sprintf("\nInitialized actions project. Sources directory created at %s. Configuration created in %s.",
-				commands.Colorizer.Bold(commands.Colorizer.Green(sources)),
-				commands.Colorizer.Bold(commands.Colorizer.Green("tenderly.yaml")),
-			))
+			logrus.Info(
+				commands.Colorizer.Sprintf(
+					"\nInitialized actions project. Sources directory created at %s. Configuration created in %s.",
+					commands.Colorizer.Bold(commands.Colorizer.Green(sources)),
+					commands.Colorizer.Bold(commands.Colorizer.Green("tenderly.yaml")),
+				),
+			)
 
 			os.Exit(0)
 		}
@@ -183,18 +205,24 @@ var initCmd = &cobra.Command{
 			if err != nil {
 				userError.LogErrorf(
 					"failed to create from template",
-					userError.NewUserError(err, fmt.Sprintf("Failed to create from template %s", actionsTemplateName)))
+					userError.NewUserError(
+						err, fmt.Sprintf("Failed to create from template %s", actionsTemplateName),
+					),
+				)
 				os.Exit(1)
 			}
 		}
 
 		// Install dependencies
 		mustInstallDependencies(sources)
 
-		logrus.Info(commands.Colorizer.Sprintf("\nInitialized actions project. Sources directory created at %s. Configuration created in %s.",
-			commands.Colorizer.Bold(commands.Colorizer.Green(sources)),
-			commands.Colorizer.Bold(commands.Colorizer.Green("tenderly.yaml")),
-		))
+		logrus.Info(
+			commands.Colorizer.Sprintf(
+				"\nInitialized actions project. Sources directory created at %s. Configuration created in %s.",
+				commands.Colorizer.Bold(commands.Colorizer.Green(sources)),
+				commands.Colorizer.Bold(commands.Colorizer.Green("tenderly.yaml")),
+			),
+		)
 
 		os.Exit(0)
 	},
@@ -229,8 +257,10 @@ func promptTemplateArg(arg actionsModel.TemplateArg) string {
 	if result == "" {
 		userError.LogErrorf(
 			"value for template arg not entered",
-			userError.NewUserError(errors.New("enter template arg"),
-				"Value for template arg not entered correctly"),
+			userError.NewUserError(
+				errors.New("enter template arg"),
+				"Value for template arg not entered correctly",
+			),
 		)
 		os.Exit(1)
 	}
@@ -241,7 +271,11 @@ func mustValidateFlags() {
 	if actionsLanguage != LanguageTypeScript && actionsLanguage != LanguageJavaScript {
 		userError.LogErrorf(
 			"language not supported",
-			userError.NewUserError(errors.New("language not supported"), fmt.Sprintf("Language %s not supported", actionsLanguage)))
+			userError.NewUserError(
+				errors.New("language not supported"),
+				fmt.Sprintf("Language %s not supported", actionsLanguage),
+			),
+		)
 		os.Exit(1)
 	}
 }
@@ -251,17 +285,21 @@ func chooseSources() string {
 		if util.ExistFile(actionsSourcesDir) {
 			userError.LogErrorf(
 				"sources dir is file: %s",
-				userError.NewUserError(errors.New("sources dir is file"),
-					"Selected sources directory is a file."),
+				userError.NewUserError(
+					errors.New("sources dir is file"),
+					"Selected sources directory is a file.",
+				),
 			)
 			os.Exit(1)
 		}
 
 		if util.ExistDir(actionsSourcesDir) {
 			userError.LogErrorf(
 				"sources dir exists: %s",
-				userError.NewUserError(errors.New("sources dir exists"),
-					"Selected sources directory already exists."),
+				userError.NewUserError(
+					errors.New("sources dir exists"),
+					"Selected sources directory already exists.",
+				),
 			)
 			os.Exit(1)
 		}
@@ -324,7 +362,8 @@ func excludeFromTsconfigParent(sourcesPath string, parentPath string) {
 		if err != nil {
 			userError.LogErrorf(
 				"failed to get path relative to parentPath",
-				userError.NewUserError(err, fmt.Sprintf("Can't find relative path for %s", sourcesPath)))
+				userError.NewUserError(err, fmt.Sprintf("Can't find relative path for %s", sourcesPath)),
+			)
 			os.Exit(1)
 		}
 		rel = relTmp