9397243366

Committed 06 Jun 2024 08:01AM UTC coverage: 53.917% (-0.5%) from 54.415%

Build # 9397243366

Build Type

Pull #96

github

Committed by

web-flow

Commit Message

Merge c97474d77 into 45114034e

Pull Request Pull Request #96: patch changes main for v1.8.9

Run Details

1359 of 1539 branches covered (88.3%)

Branch coverage included in aggregate %.

2 of 134 new or added lines in 9 files covered. (1.49%)

2 existing lines in 2 files now uncovered.

5441 of 11073 relevant lines covered (49.14%)

27.42 hits per line

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

0.0

/packages/page-spy-harmony/library/src/main/ets/helpers/socket.ts

import webSocket from '@ohos.net.webSocket';
import { InitConfig } from '../types';
import { psLog, stringifyData } from '../utils';
import Client, { combineName } from '../utils/client';
import { UPDATE_ROOM_INFO } from '../utils/message/server-type';
import {
  SocketStoreBase,
  SocketState,
  SocketWrapper,
} from '../utils/socket-base';

export class OHSocketWrapper extends SocketWrapper {
  private state: SocketState = 0;

  private socketInstance: webSocket.WebSocket | null = null;

  init(url: string) {
    this.state = SocketState.CONNECTING;
    this.socketInstance = webSocket.createWebSocket();
    this.socketInstance.on('open', (err, data) => {
      this.state = SocketState.OPEN;
      this.emit('open', data);
    });
    this.socketInstance.on('close', (err, data) => {
      this.state = SocketState.CLOSED;
      this.emit('close', data);
    });
    this.socketInstance.on('message', (err, data: string) => {
      this.emit('message', data);
    });
    this.socketInstance.on('error', (err) => {
      this.state = SocketState.CLOSED;
      this.emit('error', err);
    });
    this.socketInstance.connect(url, (err, value) => {
      if (!err) {
        psLog.log(`Connect successful.`);
      } else {
        psLog.error('Connect failed, the error: ' + JSON.stringify(err));
      }
    });
  }

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

  close() {
    this.state = SocketState.CLOSED;
    this.socketInstance?.close();
    this.clearListeners();
  }

  getState(): SocketState {
    return this.state;
  }
}

export class OHSocketStore extends SocketStoreBase {
  protected socketWrapper: OHSocketWrapper = new OHSocketWrapper();

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

  updateRoomInfo() {
    if (this.getPageSpyConfig) {
      const { project, title } = this.getPageSpyConfig();
      const name = combineName(Client.info);

      this.send(
        {
          type: UPDATE_ROOM_INFO,
          content: {
            info: {
              name,
              group: project,
              tags: {
                title,
                name,
                group: project,
              },
            },
          },
        },
        true,
      );
    }
  }

  public getSocket() {
    return this.socketWrapper;
  }

  onOffline(): void {
    // AppStorage.delete(ROOM_SESSION_KEY);
  }
}

const socketStore = new OHSocketStore();

export default socketStore;

1	import webSocket from '@ohos.net.webSocket';	×
2	import { InitConfig } from '../types';	×
3	import { psLog, stringifyData } from '../utils';	×
NEW 4	import Client, { combineName } from '../utils/client';	×
5	import { UPDATE_ROOM_INFO } from '../utils/message/server-type';	×
6	import {	×
7	SocketStoreBase,	×
8	SocketState,	×
9	SocketWrapper,	×
10	} from '../utils/socket-base';	×
11		×
12	export class OHSocketWrapper extends SocketWrapper {	×
13	private state: SocketState = 0;	×
14		×
15	private socketInstance: webSocket.WebSocket \| null = null;	×
16		×
17	init(url: string) {	×
18	this.state = SocketState.CONNECTING;	×
19	this.socketInstance = webSocket.createWebSocket();	×
20	this.socketInstance.on('open', (err, data) => {	×
21	this.state = SocketState.OPEN;	×
22	this.emit('open', data);	×
23	});	×
24	this.socketInstance.on('close', (err, data) => {	×
25	this.state = SocketState.CLOSED;	×
26	this.emit('close', data);	×
27	});	×
28	this.socketInstance.on('message', (err, data: string) => {	×
29	this.emit('message', data);	×
30	});	×
31	this.socketInstance.on('error', (err) => {	×
32	this.state = SocketState.CLOSED;	×
33	this.emit('error', err);	×
34	});	×
35	this.socketInstance.connect(url, (err, value) => {	×
36	if (!err) {	×
37	psLog.log(`Connect successful.`);	×
38	} else {	×
39	psLog.error('Connect failed, the error: ' + JSON.stringify(err));	×
40	}	×
41	});	×
42	}	×
43		×
44	send(data: string) {	×
45	this.socketInstance?.send(stringifyData(data));	×
46	}	×
47		×
48	close() {	×
49	this.state = SocketState.CLOSED;	×
50	this.socketInstance?.close();	×
51	this.clearListeners();	×
52	}	×
53		×
54	getState(): SocketState {	×
55	return this.state;	×
56	}	×
57	}	×
58		×
59	export class OHSocketStore extends SocketStoreBase {	×
60	protected socketWrapper: OHSocketWrapper = new OHSocketWrapper();	×
61		×
62	public getPageSpyConfig: (() => Required<InitConfig>) \| null = null;	×
63		×
64	updateRoomInfo() {	×
65	if (this.getPageSpyConfig) {	×
66	const { project, title } = this.getPageSpyConfig();	×
NEW 67	const name = combineName(Client.info);	×
68		×
69	this.send(	×
70	{	×
71	type: UPDATE_ROOM_INFO,	×
72	content: {	×
73	info: {	×
74	name,	×
75	group: project,	×
76	tags: {	×
77	title,	×
78	name,	×
79	group: project,	×
80	},	×
81	},	×
82	},	×
83	},	×
84	true,	×
85	);	×
86	}	×
87	}	×
88		×
89	public getSocket() {	×
90	return this.socketWrapper;	×
91	}	×
92		×
93	onOffline(): void {	×
94	// AppStorage.delete(ROOM_SESSION_KEY);	×
95	}	×
96	}	×
97		×
98	const socketStore = new OHSocketStore();	×
99		×
100	export default socketStore;	×

HuolalaTech / page-spy / 9397243366

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