GlcoinCore/squeaknode
1
0
Fork 0
mirror of https://github.com/yzernik/squeaknode.git synced 2026-08-19 13:18:26 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Rename process received payments worker (#819)

Browse source
This commit is contained in:
Jonathan Zernik 2021-02-12 01:02:49 -08:00 • committed by GitHub
parent bee8ced886
commit f35182497d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

6
squeaknode/node/sent_offers_worker.py → squeaknode/node/process_received_payments_worker.py
View file

@ -4,7 +4,7 @@ import threading
logger = logging.getLogger(__name__)
class SentOffersWorker:
class ProcessReceivedPaymentsWorker:
def __init__(self, payment_processor, stopped: threading.Event):
self.payment_processor = payment_processor
self.stopped = stopped
@ -16,8 +16,8 @@ class SentOffersWorker:
).start()
def process_subscribed_invoices(self):
logger.info("Starting SentOffersWorker...")
logger.info("Starting ProcessReceivedPaymentsWorker...")
self.payment_processor.start_processing()
self.stopped.wait()
logger.info("Stopping SentOffersWorker...")
logger.info("Stopping ProcessReceivedPaymentsWorker...")
self.payment_processor.stop_processing(permanent=True)

4
squeaknode/node/squeak_node.py
View file

@ -16,10 +16,10 @@ from squeaknode.db.db_engine import get_sqlite_connection_string
from squeaknode.db.squeak_db import SqueakDb
from squeaknode.lightning.lnd_lightning_client import LNDLightningClient
from squeaknode.node.payment_processor import PaymentProcessor
from squeaknode.node.process_received_payments_worker import ProcessReceivedPaymentsWorker
from squeaknode.node.received_payments_subscription_client import (
OpenReceivedPaymentsSubscriptionClient,
)
from squeaknode.node.sent_offers_worker import SentOffersWorker
from squeaknode.node.squeak_offer_expiry_worker import SqueakOfferExpiryWorker
from squeaknode.node.squeak_peer_sync_worker import SqueakPeerSyncWorker
from squeaknode.node.squeak_rate_limiter import SqueakRateLimiter
@ -94,7 +94,7 @@ class SqueakNode:
self.squeak_offer_expiry_worker = SqueakOfferExpiryWorker(
squeak_controller,
)
self.sent_offers_worker = SentOffersWorker(
self.sent_offers_worker = ProcessReceivedPaymentsWorker(
payment_processor, self.stopped,
)