From 78e48e65bdea126ea00ff739dbec1bb8e4240e69 Mon Sep 17 00:00:00 2001
From: j <j@mailb.org>
Date: Thu, 14 Jan 2016 17:55:15 +0530
Subject: [PATCH] remove unused pushChanges

---
 oml/changelog.py    |  4 ----
 oml/node/nodeapi.py | 22 ----------------------
 oml/node/server.py  |  1 -
 oml/nodes.py        | 10 ----------
 4 files changed, 37 deletions(-)

diff --git a/oml/changelog.py b/oml/changelog.py
index 05f10a1..eb763f7 100644
--- a/oml/changelog.py
+++ b/oml/changelog.py
@@ -58,8 +58,6 @@ class Changelog(db.Model):
         _data = _data.encode()
         state.db.session.add(c)
         state.db.session.commit()
-        #if state.nodes:
-        #    state.nodes.queue('peered', 'pushChanges', [c.json()])
         logger.debug('record change: %s', c.json())
 
     @classmethod
@@ -78,8 +76,6 @@ class Changelog(db.Model):
         _data = _data.encode()
         state.db.session.add(c)
         state.db.session.commit()
-        #if state.nodes:
-        #    state.nodes.queue('peered', 'pushChanges', [c.json()])
         logger.debug('record change: %s', c.json())
 
     @classmethod
diff --git a/oml/node/nodeapi.py b/oml/node/nodeapi.py
index e5be9f8..d24fbae 100644
--- a/oml/node/nodeapi.py
+++ b/oml/node/nodeapi.py
@@ -5,7 +5,6 @@
 from changelog import Changelog
 from user.models import User
 from websocket import trigger_event
-import settings
 import state
 
 import logging
@@ -24,27 +23,6 @@ def api_pullChanges(remote_id, user_id=None, from_=None, to=None):
     if user_id:
         return []
     return Changelog.aggregated_changes(from_)
-    '''
-    if not user_id:
-        user_id = settings.USER_ID
-    qs = Changelog.query.filter_by(user_id=user_id)
-    if from_:
-        qs = qs.filter(Changelog.revision>=from_)
-    if to:
-        qs = qs.filter(Changelog.revision<to)
-    state.nodes.queue('add', remote_id)
-    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')
-        state.nodes.queue(user_id, 'pullChanges')
-        return False
-    return True
 
 def api_requestPeering(user_id, username, message):
     user = User.get_or_create(user_id)
diff --git a/oml/node/server.py b/oml/node/server.py
index 7ebf0c0..98745fb 100644
--- a/oml/node/server.py
+++ b/oml/node/server.py
@@ -175,7 +175,6 @@ class Handler(http.server.SimpleHTTPRequestHandler):
         '''
             API
             pullChanges     [userid] from [to]
-            pushChanges     [index, change]
             requestPeering  username message
             acceptPeering   username message
             rejectPeering   message
diff --git a/oml/nodes.py b/oml/nodes.py
index c7153bf..f8fe698 100644
--- a/oml/nodes.py
+++ b/oml/nodes.py
@@ -283,16 +283,6 @@ class Node(Thread):
             r = Changelog.apply_changes(u, changes)
             return r
 
-    def pushChanges(self, changes):
-        logger.debug('pushing changes to %s %s', self.user_id, changes)
-        if self.online:
-            try:
-                r = self.request('pushChanges', changes)
-            except:
-                self.online = False
-                r = False
-            logger.debug('pushedChanges %s %s', r, self.user_id)
-
     def peering(self, action):
         with db.session():
             u = user.models.User.get_or_create(self.user_id)