Class Client

modules/network/websocket/websocket.js:50–113

*/

export class Client {
	constructor(dictionary) {
		// port, host, address, path (everything after port)
		this.path = dictionary.path ?? "/";
		this.host = dictionary.host ?? dictionary.address;
		this.headers = dictionary.headers ?? [];
		this.protocol = dictionary.protocol;
		this.state = 0;
		this.flags = 0;

		if (dictionary.socket)
			this.socket = dictionary.socket;
		else {
			dictionary.port ??= 80;
			if (dictionary.Socket)
				this.socket = new dictionary.Socket(Object.assign({}, dictionary.Socket, dictionary));
			else
				this.socket = new Socket(dictionary);
		}
		this.socket.callback = callback.bind(this);
		this.doMask = true;
	}

	write(message) {
	//@@ implement masking
		const type = (message instanceof ArrayBuffer) ? 0x82 : 0x81;
		if (0x81 === type)
			message = ArrayBuffer.fromString(message);

		const length = message.byteLength;
		// Note: WS spec requires XOR masking for clients, but w/ strongly random mask. We
		// can't achieve that on this device for now, so just punt and use 0x00000000 for
		// a no-op mask.
		if (length < 126) {
			if (this.doMask)
				this.socket.write(type, length | 0x80, 0, 0, 0, 0, message);
			else
				this.socket.write(type, length, message);
		}
		else if (length < 65536) {
			if (this.doMask)
				this.socket.write(type, 126 | 0x80, length >> 8, length & 0x0ff, 0, 0, 0, 0, message);
			else
				this.socket.write(type, 126, length >> 8, length & 0x0ff, message);
		}
		else
			throw new Error("message too long");
	}
	detach() {
		const socket = this.socket;
		delete this.socket.callback;
		delete this.socket;
		return socket;
	}
	close() {
		this.socket?.close();
		delete this.socket;