aiolabs/lnbits
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions 1

refactor splitpayments with tags

Browse source
This commit is contained in:
Tiago Vasconcelos 2023-01-05 12:20:31 +00:00
parent 4ae88ad3b9
commit 7a7bd93639
1 changed files with 25 additions and 37 deletions
Download patch file Download diff file Expand all files Collapse all files

62
lnbits/extensions/splitpayments/tasks.py
View file

@ -45,46 +45,34 @@ async def on_invoice_paid(payment: Payment) -> None:
amount_to_split = int(payment.extra.get("amount") * 1000) amount_to_split = int(payment.extra.get("amount") * 1000)
for target in targets: for target in targets:
amount = int(payment.amount * target.percent / 100) # msats if target.percent > 0:
tagged = target.tag in payment.extra
payment_hash, payment_request = await create_invoice( amount = int(payment.amount * target.percent / 100) # msats
wallet_id=target.wallet, memo = (
amount=int(amount / 1000), # sats f"split payment: {target.percent}% for {target.alias or target.wallet}"
internal=True, )
memo=f"split payment: {target.percent}% for {target.alias or target.wallet}", if tagged:
) memo = f"Pushed tagged payment to {target.alias}"
logger.debug(f"created split invoice: {payment_hash}") payment_hash, payment_request = await create_invoice(
wallet_id=target.wallet,
amount=int(amount / 1000), # sats
internal=True,
memo=memo,
)
extra = {**payment.extra, "splitted": True} logger.debug(f"created split invoice: {payment_hash}")
if not extra.get("tag"):
extra["tag"] = "splitpayments"
checking_id = await pay_invoice( extra = {**payment.extra, "splitted": True}
payment_request=payment_request, if not extra.get("tag"):
wallet_id=payment.wallet_id, extra["tag"] = "splitpayments"
extra={**payment.extra, "splitted": True},
) checking_id = await pay_invoice(
logger.debug(f"paid split invoice: {checking_id}") payment_request=payment_request,
wallet_id=payment.wallet_id,
extra={**extra},
)
logger.debug(f"paid split invoice: {checking_id}")
logger.debug(f"performing split to {len(targets)} targets") logger.debug(f"performing split to {len(targets)} targets")
if tagged == False:
for target in targets:
if target.percent > 0:
amount = int(payment.amount * target.percent / 100) # msats
payment_hash, payment_request = await create_invoice(
wallet_id=target.wallet,
amount=int(amount / 1000), # sats
internal=True,
memo=f"split payment: {target.percent}% for {target.alias or target.wallet}",
extra={"tag": "splitpayments"},
)
logger.debug(f"created split invoice: {payment_hash}")
checking_id = await pay_invoice(
payment_request=payment_request,
wallet_id=payment.wallet_id,
extra={"tag": "splitpayments"},
)
logger.debug(f"paid split invoice: {checking_id}")