From c7e316ab22546d5535731027cdc3ad209b22ad8b Mon Sep 17 00:00:00 2001
From: j <j@mailb.org>
Date: Sat, 2 Feb 2019 14:29:12 +0530
Subject: [PATCH] select for update

---
 oml/user/api.py | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/oml/user/api.py b/oml/user/api.py
index f63b8a0..b3aff56 100644
--- a/oml/user/api.py
+++ b/oml/user/api.py
@@ -474,10 +474,11 @@ def removePeering(data):
     if len(data.get('id', '')) not in (16, 43):
         logger.debug('invalid user id')
         return {}
-    u = models.User.get_or_create(data['id'])
-    u.info['message'] = data.get('message', '')
-    u.update_peering(False)
-    state.nodes.peer_queue(u.id, 'peering', 'removePeering')
+    u = models.User.get(data['id'], for_udpate=True)
+    if u:
+        u.info['message'] = data.get('message', '')
+        u.update_peering(False)
+        state.nodes.peer_queue(u.id, 'peering', 'removePeering')
     return {}
 actions.register(removePeering, cache=False)