From f35182497da93178911697c0fd6dbf4138490ad6 Mon Sep 17 00:00:00 2001
From: Jonathan Zernik <yzernik@gmail.com>
Date: Fri, 12 Feb 2021 01:02:49 -0800
Subject: [PATCH] Rename process received payments worker (#819)

---
 ...offers_worker.py => process_received_payments_worker.py} | 6 +++---
 squeaknode/node/squeak_node.py                              | 4 ++--
 2 files changed, 5 insertions(+), 5 deletions(-)
 rename squeaknode/node/{sent_offers_worker.py => process_received_payments_worker.py} (77%)

diff --git a/squeaknode/node/sent_offers_worker.py b/squeaknode/node/process_received_payments_worker.py
similarity index 77%
rename from squeaknode/node/sent_offers_worker.py
rename to squeaknode/node/process_received_payments_worker.py
index 4c10b092..e848c6e2 100644
--- a/squeaknode/node/sent_offers_worker.py
+++ b/squeaknode/node/process_received_payments_worker.py
@@ -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)
diff --git a/squeaknode/node/squeak_node.py b/squeaknode/node/squeak_node.py
index cde6b364..4a7a7b01 100644
--- a/squeaknode/node/squeak_node.py
+++ b/squeaknode/node/squeak_node.py
@@ -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,
         )