FilesExpand file tree

 develop

/

websocket.ts

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

61 lines (50 loc) · 1.49 KB

 develop

/

websocket.ts

Copy path

Top

File metadata and controls

• Code
• Blame

61 lines (50 loc) · 1.49 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

import * as websocket from "ws";

import { Server } from 'http';

import * as handler from "./class/websockethandler";

export default class WSSignaling {

server: Server;

wss: websocket.Server;

constructor(server: Server, mode: string) {

this.server = server;

this.wss = new websocket.Server({ server });

handler.reset(mode);

this.wss.on('connection', (ws: WebSocket) => {

handler.add(ws);

ws.onclose = (): void => {

handler.remove(ws);

};

ws.onmessage = (event: MessageEvent): void => {

// type: connect, disconnect JSON Schema

// connectionId: connect or disconnect connectionId

// type: offer, answer, candidate JSON Schema

// from: from connection id

// to: to connection id

// data: any message data structure

const msg = JSON.parse(event.data);

if (!msg || !this) {

return;

}

console.log(msg);

switch (msg.type) {

case "connect":

handler.onConnect(ws, msg.connectionId);

break;

case "disconnect":

handler.onDisconnect(ws, msg.connectionId);

break;

case "offer":

handler.onOffer(ws, msg.data);

break;

case "answer":

handler.onAnswer(ws, msg.data);

break;

case "candidate":

handler.onCandidate(ws, msg.data);

break;

default:

break;

}

};

});

}

}