Add automations run updated event trigger support

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,6 @@ const (
 	EntityDeleted        = "ENTITY_DELETED"
 	TimerPropertyExpired = "TIMER_PROPERTY_EXPIRED"
 	AnyEntityChange      = "ANY_ENTITY_CHANGE"
+	RunUpdated           = "RUN_UPDATED"
 	JqCondition          = "JQ"
 )

port/action/actionStateToPortBody.go

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

port/action/model.go

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

port/action/refreshActionState.go

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

port/action/resource_test.go

@@ -1567,6 +1567,49 @@ func TestAccPortAutomationTimerPropertyExpired(t *testing.T) {
 	})
 }
 
+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"
+	}
+	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 TestAccPortWebhookApproval(t *testing.T) {
 	identifier := utils.GenID()
 	actionIdentifier := utils.GenID()

port/action/schema.go

@@ -161,6 +161,7 @@ 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_updated_event"),
 						),
 					},
 				},
@@ -208,6 +209,16 @@ func ActionSchema() map[string]schema.Attribute {
 						},
 					},
 				},
+				"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,
+						},
+					},
+				},
 				"jq_condition": schema.SingleNestedAttribute{
 					MarkdownDescription: "JQ condition for automation trigger",
 					Optional:            true,