Ecosystem/basicswap
1
0
Fork 0
mirror of https://github.com/basicswap/basicswap.git synced 2025-01-03 17:29:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Set state for expired sent reverse bids.

Browse source
This commit is contained in:
tecnovert 2024-11-26 19:36:58 +02:00
parent 08df0ceae0
commit eefaab1752
No known key found for this signature in database
GPG key ID: 8ED6D8750C4E3F93
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
basicswap/basicswap.py
View file

@ -9649,7 +9649,7 @@ class BasicSwap(BaseApp):
cursor = self.openDB() cursor = self.openDB()
if check_records: if check_records:
query = """SELECT 1, bid_id, expire_at FROM bids WHERE active_ind = 1 AND state IN (:bid_received, :bid_sent, :bid_aad, :bid_aaf) AND expire_at <= :check_time query = """SELECT 1, bid_id, expire_at FROM bids WHERE active_ind = 1 AND state IN (:bid_received, :bid_sent, :bid_aad, :bid_aaf, :bid_req_sent) AND expire_at <= :check_time
UNION ALL UNION ALL
SELECT 2, offer_id, expire_at FROM offers WHERE active_ind = 1 AND state IN (:offer_received, :offer_sent) AND expire_at <= :check_time SELECT 2, offer_id, expire_at FROM offers WHERE active_ind = 1 AND state IN (:offer_received, :offer_sent) AND expire_at <= :check_time
""" """
@ -9663,6 +9663,7 @@ class BasicSwap(BaseApp):
"bid_received": int(BidStates.BID_RECEIVED), "bid_received": int(BidStates.BID_RECEIVED),
"bid_aad": int(BidStates.BID_AACCEPT_DELAY), "bid_aad": int(BidStates.BID_AACCEPT_DELAY),
"bid_aaf": int(BidStates.BID_AACCEPT_FAIL), "bid_aaf": int(BidStates.BID_AACCEPT_FAIL),
"bid_req_sent": int(BidStates.BID_REQUEST_SENT),
}, },
) )
for entry in q: for entry in q:
@ -9680,7 +9681,7 @@ class BasicSwap(BaseApp):
offers_to_expire.add(record_id) offers_to_expire.add(record_id)
for bid_id in bids_to_expire: for bid_id in bids_to_expire:
query = "SELECT expire_at, states FROM bids WHERE bid_id = :bid_id AND active_ind = 1 AND state IN (:bid_received, :bid_sent, :bid_aad, :bid_aaf)" query = "SELECT expire_at, states FROM bids WHERE bid_id = :bid_id AND active_ind = 1 AND state IN (:bid_received, :bid_sent, :bid_aad, :bid_aaf, :bid_req_sent)"
rows = cursor.execute( rows = cursor.execute(
query, query,
{ {
@ -9689,6 +9690,7 @@ class BasicSwap(BaseApp):
"bid_sent": int(BidStates.BID_SENT), "bid_sent": int(BidStates.BID_SENT),
"bid_aad": int(BidStates.BID_AACCEPT_DELAY), "bid_aad": int(BidStates.BID_AACCEPT_DELAY),
"bid_aaf": int(BidStates.BID_AACCEPT_FAIL), "bid_aaf": int(BidStates.BID_AACCEPT_FAIL),
"bid_req_sent": int(BidStates.BID_REQUEST_SENT),
}, },
).fetchall() ).fetchall()
if len(rows) > 0: if len(rows) > 0: