Function TestWatcher_LostAccess

coderd/workspaceconnwatcher/watcher_test.go:258–288

(t *testing.T)

}

func TestWatcher_LostAccess(t *testing.T) {
	t.Parallel()
	ctx := testutil.Context(t, testutil.WaitShort)
	logger := testutil.Logger(t)
	h := newHarness(ctx, t, logger)

	h.db.EXPECT().GetLatestWorkspaceBuildWithStatusByWorkspaceID(gomock.Any(), h.workspace.ID).
		Times(1).
		Return(database.GetLatestWorkspaceBuildWithStatusByWorkspaceIDRow{
			Transition:  database.WorkspaceTransitionStart,
			BuildNumber: 1,
			JobStatus:   database.ProvisionerJobStatusSucceeded,
			WorkspaceTable: database.WorkspaceTable{
				ID:             h.workspace.ID,
				OwnerID:        uuid.UUID{99}, // workspace gets a new owner, e.g.
				OrganizationID: orgID,
			},
		}, nil)

	dec, err := h.Dial(ctx, "wss://local.test/")
	require.NoError(t, err)
	defer func() {
		_ = dec.Close()
	}()
	events := dec.Chan()
	e0 := testutil.RequireReceive(ctx, t, events)
	require.NotNil(t, e0.Error)
	require.Equal(t, workspacesdk.WatchErrorDatabase, e0.Error.Code)
	require.False(t, e0.Error.Retryable)
	require.Equal(t, "unauthorized", e0.Error.Details, "should not leak internal auth details")
}

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