ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2024-12-19 04:57:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Force a log event so the test completes.

Browse Source
This commit is contained in:
Jean-Paul Calderone 2019-03-24 13:28:08 -04:00
parent c2b8024856
commit 670182c32a
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
integration/test_streaming_logs.py
View File

@ -5,6 +5,8 @@ from __future__ import (
division,
)
import json
from os.path import (
join,
)
@ -21,6 +23,8 @@ from twisted.internet.endpoints import (
HostnameEndpoint,
)
import treq
from autobahn.twisted.websocket import (
WebSocketClientFactory,
WebSocketClientProtocol,
@ -123,12 +127,17 @@ def _test_streaming_logs(reactor, temp_dir, alice):
print("Connecting to {}".format(log_url))
client = yield _connect_client(reactor, api_auth_token, log_url)
print("Connected.")
client.on_close = Deferred()
client.on_message = Deferred()
# Provoke _some_ log event.
yield treq.get(node_url)
result = yield _race(client.on_close, client.on_message)
assert result == Right("some payload")
assert isinstance(result, Right)
json.loads(result.value)
@pytest_twisted.inlineCallbacks