dummyRes.writeHead = (statusCode: number, _statusMessage: never, headers: never) => {
   if (statusCode && statusCode > 200) {
     // tslint:disable-next-line no-console
     console.error(
       `Something used 'writeHead' to write a '${statusCode}' error for websockets - check the middleware you're passing!`,
     );
     socket.close();
   } else if (headers) {
     // tslint:disable-next-line no-console
     console.error(
       "Passing headers to 'writeHead' is not supported with websockets currently - check the middleware you're passing",
     );
     socket.close();
   }
 };

 ws1.on('open', () => {
   ws1.send(JSON.stringify({
     "ev": "CREATE_MESSAGE",
     "value": "sample message"
   }))
   ws1.close()
 })

 ws.on("message", (response) => {
   const responseParsed = JSON.parse(response.toString());
   if (responseParsed.id !== jsonId) {
     return reject("Bad ID");
   }
   resolve(responseParsed.result);
   ws.close();
 });

 setTimeout(() => {
   if(ping_available === false) {
     console.error("ping is not available")
     ws.close()
     clearInterval(ping_interval)
     return
   }
 } ,4000)

	function reject(mes: string): void {
		sendEvent({
			type: 'error',
			value: {
				message: mes
			}
		});
		ws.close();
	}

	const reject = (mes: string = 'authentication failed') => {
		const res = {
			type: 'error',
			value: {
				message: mes
			}
		};
		ws.send(JSON.stringify(res));
		ws.close();
	};

function onNvimNotify(method: string) {
  switch (method) {
    case WS_STOP_COMMAND: {
      ws.close();
    }
    case DUMP_COMMAND: {
      scripts.dump();
    }
  }
}

 ws.on('message', (data) => {
   // Handle received message which contains log data in stringified JSON.
   if (argv.debug) {
     console.error(`Received message: ${data}`);
   }
   try {
     logHandleFunc(parseLogStream(data as string));
   } catch (e) {
     ws.close();
     reject(e);
   }
 });