Method handleAutomationJobsUpdate

internal/extension/host_api.go:1476–1514

(ctx context.Context, raw json.RawMessage)

}

func (h *HostAPIHandler) handleAutomationJobsUpdate(ctx context.Context, raw json.RawMessage) (any, error) {
	automation, err := h.automationManager()
	if err != nil {
		return nil, err
	}

	var params hostAPIAutomationJobUpdateParams
	if err := decodeHostAPIParams(raw, &params); err != nil {
		return nil, err
	}
	if strings.TrimSpace(params.ID) == "" {
		return nil, invalidParamsRPCError(errors.New("id is required"))
	}
	if !params.HasChanges() {
		return nil, invalidParamsRPCError(errors.New("automation job update must include at least one field"))
	}

	current, err := automation.GetJob(ctx, params.ID)
	if err != nil {
		return nil, err
	}

	if current.Source == automationpkg.JobSourceConfig {
		if err := validateHostAPIConfigJobUpdate(params.UpdateJobRequest); err != nil {
			return nil, invalidParamsRPCError(err)
		}
		return automation.SetJobEnabled(ctx, current.ID, *params.Enabled)
	}

	next, err := h.applyJobUpdateParams(ctx, current, params.UpdateJobRequest)
	if err != nil {
		return nil, err
	}
	if err := next.Validate("job"); err != nil {
		return nil, invalidParamsRPCError(err)
	}

	return automation.UpdateJob(ctx, next)
}

func (h *HostAPIHandler) handleAutomationJobsDelete(ctx context.Context, raw json.RawMessage) (any, error) {
	automation, err := h.automationManager()