back propagation

flask_server/app.py

@@ -60,6 +60,15 @@ def echo(sock):
 		sock.send(data)
 
 
+@sock.route('/echo_all')
+def echo_all(sock):
+	gmod.gx.add_to_channel(sock,"echo_all")
+	# send_to_channel("echo_all",msg,"sender")
+	while True:
+		data = sock.receive()
+		# ws.send(data)
+		gmod.gx.send_to_channel("echo_all",data,"sender")
+
 
 # @sock.route('/echo_c1')
 # def echo_coll(sock):

flask_server/rld_m2.py

@@ -65,7 +65,6 @@ def send_to_channel(name,message,sender):
 
 
 
-
 def add_to_channel(sock,name):
 	pass
 	gmod.glob["groups"].setdefault(name,set())

js_client/jsync_demo.js

@@ -50,6 +50,8 @@ function jsyncdb_init_helper(){
 		url:'wss://' + window.location.hostname  +`/djc_srv/ws/chat/${room_name}`,
 		url: `wss://${location.hostname}:5000/echo_c1${location.search}`,
 		url: `${ws_protocol}//${location.hostname}:5000/echo_c1${location.search}`,
+		url: `${ws_protocol}//${location.hostname}:5000/echo${location.search}`,
+		url: `${ws_protocol}//${location.hostname}:5000/echo_all${location.search}`,
 		// o.url = 
 		socket_name:"ws1",
 		ord:glob_u.cb.ws,

js_client/jsync_demo.old.js

@@ -0,0 +1,110 @@
+function html_info(){
+	var get_room_name = window.get_room_name || glob_u.fns.get_room_name
+
+	window?.rldi?.setint?.(400)
+	var domain_prefix = location.hostname.split(".").slice(0,-2).join(".")
+	var root_div= document.querySelector("#root_div")
+	root_div.innerHTML=""
+	var n =document.createElement("SPAN",{})
+	n.innerHTML = `<div>${domain_prefix}</div><div>room name: ${get_room_name()}</div>
+<div><span>jsyncdb:</span><span id="jsyncdb_state">uninitialized</span></div>
+	`
+	root_div.append(n)
+}
+
+
+function ds_test2(){
+	// clog("ds_test2!")
+	// window.ds_test ?ds_test():glob_u.fns.ds_test()
+	jsyncdb_init_helper()
+	// glob_u.fns.ds_test
+	// ds_test()
+}
+
+
+// 
+
+
+function jsyncdb_init_helper(){
+	// clog("WS_HELPER")
+	var fns = window.glob_u.ws.fns
+	var room_name=glob_u.fns.get_room_name()
+	var o = {
+
+		include_participants_data:1, 
+		include_ws_channel_data:1, // required for participants_data to work
+		// msto.participants and msto.ws_channels will be defined in either case so we don't need to handle cases where some users enable this and some don't
+		AutoReconnect:false,
+
+
+		// the following options attributes 
+
+
+		url:'wss://' + window.location.hostname  +`/djc_srv/ws/chat/${room_name}`,
+		socket_name:"ws1",
+		ord:glob_u.cb.ws,
+
+
+		methods:{
+		onmessage:fns.onmessage,
+		onclose:fns.onclose,
+		onerror:fns.onerror,
+		onopen:fns.onopen,
+		},
+
+
+		fns:{
+
+
+		},
+	}
+
+	var socket = window.glob_u.fns.connect_ws(o)
+	// clog({socket})
+}
+
+
+
+
+
+// if 
+
+window.dev_flag = 1
+addEventListener("load",html_info)
+
+addEventListener("load",ds_test2)
+
+
+function update_ui(o,scope,info){
+	var clog =console.log
+	clog("update_ui",{o,scope,info})
+	// hard coding stuff that will probably change here
+	switch(info.hkey) {
+		case "WS_OPEN:":
+		$("#jsyncdb_state").text("connecting...")
+		break;
+		case "WS_CLOSE:":
+		$("#jsyncdb_state").text("disconnected")
+		break;
+		case "WS_MSTO_INITED":
+		$("#jsyncdb_state").text("connected")
+		break;
+		default:
+	}
+ 
+
+}
+
+// function get_room_name() {
+// 	// return "room/name"
+// 	return "room_name"
+// }
+
+glob_u.cb.ws.reg_cb(update_ui,"WS_OPEN:","update_ui")
+glob_u.cb.ws.reg_cb(update_ui,"WS_CLOSE:","update_ui")
+glob_u.cb.ws.reg_cb(update_ui,"WS_MSTO_INITED","update_ui")
+
+// addEventListener("load",db_display)
+
+// msto.example = {key:"val",z:"undefined"}
+// clog("??")

js_client/jsync_ws.js

@@ -38,7 +38,17 @@ window.glob_u.ws.fns.onclose = function onclose(event){
 	clog("WS_CLOSE",{that:this,readyState:this.readyState,args:[...arguments]})
 	// glob_u.ws.sockets.ws1.params.ord.run_cbs("WS_CLOSE:",{event,that:this})
 	glob_u.ws.sockets[this.params.socket_name].params.ord.run_cbs("WS_CLOSE:",{event,that:this})
-	setTimeout(this.params.fns.reconnect,1000)
+	// setTimeout(this.params.fns.reconnect,1000)
+	let  timeout0 = this.params.timeout0 || 100
+	let timeout_multi = this.params.timeout_multi || 3000
+	let t =timeout_multi
+	// let now = Date.now()
+	if (this.params.HAS_OPENED && timeout_multi<Date.now()-this.params.OPEN_TIME){
+		t=timeout0
+	}
+	// clog(":TIME:",now,this.params.OPEN_TIME,now-this.params.OPEN_TIME)
+	this.params.HAS_OPENED = 0
+	setTimeout(this.params.fns.reconnect,t)
 }
 
 window.glob_u.ws.fns.onmessage = function onmessage(event){
@@ -55,7 +65,9 @@ window.glob_u.ws.fns.onerror = function onerror(event){
 
 }
 window.glob_u.ws.fns.onopen = function onopen(event){
-
+	this.params.HAS_OPENED = 1
+	this.params.OPEN_TIME = Date.now()
+	
 	// clog("WS_OPEN???",{that:this,args:[...arguments]},{on_open_once:this.on_open_once,on_open_cbs:this.params.on_open_cbs})
 	// glob_u.ws.sockets.ws1.params.ord.run_cbs("WS_OPEN:",{event,that:this})
 	glob_u.ws.sockets[this.params.socket_name].params.ord.run_cbs("WS_OPEN:",{event,that:this})
@@ -224,6 +236,35 @@ function ws_reload(){
 
 
 function get_room_name(){
+	// return 
+	var s=location.search
+	// if s[0]=="?"){}
+	s[0]=="?" ?  s = s.slice(1):0
+	var param
+	for (param of s.split("&")){
+
+		let kv = param.split("=")
+		if (kv[0]=="room"){
+			return kv[1]
+		}
+		clog("::",param,kv)
+		// clog("::",param,kv,"")
+	}
+
+	// var 
+	return "room_name"
+	var room_name=location.pathname.match(/\/loc.([^\/]*)\//)
+	if (room_name){
+		room_name = room_name[1]
+	} else {
+	room_name = location.pathname.split("/").pop()
+
+	}
+	return room_name
+
+}
+// function get_room_name(){
+function get_room_name_old(){
 
 	var room_name=location.pathname.match(/\/loc.([^\/]*)\//)
 	if (room_name){