my_ws.js - master - mtg/com

my_ws.js
280 строк7 KB
akukamil
123
21 май 2026, 17:06
21 май 2026, 17:065306480

const MIN_GIF_ID_INC=100
const MAX_GIF_ID_INC=414

irnd = function(min,max) {
	min = Math.ceil(min);
	max = Math.floor(max);
	return Math.floor(Math.random() * (max - min + 1)) + min;
}

my_ws={

	socket:0,

	child_added:{},
	child_changed:{},
	value_changed:{},
	child_removed:{},

	get_resolvers:{},
	get_req_id:0,
	reconnect_time:5000,
	connect_resolver:0,
	sleep:0,
	keep_alive_timer:0,
	keep_alive_time:45000,
	open_tm:0,
	reconnect_num:0,
	req_id:0,

	s_url:'',

	init(){
		if(!game_name){
			alert('No game_name provided!')
			return
		}
		this.s_url=`wss://timewebmtgames.ru:443/${game_name}/`+my_data.uid;
		//fbs.ref('WSDEBUG/'+my_data.uid).remove();
		//fbs.ref('WSDEBUG/'+my_data.uid).push({tm:Date.now(),event:'init'});

		if(this.socket.readyState===1) return;
		return new Promise(resolve=>{
			this.connect_resolver=resolve;
			this.reconnect('init');
		})
	},

	safe_send(data){
		if (this.sleep||this.socket.readyState!==1) return
		this.socket.send(JSON.stringify(data))
		this.reset_keep_alive('safe_send')
	},

	send_to_sleep(){

		//fbs.ref('WSDEBUG/'+my_data.uid).push({tm:Date.now(),event:'send_to_sleep'});

		clearTimeout(this.keep_alive_timer)
		this.sleep=1
		this.socket.close(1000, 'sleep')
	},

	kill(){

		clearTimeout(this.keep_alive_timer)
		this.sleep=1
		this.socket.close(1000, 'kill')

	},

	reconnect(reason){

		//fbs.ref('WSDEBUG/'+my_data.uid).push({tm:Date.now(),event:'reconnect',reason:reason||'noreason'});

		if (this.socket) {
			this.socket.onopen = null
			this.socket.onmessage = null
			this.socket.onclose = null
			this.socket.onerror = null
			this.socket.close()
		}

		this.open_tm=0
		this.sleep=0
		this.socket = new WebSocket(this.s_url)

		this.socket.onopen = () => {
			console.log('connected to server!')
			this.connect_resolver()
			this.reconnect_time=0
			this.open_tm=Date.now()
			//fbs.ref('WSDEBUG/'+my_data.uid).push({tm:Date.now(),event:'onopen'});

			//обновляем подписки
			for (const path in this.child_added)
				this.safe_send({cmd:'child_added',path})

			this.reset_keep_alive('onopen');
		};

		this.socket.onmessage = event => {

			const msg=JSON.parse(event.data);
			//console.log("Получено от сервера:", msg);

			//вызов коллбэк функции для нода если она подписана
			if (msg.event==='ca'||msg.event==='child_added')
				this.child_added[msg.node]?.(msg)

			if (msg.event==='cc')
				this.child_changed[msg.node]?.(msg)
			
			if (msg.event==='cr')
				this.child_removed[msg.node]?.(msg)

			if (msg.event==='vc')
				this.value_changed[msg.node]?.(msg)

			if (msg.event==='get')
				if (this.get_resolvers[msg.req_id])
					this.get_resolvers[msg.req_id](msg.data)

			if (msg.event==='get_tms')
				if (this.get_resolvers[msg.req_id])
					this.get_resolvers[msg.req_id](msg.data)

		};

		this.socket.onclose = event => {

			clearTimeout(this.keep_alive_timer)

			//fbs.ref('WSDEBUG/'+my_data.uid).push({tm:Date.now(),event:'close',code:event.code,reason:event.reason,type:event.type||'no_type'});

			//не восстанавливаем соединения если закрыто по команде
			if (['not_alive','no_uid','kill','sleep'].includes(event.reason)) return;

			if (this.open_tm){

				//если продержались онлайн достаточно долго то сбрасываем счетчик
				const tm=Date.now()
				const open_tm_of_socket=tm-this.open_tm
				if (open_tm_of_socket>180000) this.reconnect_num=0

				this.reconnect_time=irnd(5000,15000);
				if (this.reconnect_num>12) this.reconnect_time+=50000
				if (open_tm_of_socket<this.keep_alive_time)
					this.keep_alive_time=Math.max(10000,this.keep_alive_time-5000)
			}else{
				this.reconnect_time=Math.min(60000,Math.floor(this.reconnect_time*1.5))
			}

			this.reconnect_num++;

			console.log(`reconnecting in ${this.reconnect_time*0.001} seconds:`, event)
			setTimeout(()=>{this.reconnect('re')},this.reconnect_time)
		};

		this.socket.onerror = error => {
			////fbs.ref('WSERRORS/'+my_data.uid).push({tm:Date.now(),event:'error'});
		};

	},

	reset_keep_alive(reason){
		//console.log('reset_keep_alive',reason)
		clearTimeout(this.keep_alive_timer)
		this.keep_alive_timer=setTimeout(()=>{

			try{
				//fbs.ref('WSDEBUG/'+my_data.uid).push({tm:Date.now(),event:'keep_alive'});
				this.socket.send('1')
			}catch(e){
				//fbs.ref('WSDEBUG/'+my_data.uid).push({tm:Date.now(),event:'keep_alive_error'});
			}

			this.reset_keep_alive('timer')

		},this.keep_alive_time)

	},

	/*
		my_ws.make_req('set',{path:'players/debug100/rating',val:123})
		my_ws.make_req('set',{path:'players/debug100',val:{rating:100,name:'kamil',tm:'TMS'}})
		my_ws.make_req('remove',{path:'bg'})
		my_ws.make_req('remove_arr_elem',{path:'bg'})
		my_ws.make_req('push',{path:'chat',val:{uid:'admin',name:'Админ',msg,tm:'TMS'}})
		
	*/
	make_req(cmd, params = {}) {
				
		return new Promise(res => {
			
			if (this.sleep) res(0)
			
			this.req_id++

			const timeoutId = setTimeout(() => {
				delete this.get_resolvers[this.req_id]
				res(0);
			}, 5000);

			this.get_resolvers[this.req_id] = (data) => {
				clearTimeout(timeoutId)
				res(data)
			};

			this.safe_send({cmd,req_id:this.req_id,...params})

			//this.reset_keep_alive('req')
		});
	},

	//limit_last - это только для массивов
	get(path, limit_last) {
		return this.make_req('get', {path, limit_last})
	},

	get_tms() {
		return this.make_req('get_tms')
	},

	ss_child_added(path,callback){
		this.safe_send({cmd:'ca',path})
		this.child_added[path]=callback
	},

	ss_child_changed(path,callback){
		this.safe_send({cmd:'cc',path})
		this.child_changed[path]=callback
	},

	ss_value_changed(path,callback){
		this.safe_send({cmd:'vc',path})
		this.value_changed[path]=callback
	},

	ss_child_removed(path,callback){
		this.safe_send({cmd:'cr',path})
		this.child_removed[path]=callback
	},

	value_changed_off(path){
		this.safe_send({cmd:'vc_off',path})
	},

	child_added_off(path){
		this.safe_send({cmd:'ca_off',path})
	},

	child_changed_off(path){
		this.safe_send({cmd:'cc_off',path})
	},

	child_removed_off(path){
		this.safe_send({cmd:'cr_off',path})
	},
}

safe_ls=function(key, val) {
	try {
		if (val === null || val===undefined) {
			const data = localStorage.getItem(key);
			if (!data) return null;
			try {
				return JSON.parse(data);
			} catch {
				return data;
			}
		} else {
			const storageValue = typeof val === 'string' ? val : JSON.stringify(val)
			localStorage.setItem(key, storageValue);
			return true;
		}
	} catch (e) {
		console.error(`Storage error for key "${key}":`, e);
		return null;
	}
}