jfinn
/
jsyncdb
Watch 1
Star 0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
Browse Source

reloadables will now be in the repo

master
jfinn 9 months ago
parent
99d573dc2c
commit
9fa035efff
10 changed files with 282 additions and 8 deletions
Split View Show Diff Stats
  1. 1
    1
      flask_server/app_sio.py
  2. 5
    1
      js_client/jsync_io_demo.js
  3. 58
    0
      js_client/qflask/flask_index.html
  4. 84
    0
      js_client/qflask/jsr0.js
  5. 18
    0
      js_client/qflask/jsr1.js
  6. 3
    0
      js_client/qflask/jsr2.js
  7. 27
    0
      js_client/qflask/jsto0.js
  8. 35
    0
      js_client/qflask/jsync_info.js
  9. 37
    0
      js_client/qflask/qflask_dev.js
  10. 14
    6
      js_client/sto_only.html

+ 1
- 1
flask_server/app_sio.py View File 

@@ -126,7 +126,7 @@ def handle_message(data):
126 126 
     p("io2+",room)
127 127
128 128 
     # flask_socketio.emit('jsync.io', data, broadcast=True)
129 
-    flask_socketio.emit('jsync.io2', data,room=room, broadcast=True)
129 
+    flask_socketio.emit('jsync.io2', data ,room=room, broadcast=True)
130 130
131 131
132 132

+ 5
- 1
js_client/jsync_io_demo.js View File 

@@ -100,4 +100,8 @@ window.glob_u.ws = window.glob_u.ws || {
100 100 
 }
101 101
102 102
103 
-glob_u.ws.sockets.sio1 = create_sio_conn()
103 
+glob_u.ws.sockets.sio1 = create_sio_conn()
104 
+
105 
+
106 
+
107 
+// clog("???????????????/")

+ 58
- 0
js_client/qflask/flask_index.html View File 

@@ -0,0 +1,58 @@
1 
+<!DOCTYPE html>
2 
+<html>
3 
+<head>
4 
+    <title>WebSocket Example</title>
5 
+    <script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/3.1.3/socket.io.js"></script>
6 
+    <script type="text/javascript">
7 
+        // var socket = io.connect('https://' + document.domain + ':' + location.port);
8 
+        var socket = io.connect('https://' + "127.0.0.1" + ':' + 5000);
9 
+
10 
+
11 
+        function sendMessage() {
12 
+            var message = document.getElementById('message').value;
13 
+            socket.emit('message', message);
14 
+        }
15 
+
16 
+        socket.on('connect', function () {
17 
+            console.log('Connected to the server');
18 
+            // socket.emit('message', "run_fn");
19 
+        });
20 
+
21 
+        socket.on('response', function (data) {
22 
+            console.log('Server says: ' + data);
23 
+        });
24 
+
25 
+        function function_name(argument) {
26 
+            // body...
27 
+        }
28 
+
29 
+        clog=console.log
30 
+        function rec_q_to_tab(data_str,a,b,c,d){
31 
+            clog({that:this},arguments)
32 
+            var data = JSON.parse(data_str)
33 
+
34 
+            clog(data)
35 
+            lines = data.file_content.split("\n")
36 
+            proc_data = {arr:[]}
37 
+            for (line of lines){
38 
+                if (!line){
39 
+                    clog("NOT LINE",line)
40 
+                    continue
41 
+                }
42 
+                // clog()
43 
+                proc_data.arr.push(JSON.parse(line))
44 
+            }
45 
+
46 
+
47 
+        }
48 
+        socket.on('q_to_tab_q', rec_q_to_tab)
49 
+
50 
+
51 
+    </script>
52 
+</head>
53 
+<body>
54 
+    <h1>WebSocket Example</h1>
55 
+    <input type="text" id="message" placeholder="Type a message">
56 
+    <button onclick="sendMessage()">Send</button>
57 
+</body>
58 
+</html>

+ 84
- 0
js_client/qflask/jsr0.js View File 

