Skip to content

Commit

Permalink
switch default to websockets impl
Browse files Browse the repository at this point in the history
  • Loading branch information
narodnik committed Jan 9, 2017
1 parent 8c8133d commit ca86499
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 9 deletions.
6 changes: 3 additions & 3 deletions darkwallet-daemon.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,10 @@ def main():
settings.load()

# Start the darkwallet-daemon
if settings.use_ws_impl:
darkwallet.start_ws(settings)
else:
if settings.use_tornado_impl:
darkwallet.start(settings)
else:
darkwallet.start_ws(settings)
return 0

if __name__ == "__main__":
Expand Down
6 changes: 3 additions & 3 deletions darkwallet/settings.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,13 +24,13 @@ def _parse(self):
parser.add_argument("--port", "-p", dest="port",
help="Run on the given port.",
default=None)
parser.add_argument("--ws", "-w", dest="use_ws_impl",
parser.add_argument("--tornado", "-t", dest="use_tornado",
action="store_const", const=True, default=False,
help="Use the websocket implementation instead.")
help="Use the Tornado implementation instead.")
return parser.parse_args()

def _load(self, args):
self.use_ws_impl = args.use_ws_impl
self.use_tornado_impl = args.use_tornado

self.config_path = args.config
darkwallet.util.make_sure_dir_exists(self.config_path)
Expand Down
7 changes: 4 additions & 3 deletions darkwallet/wallet.py
Original file line number Diff line number Diff line change
Expand Up @@ -582,10 +582,11 @@ def _connect(self):
url = self._settings.url
if self._model.is_testnet:
url = self._settings.testnet_url
if self._settings.use_ws_impl:
self.client = Client(self._context, url, client_settings)
else:
# Tornado implementation.
if self._settings.use_tornado_impl:
self.client = FakeAsyncClient(self._context, url, client_settings)
else:
self.client = Client(self._context, url, client_settings)
print("Connected to %s" % url)

async def _check_updates(self):
Expand Down

0 comments on commit ca86499

Please sign in to comment.