Skip to content

fix(site): update useAgentLogs to make it more testable and add more tests #19126

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 39 commits into
base: main
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
39 commits
Select commit Hold shift + click to select a range
d6e00c3
wip: commit progress on test update
Parkreiner May 23, 2025
43d0ca8
refactor: update useAgentLogs tests as unit tests
Parkreiner May 23, 2025
727bddd
docs: rewrite comment for clarity
Parkreiner May 23, 2025
d46d144
fix: remove unnecessary type
Parkreiner May 23, 2025
91a6fc1
fix: make sure logs have different timestamps
Parkreiner May 23, 2025
ecbe7b0
fix: add different dates to reduce risk of false positives
Parkreiner May 23, 2025
d13bcdc
Merge branch 'main' into mes/logs-flake
Parkreiner May 23, 2025
0f21097
Merge branch 'main' into mes/logs-flake
Parkreiner Aug 2, 2025
abd6553
refactor: decrease coupling
Parkreiner Aug 2, 2025
bade97a
wip: commit progress on updating flake
Parkreiner Aug 2, 2025
e11fefd
Merge branch 'mes/logs-flake' of https://github.com/coder/coder into …
Parkreiner Aug 2, 2025
bc3d095
fix: get all tests passing
Parkreiner Aug 2, 2025
550d09e
chore: add one more test case
Parkreiner Aug 2, 2025
cc7e632
fix: update type mismatches
Parkreiner Aug 2, 2025
79c7ffd
refactor: clean up some code
Parkreiner Aug 2, 2025
43a0d3a
fix: make testing boundaries more formal
Parkreiner Aug 2, 2025
982d3e1
fix: remove premature optimization
Parkreiner Aug 2, 2025
41c5a12
fix: update setup
Parkreiner Aug 4, 2025
42cb73b
fix: update state sync logic
Parkreiner Aug 4, 2025
3a5f7bb
Merge branch 'main' into mes/logs-flake
Parkreiner Aug 4, 2025
35a40df
fix: update wonky types
Parkreiner Aug 4, 2025
306dbc7
Merge branch 'main' into mes/logs-flake
Parkreiner Aug 4, 2025
f49e55a
Merge branch 'main' into mes/logs-flake
Parkreiner Aug 7, 2025
c2fc772
fix: update tests
Parkreiner Aug 7, 2025
2cabd85
fix: format
Parkreiner Aug 7, 2025
855f3ca
Merge branch 'main' into mes/logs-flake
Parkreiner Aug 9, 2025
453894b
fix: apply initial feedback
Parkreiner Aug 9, 2025
c9f2b12
wip: commit refactoring progress
Parkreiner Aug 9, 2025
80865fe
refactor: update assignment
Parkreiner Aug 9, 2025
f930b29
wip: prepare to change indents
Parkreiner Aug 9, 2025
a311ac9
fix: update keygen logic
Parkreiner Aug 9, 2025
5657536
chore: add basic overflow message
Parkreiner Aug 9, 2025
6547a2f
chore: swap to tailwind
Parkreiner Aug 9, 2025
c818aec
wip: commit progress
Parkreiner Aug 12, 2025
30bb008
Merge branch 'main' into mes/logs-flake
Parkreiner Aug 15, 2025
dac3828
refactor: switch to spy setup
Parkreiner Aug 15, 2025
7a013d3
fix: get scaffolding for new AgentLogs in place
Parkreiner Aug 15, 2025
b71d051
fix: remove bad import
Parkreiner Aug 15, 2025
092c4e5
fix: knip
Parkreiner Aug 15, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
refactor: switch to spy setup
  • Loading branch information
Parkreiner committed Aug 15, 2025
commit dac38281e572293b752bfab06c7db554fca6e4ce
48 changes: 25 additions & 23 deletions site/src/modules/resources/useAgentLogs.test.ts
Original file line number Diff line number Diff line change
@@ -1,13 +1,15 @@
import { MockWorkspaceAgent } from "testHelpers/entities";
import { renderHook, waitFor } from "@testing-library/react";
import type { WorkspaceAgentLog } from "api/typesGenerated";
import { act } from "react";
import {
type MockWebSocketServer,
createMockWebSocket,
type MockWebSocketServer,
} from "testHelpers/websockets";
import { renderHook, waitFor } from "@testing-library/react";
import * as apiModule from "api/api";
import type { WorkspaceAgentLog } from "api/typesGenerated";
import * as snackbarUtils from "components/GlobalSnackbar/utils";
import { act } from "react";
import { OneWayWebSocket } from "utils/OneWayWebSocket";
import { CreateUseAgentLogsOptions, createUseAgentLogs } from "./useAgentLogs";
import { useAgentLogs } from "./useAgentLogs";

