1. 1
2. 2
3. 3
4. 4
5. 5
6. 6
7. 7
8. 8
9. 9
10. 10
11. 11
12. 12
13. 13
14. 14
15. 15
16. 16
17. 17
18. 18
19. 19
20. 20
21. 21
22. 22
23. 23
24. 24
25. 25
26. 26
27. 27
28. 28
29. 29
30. 30
31. 31
32. 32
33. 33
34. 34
35. 35
36. 36
37. 37
38. 38
39. 39
40. 40
41. 41
42. 42
43. 43
44. 44
45. 45
46. 46
47. 47
48. 48
49. 49
50. 50
51. 51
52. 52
53. 53
54. 54
55. 55
56. 56

import {Socket} from 'socket.io';

import Room from './Room';

export const clients = new Map();
export const usernameToId = new Map();

let newClientId = 0;

export default class Client {
	id: number;
	username: string;
	socket: Socket;
	disconnectTimeout: NodeJS.Timeout | null = null;
	room: Room | null = null;
	onListeners = new Map();
	onceListeners = new Map();
	constructor(username: string, socket: Socket) {
		this.id = newClientId++;
		this.username = username;
		this.socket = socket;
	}
	on(e: string, f: (...args: any[]) => void) {
		if (!this.onListeners.has(e))
			this.onListeners.set(e, []);
		this.onListeners.get(e).push(f);
		this.socket.on(e, f);
	}
	once(e: string, f: (...args: any[]) => void) {
		if (!this.onceListeners.has(e))
			this.onceListeners.set(e, []);
		this.onceListeners.get(e).push(f);
		this.socket.once(e, (...args) => {
			this.onceListeners.get(e).splice(this.onceListeners.get(e).indexOf(f), 1);
			f(...args);
		});
	}
	removeAllListeners(e: string) {
		this.socket.removeAllListeners(e);
		this.onListeners.delete(e);
		this.onceListeners.delete(e);
	}
	updateSocket(socket: Socket) {
		this.socket = socket;
		// Add listeners
		this.onListeners.forEach((fs, e) => fs.forEach((f: (...args: any[]) => void) => socket.on(e, f)));
		this.onceListeners.forEach((fs, e) => fs.forEach((f: (...args: any[]) => void) => {
			socket.once(e, (...args) => {
				this.onceListeners.get(e).splice(this.onceListeners.get(e).indexOf(f), 1);
				f(...args);
			});
		}));
		if (this.room)
			this.room.updateSocket(this);
	}
}