Trigger command

docs/trigger/README.md

@@ -0,0 +1,44 @@
+# Lighthouse custome triggers
+
+You can enable use LH_CUSTOM_TRIGGER_COMMAND environment variable to add custom triggers. It takes in a comma seperated list of commands.
+
+When these commands are triggered using ChatOps Lighthouse will convert the command arg into TRIGGER_COMMAND_ARG enviroment variable which you can refer from the pipeline.
+
+eg:
+`
+LH_CUSTOM_TRIGGER_COMMAND=deploy,trigger
+`
+```
+apiVersion: config.lighthouse.jenkins-x.io/v1alpha1
+kind: TriggerConfig
+spec:
+  presubmits:
+  - name: pr
+    context: "pr"
+    always_run: true
+    optional: false
+    source: "pullrequest.yaml"
+  - name: trigger
+    context: "trigger"
+    always_run: false
+    optional: false
+    rerun_command: /trigger this
+    trigger: (?m)^/trigger( all| this),?(\s+|$)
+    source: "trigger.yaml"
+  - name: deploy
+    context: "deployr"
+    always_run: false
+    optional: false
+    rerun_command: /deploy dev 
+    trigger: (?m)^/deploy(?:[ \t]+([-\w]+(?:,[-\w]+)*))?(?:[ \t]+([-\w]+(?:,[-\w]+)*))?
+    source: "deploy.yaml"
+  postsubmits:
+  - name: release
+    context: "release"
+    source: "release.yaml"
+    branches:
+    - ^main$
+```
+you can use ChatOps command to trigger each pipeline
+eg:
+***/deploy qa***

pkg/plugins/trigger/generic-comment.go

@@ -30,7 +30,11 @@ import (
 	"k8s.io/apimachinery/pkg/util/sets"
 )
 
-func handleGenericComment(c Client, trigger *plugins.Trigger, gc scmprovider.GenericCommentEvent) error {
+func handleGenericComment(c Client, trigger *plugins.Trigger, gc scmprovider.GenericCommentEvent) error{
+  return handleGenericCommentWithArg(c, trigger, gc, "")
+
+}
+func handleGenericCommentWithArg(c Client, trigger *plugins.Trigger, gc scmprovider.GenericCommentEvent, arg string) error {
 	org := gc.Repo.Namespace
 	repo := gc.Repo.Name
 	number := gc.Number
@@ -94,6 +98,14 @@ func handleGenericComment(c Client, trigger *plugins.Trigger, gc scmprovider.Gen
 	if err != nil {
 		return err
 	}
+  if arg != "" {
+    for i := range toTest {
+      toTest[i].Base.PipelineRunParams = append(toTest[i].Base.PipelineRunParams , job.PipelineRunParam{
+        Name: "TRIGGER_COMMAND_ARG",
+        ValueTemplate: arg,
+      })
+    }
+  }
 	return RunAndSkipJobs(c, pr, toTest, toSkip, gc.GUID, trigger.ElideSkippedContexts)
 }
 

pkg/plugins/trigger/trigger.go

@@ -77,13 +77,13 @@ var plugin = plugins.Plugin{
 
 func init() {
 	customTriggerCommand := os.Getenv(customerTriggerCommandEnvVar)
-	if customTriggerCommand != "" {
+  for _, trigger := range strings.Split(customTriggerCommand, ","){
 		customCommand := plugins.Command{
-			Name: customTriggerCommand,
+			Name: trigger,
 			Arg: &plugins.CommandArg{
 				Pattern: `[-\w]+(?:,[-\w]+)*`,
 			},
-			Description: fmt.Sprintf("Manually trigger /%s chatops commands.", customTriggerCommand),
+			Description: fmt.Sprintf("Manually trigger /%s chatops commands.", trigger),
 			Featured:    true,
 			Action: plugins.
 				Invoke(handleGenericCommentEvent).
@@ -170,8 +170,8 @@ func handlePullRequest(pc plugins.Agent, pr scm.PullRequestHook) error {
 	return handlePR(getClient(pc), pc.PluginConfig.TriggerFor(org, repo), pr)
 }
 
-func handleGenericCommentEvent(_ plugins.CommandMatch, pc plugins.Agent, gc scmprovider.GenericCommentEvent) error {
-	return handleGenericComment(getClient(pc), pc.PluginConfig.TriggerFor(gc.Repo.Namespace, gc.Repo.Name), gc)
+func handleGenericCommentEvent(cm plugins.CommandMatch, pc plugins.Agent, gc scmprovider.GenericCommentEvent) error {
+	return handleGenericCommentWithArg(getClient(pc), pc.PluginConfig.TriggerFor(gc.Repo.Namespace, gc.Repo.Name), gc, cm.Arg)
 }
 
 func handlePush(pc plugins.Agent, pe scm.PushHook) error {