chore: add mcp server fixture (#35262)

This commit is contained in:
Pavel Feldman 2025-03-19 08:21:53 -07:00 committed by GitHub
parent 23c4c256b0
commit 0350ca32b4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
6 changed files with 132 additions and 107 deletions

View File

@ -60,15 +60,9 @@ export const goBack: ToolFactory = snapshot => ({
inputSchema: zodToJsonSchema(goBackSchema), inputSchema: zodToJsonSchema(goBackSchema),
}, },
handle: async context => { handle: async context => {
return await runAndWait(context, async () => { return await runAndWait(context, 'Navigated back', async () => {
const page = await context.ensurePage(); const page = await context.ensurePage();
await page.goBack(); await page.goBack();
return {
content: [{
type: 'text',
text: `Navigated back`,
}],
};
}, snapshot); }, snapshot);
}, },
}); });
@ -82,15 +76,9 @@ export const goForward: ToolFactory = snapshot => ({
inputSchema: zodToJsonSchema(goForwardSchema), inputSchema: zodToJsonSchema(goForwardSchema),
}, },
handle: async context => { handle: async context => {
return await runAndWait(context, async () => { return await runAndWait(context, 'Navigated forward', async () => {
const page = await context.ensurePage(); const page = await context.ensurePage();
await page.goForward(); await page.goForward();
return {
content: [{
type: 'text',
text: `Navigated forward`,
}],
};
}, snapshot); }, snapshot);
}, },
}); });
@ -130,14 +118,8 @@ export const pressKey: Tool = {
}, },
handle: async (context, params) => { handle: async (context, params) => {
const validatedParams = pressKeySchema.parse(params); const validatedParams = pressKeySchema.parse(params);
return await runAndWait(context, async page => { return await runAndWait(context, `Pressed key ${validatedParams.key}`, async page => {
await page.keyboard.press(validatedParams.key); await page.keyboard.press(validatedParams.key);
return {
content: [{
type: 'text',
text: `Pressed key ${validatedParams.key}`,
}],
};
}); });
}, },
}; };

View File

@ -76,15 +76,12 @@ export const click: Tool = {
}, },
handle: async (context, params) => { handle: async (context, params) => {
await runAndWait(context, async page => { return await runAndWait(context, 'Clicked mouse', async page => {
const validatedParams = clickSchema.parse(params); const validatedParams = clickSchema.parse(params);
await page.mouse.move(validatedParams.x, validatedParams.y); await page.mouse.move(validatedParams.x, validatedParams.y);
await page.mouse.down(); await page.mouse.down();
await page.mouse.up(); await page.mouse.up();
}); });
return {
content: [{ type: 'text', text: 'Clicked mouse' }],
};
}, },
}; };
@ -104,15 +101,12 @@ export const drag: Tool = {
handle: async (context, params) => { handle: async (context, params) => {
const validatedParams = dragSchema.parse(params); const validatedParams = dragSchema.parse(params);
await runAndWait(context, async page => { return await runAndWait(context, `Dragged mouse from (${validatedParams.startX}, ${validatedParams.startY}) to (${validatedParams.endX}, ${validatedParams.endY})`, async page => {
await page.mouse.move(validatedParams.startX, validatedParams.startY); await page.mouse.move(validatedParams.startX, validatedParams.startY);
await page.mouse.down(); await page.mouse.down();
await page.mouse.move(validatedParams.endX, validatedParams.endY); await page.mouse.move(validatedParams.endX, validatedParams.endY);
await page.mouse.up(); await page.mouse.up();
}); });
return {
content: [{ type: 'text', text: `Dragged mouse from (${validatedParams.startX}, ${validatedParams.startY}) to (${validatedParams.endX}, ${validatedParams.endY})` }],
};
}, },
}; };
@ -130,13 +124,10 @@ export const type: Tool = {
handle: async (context, params) => { handle: async (context, params) => {
const validatedParams = typeSchema.parse(params); const validatedParams = typeSchema.parse(params);
await runAndWait(context, async page => { return await runAndWait(context, `Typed text "${validatedParams.text}"`, async page => {
await page.keyboard.type(validatedParams.text); await page.keyboard.type(validatedParams.text);
if (validatedParams.submit) if (validatedParams.submit)
await page.keyboard.press('Enter'); await page.keyboard.press('Enter');
}, true); });
return {
content: [{ type: 'text', text: `Typed text "${validatedParams.text}"` }],
};
}, },
}; };

View File