@@ -0,0 +1,84 @@
1 
+
2 
+function init_mu(){
3 
+
4 
+	var k,v
5 
+	clog("INIT_MU",performance.now())
6 
+	var rr = {}
7 
+	var prom1 = new Promise(pfnf(rr));
8 
+	prom1.then(init_db).then(ws_sto_connected)
9 
+	glob_u.prom.init_db_resolve_timeout_arg = {aaa:"timedout",pl:msto_z}
10 
+
11 
+	setTimeout(rr.resolve,5000,glob_u.prom.init_db_resolve_timeout_arg)
12 
+	var rn = ((Math.random()+"").replace("0.","") - 0).toString(16)
13 
+
14 
+	tmsgx4({sto_event_type:"db_sync_request","CLIENT_KEY":"ws_sto",request_rn:rn})
15 
+	clog("tmsgx4 iunit_mu",tmsgx4)
16 
+	glob_u.prom.init_db_resolve = rr.resolve
17 
+	glob_u.prom.init_db_resolve.rn = rn
18 
+
19 
+}
20 
+
21 
+
22 
+
23 
+
24 
+function init_db(objx){
25 
+	// clog("init_db~")
26 
+	console.trace("init_db")
27 
+	trc_sto("init_db",{})
28 
+	glob_u.prom.init_db_resolve.resolved=1
29 
+	var glob_mx = glob_u.data
30 
+		var obj
31 
+
32 
+	if (objx.participants){obj = objx} else {obj = objx.pl}
33 
+pf = new Proxy_Permissions({},"pf")
34 
+msto_prx = new Proxy(obj,pf)
35 
+window.msto_prx=msto_prx
36 
+// window.msto_prx0 =msto_prx
37 
+pf.init(msto_prx)
38 
+msto_prx.walker_start(msto_prx)
39 
+glob_mx.init_db=true
40 
+
41 
+var dbl_proxy_obj = {
42 
+		get my_channel(){
43 
+			return msto.ws_channels[get_ws_channel_name()]
44 
+			// my_data("pfx get k1")
45 
+		},
46 
+		set my_channel(val){
47 
+			clog("pfx set my_channel")
48 
+			msto.ws_channels[get_ws_channel_name()] = val
49 
+		},
50 
+
51 
+
52 
+		get my_data(){
53 
+			return msto.participants[get_local_sto_id()]
54 
+		},
55 
+		set my_data(val){
56 
+			clog("pfx set my_data")
57 
+			msto.participants[get_local_sto_id()] = val
58 
+
59 
+		},
60 
+		private_local:{},
61 
+
62 
+
63 
+}
64 
+pf.dbl_proxy_obj=dbl_proxy_obj
65 
+window.msto=new Proxy(msto_prx, DBL_Proxy)
66 
+
67 
+
68 
+}
69 
+
70 
+
71 
+
72 
+
73 
+function init_mu_delay(argument) {
74 
+	// body...
75 
+	clog("INIT_MU DELAYED",performance.now())
76 
+	setTimeout(init_mu,100)
77 
+
78 
+}
79 
+
80 
+
81 
+addEventListener("load",init_mu_delay)
82 
+rldi.setint(500)
83 
+window.rld_int=500
84 
+

+ 18
- 0
js_client/qflask/jsr1.js View File 

@@ -0,0 +1,18 @@
1 
+function pfnf(o){
2 
+	return  function(resolve, reject){
3 
+		o.resolve=resolve
4 
+		o.reject=reject
5 
+	}
6 
+}
7 
+
8 
+
9 
+
10 
+
11 
+function ws_sto_connected(argument) {
12 
+	// body...
13 
+	clog("ws_sto_connected DO NOTHING")
14 
+	glob_u.prom.init_db_resolve.resolved_inited = 1
15 
+	glob_u.prom.init_db_resolve.resolved_inited = 2
16 
+}
17 
+
18 
+clog("....")

+ 3
- 0
js_client/qflask/jsr2.js View File 

@@ -0,0 +1,3 @@
1 
+
2 
+clog("JSR2\n\n")
3 
+

+ 27
- 0
js_client/qflask/jsto0.js View File 

@@ -0,0 +1,27 @@
1 
+msto_z = {
2 
+	conference:{
3 
+		events:{},
4 
+	},
5 
+	participants:{},
6 
+	ws_channels:{},
7 
+}
8 
+// glob_u.fns.get_local_sto_id = get_local_sto_id
9 
+// glob_u.fns.get_ws_channel_name = get_ws_channel_name
10 
+// glob_u.fns.get_session_sto_id = get_session_sto_id
11 
+
12 
+
13 
+
14 
+
15 
+
16 
+
17 
+function get_local_sto_id(){
18 
+	return glob_u.data.jsync_local_id
19 
+}
20 
+function get_session_sto_id(){
21 
+	return glob_u.data.jsync_session_id
22 
+}
23 
+
24 
+function get_ws_channel_name(){
25 
+	return glob_u.data.channel_name
26 
+
27 
+}

+ 35
- 0
js_client/qflask/jsync_info.js View File 

@@ -0,0 +1,35 @@
1 
+// console.clear()
2 
+
3 
+clog("JSYNC INFO PLACEHOLDER")
4 
+
5 
+
6 
+function trc_sto(argument) {
7 
+	// body...
8 
+	clog("trc_sto",arguments,this)
9 
+}
10 
+
11 
+function fn(argument) {
12 
+	var r = {
13 
+		_o:{},
14 
+		o:{},
15 
+	}
16 
+	//
17 
+	r._o=glob_u.cb.ws.cb_sto
18 
+	var k,v,z,z2
19 
+	for ([k,v,z] of Object.entries(glob_u.cb.ws.cb_sto)){
20 
+		// clog(":",[k,v,z])
21 
+		r.o[k]=[]
22 
+		for (elm of v){
23 
+			clog("::",elm)
24 
+			r.o[k].push(elm.cb)
25 
+		}
26 
+		clog(":",[k,v,z])
27 
+		// r.o
28 
+	}
29 
+	clog(r)
30 
+	return r
31 
+}
32 
+
33 
+fn()
34 
+
35 
+

+ 37
- 0
js_client/qflask/qflask_dev.js View File 

@@ -0,0 +1,37 @@
1 
+
2 
+
3 
+function set_rld_int(){rldi.setint(600)}
4 
+if (document.readyState != "complete"){
5 
+	window.addEventListener("load",set_rld_int)
6 
+} else {set_rld_int()}
7 
+
8 
+
9 
+clog("QFLASK")
10 
+
11 
+
12 
+function rfn_construct(){
13 
+	clog("RFN:construct")
14 
+	return Reflect.construct(...arguments)
15 
+}
16 
+
17 
+ws_prx = {
18 
+	construct: rfn_construct,
19 
+}
20 
+
21 
+
22 
+function dec_socket(){
23 
+	clog("WebSocket!!!")
24 
+	window.WebSocket_orig =window.WebSocket_orig || WebSocket
25 
+	window.WebSocket_prx = new Proxy(window.WebSocket_orig,ws_prx)
26 
+	window.WebSocket = window.WebSocket_prx
27 
+// URL = new Proxy(URL_orig,rprox2)
28 
+
29 
+
30 
+}
31 
+
32 
+
33 
+
34 
+dec_socket()
35 
+
36 
+
37 
+s = new WebSocket("wss://jsyncdb.com/djc_srv/ws/chat/sto_demo")

+ 14
- 6
js_client/sto_only.html View File 

@@ -13,8 +13,14 @@
13 13
14 14
15 15 
     <script src="https://rld.jfidev.com/ign/j7/rldjs/rldjs5.js?v=139"></script>
16 
+    <!-- <script class="rld rrld" src="/rls.js?c=00x"></script> -->
17 
+    <!-- <script class="rld rrld_u" src="/rls_u.js?c=c50fb605ecc3903a40c4b4e8a41ab12c"></script> -->
18 
+    <script class="rld rrld" src="http://127.4.0.1/rls.js?c=00x"></script>
19 
+    <script class="rld rrld_u" src="http://127.4.0.1/rls_u.js?c=c50fb605ecc3903a40c4b4e8a41ab12c"></script>
20 
+    <!--
16 21 
     <script class="rld rrld" src="https://rld.jfidev.com/ign/rls.js?c=00x"></script>
17 22 
     <script class="rld rrld_u" src="https://rld.jfidev.com/ign/rls_u.js?c=c50fb605ecc3903a40c4b4e8a41ab12c"></script>
23 
+     -->
18 24
19 25 
 <script class="rld" src="/jsync_dep.js"></script>
20 26 
 <script class="rld" src="/jsync_t1.js"></script>
 
@@ -26,13 +32,13 @@
26 32
27 33
28 34
29 
-<script class="rld" src="https://jfidev.com/ign/indx/jsyncdb/qflask/jsync_info.js"></script>
35 
+<script class="rld" src="/qflask/jsync_info.js"></script>
30 36
31 
-<script class="rld" src="https://jfidev.com/ign/indx/jsyncdb/qflask/jsto0.js"></script>
37 
+<script class="rld" src="/qflask/jsto0.js"></script>
32 38
33 
-<script class="rld" src="https://jfidev.com/ign/indx/jsyncdb/qflask/jsr0.js"></script>
34 
-<script class="rld" src="https://jfidev.com/ign/indx/jsyncdb/qflask/jsr1.js"></script>
35 
-<script class="rld" src="https://jfidev.com/ign/indx/jsyncdb/qflask/jsr2.js"></script>
39 
+<script class="rld" src="/qflask/jsr0.js"></script>
40 
+<script class="rld" src="/qflask/jsr1.js"></script>
41 
+<script class="rld" src="/qflask/jsr2.js"></script>
36 42
37 43
38 44 
 
@@ -44,4 +50,6 @@
44 50
45 51
46 52 
 </body>
47 
-</html>
53 
+</html>
54 
+
55 
+

Write Preview
Loading…
Cancel
Save