Add automation run created and any run change event trigger support

examples/resources/port_action/main.tf

@@ -96,3 +96,41 @@ resource "port_action" "restart_microservice" {
     url  = "https://app.getport.io"
   }
 }
+
+resource "port_action" "notifiy_on_mocrosiervice_creation" {
+  title      = "Notify On Microservice Creation"
+  icon       = "Terraform"
+  identifier = "examples-automation-notify-on-microservice-creation"
+  automation_trigger = {
+    entity_created_event = {
+      blueprint_identifier = port_blueprint.microservice.identifier
+    }
+  }
+  webhook_method = {
+    type = "WEBHOOK"
+    url  = "https://example.com"
+  }
+  publish = true
+}
+
+resource "port_action" "notifiy_on_microservice_restart_failed" {
+  title      = "Notify On Microservice Restart Failed"
+  icon       = "Terraform"
+  identifier = "examples-automation-notify-on-microservice-restart-failed"
+  automation_trigger = {
+    run_updated_event = {
+      action_identifier = port_action.restart_microservice.identifier
+    }
+    jq_condition = {
+      combinator = "and"
+      expressions = [
+        ".diff.after.status == \"FAILURE\""
+      ],
+    }
+  }
+  webhook_method = {
+    type = "WEBHOOK"
+    url  = "https://example.com"
+  }
+  publish = true
+}

internal/cli/models.go

@@ -205,6 +205,7 @@ type (
 		Type                string  `json:"type"`
 		BlueprintIdentifier *string `json:"blueprintIdentifier,omitempty"`
 		PropertyIdentifier  *string `json:"propertyIdentifier,omitempty"`
+		ActionIdentifier    *string `json:"actionIdentifier,omitempty"`
 	}
 
 	TriggerCondition struct {

internal/consts/provider.go

@@ -16,5 +16,8 @@ const (
 	EntityDeleted        = "ENTITY_DELETED"
 	TimerPropertyExpired = "TIMER_PROPERTY_EXPIRED"
 	AnyEntityChange      = "ANY_ENTITY_CHANGE"
+	RunCreated           = "RUN_CREATED"
+	RunUpdated           = "RUN_UPDATED"
+	AnyRunChange         = "ANY_RUN_CHANGE"
 	JqCondition          = "JQ"
 )

port/action/actionStateToPortBody.go

@@ -165,6 +165,27 @@ func triggerToBody(ctx context.Context, data *ActionModel) (*cli.Trigger, error)
 			}
 		}
 
+		if data.AutomationTrigger.RunCreatedEvent != nil {
+			automationTrigger.Event = &cli.TriggerEvent{
+				Type:             consts.RunUpdated,
+				ActionIdentifier: data.AutomationTrigger.RunCreatedEvent.ActionIdentifier.ValueStringPointer(),
+			}
+		}
+
+		if data.AutomationTrigger.RunUpdatedEvent != nil {
+			automationTrigger.Event = &cli.TriggerEvent{
+				Type:             consts.RunUpdated,
+				ActionIdentifier: data.AutomationTrigger.RunUpdatedEvent.ActionIdentifier.ValueStringPointer(),
+			}
+		}
+
+		if data.AutomationTrigger.AnyRunChangeEvent != nil {
+			automationTrigger.Event = &cli.TriggerEvent{
+				Type:             consts.RunUpdated,
+				ActionIdentifier: data.AutomationTrigger.AnyRunChangeEvent.ActionIdentifier.ValueStringPointer(),
+			}
+		}
+
 		return automationTrigger, nil
 	}
 

port/action/model.go

@@ -299,6 +299,18 @@ type TimerPropertyExpiredEventModel struct {
 	PropertyIdentifier  types.String `tfsdk:"property_identifier"`
 }
 