@ -48,7 +48,7 @@ export const click: Tool = {
handle: async (context, params) => { handle: async (context, params) => {
const validatedParams = elementSchema.parse(params); const validatedParams = elementSchema.parse(params);
return runAndWait(context, page => refLocator(page, validatedParams.ref).click(), true); return runAndWait(context, `"${validatedParams.element}" clicked`, page => refLocator(page, validatedParams.ref).click(), true);
}, },
}; };
@ -68,7 +68,7 @@ export const drag: Tool = {
handle: async (context, params) => { handle: async (context, params) => {
const validatedParams = dragSchema.parse(params); const validatedParams = dragSchema.parse(params);
return runAndWait(context, async page => { return runAndWait(context, `Dragged "${validatedParams.startElement}" to "${validatedParams.endElement}"`, async page => {
const startLocator = refLocator(page, validatedParams.startRef); const startLocator = refLocator(page, validatedParams.startRef);
const endLocator = refLocator(page, validatedParams.endRef); const endLocator = refLocator(page, validatedParams.endRef);
await startLocator.dragTo(endLocator); await startLocator.dragTo(endLocator);
@ -85,7 +85,7 @@ export const hover: Tool = {
handle: async (context, params) => { handle: async (context, params) => {
const validatedParams = elementSchema.parse(params); const validatedParams = elementSchema.parse(params);
return runAndWait(context, page => refLocator(page, validatedParams.ref).hover(), true); return runAndWait(context, `Hovered over "${validatedParams.element}"`, page => refLocator(page, validatedParams.ref).hover(), true);
}, },
}; };
@ -103,7 +103,7 @@ export const type: Tool = {
handle: async (context, params) => { handle: async (context, params) => {
const validatedParams = typeSchema.parse(params); const validatedParams = typeSchema.parse(params);
return await runAndWait(context, async page => { return await runAndWait(context, `Typed "${validatedParams.text}" into "${validatedParams.element}"`, async page => {
const locator = refLocator(page, validatedParams.ref); const locator = refLocator(page, validatedParams.ref);
await locator.fill(validatedParams.text); await locator.fill(validatedParams.text);
if (validatedParams.submit) if (validatedParams.submit)

View File

@ -71,20 +71,25 @@ async function waitForCompletion<R>(page: playwright.Page, callback: () => Promi
} }
} }
export async function runAndWait(context: Context, callback: (page: playwright.Page) => Promise<any>, snapshot: boolean = false): Promise<ToolResult> { export async function runAndWait(context: Context, status: string, callback: (page: playwright.Page) => Promise<any>, snapshot: boolean = false): Promise<ToolResult> {
const page = await context.ensurePage(); const page = await context.ensurePage();
const result = await waitForCompletion(page, () => callback(page)); await waitForCompletion(page, () => callback(page));
return snapshot ? captureAriaSnapshot(page) : result; return snapshot ? captureAriaSnapshot(page, status) : {
content: [{ type: 'text', text: status }],
};
} }
export async function captureAriaSnapshot(page: playwright.Page): Promise<ToolResult> { export async function captureAriaSnapshot(page: playwright.Page, status: string = ''): Promise<ToolResult> {
const snapshot = await page.locator('html').ariaSnapshot({ ref: true }); const snapshot = await page.locator('html').ariaSnapshot({ ref: true });
return { return {
content: [{ type: 'text', text: ` content: [{ type: 'text', text: `${status ? `${status}\n` : ''}
# Page URL: ${page.url()} - Page URL: ${page.url()}
# Page Title: ${page.title()} - Page Title: ${await page.title()}
# Page Snapshot - Page Snapshot
${snapshot}` \`\`\`yaml
${snapshot}
\`\`\`
`
}], }],
}; };
} }

View File

@ -14,54 +14,9 @@
* limitations under the License. * limitations under the License.
*/ */
import path from 'path'; import { test, expect } from './fixtures';
import { test, expect } from '@playwright/test';
import { MCPServer } from './fixtures';
async function startServer(): Promise<MCPServer> {
const server = new MCPServer('node', [path.join(__dirname, '../cli.js'), '--headless']);
const initialize = await server.send({
jsonrpc: '2.0',
id: 0,
method: 'initialize',
params: {
protocolVersion: '2024-11-05',
capabilities: {},
clientInfo: {
name: 'Playwright Test',
version: '0.0.0',
},
},
});
expect(initialize).toEqual(expect.objectContaining({
id: 0,
result: expect.objectContaining({
protocolVersion: '2024-11-05',
capabilities: {
tools: {},
resources: {},
},
serverInfo: expect.objectContaining({
name: 'Playwright',
version: expect.any(String),
}),
}),
}));
await server.sendNoReply({
jsonrpc: '2.0',
method: 'notifications/initialized',
});
return server;
}
test('test tool list', async ({}) => {
const server = await startServer();
test('test tool list', async ({ server }) => {
const list = await server.send({ const list = await server.send({
jsonrpc: '2.0', jsonrpc: '2.0',
id: 1, id: 1,
@ -110,9 +65,7 @@ test('test tool list', async ({}) => {
})); }));
}); });
test('test resources list', async ({}) => { test('test resources list', async ({ server }) => {
const server = await startServer();
const list = await server.send({ const list = await server.send({
jsonrpc: '2.0', jsonrpc: '2.0',
id: 2, id: 2,
@ -132,9 +85,7 @@ test('test resources list', async ({}) => {
})); }));
}); });
test('test browser_navigate', async ({}) => { test('test browser_navigate', async ({ server }) => {
const server = await startServer();
const response = await server.send({ const response = await server.send({
jsonrpc: '2.0', jsonrpc: '2.0',
id: 2, id: 2,
@ -142,7 +93,7 @@ test('test browser_navigate', async ({}) => {
params: { params: {
name: 'browser_navigate', name: 'browser_navigate',
arguments: { arguments: {
url: 'https://example.com', url: 'data:text/html,<html><title>Title</title><body>Hello, world!</body></html>',
}, },
}, },
}); });
@ -152,11 +103,60 @@ test('test browser_navigate', async ({}) => {
result: { result: {
content: [{ content: [{
type: 'text', type: 'text',
text: expect.stringContaining(` text: `
# Page URL: https://example.com/ - Page URL: data:text/html,<html><title>Title</title><body>Hello, world!</body></html>
# Page Title: [object Promise] - Page Title: Title
# Page Snapshot - Page Snapshot
- document`), \`\`\`yaml
- document [ref=s1e2]: Hello, world!
\`\`\`
`,
}],
},
}));
});
test('test browser_click', async ({ server }) => {
await server.send({
jsonrpc: '2.0',
id: 2,
method: 'tools/call',
params: {
name: 'browser_navigate',
arguments: {
url: 'data:text/html,<html><title>Title</title><button>Submit</button></html>',
},
},
});
const response = await server.send({
jsonrpc: '2.0',
id: 3,
method: 'tools/call',
params: {
name: 'browser_click',
arguments: {
element: 'Submit button',
ref: 's1e4',
},
},
});
expect(response).toEqual(expect.objectContaining({
id: 3,
result: {
content: [{
type: 'text',
text: `\"Submit button\" clicked
- Page URL: data:text/html,<html><title>Title</title><button>Submit</button></html>
- Page Title: Title
- Page Snapshot
\`\`\`yaml
- document [ref=s2e2]:
- button \"Submit\" [ref=s2e4]
\`\`\`
`,
}], }],
}, },
})); }));

View File

@ -14,12 +14,17 @@
* limitations under the License. * limitations under the License.
*/ */
import path from 'path';
import { spawn } from 'child_process'; import { spawn } from 'child_process';
import EventEmitter from 'events'; import EventEmitter from 'events';
import { test as baseTest, expect } from '@playwright/test';
import type { ChildProcess } from 'child_process'; import type { ChildProcess } from 'child_process';
export class MCPServer extends EventEmitter { export { expect } from '@playwright/test';
class MCPServer extends EventEmitter {
private _child: ChildProcess; private _child: ChildProcess;
private _messageQueue: any[] = []; private _messageQueue: any[] = [];
private _messageResolvers: ((value: any) => void)[] = []; private _messageResolvers: ((value: any) => void)[] = [];
@ -102,3 +107,45 @@ export class MCPServer extends EventEmitter {
}); });
} }
} }
export const test = baseTest.extend<{ server: MCPServer }>({
server: async ({}, use) => {
const server = new MCPServer('node', [path.join(__dirname, '../cli.js'), '--headless']);
const initialize = await server.send({
jsonrpc: '2.0',
id: 0,
method: 'initialize',
params: {
protocolVersion: '2024-11-05',
capabilities: {},
clientInfo: {
name: 'Playwright Test',
version: '0.0.0',
},
},
});
expect(initialize).toEqual(expect.objectContaining({
id: 0,
result: expect.objectContaining({
protocolVersion: '2024-11-05',
capabilities: {
tools: {},
resources: {},
},
serverInfo: expect.objectContaining({
name: 'Playwright',
version: expect.any(String),
}),
}),
}));
await server.sendNoReply({
jsonrpc: '2.0',
method: 'notifications/initialized',
});
await use(server);
await server.close();
},
});