|
@@ -545,7 +545,6 @@ function create_ws_ord(){
|
545
|
545
|
window.glob_u.ws.fns.dispatch = function dispatch(o,obj_x,info){
|
546
|
546
|
var event = o.event
|
547
|
547
|
// socket = o.that
|
548
|
|
- // clog("jtx dispatch",{o,obj_x,info,that:this})
|
549
|
548
|
var data = JSON.parse(event.data)
|
550
|
549
|
// clog("WS_dispatch",data,socket.params.ord,data["CLIENT_KEY"])
|
551
|
550
|
// clog("trc:sto:ws_rec",data.CLIENT_KEY,data.sto_event_type,data)
|
|
@@ -688,7 +687,6 @@ glob_u.cb.ws.reg_cb(window.glob_u.ws.fns.dispatch,"WS_MESSAGE:","WS_MESSAGE")
|
688
|
687
|
var Proxy_Permissions,Proxy_Factory
|
689
|
688
|
|
690
|
689
|
function mhndlr_rld_2(_o,scope,info){
|
691
|
|
- // clog("jtx mhndlr_rld_2",{_o,scope,info,that:this})
|
692
|
690
|
var dlog =nop
|
693
|
691
|
try {
|
694
|
692
|
var parsed = _o.data
|
|
@@ -701,7 +699,6 @@ function mhndlr_rld_2(_o,scope,info){
|
701
|
699
|
switch (parsed.sto_event_type){
|
702
|
700
|
case "set_msg":
|
703
|
701
|
// if (!glob_u.prom.init_db_resolve.resolved){
|
704
|
|
- // if (!glob_u.prom.init_db_resolve.resolved_inited){
|
705
|
702
|
if (!glob_u.prom.init_db_resolve.resolved_inited && _o?.event?.target?.pre_init_msgs){
|
706
|
703
|
_o.event.target.pre_init_msgs.push(_o)
|
707
|
704
|
}
|
|
@@ -905,6 +902,7 @@ Proxy_Factory = class Proxy_Factory {
|
905
|
902
|
}
|
906
|
903
|
|
907
|
904
|
_set_recv(path,prop,val,id){
|
|
905
|
+ console.trace("_set_recv",{path,prop,val,id})
|
908
|
906
|
|
909
|
907
|
var p = path
|
910
|
908
|
var nprop = deep_prop_v0(this.root,p)
|
|
@@ -1230,7 +1228,7 @@ var DBL_Proxy = {
|
1230
|
1228
|
|
1231
|
1229
|
|
1232
|
1230
|
function init_db(objx){
|
1233
|
|
- // clog("init_db~")
|
|
1231
|
+ clog("init_db~",arguments,this)
|
1234
|
1232
|
console.trace("init_db")
|
1235
|
1233
|
trc_sto("init_db",{})
|
1236
|
1234
|
glob_u.prom.init_db_resolve.resolved=1
|
|
@@ -1325,11 +1323,12 @@ window.msto=new Proxy(msto_prx, DBL_Proxy)
|
1325
|
1323
|
|
1326
|
1324
|
|
1327
|
1325
|
function handle_pre_init_msgs(){
|
1328
|
|
- clog("handle_pre_init_msgs")
|
|
1326
|
+ // clog("handle_pre_init_msgs")
|
1329
|
1327
|
var k,v,i
|
1330
|
1328
|
var _o
|
1331
|
1329
|
glob_u.prom.init_db_resolve.resolved_inited = 1
|
1332
|
|
- for (v of glob_u.ws.sockets.ws1.pre_init_msgs){
|
|
1330
|
+ // TODOL FIX HARDCODEING
|
|
1331
|
+ for (v of glob_u.ws.sockets.ws1?.pre_init_msgs || []){
|
1333
|
1332
|
if (v.data.sto_event_type == "set_msg"){
|
1334
|
1333
|
msto.my_data.rehandle=1
|
1335
|
1334
|
_o={...v,data:jc(v.data)}
|
|
@@ -1353,6 +1352,7 @@ function init_mu(){
|
1353
|
1352
|
var k,v
|
1354
|
1353
|
|
1355
|
1354
|
var rr = {}
|
|
1355
|
+ console.trace("init_mu")
|
1356
|
1356
|
var prom1 = new Promise(pfnf(rr));
|
1357
|
1357
|
prom1.then(init_db).then(ws_sto_connected)
|
1358
|
1358
|
glob_u.prom.init_db_resolve_timeout_arg = {aaa:"timedout",pl:msto_z}
|