auto commit

mdev/dev_sto.native.js

@@ -0,0 +1,325 @@
+
+var NS = {
+	// set_msg:"update_query"
+	UPDATE_QUERY:"set_msg",
+	// UPDATE_QUERY:"update_query",
+	JOIN_DB:"connect_jdb",
+	// JOIN_DB:"update_query",
+}
+function pfnf(o){
+	return  function(resolve, reject){
+		o.resolve=resolve
+		o.reject=reject
+		// clog(arguments)
+	}
+}
+
+
+class Proxy_Factory {
+
+	constructor(o,n="dflt",base_n="dflt",full_n="dflt-dflt",socket_name=""){
+		this.db = o
+		this.n = n
+		this.socket_name = socket_name
+		this.base_n = base_n
+		this.full_n = full_n
+
+		this.hidden_props = ["add_proxy","_set","walker","walker_start","prxy","_sett","_sett2"]
+		this._pub_cb =[]
+		this.__prx = true
+		this.SymPrx = Symbol("SymPrx")
+		clog("mx Proxy_Factory")
+
+
+		// clog("pfx",{o,n,that:this})
+	}
+
+
+	constructor_x(){
+		// o,n="dflt",base_n="dflt",full_n="dflt-dflt",socket_name=""
+		// this.constructor_m(...arguments)
+		clog("Proxy_Factory constructor")
+		Proxy_Factory.prototype.constructor_m.call(this,...arguments)
+	}
+			mx1(){
+		clog(("mx1: Proxy_Factory"))
+	}
+
+
+	init(o){
+		// dlog("BP",this,this.baseProp,this.__proto__.baseProp,window.baseProp)
+		// clog("pfx init",{o,that:this})
+		this.root = o
+	}
+	sync(o){
+		this.root = jc(o.root)
+		o._pub_cb.push(this._set_recv.bind(this))
+	}
+	get prxy(){
+		return this
+	}
+
+	_set(o,k,v,prx,a0){
+		this.obj[k]=prx
+	}
+
+	_sett(o,k,v,prx,a0){
+		dlog("_SETT",this,arguments)
+	}
+	_sett2(o,k,v,prx,a0){
+		dlog("_SETT2",this,arguments)
+	}
+
+	set_pub(obj, prop, val,receiver){
+		// dlog("qia_pub",obj, prop, val,receiver)
+		// dlog("qia_pub2",this.n,obj.__path_arr, prop, jx(val))
+		this._set_pub(obj.__path_arr, prop, jx(val))
+
+	}
+	// dev_glob.fns.tmp_send
+
+	_connect_db(){
+			/*
+		dev_glob.fns.tmp_send({
+				"key":"connect_jdb",
+				// ,
+				init_obj:this.db,
+				"payload":{},
+				db_id:this.db_conn.db_id,
+		},this.socket_name)
+		//	*/
+			this._wssto_send({
+				// "key":"connect_jdb",
+				"key":NS.JOIN_DB,
+				// ,
+				tx:["abc",,2],
+				init_obj:this.db,
+				"payload":{},
+			})
+	}
+
+
+	get db_conn(){
+		return {db_id:{n:this.n,base_n:this.base_n,full_n:this.full_n},socket_name:this.socket_name}
+	}
+	// _req_sync(){}
+	_wssto_send(o){
+		clog("wssto: m0")
+		if (!o.wssto_key){
+			o.wssto_key = o.key
+			o.key = "wssto"
+		}
+		// o.key = "_wssto_" + o.key
+		this.send(o)
+	}
+	send(o){
+		dev_glob.fns.tmp_send({
+				db_id:this.db_conn.db_id,
+				...o,
+				},this.socket_name)
+	}
+	send_raw(){
+		clog("DBQ")
+	}
+
+	_set_pub(path,key,val){
+		var k,v
+
+		clog("dev_sto","_set_pub")
+					 /*
+			tmsgx({
+				"type":"set_msg",
+				"payload":{path,key,val},
+			},"code")
+			//		*/
+			//
+			this._wssto_send({
+				// "type":"set_msg",
+				"type":NS.UPDATE_QUERY,
+				"key":NS.UPDATE_QUERY,
+				"payload":{path,key,val},
+			})
+			/*
+			dev_glob.fns.tmp_send({
+
+			// tmsgx3({
+			// })
+				"type":"set_msg",
+				"key":"set_msg",
+				db_id:this.db_conn.db_id,
+				// "payload":{path,key,val,db_id:{n:this.n,base_n:this.base_n}},},this.socket_name
+				"payload":{path,key,val},},this.socket_name
+				// window.tmsgx_to || {}
+			// {to:"nl4qbyiz61z-mce1@specplot.com/FlUkwrLs"},
+			// {to:"maf@conference.i.specplot.com/0695c1e4"},
+			// {},
+			)
+			*/
+		for (v of this._pub_cb){
+			v(path,key,val)
+
+		}
+	}
+
+	_set_recv(path,prop,val){
+		// return
+		var p = path
+		var nprop = deep_prop_v0(this.root,p)
+		clog("_set_recv:",nprop)
+		var dpth = nprop.__dpth
+		if (tlu[typeof(val)]){
+		nprop._set(nprop,prop,val,val)
+		} else {
+		nprop._set(nprop,prop,val,new Proxy(val,this))
+		nprop[prop].add_proxy(nprop,prop,val,dpth+1)
+		}
+		// var tf = {}
+		// this.walker(nprop[prop],tf,dpth+2)
+		this.walker(nprop[prop],{},dpth+2)
+	}
+
+	set(obj, prop, val,receiver){
+		// dlog("prx_db set ",this,obj, prop, val,receiver,val.__prx)
+		// clog("prx_db set ",{that:this,obj, prop, val,receiver},val.__prx)
+		// clog("prx_db set ",obj.__path_arr)
+		if (obj[prop] === val){
+			return Reflect.set(...arguments)
+		}
+
+		this.set_pub(obj, prop, val,receiver)
+		this.event_proc("set")
+
+		if ("__prx" == prop){
+			this.__prx=val
+			return this.__prx
+		}
+
+		if (typeof(val) === "object" && val != null && !(val.__prx)){
+			var ret = Reflect.set(...arguments)
+			this.set_obj(obj, prop, val,receiver)
+			return ret
+		}
+
+		return Reflect.set(...arguments)
+	}
+	get(obj, prop,receiver){
+		// dlog("prx_db get ...",prop==isProxy,this,obj, prop,receiver)
+		if (this.hidden_props.includes(prop)){
+			switch (prop){
+				case "add_proxy":
+				return this.add_proxy.bind(this)
+			break;
+				case "prxy":
+				return this
+				case "_set":
+				// dlog("_SET")
+				// return this._set.bind({this})
+				return this._set.bind({that:this,obj, prop,receiver})
+				case "_sett":
+				return this._sett.bind({that:this,obj, prop,receiver})
+				case "_sett2":
+				return this._sett2.bind({that:this})
+				case "walker_start":
+				return this.walker_start
+				case "walker":
+				return this.walker
+			break;
+			}
+		}
+
+		if (isProxy == prop){ return true }
+		if ("__prx" == prop){ return this.__prx }
+
+		return Reflect.get(...arguments)
+	}
+	add_proxy(o,k,v,dpth){
+		// clog("~add_proxy~",o,k,v,dpth)
+		// clog("~add_proxy~",o.__prx,o,k,v,dpth,xpath)
+		var xpath = o.__path
+		var apath = o.__path_arr
+		this.event_proc("add_proxy")
+		if (!apath){
+			apath=[]
+		}
+
+		if (!xpath){
+			xpath="ROOT!"
+		}
+
+		Object.defineProperty(v,"__path_arr",Object.assign({value:apath.concat(k),},this.baseProp))
+		Object.defineProperty(v,"__path",Object.assign({value:xpath+":"+k,},this.baseProp))
+		Object.defineProperty(v,"__dpth",Object.assign({value:dpth,},this.baseProp))
+		// Object.defineProperty(v,"__dbg",Object.assign({value:{},},this.baseProp))
+
+	}
+	set_obj(obj, prop, val,receiver){
+		var dpth = obj.__dpth
+		var tf = {}
+		this.walker(receiver,tf,dpth)
+	}
+
+	walker(o,tfo,dpth=0){
+		// dlog("qia WALK",this)
+		if (dpth > 7){
+			console.error("MAX DEPTH")
+			return
+		}
+		var k,v
+		var tf
+			for ([k,v] of Object.entries(o)){
+				tf = type_info(v)
+				if (tf.deep_not_prx){
+					o._set(o,k,v,new Proxy(v,this.prxy))
+					o[k].add_proxy(o,k,v,dpth)
+				this.walker(o[k],tf,dpth+1)
+				}
+			}
+	}
+	walker_start(o,dpth){
+		var tf = type_info(o)
+		o.add_proxy({},[],o,-1)
+		this.walker(o,tf,0)
+	}
+	event_proc(e){}
+}
+
+	class Proxy_Permissions extends Proxy_Factory {
+		// constructor_m(a,a1){
+		constructor(a,a1){
+			clog("mx Proxy_Permissions")
+			super(...arguments)
+		}
+	constructor_x(){
+		// o,n="dflt",base_n="dflt",full_n="dflt-dflt",socket_name=""
+			super.constructor_x(...arguments)
+		this.constructor_m(...arguments)
+		// Proxy_Permissions.prototype.constructor_m.call(this,...arguments)
+		// this.prototype.constructor_m.call(this,...arguments)
+	}
+		mx1(){
+		clog(("mx1: Proxy_Permissions"))
+	}
+
+
+		set(obj, prop, val,receiver){
+			// clog("PRX_PERM",obj.__path_arr,prop)
+			var k,v
+			var r
+			var matched
+			var fp = obj.__path_arr.concat(prop)
+			for ([k,v] of Object.entries(permissions_def)){
+				matched = arr_match(v.m,fp)
+				if (matched){
+					r = v.fn({that:this,obj, prop, val,receiver},{fp,k,v}) || {}
+				}
+				// if (r.return)
+			}
+			// case
+			// if (obj.__path_arr && obj.__path_arr.length){}
+			return super.set(obj, prop, val,receiver)
+		}
+		_set(){
+			// clog("Proxy_Permissions _set")
+			super._set(...arguments)
+		}
+	}