chore: stream trace viewer logs (#27807)

This commit is contained in:
Pavel Feldman 2023-10-26 11:15:43 -07:00 committed by GitHub
parent 5f366088be
commit 778047facc
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
9 changed files with 347 additions and 41 deletions

View file

@ -43,7 +43,7 @@ import { Snapshotter } from './snapshotter';
import { yazl } from '../../../zipBundle'; import { yazl } from '../../../zipBundle';
import type { ConsoleMessage } from '../../console'; import type { ConsoleMessage } from '../../console';
const version: trace.VERSION = 5; const version: trace.VERSION = 6;
export type TracerOptions = { export type TracerOptions = {
name?: string; name?: string;
@ -368,6 +368,14 @@ export class Tracing extends SdkObject implements InstrumentationListener, Snaps
return this._captureSnapshot(event.inputSnapshot, sdkObject, metadata, element); return this._captureSnapshot(event.inputSnapshot, sdkObject, metadata, element);
} }
onCallLog(sdkObject: SdkObject, metadata: CallMetadata, logName: string, message: string) {
if (logName !== 'api')
return;
const event = createActionLogTraceEvent(metadata, message);
if (event)
this._appendTraceEvent(event);
}
async onAfterCall(sdkObject: SdkObject, metadata: CallMetadata) { async onAfterCall(sdkObject: SdkObject, metadata: CallMetadata) {
if (!this._state?.callIds.has(metadata.id)) if (!this._state?.callIds.has(metadata.id))
return; return;
@ -466,7 +474,7 @@ export class Tracing extends SdkObject implements InstrumentationListener, Snaps
private _appendTraceEvent(event: trace.TraceEvent) { private _appendTraceEvent(event: trace.TraceEvent) {
const visited = visitTraceEvent(event, this._state!.traceSha1s); const visited = visitTraceEvent(event, this._state!.traceSha1s);
// Do not flush (console) events, they are too noisy, unless we are in ui mode (live). // Do not flush (console) events, they are too noisy, unless we are in ui mode (live).
const flush = this._state!.options.live || (event.type !== 'event' && event.type !== 'console'); const flush = this._state!.options.live || (event.type !== 'event' && event.type !== 'console' && event.type !== 'log');
this._fs.appendFile(this._state!.traceFile, JSON.stringify(visited) + '\n', flush); this._fs.appendFile(this._state!.traceFile, JSON.stringify(visited) + '\n', flush);
} }
@ -531,6 +539,17 @@ function createInputActionTraceEvent(metadata: CallMetadata): trace.InputActionT
}; };
} }
function createActionLogTraceEvent(metadata: CallMetadata, message: string): trace.LogTraceEvent | null {
if (metadata.internal || metadata.method.startsWith('tracing'))
return null;
return {
type: 'log',
callId: metadata.id,
time: monotonicTime(),
message,
};
}
function createAfterActionTraceEvent(metadata: CallMetadata): trace.AfterActionTraceEvent | null { function createAfterActionTraceEvent(metadata: CallMetadata): trace.AfterActionTraceEvent | null {
if (metadata.internal || metadata.method.startsWith('tracing')) if (metadata.internal || metadata.method.startsWith('tracing'))
return null; return null;
@ -538,7 +557,6 @@ function createAfterActionTraceEvent(metadata: CallMetadata): trace.AfterActionT
type: 'after', type: 'after',
callId: metadata.id, callId: metadata.id,
endTime: metadata.endTime, endTime: metadata.endTime,
log: metadata.log,
error: metadata.error?.error, error: metadata.error?.error,
result: metadata.result, result: metadata.result,
}; };

View file

@ -130,7 +130,6 @@ export class TestTracing {
type: 'after', type: 'after',
callId, callId,
endTime: monotonicTime(), endTime: monotonicTime(),
log: [],
attachments: serializeAttachments(attachments), attachments: serializeAttachments(attachments),
error, error,
}); });

View file

@ -33,7 +33,7 @@ export type ContextEntry = {
options: trace.BrowserContextEventOptions; options: trace.BrowserContextEventOptions;
pages: PageEntry[]; pages: PageEntry[];
resources: ResourceSnapshot[]; resources: ResourceSnapshot[];
actions: trace.ActionTraceEvent[]; actions: ActionEntry[];
events: (trace.EventTraceEvent | trace.ConsoleMessageTraceEvent)[]; events: (trace.EventTraceEvent | trace.ConsoleMessageTraceEvent)[];
stdio: trace.StdioTraceEvent[]; stdio: trace.StdioTraceEvent[];
hasSource: boolean; hasSource: boolean;
@ -47,6 +47,11 @@ export type PageEntry = {
height: number, height: number,
}[]; }[];
}; };
export type ActionEntry = trace.ActionTraceEvent & {
log: { time: number, message: string }[];
};
export function createEmptyContext(): ContextEntry { export function createEmptyContext(): ContextEntry {
return { return {
isPrimary: false, isPrimary: false,

View file

@ -17,8 +17,9 @@
import type * as trace from '@trace/trace'; import type * as trace from '@trace/trace';
import type * as traceV3 from './versions/traceV3'; import type * as traceV3 from './versions/traceV3';
import type * as traceV4 from './versions/traceV4'; import type * as traceV4 from './versions/traceV4';
import type * as traceV5 from './versions/traceV5';
import { parseClientSideCallMetadata } from '../../../packages/playwright-core/src/utils/isomorphic/traceUtils'; import { parseClientSideCallMetadata } from '../../../packages/playwright-core/src/utils/isomorphic/traceUtils';
import type { ContextEntry, PageEntry } from './entries'; import type { ActionEntry, ContextEntry, PageEntry } from './entries';
import { createEmptyContext } from './entries'; import { createEmptyContext } from './entries';
import { SnapshotStorage } from './snapshotStorage'; import { SnapshotStorage } from './snapshotStorage';
@ -67,7 +68,7 @@ export class TraceModel {
let done = 0; let done = 0;
for (const ordinal of ordinals) { for (const ordinal of ordinals) {
const contextEntry = createEmptyContext(); const contextEntry = createEmptyContext();
const actionMap = new Map<string, trace.ActionTraceEvent>(); const actionMap = new Map<string, ActionEntry>();
contextEntry.traceUrl = backend.traceURL(); contextEntry.traceUrl = backend.traceURL();
contextEntry.hasSource = hasSource; contextEntry.hasSource = hasSource;
@ -150,12 +151,15 @@ export class TraceModel {
return pageEntry; return pageEntry;
} }
appendEvent(contextEntry: ContextEntry, actionMap: Map<string, trace.ActionTraceEvent>, line: string) { appendEvent(contextEntry: ContextEntry, actionMap: Map<string, ActionEntry>, line: string) {
if (!line) if (!line)
return; return;
const event = this._modernize(JSON.parse(line)); const events = this._modernize(JSON.parse(line));
if (!event) for (const event of events)
return; this._innerAppendEvent(contextEntry, actionMap, event);
}
private _innerAppendEvent(contextEntry: ContextEntry, actionMap: Map<string, ActionEntry>, event: trace.TraceEvent) {
switch (event.type) { switch (event.type) {
case 'context-options': { case 'context-options': {
this._version = event.version; this._version = event.version;
@ -184,11 +188,18 @@ export class TraceModel {
existing!.point = event.point; existing!.point = event.point;
break; break;
} }
case 'log': {
const existing = actionMap.get(event.callId);
existing!.log.push({
time: event.time,
message: event.message,
});
break;
}
case 'after': { case 'after': {
const existing = actionMap.get(event.callId); const existing = actionMap.get(event.callId);
existing!.afterSnapshot = event.afterSnapshot; existing!.afterSnapshot = event.afterSnapshot;
existing!.endTime = event.endTime; existing!.endTime = event.endTime;
existing!.log = event.log;
existing!.result = event.result; existing!.result = event.result;
existing!.error = event.error; existing!.error = event.error;
existing!.attachments = event.attachments; existing!.attachments = event.attachments;
@ -197,7 +208,7 @@ export class TraceModel {
break; break;
} }
case 'action': { case 'action': {
actionMap.set(event.callId, event); actionMap.set(event.callId, { ...event, log: [] });
break; break;
} }
case 'event': { case 'event': {
@ -238,36 +249,40 @@ export class TraceModel {
} }
} }
private _modernize(event: any): trace.TraceEvent | null { private _modernize(event: any): trace.TraceEvent[] {
if (this._version === undefined) if (this._version === undefined)
return event; return [event];
const lastVersion: trace.VERSION = 5; const lastVersion: trace.VERSION = 6;
for (let version = this._version; version < lastVersion; ++version) { let events = [event];
event = (this as any)[`_modernize_${version}_to_${version + 1}`].call(this, event); for (let version = this._version; version < lastVersion; ++version)
if (!event) events = (this as any)[`_modernize_${version}_to_${version + 1}`].call(this, events);
return null; return events;
}
return event;
} }
_modernize_0_to_1(event: any): any { _modernize_0_to_1(events: any[]): any[] {
if (event.type === 'action') { for (const event of events) {
if (event.type !== 'action')
continue;
if (typeof event.metadata.error === 'string') if (typeof event.metadata.error === 'string')
event.metadata.error = { error: { name: 'Error', message: event.metadata.error } }; event.metadata.error = { error: { name: 'Error', message: event.metadata.error } };
} }
return event; return events;
} }
_modernize_1_to_2(event: any): any { _modernize_1_to_2(events: any[]): any[] {
if (event.type === 'frame-snapshot' && event.snapshot.isMainFrame) { for (const event of events) {
if (event.type !== 'frame-snapshot' || !event.snapshot.isMainFrame)
continue;
// Old versions had completely wrong viewport. // Old versions had completely wrong viewport.
event.snapshot.viewport = this.contextEntries[0]?.options?.viewport || { width: 1280, height: 720 }; event.snapshot.viewport = this.contextEntries[0]?.options?.viewport || { width: 1280, height: 720 };
} }
return event; return events;
} }
_modernize_2_to_3(event: any): any { _modernize_2_to_3(events: any[]): any[] {
if (event.type === 'resource-snapshot' && !event.snapshot.request) { for (const event of events) {
if (event.type !== 'resource-snapshot' || event.snapshot.request)
continue;
// Migrate from old ResourceSnapshot to new har entry format. // Migrate from old ResourceSnapshot to new har entry format.
const resource = event.snapshot; const resource = event.snapshot;
event.snapshot = { event.snapshot = {
@ -289,10 +304,20 @@ export class TraceModel {
_monotonicTime: resource.timestamp, _monotonicTime: resource.timestamp,
}; };
} }
return event; return events;
} }
_modernize_3_to_4(event: traceV3.TraceEvent): traceV4.TraceEvent | null { _modernize_3_to_4(events: traceV3.TraceEvent[]): traceV4.TraceEvent[] {
const result: traceV4.TraceEvent[] = [];
for (const event of events) {
const e = this._modernize_event_3_to_4(event);
if (e)
result.push(e);
}
return result;
}
_modernize_event_3_to_4(event: traceV3.TraceEvent): traceV4.TraceEvent | null {
if (event.type !== 'action' && event.type !== 'event') { if (event.type !== 'action' && event.type !== 'event') {
return event as traceV3.ContextCreatedTraceEvent | return event as traceV3.ContextCreatedTraceEvent |
traceV3.ScreencastFrameTraceEvent | traceV3.ScreencastFrameTraceEvent |
@ -344,7 +369,17 @@ export class TraceModel {
}; };
} }
_modernize_4_to_5(event: traceV4.TraceEvent): trace.TraceEvent | null { _modernize_4_to_5(events: traceV4.TraceEvent[]): traceV5.TraceEvent[] {
const result: traceV5.TraceEvent[] = [];
for (const event of events) {
const e = this._modernize_event_4_to_5(event);
if (e)
result.push(e);
}
return result;
}
_modernize_event_4_to_5(event: traceV4.TraceEvent): traceV5.TraceEvent | null {
if (event.type === 'event' && event.method === '__create__' && event.class === 'JSHandle') if (event.type === 'event' && event.method === '__create__' && event.class === 'JSHandle')
this._jsHandles.set(event.params.guid, event.params.initializer); this._jsHandles.set(event.params.guid, event.params.initializer);
if (event.type === 'object') { if (event.type === 'object') {
@ -384,6 +419,24 @@ export class TraceModel {
} }
return event; return event;
} }
_modernize_5_to_6(events: traceV5.TraceEvent[]): trace.TraceEvent[] {
const result: trace.TraceEvent[] = [];
for (const event of events) {
result.push(event);
if (event.type !== 'after' || !event.log.length)
continue;
for (const log of event.log) {
result.push({
type: 'log',
callId: event.callId,
message: log,
time: -1,
});
}
}
return result;
}
} }
function stripEncodingFromContentType(contentType: string) { function stripEncodingFromContentType(contentType: string) {

View file

@ -14,21 +14,21 @@
* limitations under the License. * limitations under the License.
*/ */
import type { ActionTraceEvent } from '@trace/trace'; import type { ActionTraceEventInContext } from './modelUtil';
import * as React from 'react'; import * as React from 'react';
import { ListView } from '@web/components/listView'; import { ListView } from '@web/components/listView';
import { PlaceholderPanel } from './placeholderPanel'; import { PlaceholderPanel } from './placeholderPanel';
const LogList = ListView<string>; const LogList = ListView<{ message: string, time: number }>;
export const LogTab: React.FunctionComponent<{ export const LogTab: React.FunctionComponent<{
action: ActionTraceEvent | undefined, action: ActionTraceEventInContext | undefined,
}> = ({ action }) => { }> = ({ action }) => {
if (!action?.log.length) if (!action?.log.length)
return <PlaceholderPanel text='No log entries' />; return <PlaceholderPanel text='No log entries' />;
return <LogList return <LogList
name='log' name='log'
items={action?.log || []} items={action?.log || []}
render={logLine => logLine} render={logLine => logLine.message}
/>; />;
}; };

View file

@ -38,6 +38,7 @@ export type SourceModel = {
export type ActionTraceEventInContext = ActionTraceEvent & { export type ActionTraceEventInContext = ActionTraceEvent & {
context: ContextEntry; context: ContextEntry;
log: { time: number, message: string }[];
}; };
export type ActionTreeItem = { export type ActionTreeItem = {

View file

@ -0,0 +1,225 @@
/**
* Copyright (c) Microsoft Corporation.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import type { Entry as ResourceSnapshot } from '../../../trace/src/har';
type Language = 'javascript' | 'python' | 'java' | 'csharp' | 'jsonl';
type Point = { x: number, y: number };
type Size = { width: number, height: number };
type StackFrame = {
file: string,
line: number,
column: number,
function?: string,
};
type SerializedValue = {
n?: number,
b?: boolean,
s?: string,
v?: 'null' | 'undefined' | 'NaN' | 'Infinity' | '-Infinity' | '-0',
d?: string,
u?: string,
bi?: string,
m?: SerializedValue,
se?: SerializedValue,
r?: {
p: string,
f: string,
},
a?: SerializedValue[],
o?: {
k: string,
v: SerializedValue,
}[],
h?: number,
id?: number,
ref?: number,
};
type SerializedError = {
error?: {
message: string,
name: string,
stack?: string,
},
value?: SerializedValue,
};
type NodeSnapshot =
// Text node.
string |
// Subtree reference, "x snapshots ago, node #y". Could point to a text node.
// Only nodes that are not references are counted, starting from zero, using post-order traversal.
[ [number, number] ] |
// Just node name.
[ string ] |
// Node name, attributes, child nodes.
// Unfortunately, we cannot make this type definition recursive, therefore "any".
[ string, { [attr: string]: string }, ...any ];
type ResourceOverride = {
url: string,
sha1?: string,
ref?: number
};
type FrameSnapshot = {
snapshotName?: string,
callId: string,
pageId: string,
frameId: string,
frameUrl: string,
timestamp: number,
collectionTime: number,
doctype?: string,
html: NodeSnapshot,
resourceOverrides: ResourceOverride[],
viewport: { width: number, height: number },
isMainFrame: boolean,
};
export type BrowserContextEventOptions = {
viewport?: Size,
deviceScaleFactor?: number,
isMobile?: boolean,
userAgent?: string,
};
export type ContextCreatedTraceEvent = {
version: number,
type: 'context-options',
browserName: string,
channel?: string,
platform: string,
wallTime: number,
title?: string,
options: BrowserContextEventOptions,
sdkLanguage?: Language,
testIdAttributeName?: string,
};
export type ScreencastFrameTraceEvent = {
type: 'screencast-frame',
pageId: string,
sha1: string,
width: number,
height: number,
timestamp: number,
};
export type BeforeActionTraceEvent = {
type: 'before',
callId: string;
startTime: number;
apiName: string;
class: string;
method: string;
params: Record<string, any>;
wallTime: number;
beforeSnapshot?: string;
stack?: StackFrame[];
pageId?: string;
parentId?: string;
};
export type InputActionTraceEvent = {
type: 'input',
callId: string;
inputSnapshot?: string;
point?: Point;
};
export type AfterActionTraceEventAttachment = {
name: string;
contentType: string;
path?: string;
sha1?: string;
base64?: string;
};
export type AfterActionTraceEvent = {
type: 'after',
callId: string;
endTime: number;
afterSnapshot?: string;
log: string[];
error?: SerializedError['error'];
attachments?: AfterActionTraceEventAttachment[];
result?: any;
};
export type EventTraceEvent = {
type: 'event',
time: number;
class: string;
method: string;
params: any;
pageId?: string;
};
export type ConsoleMessageTraceEvent = {
type: 'console';
time: number;
pageId?: string;
messageType: string,
text: string,
args?: { preview: string, value: any }[],
location: {
url: string,
lineNumber: number,
columnNumber: number,
},
};
export type ResourceSnapshotTraceEvent = {
type: 'resource-snapshot',
snapshot: ResourceSnapshot,
};
export type FrameSnapshotTraceEvent = {
type: 'frame-snapshot',
snapshot: FrameSnapshot,
};
export type ActionTraceEvent = {
type: 'action',
} & Omit<BeforeActionTraceEvent, 'type'>
& Omit<AfterActionTraceEvent, 'type'>
& Omit<InputActionTraceEvent, 'type'>;
export type StdioTraceEvent = {
type: 'stdout' | 'stderr';
timestamp: number;
text?: string;
base64?: string;
};
export type TraceEvent =
ContextCreatedTraceEvent |
ScreencastFrameTraceEvent |
ActionTraceEvent |
BeforeActionTraceEvent |
InputActionTraceEvent |
AfterActionTraceEvent |
EventTraceEvent |
ConsoleMessageTraceEvent |
ResourceSnapshotTraceEvent |
FrameSnapshotTraceEvent |
StdioTraceEvent;

View file

@ -21,7 +21,7 @@ import type { FrameSnapshot, ResourceSnapshot } from './snapshot';
export type Size = { width: number, height: number }; export type Size = { width: number, height: number };
// Make sure you add _modernize_N_to_N1(event: any) to traceModel.ts. // Make sure you add _modernize_N_to_N1(event: any) to traceModel.ts.
export type VERSION = 5; export type VERSION = 6;
export type BrowserContextEventOptions = { export type BrowserContextEventOptions = {
viewport?: Size, viewport?: Size,
@ -87,12 +87,18 @@ export type AfterActionTraceEvent = {
callId: string; callId: string;
endTime: number; endTime: number;
afterSnapshot?: string; afterSnapshot?: string;
log: string[];
error?: SerializedError['error']; error?: SerializedError['error'];
attachments?: AfterActionTraceEventAttachment[]; attachments?: AfterActionTraceEventAttachment[];
result?: any; result?: any;
}; };
export type LogTraceEvent = {
type: 'log',
callId: string;
time: number;
message: string;
};
export type EventTraceEvent = { export type EventTraceEvent = {
type: 'event', type: 'event',
time: number; time: number;
@ -147,6 +153,7 @@ export type TraceEvent =
InputActionTraceEvent | InputActionTraceEvent |
AfterActionTraceEvent | AfterActionTraceEvent |
EventTraceEvent | EventTraceEvent |
LogTraceEvent |
ConsoleMessageTraceEvent | ConsoleMessageTraceEvent |
ResourceSnapshotTraceEvent | ResourceSnapshotTraceEvent |
FrameSnapshotTraceEvent | FrameSnapshotTraceEvent |

View file

@ -115,7 +115,6 @@ export async function parseTraceRaw(file: string): Promise<{ events: any[], reso
...event, ...event,
type: 'action', type: 'action',
endTime: 0, endTime: 0,
log: []
}; };
actionMap.set(event.callId, action); actionMap.set(event.callId, action);
} else if (event.type === 'input') { } else if (event.type === 'input') {
@ -126,7 +125,6 @@ export async function parseTraceRaw(file: string): Promise<{ events: any[], reso
const existing = actionMap.get(event.callId); const existing = actionMap.get(event.callId);
existing.afterSnapshot = event.afterSnapshot; existing.afterSnapshot = event.afterSnapshot;
existing.endTime = event.endTime; existing.endTime = event.endTime;
existing.log = event.log;
existing.error = event.error; existing.error = event.error;
existing.result = event.result; existing.result = event.result;
} }