Function requireNotInsertedErr

rivertest/rivertest.go:262–305

(ctx context.Context, t testingT, exec riverdriver.Executor, expectedJob TArgs, opts *RequireInsertedOpts)

}

func requireNotInsertedErr[TDriver riverdriver.Driver[TTx], TTx any, TArgs river.JobArgs](ctx context.Context, t testingT, exec riverdriver.Executor, expectedJob TArgs, opts *RequireInsertedOpts) error {
	t.Helper()

	var schema string
	if opts != nil {
		schema = opts.Schema
	}

	// Returned ordered by ID.
	jobRows, err := exec.JobGetByKindMany(ctx, &riverdriver.JobGetByKindManyParams{
		Kind:   []string{expectedJob.Kind()},
		Schema: schema,
	})
	if err != nil {
		return fmt.Errorf("error querying jobs: %w", err)
	}

	if len(jobRows) < 1 {
		return nil
	}

	if len(jobRows) > 0 && opts == nil {
		failuref(t, "%d jobs found with kind, but expected to find none: %s", len(jobRows), expectedJob.Kind())
		return nil
	}

	// If any of these job rows failed assertions against opts, then the test
	// fails, but if they all succeed, then we consider no matching jobs to have
	// been inserted, and the test succeeds.
	for _, jobRow := range jobRows {
		var actualArgs TArgs
		if err := json.Unmarshal(jobRow.EncodedArgs, &actualArgs); err != nil {
			return fmt.Errorf("error unmarshaling job args: %w", err)
		}

		if opts != nil {
			if !compareJobToInsertOpts(t, jobRow, opts, -1, true) {
				return nil
			}
		}
	}

	return nil
}

// ExpectedJob is a single job to expect encapsulating job args and possible
// insertion options.