Function openLowBusyTestKernel

internal/resources/kernel_test.go:1196–1241

(t *testing.T, opts ...Option)

}

func openLowBusyTestKernel(t *testing.T, opts ...Option) (*Kernel, *sql.DB) {
	t.Helper()

	dbPath := filepath.Join(t.TempDir(), store.GlobalDatabaseName)
	dsnURL := url.URL{
		Scheme: "file",
		Path:   filepath.ToSlash(dbPath),
	}
	query := dsnURL.Query()
	query.Add("_pragma", "busy_timeout(1)")
	query.Add("_pragma", "foreign_keys(ON)")
	query.Add("_pragma", "journal_mode(WAL)")
	query.Add("_pragma", "synchronous(NORMAL)")
	dsnURL.RawQuery = query.Encode()

	db, err := sql.Open("sqlite", dsnURL.String())
	if err != nil {
		t.Fatalf("sql.Open() error = %v", err)
	}
	db.SetMaxOpenConns(8)
	db.SetMaxIdleConns(8)
	t.Cleanup(func() {
		if closeErr := db.Close(); closeErr != nil {
			t.Fatalf("db.Close() error = %v", closeErr)
		}
	})

	ctx := testutil.Context(t)
	if err := db.PingContext(ctx); err != nil {
		t.Fatalf("db.PingContext() error = %v", err)
	}
	if err := store.EnsureSchema(ctx, db, SchemaStatements()); err != nil {
		t.Fatalf("EnsureSchema() error = %v", err)
	}

	options := append([]Option{
		WithNow(func() time.Time {
			return time.Date(2026, 4, 15, 12, 0, 0, 0, time.UTC)
		}),
	}, opts...)
	kernel, err := NewKernel(db, options...)
	if err != nil {
		t.Fatalf("NewKernel() error = %v", err)
	}
	return kernel, db
}

func holdResourceWriteLock(ctx context.Context, t *testing.T, db *sql.DB) {
	t.Helper()