From 80cebd851409d0e19e6ea3ef76b99c2aa90bf4e4 Mon Sep 17 00:00:00 2001 From: Jonathan Zernik Date: Sun, 24 Oct 2021 18:35:00 -0500 Subject: [PATCH] Rename db query properties to remove negations (#1719) --- squeaknode/db/squeak_db.py | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/squeaknode/db/squeak_db.py b/squeaknode/db/squeak_db.py index 8e7ef513..cf8d6c11 100644 --- a/squeaknode/db/squeak_db.py +++ b/squeaknode/db/squeak_db.py @@ -167,8 +167,8 @@ class SqueakDb: return self.timestamp_now_ms / 1000 >= expire_time_s @property - def received_offer_is_not_paid(self): - return self.received_offers.c.paid == False # noqa: E711 + def received_offer_is_paid(self): + return self.received_offers.c.paid == True # noqa: E711 # @property # def received_offer_is_not_expired(self): @@ -187,16 +187,16 @@ class SqueakDb: return self.timestamp_now_ms / 1000 >= expire_time @property - def sent_offer_is_not_paid(self): - return self.sent_offers.c.paid == False # noqa: E711 + def sent_offer_is_paid(self): + return self.sent_offers.c.paid == True # noqa: E711 @property - def sent_offer_is_not_expired(self): + def sent_offer_is_expired(self): expire_time = ( self.sent_offers.c.invoice_timestamp + self.sent_offers.c.invoice_expiry ) - return self.timestamp_now_ms / 1000 < expire_time + return self.timestamp_now_ms / 1000 >= expire_time def insert_squeak(self, squeak: CSqueak, block_header: CBlockHeader) -> Optional[bytes]: """ Insert a new squeak. @@ -1006,7 +1006,7 @@ class SqueakDb: s = ( select([self.received_offers]) .where(self.received_offers.c.squeak_hash == squeak_hash) - .where(self.received_offer_is_not_paid) + .where(not_(self.received_offer_is_paid)) .where(not_(self.received_offer_invoice_is_expired)) ) with self.get_connection() as connection: @@ -1224,8 +1224,8 @@ class SqueakDb: .where(self.sent_offers.c.squeak_hash == squeak_hash) .where(self.sent_offers.c.peer_network == peer_address.network.name) .where(self.sent_offers.c.peer_host == peer_address.host) - .where(self.sent_offer_is_not_paid) - .where(self.sent_offer_is_not_expired) + .where(not_(self.sent_offer_is_paid)) + .where(not_(self.sent_offer_is_expired)) ) with self.get_connection() as connection: result = connection.execute(s)