Method triggerFromCreateParams

internal/extension/host_api.go:2263–2308

(
	ctx context.Context,
	req hostAPIAutomationTriggerCreateParams,
)

}

func (h *HostAPIHandler) triggerFromCreateParams(
	ctx context.Context,
	req hostAPIAutomationTriggerCreateParams,
) (automationpkg.Trigger, automationpkg.WebhookSecretWrite, error) {
	workspaceID, err := h.resolveAutomationWorkspaceID(ctx, req.WorkspaceID)
	if err != nil {
		return automationpkg.Trigger{}, automationpkg.WebhookSecretWrite{}, err
	}

	enabled := true
	if req.Enabled != nil {
		enabled = *req.Enabled
	}

	retry := automationpkg.DefaultRetryConfig()
	if req.Retry != nil {
		retry = *req.Retry
	}

	fireLimit := automationpkg.DefaultFireLimitConfig()
	if req.FireLimit != nil {
		fireLimit = *req.FireLimit
	}

	trigger := automationpkg.Trigger{
		Scope:        req.Scope,
		Name:         strings.TrimSpace(req.Name),
		AgentName:    strings.TrimSpace(req.AgentName),
		WorkspaceID:  workspaceID,
		Prompt:       strings.TrimSpace(req.Prompt),
		Event:        strings.TrimSpace(req.Event),
		Filter:       cloneHostAPIStringMap(req.Filter),
		Enabled:      enabled,
		Retry:        retry,
		FireLimit:    fireLimit,
		Source:       automationpkg.JobSourceDynamic,
		WebhookID:    strings.TrimSpace(req.WebhookID),
		EndpointSlug: strings.TrimSpace(req.EndpointSlug),
	}
	write := automationpkg.WebhookSecretWrite{}
	if strings.TrimSpace(req.WebhookSecretValue) != "" {
		value := strings.TrimSpace(req.WebhookSecretValue)
		write.Value = &value
	}
	return trigger, write, nil
}

func (h *HostAPIHandler) applyTriggerUpdateParams(
	ctx context.Context,