forked from LBRYCommunity/lbry-sdk
missing channel_to_claim delete
This commit is contained in:
parent
7f743ff3f1
commit
69651453dd
1 changed files with 11 additions and 4 deletions
|
@ -691,11 +691,18 @@ class BlockProcessor:
|
||||||
)
|
)
|
||||||
])
|
])
|
||||||
if staged.signing_hash and claim_from_db:
|
if staged.signing_hash and claim_from_db:
|
||||||
self.db_op_stack.append(RevertableDelete(
|
self.db_op_stack.extend([
|
||||||
|
RevertableDelete(
|
||||||
|
*Prefixes.channel_to_claim.pack_item(
|
||||||
|
staged.signing_hash, staged.name, staged.tx_num, staged.position, staged.claim_hash
|
||||||
|
)
|
||||||
|
),
|
||||||
|
RevertableDelete(
|
||||||
*Prefixes.claim_to_channel.pack_item(
|
*Prefixes.claim_to_channel.pack_item(
|
||||||
staged.claim_hash, staged.tx_num, staged.position, staged.signing_hash
|
staged.claim_hash, staged.tx_num, staged.position, staged.signing_hash
|
||||||
)
|
)
|
||||||
))
|
)
|
||||||
|
])
|
||||||
|
|
||||||
def _expire_claims(self, height: int):
|
def _expire_claims(self, height: int):
|
||||||
expired = self.db.get_expired_by_height(height)
|
expired = self.db.get_expired_by_height(height)
|
||||||
|
|
Loading…
Reference in a new issue