const millisecondsInOneMinute = 60_000;

Expand Down Expand Up @@ -38,25 +40,25 @@ type ServerResult = { current: MockWebSocketServer | undefined };
type MountHookOptions = Readonly<{
initialAgentId: string;
enabled?: boolean;
onError?: CreateUseAgentLogsOptions["onError"];
}>;

type MountHookResult = Readonly<{
rerender: (props: { agentId: string; enabled: boolean }) => void;
serverResult: ServerResult;
rerender: (props: { agentId: string; enabled: boolean }) => void;
displayError: jest.SpyInstance<void, [s1: string, s2?: string], unknown>;

// Note: the `current` property is only "halfway" readonly; the value is
// readonly, but the key is still mutable
hookResult: { current: readonly WorkspaceAgentLog[] };
}>;

function mountHook(options: MountHookOptions): MountHookResult {
const { initialAgentId, enabled = true, onError = jest.fn() } = options;

const { initialAgentId, enabled = true } = options;
const serverResult: ServerResult = { current: undefined };
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

if we stick with this we could just use createRef and React.RefObject<MockWebSocketServer> instead of making our own type here

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Those are not the same. createRef is for interfacing with class components, and creates a mutable object that's still part of React's data flow

This setup is ejecting a value created during React's lifecycle into an outside function. React has absolutely no idea that this exists, but it's how a lot of React testing tools work under the hood. I get the aversion to having more bespoke types, but switching to the built-in type would be lying about it actually is

const useAgentLogs = createUseAgentLogs({
onError,
createSocket: (agentId, params) => {

jest
.spyOn(apiModule, "watchWorkspaceAgentLogs")
.mockImplementation((agentId, params) => {
return new OneWayWebSocket({
apiRoute: `/api/v2/workspaceagents/${agentId}/logs`,
searchParams: new URLSearchParams({
Expand All @@ -69,15 +71,17 @@ function mountHook(options: MountHookOptions): MountHookResult {
return mockSocket;
},
});
},
});
});

void jest.spyOn(console, "error").mockImplementation(() => {});
const displayError = jest.spyOn(snackbarUtils, "displayError");

const { result: hookResult, rerender } = renderHook(
(props) => useAgentLogs(props),
{ initialProps: { agentId: initialAgentId, enabled: enabled } },
{ initialProps: { enabled, agentId: initialAgentId } },
);

return { rerender, serverResult, hookResult };
return { rerender, serverResult, hookResult, displayError };
}

describe("useAgentLogs", () => {
Expand Down Expand Up @@ -140,26 +144,24 @@ describe("useAgentLogs", () => {
});

it("Calls error callback when error is received (but only while hook is enabled)", async () => {
const onError = jest.fn();
const { serverResult, rerender } = mountHook({
const { serverResult, rerender, displayError } = mountHook({
initialAgentId: MockWorkspaceAgent.id,
// Start off disabled so that we can check that the callback is
// never called when there is no connection
enabled: false,
onError,
});

const errorEvent = new Event("error");
await act(async () => serverResult.current?.publishError(errorEvent));
expect(onError).not.toHaveBeenCalled();
expect(displayError).not.toHaveBeenCalled();

rerender({ agentId: MockWorkspaceAgent.id, enabled: true });
await act(async () => serverResult.current?.publishError(errorEvent));
expect(onError).toHaveBeenCalledTimes(1);
expect(displayError).toHaveBeenCalledTimes(1);
});

// This is a protection to avoid duplicate logs when the hook goes back to
// being re-enabled
// // This is a protection to avoid duplicate logs when the hook goes back to
// // being re-enabled
it("Clears logs when hook becomes disabled", async () => {
const { hookResult, serverResult, rerender } = mountHook({
initialAgentId: MockWorkspaceAgent.id,
Expand Down
124 changes: 50 additions & 74 deletions site/src/modules/resources/useAgentLogs.ts
Original file line number Diff line number Diff line change
@@ -1,97 +1,73 @@
import {
type WatchWorkspaceAgentLogsParams,
watchWorkspaceAgentLogs,
} from "api/api";
import { watchWorkspaceAgentLogs } from "api/api";
import type { WorkspaceAgentLog } from "api/typesGenerated";
import { displayError } from "components/GlobalSnackbar/utils";
import { useEffect, useState } from "react";
import type { OneWayWebSocket } from "utils/OneWayWebSocket";

export type CreateUseAgentLogsOptions = Readonly<{
onError: (errorEvent: Event) => void;
createSocket: (
agentId: string,
params?: WatchWorkspaceAgentLogsParams,
) => OneWayWebSocket<WorkspaceAgentLog[]>;
}>;

type UseAgentLogsOptions = Readonly<{
agentId: string;
enabled?: boolean;
}>;

export function createUseAgentLogs(createOptions: CreateUseAgentLogsOptions) {
const { createSocket, onError } = createOptions;
export function useAgentLogs(
options: UseAgentLogsOptions,
): readonly WorkspaceAgentLog[] {
const { agentId, enabled = true } = options;
const [logs, setLogs] = useState<readonly WorkspaceAgentLog[]>([]);

return function useAgentLogs(
options: UseAgentLogsOptions,
): readonly WorkspaceAgentLog[] {
const { agentId, enabled = true } = options;
const [logs, setLogs] = useState<readonly WorkspaceAgentLog[]>([]);
// Clean up the logs when the agent is not enabled, using a mid-render
// sync to remove any risk of screen flickering. Clearing the logs helps
// ensure that if the hook flips back to being enabled, we can receive a
// fresh set of logs from the beginning with zero risk of duplicates.
const [prevEnabled, setPrevEnabled] = useState(enabled);
if (!enabled && prevEnabled) {
setLogs([]);
setPrevEnabled(false);
}
if (enabled && !prevEnabled) {
setPrevEnabled(true);
}

// Clean up the logs when the agent is not enabled, using a mid-render
// sync to remove any risk of screen flickering. Clearing the logs helps
// ensure that if the hook flips back to being enabled, we can receive a
// fresh set of logs from the beginning with zero risk of duplicates.
const [prevEnabled, setPrevEnabled] = useState(enabled);
if (!enabled && prevEnabled) {
setLogs([]);
setPrevEnabled(false);
}
if (enabled && !prevEnabled) {
setPrevEnabled(true);
useEffect(() => {
if (!enabled) {
return;
}

useEffect(() => {
if (!enabled) {
// Always fetch the logs from the beginning. We may want to optimize
// this in the future, but it would add some complexity in the code
// that might not be worth it.
const socket = watchWorkspaceAgentLogs(agentId, { after: 0 });
socket.addEventListener("message", (e) => {
if (e.parseError) {
console.warn("Error parsing agent log: ", e.parseError);
return;
}

// Always fetch the logs from the beginning. We may want to optimize
// this in the future, but it would add some complexity in the code
// that might not be worth it.
const socket = createSocket(agentId, { after: 0 });
socket.addEventListener("message", (e) => {
if (e.parseError) {
console.warn("Error parsing agent log: ", e.parseError);
return;
}

if (e.parsedMessage.length === 0) {
return;
}
if (e.parsedMessage.length === 0) {
return;
}

setLogs((logs) => {
const newLogs = [...logs, ...e.parsedMessage];
newLogs.sort((l1, l2) => {
const d1 = new Date(l1.created_at).getTime();
const d2 = new Date(l2.created_at).getTime();
return d1 - d2;
});
return newLogs;
setLogs((logs) => {
const newLogs = [...logs, ...e.parsedMessage];
newLogs.sort((l1, l2) => {
const d1 = new Date(l1.created_at).getTime();
const d2 = new Date(l2.created_at).getTime();
return d1 - d2;
});
return newLogs;
});
});

socket.addEventListener("error", (e) => {
onError(e);
socket.close();
});
socket.addEventListener("error", (e) => {
console.error("Error in agent log socket: ", e);
displayError(
"Unable to watch agent logs",
"Please try refreshing the browser",
);
socket.close();
});

return () => socket.close();
}, [agentId, enabled]);
return () => socket.close();
}, [agentId, enabled]);

return logs;
};
return logs;
}

// The baseline implementation to use for production
export const useAgentLogs = createUseAgentLogs({
createSocket: watchWorkspaceAgentLogs,
onError: (errorEvent) => {
console.error("Error in agent log socket: ", errorEvent);
displayError(
"Unable to watch agent logs",
"Please try refreshing the browser",
);
},
});
Loading