Function newHarness

coderd/workspaceconnwatcher/watcher_test.go:49–68

(ctx context.Context, t *testing.T, logger slog.Logger)

}

func newHarness(ctx context.Context, t *testing.T, logger slog.Logger) *harness {
	h := &harness{
		workspace: database.Workspace{
			ID:             workspaceID,
			OrganizationID: orgID,
			OwnerID:        userID,
		},
		orgID:  orgID,
		userID: userID,
		logger: logger,
	}
	ps := pubsub.NewInMemory()
	h.pub = ps

	var authzDB database.Store
	_, h.db, authzDB, _ = coderdtest.MockedDatabaseWithAuthz(t, logger)
	h.watcher = workspaceconnwatcher.New(ctx, logger.Named("watcher"), ps, authzDB)
	t.Cleanup(h.watcher.Close)
	return h
}

func (h *harness) Dial(ctx context.Context, url string) (*wsjson.Decoder[workspacesdk.ConnectionWatchEvent], error) {
	rt := testutil.InMemWebsocketRoundTripper{