fix inital peering
This commit is contained in:
parent
3cde05b9ba
commit
ea9de0f311
1 changed files with 3 additions and 3 deletions
|
@ -78,10 +78,10 @@ class NodeServer(ThreadingMixIn, TLSTCPServer):
|
||||||
def api_call(action, user_id, args):
|
def api_call(action, user_id, args):
|
||||||
with db.session():
|
with db.session():
|
||||||
u = user.models.User.get(user_id)
|
u = user.models.User.get(user_id)
|
||||||
if action in ('pullChanges', ) and not u.peered and u.pending == 'sent':
|
if u and action in ('pullChanges', ) and not u.peered and u.pending == 'sent':
|
||||||
u.update_peering(True)
|
u.update_peering(True)
|
||||||
state.nodes.queue('add', user.id, True)
|
state.nodes.queue('add', u.id, True)
|
||||||
trigger_event('peering.accept', user.json())
|
trigger_event('peering.accept', u.json())
|
||||||
if action in (
|
if action in (
|
||||||
'requestPeering', 'acceptPeering', 'rejectPeering',
|
'requestPeering', 'acceptPeering', 'rejectPeering',
|
||||||
'removePeering', 'cancelPeering'
|
'removePeering', 'cancelPeering'
|
||||||
|
|
Loading…
Reference in a new issue