From 971a6733a9ec81bbdb5616875d29d85e5d270e68 Mon Sep 17 00:00:00 2001 From: Mark Veidemanis Date: Fri, 4 Mar 2022 22:17:17 +0000 Subject: [PATCH] Remove debugging code and loop constructor --- handler/tests/test_transactions.py | 2 +- handler/util.py | 22 ---------------------- 2 files changed, 1 insertion(+), 23 deletions(-) diff --git a/handler/tests/test_transactions.py b/handler/tests/test_transactions.py index eed6dbd..6774388 100644 --- a/handler/tests/test_transactions.py +++ b/handler/tests/test_transactions.py @@ -114,7 +114,7 @@ class TestTransactions(TestCase): return trade def mock_hmset(self, string, data): - print("HMSET", string, data) + pass def mock_keys(self, string): return [v["id"] for k, v in self.trades.items() if k in self.return_trades] diff --git a/handler/util.py b/handler/util.py index 56f132f..f5a9a91 100644 --- a/handler/util.py +++ b/handler/util.py @@ -1,7 +1,5 @@ # Twisted/Klein imports from twisted.logger import Logger -from twisted.internet import reactor -from twisted.internet.task import LoopingCall, deferLater # Other library imports from httpx import ReadTimeout, ReadError, RemoteProtocolError @@ -25,26 +23,6 @@ def xmerge_attrs(init_map): setattr(object_instance, classname_inside, object_instance_inside) -def setup_call_loops(token_setting, function_init, function_continuous, delay, function_post_start=None): - """ - Setup the loops for dealing with access, refresh and auth tokens for various providers. - :param token_setting: the setting for whether to do the initial authentication - :param function_init: the initial authentication function - :param function_continuous: the ongoing authentication function (refresh_token -> access_token) - :param delay: time in seconds to wait between calls to function_continuous - :param function_post_start: an optional function to run after the access token is obtained - """ - if token_setting == "1": - deferLater(reactor, 1, function_init) - else: - deferLater(reactor, 1, function_continuous, True) - if function_post_start: - deferLater(reactor, 4, function_post_start) - - lc = LoopingCall(function_continuous) - lc.start(delay) - - def convert(data): """ Recursively convert a dictionary.