From 41af3b37b5c951fba2549ed0f0cabd5e1235f67d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Oliver=20Hn=C3=A1t?= <oliver.hnat@gmail.com>
Date: Wed, 2 Nov 2022 15:32:44 +0100
Subject: [PATCH] Added graph

---
 __pycache__/dashboard.cpython-310.pyc      | Bin 819 -> 1572 bytes
 dashboard.py                               |  25 +++++++++++++++++++--
 dashboard_static/index.html                |   4 ++++
 demos/wordcloud.py                         |   2 +-
 eca/__pycache__/arff.cpython-310.pyc       | Bin 10596 -> 10610 bytes
 eca/__pycache__/generators.cpython-310.pyc | Bin 3899 -> 3913 bytes
 6 files changed, 28 insertions(+), 3 deletions(-)

diff --git a/__pycache__/dashboard.cpython-310.pyc b/__pycache__/dashboard.cpython-310.pyc
index fa27820446057a79adfd6ff7111686db9eb9ffa2..7a0a8628cf0b125c1ea27feb05fdcce8f1915948 100644
GIT binary patch
literal 1572
zcmah}OK&7K5Vqa!o=ztj60xv6P6&`_5E<phA&QW8k1&_8LbO05Pur99#?x+WPhRSX
zLvrOGa7ei2FZs$TXHIYcsyx}<Y@`)#xw^`adVXcIzFrU*^p|P<S4zkqDBK?j2w%f=
zEf7g0)#N+;Gfn5LVifsACsh*vyyB8qsmf$}L1iWfm*j$01DVT}OH$>EU#-aEnpVX=
zk*mMcYE`bub=X;h8$-D9mfVOp)@8Cs%FSD_NlF^%=Rh7gFRY)K*-SUBn)qX-yc<^=
zQn-Vu5mrv%fN$!+o3`;a!@G9_c?ga?f$81@;vo>pWFq;m351aLWI`nYliB!e)pf>t
zx4q?0d`P32TMBndRu$?<wSLlyxvExuGgp(DsJ*dvxo<I9A+61#^(6~Q?N0(#H^gF!
z|Ndt5%qi<eMmI;w9<;)bo+@|fO*eW5R$8w{KPX|hN8cK`&}w_+j~nlm{j#&>xvKr>
zWuRN#X-J*&i*5*t9S1UG1+{Cy)ab*Df&9z3H$d>DC!Y4SXBY78ksCTjN9W=MNYj={
zNVPduHl#;FFH}euU8ijHe@RwBN#M0^x_5zdnAi<!--h2=^5geklzCMg8LidnRA^o0
zGh=+@im7miYRTuotGJqZ)wYeR2DNQ!*sd~X>RQ<<wTu1fX^m-pG0+so^8}{*3Wz6H
zv?tf}oO*`Uyd*unU?3$>*ZUHGCG`|)oQ_{pj7CuT9xBd(^yG?MgJ{=5D5=H7-2e!W
zALb$7(PBQ8V)tV>@h9rY$=Ty$W2M{L(WVyK?E<qr^M5uyIeKL?tT@0$)MOul-UpT~
zCjS#$e+=Z!nh_9Ka_B62$RTt#zC|~on-Z<sH>&;=&cxcTk&=f&ClH4%V6M}RN4Rt$
zn>8910X>7ca!%~4kXhvx+CT6$q%n+-P$l+3L5K0<)Z&^&e7@GK2<HrDEc7lgJ$+8j
znTHq<wv>3*Gs)hEsGgFahUW?FKqLF4Paw{8#$@(eJooc3w)9{eZ3OPsiLW>S?=U1n
zN{dFo{|s8VF|FN1kq0h?7lEsJ<D-Kiao(2PA~Ng>67<-<g9PJQlGqo+ebp)}{N3YJ
z!mdN`WUSyDlv73vTKvQRwV%OaISh%aMKuJnb$8KNw|qk~D_UvhfmszcEi}=jHt;~e
z+XJ;Y2x)wWV!y}U3xnFsyGASfA$o)_+%man=$@C+-{@+-Gmo##E~4Lk03;`CG-o;G
RJWC6j4~jHT@+8ZL^go9oSi=AS

delta 464
zcmYjNze~eF6wW1=pKXHG3JwkxK?tJIRizH?s4n6Xf+gmTHq!LM<!TY!+QGGE(m@dX
z3v}|IaB<6@;^e!C)Cce5@!iMwy?3wmcf(_@>nKofTT%R_Exb*1ve<34ae%2#^cf-s
zG3Uw*1qQK*Jy!w~cnA0zsaL#3v~$IG7ti<h;OSA;$8oWX4g(upzdPN7@FJ%?4@Htr
zld#9)NlM2e4^J7HjA*MJifJMQ<$D=t*EAL(iSpqUi#XZOZc9C<Vv@OFm16);br7!=
zpQw%e2X&_>Gk68^h!V%6BwLqa6<`JNhJ4onVoCg!27~M_blxmp@Y*F&;0X1s()wzN
zNhG2Y(=-vj#!b+1OM<le&0B_g13IQW60|R-l!^^$Dt9$h5A!ArzFpku+fjovCi*cO
x3%I|ZMPgX$^af^LldjdOQvT0>8Dbr!)qiymDDqVROQ|DE#n{jtWSNHMp&wwoXHNhC

diff --git a/dashboard.py b/dashboard.py
index 7b8637f..5e3c689 100644
--- a/dashboard.py
+++ b/dashboard.py
@@ -2,6 +2,7 @@ from eca import *
 from eca.generators import start_offline_tweets
 
 import random
+import re
 
 ## You might have to update the root path to point to the correct path
 ## (by default, it points to <rules>_static)
@@ -12,7 +13,7 @@ root_content_path = 'dashboard_static'
 # the action will be called with the context and the event
 @event('init')
 def setup(ctx, e):
-    start_offline_tweets('sports1.txt', event_name="tweet", time_factor=0.1)
+    start_offline_tweets('sports1.txt', event_name="tweet", time_factor=1)
     ctx.count = 0
     # fire('sample', {'previous': 0.0})
 
@@ -21,6 +22,22 @@ def setup(ctx, e):
 def clip(lower, value, upper):
     return max(lower, min(value, upper))
 
+
+# simple word splitter
+pattern = re.compile('\W+')
+
+# sample stopword list, needs to be much more sophisticated
+stopwords = ["volleyball", "football", "basketball", "baseball", "tennis", "cricket", "soccer", "rugby"]
+
+
+def words(message):
+    result = pattern.split(message)
+    result = map(lambda w: w.lower(), result)
+    result = filter(lambda w: w in stopwords, result)
+    result = filter(lambda w: len(w) > 2, result)
+    return result
+
+
 @event('tweet')
 def generate_tweet(ctx, e):
     tweet = e.data
@@ -28,7 +45,11 @@ def generate_tweet(ctx, e):
     # sample = clip(-100, e.data['previous'] + random.uniform(+5.0, -5.0), 100)
     # emit to outside world
     emit('tweet', tweet)
-
+    for w in words(tweet['text']):
+        emit('balk', {
+            'action': 'add',
+            'value': (str(w), 1)
+        })
     # # chain event
     # fire('tweet', {'previous': tweet}, delay=0.05)
 
diff --git a/dashboard_static/index.html b/dashboard_static/index.html
index ffb7f08..e038778 100644
--- a/dashboard_static/index.html
+++ b/dashboard_static/index.html
@@ -111,6 +111,7 @@
                     </div>
                     <div class="popchart column">
                         <span class="colheader chartheader">Sports Popularity Filter</span>
+                        <div id="balk" style="height:300px; background-color: white;"></div>
                     </div>
                 </div>
             </div>
@@ -118,6 +119,7 @@
     </div>
     <script src="/lib/jquery-2.1.1.min.js"></script>
     <script src="/lib/jquery.flot.min.js"></script>
+    <script src="/lib/jquery.flot.categories.min.js"></script>
     <script src="/lib/core.js"></script>
     <script src="/lib/charts.js"></script>
     <script src="/lib/log.js"></script>
@@ -128,6 +130,8 @@
         block("#tweet").tweets({
             memory: 20
         });
+        block('#balk').barchart();
+        events.connect('balk', '#balk');
         events.connect("tweet", "#tweet");
 
         // // create a rolling chart block
diff --git a/demos/wordcloud.py b/demos/wordcloud.py
index 5b59539..987fe12 100644
--- a/demos/wordcloud.py
+++ b/demos/wordcloud.py
@@ -16,7 +16,7 @@ def add_request_handlers(httpd):
 @event('init')
 def setup(ctx, e):
     # start the offline tweet stream
-    start_offline_tweets('data/bata_2014.txt', 'chirp', time_factor=100000)
+    start_offline_tweets('sports1.txt', 'chirp', time_factor=100000)
     ctx.words = {}
 
 # simple word splitter
diff --git a/eca/__pycache__/arff.cpython-310.pyc b/eca/__pycache__/arff.cpython-310.pyc
index dab7427d1e834bcde8ccb59363edf0b65174b18e..1516621a59785020207256a2be42150d073cc160 100644
GIT binary patch
delta 112
zcmaD7^eKohpO=@50SL;sh9?KBZ{*`-cJ<Z|Elw>e*3Zw$EK4oQ$V)8IcS$YIF3B&@
z4=pKA%_~XOk4#N0GSv6YPbtkwHPkOD&nziPEz&J0%FjwoF40d-PSoG*#~jPbcx&?-
Nj#yzJ#U&HP3jk99CVl__

delta 98
zcmewq^dyKcpO=@50SN3L#3x_Y*vQApY;Nmp6%$&VT2vfUl9^kc8RL?lT$-DjS5h3~
zo1apeld51CQ&OH;Qj%JvTTqmrm6}`<lbW0uvpI%2mX-0>=3N}I!azzwCW;pTiyb1`

diff --git a/eca/__pycache__/generators.cpython-310.pyc b/eca/__pycache__/generators.cpython-310.pyc
index 01498c6c8ba1f70d9813f18b01d362c22d8e231b..155bc4d8708199018b99b564bcb0b143f7aecc2c 100644
GIT binary patch
delta 97
zcmdljcT$cwpO=@50SL;sh9~=O<Xyz%8mJ#yoLW?@pP!RimRgjNmsq0jl3JWyl3$=7
zT2h{xSCXn9nVMK+sPCJfQks)$s9#c^SyGZ(q+3vwpOu<iqMw?asK5CcQz#DrDxo3#

delta 83
zcmX>pw_A=kpO=@50SN3L#3vu!$h(Ni+}YVGCbT%Us5qu1Gq*f5#w9<wG&eP`q&UVm
lKczG$RlzW(q&%~vB(+GlpeR2pHMt}vH90Y6^B1O29srox9rFMH