tagged working
This commit is contained in:
parent
c91b5031bf
commit
5f53eb8e4e
4 changed files with 67 additions and 31 deletions
|
|
@ -16,7 +16,7 @@ class TargetPutList(BaseModel):
|
||||||
wallet: str = Query(...)
|
wallet: str = Query(...)
|
||||||
alias: str = Query("")
|
alias: str = Query("")
|
||||||
percent: float = Query(..., ge=0, lt=100)
|
percent: float = Query(..., ge=0, lt=100)
|
||||||
tag: str = Query("")
|
tag: str
|
||||||
|
|
||||||
|
|
||||||
class TargetPut(BaseModel):
|
class TargetPut(BaseModel):
|
||||||
|
|
|
||||||
|
|
@ -39,6 +39,15 @@ new Vue({
|
||||||
timeout: 500
|
timeout: 500
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
|
clearTarget(index) {
|
||||||
|
this.targets.splice(index, 1)
|
||||||
|
console.log(this.targets)
|
||||||
|
this.$q.notify({
|
||||||
|
message:
|
||||||
|
'Removed item. You must click to save manually.',
|
||||||
|
timeout: 500
|
||||||
|
})
|
||||||
|
},
|
||||||
getTargets() {
|
getTargets() {
|
||||||
LNbits.api
|
LNbits.api
|
||||||
.request(
|
.request(
|
||||||
|
|
@ -53,7 +62,16 @@ new Vue({
|
||||||
this.currentHash = hashTargets(response.data)
|
this.currentHash = hashTargets(response.data)
|
||||||
this.targets = response.data.concat({})
|
this.targets = response.data.concat({})
|
||||||
for (let i = 0; i < this.targets.length; i++) {
|
for (let i = 0; i < this.targets.length; i++) {
|
||||||
if(this.targets[i].tag !=
|
if(this.targets[i].tag.length > 0){
|
||||||
|
this.targets[i].method = "tag"
|
||||||
|
}
|
||||||
|
else if (this.targets[i].percent.length > 0){
|
||||||
|
this.targets[i].method = "split"
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
this.targets[i].method = ""
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
},
|
},
|
||||||
|
|
@ -64,17 +82,19 @@ new Vue({
|
||||||
clearChanged(index) {
|
clearChanged(index) {
|
||||||
if(this.targets[index].method == 'split'){
|
if(this.targets[index].method == 'split'){
|
||||||
this.targets[index].tag = null
|
this.targets[index].tag = null
|
||||||
|
this.targets[index].method = 'split'
|
||||||
}
|
}
|
||||||
else{
|
else{
|
||||||
this.targets[index].percent = null
|
this.targets[index].percent = null
|
||||||
|
this.targets[index].method = 'tag'
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
targetChanged(index) {
|
targetChanged(index) {
|
||||||
// fix percent min and max range
|
// fix percent min and max range
|
||||||
console.log(this.targets)
|
|
||||||
if (this.targets[index].percent) {
|
if (this.targets[index].percent) {
|
||||||
if (this.targets[index].percent > 100) this.targets[index].percent = 100
|
if (this.targets[index].percent > 100) this.targets[index].percent = 100
|
||||||
if (this.targets[index].percent < 0) this.targets[index].percent = 0
|
if (this.targets[index].percent < 0) this.targets[index].percent = 0
|
||||||
|
this.targets[index].tag = ""
|
||||||
}
|
}
|
||||||
|
|
||||||
// not percentage
|
// not percentage
|
||||||
|
|
@ -128,15 +148,12 @@ new Vue({
|
||||||
if (t !== index) target.percent -= +(diff * target.percent).toFixed(2)
|
if (t !== index) target.percent -= +(diff * target.percent).toFixed(2)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
// overwrite so changes appear
|
// overwrite so changes appear
|
||||||
this.targets = this.targets
|
this.targets = this.targets
|
||||||
console.log(this.targets)
|
|
||||||
},
|
},
|
||||||
saveTargets() {
|
saveTargets() {
|
||||||
console.log(this.targets)
|
|
||||||
for (let i = 0; i < this.targets.length; i++) {
|
for (let i = 0; i < this.targets.length; i++) {
|
||||||
if (this.targets[i].tag){
|
if (this.targets[i].tag != ''){
|
||||||
this.targets[i].percent = 0
|
this.targets[i].percent = 0
|
||||||
}
|
}
|
||||||
else{
|
else{
|
||||||
|
|
|
||||||
|
|
@ -25,7 +25,7 @@ async def on_invoice_paid(payment: Payment) -> None:
|
||||||
return
|
return
|
||||||
|
|
||||||
targets = await get_targets(payment.wallet_id)
|
targets = await get_targets(payment.wallet_id)
|
||||||
|
logger.debug(targets)
|
||||||
if not targets:
|
if not targets:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
|
@ -35,28 +35,46 @@ async def on_invoice_paid(payment: Payment) -> None:
|
||||||
logger.error("splitpayment failure: total percent adds up to more than 100%")
|
logger.error("splitpayment failure: total percent adds up to more than 100%")
|
||||||
return
|
return
|
||||||
|
|
||||||
logger.debug(f"performing split payments to {len(targets)} targets")
|
logger.debug(f"checking if tagged for {len(targets)} targets")
|
||||||
|
tagged = False
|
||||||
for target in targets:
|
for target in targets:
|
||||||
|
if payment.extra.get("tag") == target.tag:
|
||||||
|
tagged = True
|
||||||
|
payment_hash, payment_request = await create_invoice(
|
||||||
|
wallet_id=target.wallet,
|
||||||
|
amount=int(payment.amount / 1000), # sats
|
||||||
|
internal=True,
|
||||||
|
memo=f"Pushed tagged payment to {target.alias}",
|
||||||
|
extra={"tag": "splitpayments"},
|
||||||
|
)
|
||||||
|
logger.debug(f"created split invoice: {payment_hash}")
|
||||||
|
|
||||||
if target.tag and payment.extra.get("tag") == target.tag:
|
checking_id = await pay_invoice(
|
||||||
amount = int(payment.amount)
|
payment_request=payment_request,
|
||||||
elif target.percent:
|
wallet_id=payment.wallet_id,
|
||||||
|
extra={"tag": "splitpayments"},
|
||||||
|
)
|
||||||
|
logger.debug(f"paid split invoice: {checking_id}")
|
||||||
|
|
||||||
|
logger.debug(f"performing split to {len(targets)} targets")
|
||||||
|
logger.debug("pitbull")
|
||||||
|
if tagged == False:
|
||||||
|
for target in targets:
|
||||||
amount = int(payment.amount * target.percent / 100) # msats
|
amount = int(payment.amount * target.percent / 100) # msats
|
||||||
else:
|
payment_hash, payment_request = await create_invoice(
|
||||||
return
|
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}")
|
||||||
|
|
||||||
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}")
|
|
||||||
|
|
|
||||||
|
|
@ -67,7 +67,7 @@
|
||||||
></q-toggle>
|
></q-toggle>
|
||||||
|
|
||||||
<q-input
|
<q-input
|
||||||
v-if="target.method == 'tag' || target.tag != ''"
|
v-if="target.method == 'tag'"
|
||||||
style="width: 150px"
|
style="width: 150px"
|
||||||
dense
|
dense
|
||||||
outlined
|
outlined
|
||||||
|
|
@ -97,6 +97,7 @@
|
||||||
>
|
>
|
||||||
<q-tooltip>Add more</q-tooltip>
|
<q-tooltip>Add more</q-tooltip>
|
||||||
</q-btn>
|
</q-btn>
|
||||||
|
<q-btn v-if="t < targets.length - 1" @click="clearTarget(t)" round color="red" size="5px" icon="close"></q-btn>
|
||||||
</div>
|
</div>
|
||||||
<div class="row justify-evenly q-pa-lg">
|
<div class="row justify-evenly q-pa-lg">
|
||||||
<div>
|
<div>
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue