Function Job_Build

rivershared/testfactory/test_factory.go:51–108

(tb testing.TB, opts *JobOpts)

}

func Job_Build(tb testing.TB, opts *JobOpts) *riverdriver.JobInsertFullParams {
	tb.Helper()

	attemptedAt := opts.AttemptedAt
	if attemptedAt == nil && (opts.State != nil && (slices.Contains([]rivertype.JobState{
		rivertype.JobStateCompleted,
		rivertype.JobStateDiscarded,
		rivertype.JobStateRetryable,
		rivertype.JobStateRunning,
	}, *opts.State))) {
		attemptedAt = ptrutil.Ptr(time.Now())
	}

	encodedArgs := opts.EncodedArgs
	if opts.EncodedArgs == nil {
		encodedArgs = []byte("{}")
	}

	finalizedAt := opts.FinalizedAt
	if finalizedAt == nil && (opts.State != nil && (slices.Contains([]rivertype.JobState{
		rivertype.JobStateCompleted,
		rivertype.JobStateCancelled,
		rivertype.JobStateDiscarded,
	}, *opts.State))) {
		finalizedAt = ptrutil.Ptr(time.Now())
	}

	metadata := opts.Metadata
	if opts.Metadata == nil {
		metadata = []byte("{}")
	}

	tags := opts.Tags
	if tags == nil {
		tags = []string{}
	}

	return &riverdriver.JobInsertFullParams{
		Attempt:      ptrutil.ValOrDefault(opts.Attempt, 0),
		AttemptedAt:  attemptedAt,
		AttemptedBy:  opts.AttemptedBy,
		CreatedAt:    opts.CreatedAt,
		EncodedArgs:  encodedArgs,
		Errors:       opts.Errors,
		FinalizedAt:  finalizedAt,
		Kind:         ptrutil.ValOrDefault(opts.Kind, "fake_job"),
		MaxAttempts:  ptrutil.ValOrDefault(opts.MaxAttempts, rivercommon.MaxAttemptsDefault),
		Metadata:     metadata,
		Priority:     ptrutil.ValOrDefault(opts.Priority, rivercommon.PriorityDefault),
		Queue:        ptrutil.ValOrDefault(opts.Queue, rivercommon.QueueDefault),
		ScheduledAt:  opts.ScheduledAt,
		Schema:       opts.Schema,
		State:        ptrutil.ValOrDefault(opts.State, rivertype.JobStateAvailable),
		Tags:         tags,
		UniqueKey:    opts.UniqueKey,
		UniqueStates: opts.UniqueStates,
	}
}