open.source/magic-wormhole
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Channel.add_message(server_rx=): add new arg

Browse Source
This commit is contained in:
Brian Warner 2016-05-05 18:32:04 -07:00
parent fe2dfc1a35
commit d9ba55621b
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/wormhole/server/rendezvous.py
View File

@ -54,25 +54,25 @@ class Channel:
for ep in self._listeners:
ep.send_rendezvous_event({"phase": phase, "body": body})
def _add_message(self, side, phase, body):
def _add_message(self, side, phase, body, server_rx):
db = self._db
db.execute("INSERT INTO `messages`"
" (`appid`, `channelid`, `side`, `phase`, `body`, `server_rx`)"
" VALUES (?,?,?,?, ?,?)",
(self._appid, self._channelid, side, phase,
body, time.time()))
body, server_rx))
db.commit()
def allocate(self, side):
self._add_message(side, ALLOCATE, None)
self._add_message(side, ALLOCATE, None, time.time())
def add_message(self, side, phase, body):
self._add_message(side, phase, body)
def add_message(self, side, phase, body, server_rx):
self._add_message(side, phase, body, server_rx)
self.broadcast_message(phase, body)
return self.get_messages() # for rendezvous_web.py POST /add
def deallocate(self, side, mood):
self._add_message(side, DEALLOCATE, mood)
self._add_message(side, DEALLOCATE, mood, time.time())
db = self._db
seen = set([row["side"] for row in
db.execute("SELECT `side` FROM `messages`"

2
src/wormhole/server/rendezvous_web.py
View File

@ -132,7 +132,7 @@ class Adder(RelayResource):
app = self._rendezvous.get_app(appid)
channel = app.get_channel(channelid)
messages = channel.add_message(side, phase, body)
messages = channel.add_message(side, phase, body, time.time())
response = {"welcome": self._welcome, "messages": messages,
"sent": time.time()}
return json_response(request, response)

2
src/wormhole/server/rendezvous_websocket.py
View File

@ -152,7 +152,7 @@ class WebSocketRendezvous(websocket.WebSocketServerProtocol):
raise Error("missing 'phase'")
if "body" not in msg:
raise Error("missing 'body'")
channel.add_message(self._side, msg["phase"], msg["body"])
channel.add_message(self._side, msg["phase"], msg["body"], time.time())
def handle_deallocate(self, channel, msg):
deleted = channel.deallocate(self._side, msg.get("mood"))