Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
33 changes: 14 additions & 19 deletions src/McpContext.ts
Original file line number Diff line number Diff line change
Expand Up @@ -207,13 +207,12 @@ export class McpContext implements Context {
return this.#requestPage?.pptrPage ?? this.getSelectedPptrPage();
}

resolveCdpRequestId(cdpRequestId: string): number | undefined {
const selectedPage = this.#resolveTargetPage();
resolveCdpRequestId(page: McpPage, cdpRequestId: string): number | undefined {
if (!cdpRequestId) {
this.logger('no network request');
return;
}
const request = this.#networkCollector.find(selectedPage, request => {
const request = this.#networkCollector.find(page.pptrPage, request => {
// @ts-expect-error id is internal.
return request.id === cdpRequestId;
});
Expand All @@ -225,31 +224,27 @@ export class McpContext implements Context {
}

resolveCdpElementId(
page: McpPage,
cdpBackendNodeId: number,
page?: Page,
): string | undefined {
if (!cdpBackendNodeId) {
this.logger('no cdpBackendNodeId');
return;
}
const snapshots = page
? [this.#mcpPages.get(page)?.textSnapshot].filter(Boolean)
: [...this.#mcpPages.values()].map(mp => mp.textSnapshot).filter(Boolean);
if (!snapshots.length) {
const snapshot = page.textSnapshot;
if (!snapshot) {
this.logger('no text snapshot');
return;
}
// TODO: index by backendNodeId instead.
for (const snapshot of snapshots) {
const queue = [snapshot!.root];
while (queue.length) {
const current = queue.pop()!;
if (current.backendNodeId === cdpBackendNodeId) {
return current.id;
}
for (const child of current.children) {
queue.push(child);
}
const queue = [snapshot.root];
while (queue.length) {
const current = queue.pop()!;
if (current.backendNodeId === cdpBackendNodeId) {
return current.id;
}
for (const child of current.children) {
queue.push(child);
}
}
return;
Expand Down Expand Up @@ -971,8 +966,8 @@ export class McpContext implements Context {
if (data?.cdpBackendNodeId) {
snapshot.hasSelectedElement = true;
snapshot.selectedElementUid = this.resolveCdpElementId(
mcpPage,
data?.cdpBackendNodeId,
page,
);
}

Expand Down
13 changes: 11 additions & 2 deletions src/McpResponse.ts
Original file line number Diff line number Diff line change
Expand Up @@ -320,10 +320,19 @@ export class McpResponse implements Response {
devTools: devTools ?? undefined,
});
} else if (message instanceof DevTools.AggregatedIssue) {
if (!this.#page) {
throw new Error(`Response must have an McpPage`);
}
const formatter = new IssueFormatter(message, {
id: consoleMessageStableId,
requestIdResolver: context.resolveCdpRequestId.bind(context),
elementIdResolver: context.resolveCdpElementId.bind(context),
requestIdResolver: context.resolveCdpRequestId.bind(
context,
this.#page,
),
elementIdResolver: context.resolveCdpElementId.bind(
context,
this.#page,
),
});
if (!formatter.isValid()) {
throw new Error(
Expand Down
5 changes: 4 additions & 1 deletion src/tools/ToolDefinition.ts
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,10 @@ export type Context = Readonly<{
/**
* Returns a reqid for a cdpRequestId.
*/
resolveCdpRequestId(cdpRequestId: string): number | undefined;
resolveCdpRequestId(
page: ContextPage,
cdpRequestId: string,
): number | undefined;
getScreenRecorder(): {recorder: ScreenRecorder; filePath: string} | null;
setScreenRecorder(
data: {recorder: ScreenRecorder; filePath: string} | null,
Expand Down
4 changes: 2 additions & 2 deletions src/tools/network.ts
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ export const listNetworkRequests = definePageTool({
const data = await context.getDevToolsData();
response.attachDevToolsData(data);
const reqid = data?.cdpRequestId
? context.resolveCdpRequestId(data.cdpRequestId)
? context.resolveCdpRequestId(request.page, data.cdpRequestId)
: undefined;
response.setIncludeNetworkRequests(true, {
pageSize: request.params.pageSize,
Expand Down Expand Up @@ -123,7 +123,7 @@ export const getNetworkRequest = definePageTool({
const data = await context.getDevToolsData();
response.attachDevToolsData(data);
const reqid = data?.cdpRequestId
? context.resolveCdpRequestId(data.cdpRequestId)
? context.resolveCdpRequestId(request.page, data.cdpRequestId)
: undefined;
if (reqid) {
response.attachNetworkRequest(reqid, {
Expand Down
2 changes: 2 additions & 0 deletions tests/tools/console.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -212,6 +212,7 @@ describe('console', () => {
context,
);
const response2 = new McpResponse({} as ParsedArguments);
response2.setPage(context.getSelectedMcpPage());
await getConsoleMessage.handler(
{params: {msgid: 1}, page: context.getSelectedMcpPage()},
response2,
Expand Down Expand Up @@ -267,6 +268,7 @@ describe('console', () => {
context,
);
const response2 = new McpResponse({} as ParsedArguments);
response2.setPage(context.getSelectedMcpPage());
await getConsoleMessage.handler(
{params: {msgid: id}, page: context.getSelectedMcpPage()},
response2,
Expand Down