9030838288

Committed 10 May 2024 10:22AM UTC coverage: 62.939% (-0.4%) from 63.325%

Build # 9030838288

Build Type

Pull #78

github

Committed by

web-flow

Commit Message

Merge 04510a7ba into a436a3918

Pull Request Pull Request #78: reconnect mechanism optimization 重连机制优化

Run Details

1328 of 1486 branches covered (89.37%)

Branch coverage included in aggregate %.

322 of 473 new or added lines in 14 files covered. (68.08%)

15 existing lines in 6 files now uncovered.

5370 of 9156 relevant lines covered (58.65%)

30.86 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

86.34

/packages/page-spy-browser/src/helpers/socket.ts

import { getRandomId, stringifyData } from 'base/src';
import atom from 'base/src/atom';
import { ROOM_SESSION_KEY } from 'base/src/constants';
import { makeMessage } from 'base/src/message';
import { UPDATE_ROOM_INFO } from 'base/src/message/server-type';
import {
  SocketStoreBase,
  SocketState,
  SocketWrapper,
  WebSocketEvents,
} from 'base/src/socket-base';
import { SpyBase } from 'packages/page-spy-types';
import { InitConfig } from 'page-spy-browser/types';

export class WebSocketWrapper extends SocketWrapper {
  private socketInstance: WebSocket | null = null;

  init(url: string) {
    this.socketInstance = new WebSocket(url);
    const eventNames: WebSocketEvents[] = ['open', 'close', 'error', 'message'];
    eventNames.forEach((eventName) => {
      this.socketInstance!.addEventListener(eventName, (data) => {
        this.events[eventName].forEach((cb) => {
          cb(data);
        });
      });
    });
  }

  send(data: string) {
    this.socketInstance?.send(stringifyData(data));
  }

  close() {
    this.socketInstance?.close();
  }

  getState(): SocketState {
    return this.socketInstance?.readyState as SocketState;
  }
}

export class WebSocketStore extends SocketStoreBase {
  // websocket instance
  protected socketWrapper: WebSocketWrapper = new WebSocketWrapper();

  public getPageSpyConfig: (() => Required<InitConfig>) | null = null;

  updateRoomInfo() {
    if (this.getPageSpyConfig) {
      const { project, title } = this.getPageSpyConfig();
      this.send(
        {
          type: UPDATE_ROOM_INFO,
          content: {
            info: {
              name: navigator.userAgent,
              group: project,
              tags: {
                title,
              },
            },
          },
        },
        true,
      );
    }
  }

  public getSocket() {
    return this.socketWrapper;
  }

  // disable lint: this is an abstract method of parent class, so it cannot be static
  // eslint-disable-next-line class-methods-use-this
  onOffline(): void {
    window.dispatchEvent(new CustomEvent('sdk-inactive'));
    sessionStorage.removeItem(ROOM_SESSION_KEY);
  }

  // eslint-disable-next-line @typescript-eslint/no-useless-constructor
  constructor() {
    super();
    this.addListener('debug', WebSocketStore.handleDebugger);
  }

  // run executable code which received from remote and send back the result
  private static handleDebugger(
    { source }: SpyBase.InteractiveEvent<string>,
    reply: (data: any) => void,
  ) {
    const { type, data } = source;
    if (type === 'debug') {
      const originMsg = makeMessage('console', {
        logType: 'debug-origin',
        logs: [
          {
            id: getRandomId(),
            type: 'debug-origin',
            value: data,
          },
        ],
      });
      reply(originMsg);
      try {
        // eslint-disable-next-line no-new-func, @typescript-eslint/no-implied-eval
        const result = new Function(`return ${data}`)();
        const evalMsg = makeMessage('console', {
          logType: 'debug-eval',
          logs: [atom.transformToAtom(result)],
        });
        reply(evalMsg);
      } catch (err) {
        const errMsg = makeMessage('console', {
          logType: 'error',
          logs: [
            {
              type: 'error',
              value: (err as Error).stack,
            },
          ],
        });
        reply(errMsg);
      }
    }
  }
}

export default new WebSocketStore();

1	import { getRandomId, stringifyData } from 'base/src';	2✔
2	import atom from 'base/src/atom';	2✔
3	import { ROOM_SESSION_KEY } from 'base/src/constants';	2✔
4	import { makeMessage } from 'base/src/message';	2✔
5	import { UPDATE_ROOM_INFO } from 'base/src/message/server-type';	2✔
6	import {	2✔
7	SocketStoreBase,	2✔
8	SocketState,	2✔
9	SocketWrapper,	2✔
10	WebSocketEvents,	2✔
11	} from 'base/src/socket-base';	2✔
12	import { SpyBase } from 'packages/page-spy-types';	2✔
13	import { InitConfig } from 'page-spy-browser/types';	2✔
14		2✔
15	export class WebSocketWrapper extends SocketWrapper {	2✔
16	private socketInstance: WebSocket \| null = null;	2✔
17		2✔
18	init(url: string) {	2✔
19	this.socketInstance = new WebSocket(url);	24✔
20	const eventNames: WebSocketEvents[] = ['open', 'close', 'error', 'message'];	24✔
21	eventNames.forEach((eventName) => {	24✔
22	this.socketInstance!.addEventListener(eventName, (data) => {	96✔
23	this.events[eventName].forEach((cb) => {	60✔
24	cb(data);	60✔
25	});	60✔
26	});	96✔
27	});	24✔
28	}	24✔
29		2✔
30	send(data: string) {	2✔
31	this.socketInstance?.send(stringifyData(data));	8✔
32	}	8✔
33		2✔
34	close() {	2✔
35	this.socketInstance?.close();	10✔
36	}	10✔
37		2✔
38	getState(): SocketState {	2✔
39	return this.socketInstance?.readyState as SocketState;	24✔
40	}	24✔
41	}	2✔
42		2✔
43	export class WebSocketStore extends SocketStoreBase {	2✔
44	// websocket instance	2✔
45	protected socketWrapper: WebSocketWrapper = new WebSocketWrapper();	2✔
46		28✔
47	public getPageSpyConfig: (() => Required<InitConfig>) \| null = null;	2✔
48		2✔
49	updateRoomInfo() {	2✔
50	if (this.getPageSpyConfig) {	10!
NEW 51	const { project, title } = this.getPageSpyConfig();	×
NEW 52	this.send(	×
NEW 53	{	×
NEW 54	type: UPDATE_ROOM_INFO,	×
NEW 55	content: {	×
NEW 56	info: {	×
NEW 57	name: navigator.userAgent,	×
NEW 58	group: project,	×
NEW 59	tags: {	×
NEW 60	title,	×
NEW 61	},	×
NEW 62	},	×
NEW 63	},	×
NEW 64	},	×
NEW 65	true,	×
NEW 66	);	×
NEW 67	}	×
68	}	10✔
69		2✔
70	public getSocket() {	2✔
71	return this.socketWrapper;	2✔
72	}	2✔
73		2✔
74	// disable lint: this is an abstract method of parent class, so it cannot be static	2✔
75	// eslint-disable-next-line class-methods-use-this	2✔
76	onOffline(): void {	2✔
UNCOV 77	window.dispatchEvent(new CustomEvent('sdk-inactive'));	×
NEW 78	sessionStorage.removeItem(ROOM_SESSION_KEY);	×
UNCOV 79	}	×
80		2✔
81	// eslint-disable-next-line @typescript-eslint/no-useless-constructor	2✔
82	constructor() {	2✔
83	super();	28✔
84	this.addListener('debug', WebSocketStore.handleDebugger);	28✔
85	}	28✔
86		2✔
87	// run executable code which received from remote and send back the result	2✔
88	private static handleDebugger(	2✔
89	{ source }: SpyBase.InteractiveEvent<string>,	2✔
90	reply: (data: any) => void,	2✔
91	) {	2✔
92	const { type, data } = source;	2✔
93	if (type === 'debug') {	2✔
94	const originMsg = makeMessage('console', {	2✔
95	logType: 'debug-origin',	2✔
96	logs: [	2✔
97	{	2✔
98	id: getRandomId(),	2✔
99	type: 'debug-origin',	2✔
100	value: data,	2✔
101	},	2✔
102	],	2✔
103	});	2✔
104	reply(originMsg);	2✔
105	try {	2✔
106	// eslint-disable-next-line no-new-func, @typescript-eslint/no-implied-eval	2✔
107	const result = new Function(`return ${data}`)();	2✔
108	const evalMsg = makeMessage('console', {	2✔
109	logType: 'debug-eval',	2✔
110	logs: [atom.transformToAtom(result)],	2✔
111	});	2✔
112	reply(evalMsg);	2✔
113	} catch (err) {	2✔
114	const errMsg = makeMessage('console', {	2✔
115	logType: 'error',	2✔
116	logs: [	2✔
117	{	2✔
118	type: 'error',	2✔
119	value: (err as Error).stack,	2✔
120	},	2✔
121	],	2✔
122	});	2✔
123	reply(errMsg);	2✔
124	}	2✔
125	}	2✔
126	}	2✔
127	}	2✔
128		2✔
129	export default new WebSocketStore();	2✔

HuolalaTech / page-spy / 9030838288

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous