report bandwidth, only pull changes

oml/bandwidth.py

@@ -0,0 +1,26 @@
+import state
+from websocket import trigger_event
+
+class Bandwidth(object):
+    up = 0
+    down = 0
+    _last = {}
+
+    def __init__(self):
+        self.update()
+
+    def update(self):
+        bandwidth = {'up': self.up, 'down': self.down}
+        if bandwidth != self._last:
+            trigger_event('bandwidth', bandwidth)
+            self._last = bandwidth
+        self.up = 0
+        self.down = 0
+        state.main.call_later(1, self.update)
+
+    def download(self, amount):
+        self.down += amount * 8
+
+    def upload(self, amount):
+        self.up += amount * 8
+

oml/changelog.py

@@ -58,8 +58,8 @@ class Changelog(db.Model):
         _data = _data.encode()
         state.db.session.add(c)
         state.db.session.commit()
-        if state.nodes:
+        #if state.nodes:
-            state.nodes.queue('peered', 'pushChanges', [c.json()])
+        #    state.nodes.queue('peered', 'pushChanges', [c.json()])
 
     @classmethod
     def apply_changes(cls, user, changes):

oml/node/nodeapi.py

@@ -34,6 +34,8 @@ def api_pullChanges(remote_id, user_id=None, from_=None, to=None):
     return [c.json() for c in qs]
 
 def api_pushChanges(user_id, changes):
+    logger.debug('pushChanges no longer used, ignored')
+    return True
     user = User.get(user_id)
     if not Changelog.apply_changes(user, changes):
         logger.debug('FAILED TO APPLY CHANGE')

oml/nodes.py

@@ -244,7 +244,7 @@ class Node(Thread):
                         else:
                             #fixme, what about cancel/reject peering here?
                             self.peering('removePeering')
-                    if self.online:
+                    if self.peered and self.online:
                         self.pullChanges()
             except:
                 logger.debug('failed to connect to %s', self.user_id)
@@ -316,14 +316,17 @@ class Node(Thread):
             return False
         if r.getcode() == 200:
             try:
+                fileobj = r
                 if r.headers.get('content-encoding', None) == 'gzip':
-                    content = gzip.GzipFile(fileobj=r).read()
+                    fileobj = gzip.GzipFile(fileobj=r)
-                else:
                 content = b''
                 ct = datetime.utcnow()
-                    for chunk in iter(lambda: r.read(16*1024), b''):
+                size = 0
+                for chunk in iter(lambda: fileobj.read(16*1024), b''):
                     content += chunk
-                        if (datetime.utcnow() - ct).total_seconds() > 1:
+                    size += len(chunk)
+                    since_ct = (datetime.utcnow() - ct).total_seconds()
+                    if since_ct > 1:
                         ct = datetime.utcnow()
                         t = Transfer.get(item.id)
                         t.progress = len(content) / item.info['size']
@@ -331,8 +334,11 @@ class Node(Thread):
                         trigger_event('transfer', {
                             'id': item.id, 'progress': t.progress
                         })
+                        if state.bandwidth:
+                            state.bandwidth.download(size/since_ct)
+                            size = 0
                 '''
-                    content = r.read()
+                content = fileobj.read()
                 '''
 
                 t2 = datetime.utcnow()
@@ -468,3 +474,8 @@ def check_nodes():
                 if not state.nodes.is_online(u.id):
                     logger.debug('queued peering message for %s trying to connect...', u.id)
                     state.nodes.queue('add', u.id)
+            for u in user.models.User.query.filter_by(peered=True):
+                if state.nodes.is_online(u.id):
+                    u.pullChanges()
+                else:
+                    u.go_online()

oml/server.py

@@ -110,6 +110,8 @@ def run():
         import downloads
         import nodes
         import tor
+        import bandwidth
+        state.bandwidth = bandwidth.Bandwidth()
         state.tor = tor.Tor()
         state.node = node.server.start()
         state.downloads = downloads.Downloads()

oml/state.py

@@ -1,3 +1,4 @@
+bandwidth = None
 host = None
 main = None
 nodes = False

oml/update.py

@@ -184,7 +184,7 @@ def getVersion(data):
         p = subprocess.Popen(cmd, stdout=subprocess.PIPE, close_fds=True)
         stdout, stderr = p.communicate()
         new = stdout.strip()[:40]
-        response['update'] = current != new
+        response['update'] = len(new) == 40 and current != new
     else:
         if not os.path.exists(os.path.join(settings.updates_path, 'release.json')):
             return response

static/js/connectionButton.js

@@ -10,24 +10,34 @@ oml.ui.connectionButton = function() {
         })
         .bindEvent({
             // ...
-        });
+        }),
+        bandwidth;
 
     /*
-    oml.ui.statusIcon(oml.user.online ? 'connected' : 'disconnected')
+    oml.ui.statusIcon(oml.user)
         .css({float: 'left'})
         .appendTo(that);
     */
 
-    Ox.Element()
+    function formatBandwidth(up, down) {
+        return '↓'+Ox.formatValue(down, 'b')+' / ↑'+Ox.formatValue(up, 'b')+'';
+    }
+
+    bandwidth = Ox.Element()
         .addClass('OxLight')
         .css({
             float: 'left',
             marginTop: '2px',
             fontSize: '9px'
         })
-        .html('↓0K/↑0K')
+        .html(formatBandwidth(0, 0))
         .appendTo(that);
 
+    oml.bindEvent({
+        bandwidth: function(data) {
+            bandwidth.html(formatBandwidth(data.up, data.down));
+        }
+    });
     return that;
 
 };