Method CreateRun

server-source-code/internal/store/patching.go:249–295

CreateRun creates a new patch run. If id is empty, a new UUID is generated. triggeredByUserID is the user who initiated the run (optional; nil for agent/system). dryRun when true creates a validation-only run with status "pending_validation". scheduledAt is when the patch will run (optional; nil for

(ctx context.Context, id, hostID, jobID, patchType string, packageName *string, packageNames []string, triggeredByUserID *string, dryRun bool, scheduledAt *time.Time, policyID, policyName *string, policySnapshot []byte, opts *CreateRunOpts)

// policyID, policyName, policySnapshot capture the effective policy at trigger time (all optional).
// opts.InitialStatus, if non-empty, overrides the dry-run-derived status.
func (s *PatchRunsStore) CreateRun(ctx context.Context, id, hostID, jobID, patchType string, packageName *string, packageNames []string, triggeredByUserID *string, dryRun bool, scheduledAt *time.Time, policyID, policyName *string, policySnapshot []byte, opts *CreateRunOpts) (string, error) {
	if id == "" {
		id = uuid.New().String()
	}
	var pkgNames []byte
	if len(packageNames) > 0 {
		var err error
		pkgNames, err = json.Marshal(packageNames)
		if err != nil {
			return "", err
		}
	}
	status := "queued"
	if dryRun {
		status = "pending_validation"
	}
	if opts != nil && opts.InitialStatus != "" {
		status = opts.InitialStatus
	}
	sched := pgtime.FromPtr(scheduledAt)
	var validationRunID *string
	var approvedByUserID *string
	if opts != nil {
		validationRunID = opts.ValidationRunID
		approvedByUserID = opts.ApprovedByUserID
	}
	d := s.db.DB(ctx)
	err := d.Queries.CreatePatchRun(ctx, db.CreatePatchRunParams{
		ID:                id,
		HostID:            hostID,
		JobID:             jobID,
		PatchType:         patchType,
		PackageName:       packageName,
		PackageNames:      pkgNames,
		Status:            status,
		ShellOutput:       "",
		TriggeredByUserID: triggeredByUserID,
		DryRun:            dryRun,
		ScheduledAt:       sched,
		PolicyID:          policyID,
		PolicyName:        policyName,
		PolicySnapshot:    policySnapshot,
		ValidationRunID:   validationRunID,
		ApprovedByUserID:  approvedByUserID,
	})
	return id, err
}

// GetByID returns a patch run by ID with host info.
func (s *PatchRunsStore) GetByID(ctx context.Context, id string) (*db.GetPatchRunByIDRow, error) {