+type RunCreatedEvent struct {
+	ActionIdentifier types.String `tfsdk:"action_identifier"`
+}
+
+type RunUpdatedEvent struct {
+	ActionIdentifier types.String `tfsdk:"action_identifier"`
+}
+
+type AnyRunChangeEvent struct {
+	ActionIdentifier types.String `tfsdk:"action_identifier"`
+}
+
 type JqConditionModel struct {
 	Expressions []types.String `tfsdk:"expressions"`
 	Combinator  types.String   `tfsdk:"combinator"`
@@ -310,6 +322,9 @@ type AutomationTriggerModel struct {
 	EntityDeletedEvent        *EntityDeletedEventModel        `tfsdk:"entity_deleted_event"`
 	AnyEntityChangeEvent      *AnyEntityChangeEventModel      `tfsdk:"any_entity_change_event"`
 	TimerPropertyExpiredEvent *TimerPropertyExpiredEventModel `tfsdk:"timer_property_expired_event"`
+	RunCreatedEvent           *RunCreatedEvent                `tfsdk:"run_created_event"`
+	RunUpdatedEvent           *RunUpdatedEvent                `tfsdk:"run_updated_event"`
+	AnyRunChangeEvent         *AnyRunChangeEvent              `tfsdk:"any_run_chnage_event"`
 	JqCondition               *JqConditionModel               `tfsdk:"jq_condition"`
 }
 

port/action/refreshActionState.go

@@ -385,6 +385,24 @@ func writeTriggerToResource(ctx context.Context, a *cli.Action, state *ActionMod
 			}
 		}
 
+		if a.Trigger.Event.Type == consts.RunCreated {
+			automationTrigger.RunCreatedEvent = &RunCreatedEvent{
+				ActionIdentifier: types.StringValue(*a.Trigger.Event.ActionIdentifier),
+			}
+		}
+
+		if a.Trigger.Event.Type == consts.RunUpdated {
+			automationTrigger.RunUpdatedEvent = &RunUpdatedEvent{
+				ActionIdentifier: types.StringValue(*a.Trigger.Event.ActionIdentifier),
+			}
+		}
+
+		if a.Trigger.Event.Type == consts.AnyRunChange {
+			automationTrigger.AnyRunChangeEvent = &AnyRunChangeEvent{
+				ActionIdentifier: types.StringValue(*a.Trigger.Event.ActionIdentifier),
+			}
+		}
+
 		state.AutomationTrigger = automationTrigger
 	}
 

port/action/resource_test.go

@@ -1567,6 +1567,141 @@ func TestAccPortAutomationTimerPropertyExpired(t *testing.T) {
 	})
 }
 
