Function TestUniqueOpts_validate

insert_opts_test.go:35–78

(t *testing.T)

}

func TestUniqueOpts_validate(t *testing.T) {
	t.Parallel()

	require.NoError(t, (&UniqueOpts{}).validate())
	require.NoError(t, (&UniqueOpts{
		ByArgs:   true,
		ByPeriod: 1 * time.Second,
		ByQueue:  true,
	}).validate())

	require.EqualError(t, (&UniqueOpts{ByPeriod: 1 * time.Millisecond}).validate(), "UniqueOpts.ByPeriod should not be less than 1 second")
	require.EqualError(t, (&UniqueOpts{ByState: []rivertype.JobState{rivertype.JobState("invalid")}}).validate(), `UniqueOpts.ByState contains invalid state "invalid"`)

	requiredStates := []rivertype.JobState{
		rivertype.JobStateAvailable,
		rivertype.JobStatePending,
		rivertype.JobStateRunning,
		rivertype.JobStateScheduled,
	}

	for _, state := range requiredStates {
		// Test with each state individually removed from requiredStates to ensure
		// it's validated.

		// Create a copy of requiredStates without the current state
		var testStates []rivertype.JobState
		for _, s := range requiredStates {
			if s != state {
				testStates = append(testStates, s)
			}
		}

		// Test validation
		require.EqualError(t, (&UniqueOpts{ByState: testStates}).validate(), "UniqueOpts.ByState must contain all required states, missing: "+string(state))
	}

	// test with more than one required state missing:
	require.EqualError(t, (&UniqueOpts{ByState: []rivertype.JobState{
		rivertype.JobStateAvailable,
		rivertype.JobStateScheduled,
	}}).validate(), "UniqueOpts.ByState must contain all required states, missing: pending, running")

	require.NoError(t, (&UniqueOpts{ByState: rivertype.JobStates()}).validate())
}