From 02d479b92dbb62ed51b2cf357536f75ea50fe3f9 Mon Sep 17 00:00:00 2001
From: Jack Robison <jackrobison@lbry.io>
Date: Fri, 2 Jul 2021 17:03:51 -0400
Subject: [PATCH] fix mismatch in claim_to_txo<->txo_to_claim

---
 lbry/wallet/server/block_processor.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lbry/wallet/server/block_processor.py b/lbry/wallet/server/block_processor.py
index 155322a92..c092fc320 100644
--- a/lbry/wallet/server/block_processor.py
+++ b/lbry/wallet/server/block_processor.py
@@ -258,6 +258,7 @@ class BlockProcessor:
 
         self.pending_channels = {}
         self.amount_cache = {}
+        self.expired_claim_hashes: Set[bytes] = set()
 
     def claim_producer(self):
         if self.db.db_height <= 1:
@@ -669,7 +670,7 @@ class BlockProcessor:
 
         if staged.name.startswith('@'):  # abandon a channel, invalidate signatures
             for k, claim_hash in self.db.db.iterator(prefix=Prefixes.channel_to_claim.pack_partial_key(staged.claim_hash)):
-                if claim_hash in self.abandoned_claims:
+                if claim_hash in self.abandoned_claims or claim_hash in self.expired_claim_hashes:
                     continue
                 self.signatures_changed.add(claim_hash)
                 if claim_hash in self.claim_hash_to_txo:
@@ -702,6 +703,7 @@ class BlockProcessor:
 
     def _expire_claims(self, height: int):
         expired = self.db.get_expired_by_height(height)
+        self.expired_claim_hashes.update(set(expired.keys()))
         spent_claims = {}
         ops = []
         for expired_claim_hash, (tx_num, position, name, txi) in expired.items():
@@ -1291,6 +1293,7 @@ class BlockProcessor:
         self.pending_channels.clear()
         self.amount_cache.clear()
         self.signatures_changed.clear()
+        self.expired_claim_hashes.clear()
 
         # for cache in self.search_cache.values():
         #     cache.clear()