Async django interaction with Pipe component

Author: Mark Gibbs

demo/demo/consumers.py

@@ -3,13 +3,31 @@
 import json
 
 class MessageConsumer(WebsocketConsumer):
+
     def connect(self):
         self.accept()
+
     def disconnect(self, close_code):
         pass
+
+    def send_to_widgets(self, channel_name, label, value):
+        self.send(json.dumps({'channel_name':channel_name,
+                              'label':label,
+                              'value':value}))
     def receive(self, text_data):
         print("Got incoming")
         message = json.loads(text_data)
         print(text_data)
         self.send(json.dumps({'message':"Thanks for [%s]"%text_data}))
         self.send(json.dumps({'original_message':message}))
+
+        # TODO if type is connection_triplet then store and/or update the info
+        # TODO else do something appropriate with the message
+
+        channel_name = message.get('channel_name',"UNNAMED_CHANNEL")
+        uid = message.get('uid',"0000-0000")
+        label = message.get('label','DEFAULT$LABEL')
+
+        self.send_to_widgets(channel_name=channel_name,
+                             label=label,
+                             value=uid)

demo/demo/plotly_apps.py

@@ -2,6 +2,8 @@
 import dash_core_components as dcc
 import dash_html_components as html
 
+import dpd_components as dpd
+
 from django_plotly_dash import DjangoDash
 
 app = DjangoDash('SimpleExample')
@@ -52,3 +54,26 @@ def callback_c(*args,**kwargs):
     da = kwargs['dash_app']
     return "Args are [%s] and kwargs are %s" %(",".join(args),str(kwargs))
 
+a3 = DjangoDash("Connected")
+
+a3.layout = html.Div([
+    dpd.Pipe(id="dynamic",
+             value="Dynamo 123",
+             label="rotational energy",
+             channel_name="test_widget_channel",
+             uid="need_to_generate_this"),
+    dpd.DPDirectComponent(id="direct"),
+    dcc.RadioItems(id="dropdown-one",options=[{'label':i,'value':j} for i,j in [
+    ("O2","Oxygen"),("N2","Nitrogen"),("CO2","Carbon Dioxide")]
+    ],value="Oxygen"),
+    html.Div(id="output-three")
+    ])
+
+@a3.expanded_callback(
+    dash.dependencies.Output('output-three','children'),
+    [dash.dependencies.Input('dynamic','value'),
+     dash.dependencies.Input('dynamic','label'),
+     ])
+def callback_a3(*args, **kwargs):
+    da = kwargs['dash_app']
+    return "Args are [%s] and kwargs are %s" %(",".join(args),str(kwargs))

demo/demo/settings.py

@@ -130,6 +130,10 @@
 
 import dash_core_components as dcc
 _rname = os.path.join(os.path.dirname(dcc.__file__),'..')
-for dash_module_name in ['dash_core_components','dash_html_components','dash_renderer',]:
+for dash_module_name in ['dash_core_components',
+                         'dash_html_components',
+                         'dash_renderer',]:
     STATICFILES_DIRS.append( ("dash/%s"%dash_module_name, os.path.join(_rname,dash_module_name)) )
 
+# Fudge to work with channels in debug mode
+STATICFILES_DIRS.append(("dash/dpd_components","/home/mark/local/dpd-components/lib"))

demo/demo/templates/index.html

@@ -15,6 +15,10 @@
     Content here
     {%plotly_app name="Ex2"%}
   </div>
+  <div>
+    Content here
+    {%plotly_app name="Connected"%}
+  </div>
 </body>
 {%plotly_message_pipe%}
 </html>

dev_requirements.txt

@@ -39,7 +39,6 @@ nbformat==4.4.0
 packaging==17.1
 path-and-address==2.0.1
 pathtools==0.1.2
-pkg-resources==0.0.0
 pkginfo==1.4.2
 plotly==2.5.1
 port-for==0.3.1

django_plotly_dash/dash_wrapper.py

@@ -155,7 +155,7 @@ def __init__(self, base_pathname=None, replacements = None, ndid=None, expanded_
         super(WrappedDash, self).__init__(**kwargs)
 
         self.css.config.serve_locally = True
-        self.css.config.serve_locally = False
+        #self.css.config.serve_locally = False
 
         self.scripts.config.serve_locally = self.css.config.serve_locally
 

django_plotly_dash/templates/django_plotly_dash/plotly_messaging.html

@@ -22,6 +22,9 @@
         console.log(stream);
     };
     dpd_wsb.add_callback(lcb);
-    dpd_wsb.add_callback(lcb);
+    if( window.dpd_wsb_pre ) {
+      for(var i in window.dpd_wsb_pre.callbacks ) dpd_wsb.add_callback(window.dpd_wsb_pre.callbacks[i]);
+      for(var j in window.dpd_wsb_pre.sender_targets ) window.dpd_wsb_pre.sender_targets[i].add_sender(dpd_wsb);
+    }
   }
 </script>

make_env

@@ -1,6 +1,6 @@
 #!/usr/bin/env bash
 #
-virtualenv -p python3 env
+virtualenv -p python3.6 env
 source env/bin/activate
 pip install -r requirements.txt
 pip install -r dev_requirements.txt