+func TestAccPortAutomationRunCreated(t *testing.T) {
+	identifier := utils.GenID()
+	actionIdentifier := utils.GenID()
+	var testAccActionConfigCreate = testAccCreateBlueprintConfig(identifier) + fmt.Sprintf(`
+	resource "port_action" "self_serve_action" {
+	title      = "self serve action"
+	identifier = "self_serve_action"
+	icon       = "Terraform"
+	self_service_trigger = {
+		operation = "CREATE"
+		user_properties = {
+		}
+	}
+	kafka_method = {}
+	}
+
+	resource "port_action" "create_microservice" {
+	title      = "TF Provider Test"
+	identifier = "%s"
+	icon       = "Terraform"
+	automation_trigger = {
+		run_created_event = {
+			action_identifier = "self_serve_action"
+		}
+	}
+	kafka_method = {}
+	depends_on   = [port_action.self_serve_action]
+	}`, actionIdentifier)
+	resource.Test(t, resource.TestCase{
+		PreCheck:                 func() { acctest.TestAccPreCheck(t) },
+		ProtoV6ProviderFactories: acctest.TestAccProtoV6ProviderFactories,
+		Steps: []resource.TestStep{
+			{
+				Config: acctest.ProviderConfig + testAccActionConfigCreate,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttr("port_action.create_microservice", "title", "TF Provider Test"),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "identifier", actionIdentifier),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "icon", "Terraform"),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "automation_trigger.run_created_event.action_identifier", "self_serve_action"),
+				),
+			},
+		},
+	})
+}
+
+func TestAccPortAutomationRunUpdated(t *testing.T) {
+	identifier := utils.GenID()
+	actionIdentifier := utils.GenID()
+	var testAccActionConfigCreate = testAccCreateBlueprintConfig(identifier) + fmt.Sprintf(`
+	resource "port_action" "self_serve_action" {
+	title      = "self serve action"
+	identifier = "self_serve_action"
+	icon       = "Terraform"
+	self_service_trigger = {
+		operation = "CREATE"
+		user_properties = {
+		}
+	}
+	kafka_method = {}
+	}
+
+	resource "port_action" "create_microservice" {
+	title      = "TF Provider Test"
+	identifier = "%s"
+	icon       = "Terraform"
+	automation_trigger = {
+		run_updated_event = {
+			action_identifier = "self_serve_action"
+		}
+	}
+	kafka_method = {}
+	depends_on   = [port_action.self_serve_action]
+	}`, actionIdentifier)
+	resource.Test(t, resource.TestCase{
+		PreCheck:                 func() { acctest.TestAccPreCheck(t) },
+		ProtoV6ProviderFactories: acctest.TestAccProtoV6ProviderFactories,
+		Steps: []resource.TestStep{
+			{
+				Config: acctest.ProviderConfig + testAccActionConfigCreate,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttr("port_action.create_microservice", "title", "TF Provider Test"),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "identifier", actionIdentifier),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "icon", "Terraform"),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "automation_trigger.run_updated_event.action_identifier", "self_serve_action"),
+				),
+			},
+		},
+	})
+}
+
+func TestAccPortAutomationAnyRunChange(t *testing.T) {
+	identifier := utils.GenID()
+	actionIdentifier := utils.GenID()
+	var testAccActionConfigCreate = testAccCreateBlueprintConfig(identifier) + fmt.Sprintf(`
+	resource "port_action" "self_serve_action" {
+	title      = "self serve action"
+	identifier = "self_serve_action"
+	icon       = "Terraform"
+	self_service_trigger = {
+		operation = "CREATE"
+		user_properties = {
+		}
+	}
+	kafka_method = {}
+	}
+
+	resource "port_action" "create_microservice" {
+	title      = "TF Provider Test"
+	identifier = "%s"
+	icon       = "Terraform"
+	automation_trigger = {
+		any_run_change_event = {
+			action_identifier = "self_serve_action"
+		}
+	}
+	kafka_method = {}
+	depends_on   = [port_action.self_serve_action]
+	}`, actionIdentifier)
+	resource.Test(t, resource.TestCase{
+		PreCheck:                 func() { acctest.TestAccPreCheck(t) },
+		ProtoV6ProviderFactories: acctest.TestAccProtoV6ProviderFactories,
+		Steps: []resource.TestStep{
+			{
+				Config: acctest.ProviderConfig + testAccActionConfigCreate,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttr("port_action.create_microservice", "title", "TF Provider Test"),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "identifier", actionIdentifier),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "icon", "Terraform"),
+					resource.TestCheckResourceAttr("port_action.create_microservice", "automation_trigger.any_run_change_event.action_identifier", "self_serve_action"),
+				),
+			},
+		},
+	})
+}
+
 func TestAccPortWebhookApproval(t *testing.T) {
 	identifier := utils.GenID()
 	actionIdentifier := utils.GenID()

port/action/schema.go

@@ -161,6 +161,9 @@ func ActionSchema() map[string]schema.Attribute {
 							path.MatchRelative().AtParent().AtName("entity_deleted_event"),
 							path.MatchRelative().AtParent().AtName("any_entity_change_event"),
 							path.MatchRelative().AtParent().AtName("timer_property_expired_event"),
+							path.MatchRelative().AtParent().AtName("run_created_event"),
+							path.MatchRelative().AtParent().AtName("run_updated_event"),
+							path.MatchRelative().AtParent().AtName("any_run_change_event"),
 						),
 					},
 				},
@@ -208,6 +211,36 @@ func ActionSchema() map[string]schema.Attribute {
 						},
 					},
 				},
+				"run_created_event": schema.SingleNestedAttribute{
+					MarkdownDescription: "Run created event trigger",
+					Optional:            true,
+					Attributes: map[string]schema.Attribute{
+						"action_identifier": schema.StringAttribute{
+							MarkdownDescription: "The action identifier of the created run",
+							Required:            true,
+						},
+					},
+				},
+				"run_updated_event": schema.SingleNestedAttribute{
+					MarkdownDescription: "Run updated event trigger",
+					Optional:            true,
+					Attributes: map[string]schema.Attribute{
+						"action_identifier": schema.StringAttribute{
+							MarkdownDescription: "The action identifier of the updated run",
+							Required:            true,
+						},
+					},
+				},
+				"any_run_change_event": schema.SingleNestedAttribute{
+					MarkdownDescription: "Any run change event trigger",
+					Optional:            true,
+					Attributes: map[string]schema.Attribute{
+						"action_identifier": schema.StringAttribute{
+							MarkdownDescription: "The action identifier of the changed run",
+							Required:            true,
+						},
+					},
+				},
 				"jq_condition": schema.SingleNestedAttribute{
 					MarkdownDescription: "JQ condition for automation trigger",
 					Optional:            true,