3 Commits

Author SHA1 Message Date
tecnovert
a04ce28ca2 Merge pull request #420 from tecnovert/tests
tests: add "fetchpricesthread" setting
2026-01-19 09:12:18 +00:00
tecnovert
52da86bc86 fix countEvents 2026-01-19 11:07:27 +02:00
tecnovert
1d5778a72c tests: add "fetchpricesthread" setting 2026-01-19 10:09:05 +02:00
2 changed files with 20 additions and 13 deletions

View File

@@ -1280,12 +1280,17 @@ class BasicSwap(BaseApp, BSXNetwork, UIApp):
else:
self.log.info("AMM autostart is disabled")
self._price_fetch_running = True
self._price_fetch_thread = threading.Thread(
target=self._backgroundPriceFetchLoop, daemon=True
if self.settings.get("fetchpricesthread", True):
self._price_fetch_running = True
self._price_fetch_thread = threading.Thread(
target=self._backgroundPriceFetchLoop, daemon=True
)
self._price_fetch_thread.start()
self.log.info(
"Background price fetching {}".format(
"started" if self._price_fetch_running else "is disabled"
)
)
self._price_fetch_thread.start()
self.log.info("Background price fetching started")
if "htmlhost" in self.settings:
self.log.info(
@@ -3271,7 +3276,9 @@ class BasicSwap(BaseApp, BSXNetwork, UIApp):
self.log.debug(f"logBidEvent {self.log.id(bid_id)} {event_type}")
self.logEvent(Concepts.BID, bid_id, event_type, event_msg, cursor)
def countEvents(self, linked_type: int, linked_id: bytes, event_type: int, cursor):
def countEvents(
self, linked_type: int, linked_id: bytes, event_type: int, cursor
) -> int:
q = cursor.execute(
"SELECT COUNT(*) FROM eventlog WHERE linked_type = :linked_type AND linked_id = :linked_id AND event_type = :event_type",
{
@@ -3282,8 +3289,8 @@ class BasicSwap(BaseApp, BSXNetwork, UIApp):
).fetchone()
return q[0]
def countBidEvents(self, bid, event_type: int, cursor):
return self.countEvents(int(Concepts.BID), bid.bid_id, int(event_type))
def countBidEvents(self, bid, event_type: int, cursor) -> int:
return self.countEvents(int(Concepts.BID), bid.bid_id, int(event_type), cursor)
def getEvents(self, linked_type: int, linked_id: bytes):
events = []

View File

@@ -2,7 +2,7 @@
# -*- coding: utf-8 -*-
# Copyright (c) 2021-2024 tecnovert
# Copyright (c) 2024-2025 The Basicswap developers
# Copyright (c) 2024-2026 The Basicswap developers
# Distributed under the MIT software license, see the accompanying
# file LICENSE or http://www.opensource.org/licenses/mit-license.php.
@@ -921,10 +921,10 @@ class BasicSwapTest(TestFunctions):
@classmethod
def setUpClass(cls):
super(BasicSwapTest, cls).setUpClass()
if False:
for client in cls.swap_clients:
client.log.safe_logs = True
client.log.safe_logs_prefix = b"tests"
@classmethod
def addCoinSettings(cls, settings, datadir, node_id):
settings["fetchpricesthread"] = False
def test_001_nested_segwit(self):
# p2sh-p2wpkh