fixed update
This commit is contained in:
parent
dd1dea90c1
commit
532cd08698
4 changed files with 14 additions and 7 deletions
4
crud.py
4
crud.py
|
|
@ -34,9 +34,9 @@ async def get_myextensions(wallet_ids: Union[str, List[str]]) -> List[MyExtensio
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
async def update_myextension(data: MyExtension) -> MyExtension:
|
async def update_myextension(data: CreateMyExtensionData) -> MyExtension:
|
||||||
await db.update("myextension.maintable", data)
|
await db.update("myextension.maintable", data)
|
||||||
return data
|
return MyExtension(**data.dict())
|
||||||
|
|
||||||
|
|
||||||
async def delete_myextension(myextension_id: str) -> None:
|
async def delete_myextension(myextension_id: str) -> None:
|
||||||
|
|
|
||||||
|
|
@ -108,6 +108,7 @@ window.app = Vue.createApp({
|
||||||
},
|
},
|
||||||
|
|
||||||
async updateMyExtension(wallet, data) {
|
async updateMyExtension(wallet, data) {
|
||||||
|
data.wallet = wallet.id
|
||||||
await LNbits.api
|
await LNbits.api
|
||||||
.request(
|
.request(
|
||||||
'PUT',
|
'PUT',
|
||||||
|
|
@ -126,6 +127,9 @@ window.app = Vue.createApp({
|
||||||
},
|
},
|
||||||
async deleteMyExtension(tempId) {
|
async deleteMyExtension(tempId) {
|
||||||
var myextension = _.findWhere(this.myex, {id: tempId})
|
var myextension = _.findWhere(this.myex, {id: tempId})
|
||||||
|
const wallet = _.findWhere(this.g.user.wallets, {
|
||||||
|
id: myextension.wallet
|
||||||
|
})
|
||||||
await LNbits.utils
|
await LNbits.utils
|
||||||
.confirmDialog('Are you sure you want to delete this MyExtension?')
|
.confirmDialog('Are you sure you want to delete this MyExtension?')
|
||||||
.onOk(function () {
|
.onOk(function () {
|
||||||
|
|
@ -133,11 +137,12 @@ window.app = Vue.createApp({
|
||||||
.request(
|
.request(
|
||||||
'DELETE',
|
'DELETE',
|
||||||
'/myextension/api/v1/myex/' + tempId,
|
'/myextension/api/v1/myex/' + tempId,
|
||||||
_.findWhere(this.g.user.wallets, {id: myextension.wallet})
|
wallet.adminkey
|
||||||
.adminkey
|
|
||||||
)
|
)
|
||||||
.then(() => {
|
.then(() => {
|
||||||
this.myex = _.reject(this.myex, obj => obj.id == tempId)
|
this.myex = _.reject(this.myex, function (obj) {
|
||||||
|
return obj.id === myextension.id
|
||||||
|
})
|
||||||
})
|
})
|
||||||
.catch(error => {
|
.catch(error => {
|
||||||
LNbits.utils.notifyApiError(error)
|
LNbits.utils.notifyApiError(error)
|
||||||
|
|
|
||||||
3
tasks.py
3
tasks.py
|
|
@ -5,6 +5,7 @@ from lnbits.core.services import websocket_updater
|
||||||
from lnbits.tasks import register_invoice_listener
|
from lnbits.tasks import register_invoice_listener
|
||||||
|
|
||||||
from .crud import get_myextension, update_myextension
|
from .crud import get_myextension, update_myextension
|
||||||
|
from .models import CreateMyExtensionData
|
||||||
|
|
||||||
#######################################
|
#######################################
|
||||||
########## RUN YOUR TASKS HERE ########
|
########## RUN YOUR TASKS HERE ########
|
||||||
|
|
@ -40,7 +41,7 @@ async def on_invoice_paid(payment: Payment) -> None:
|
||||||
total = myextension.total + payment.amount
|
total = myextension.total + payment.amount
|
||||||
|
|
||||||
myextension.total = total
|
myextension.total = total
|
||||||
await update_myextension(myextension)
|
await update_myextension(CreateMyExtensionData(**myextension.dict()))
|
||||||
|
|
||||||
# here we could send some data to a websocket on
|
# here we could send some data to a websocket on
|
||||||
# wss://<your-lnbits>/api/v1/ws/<myextension_id> and then listen to it on
|
# wss://<your-lnbits>/api/v1/ws/<myextension_id> and then listen to it on
|
||||||
|
|
|
||||||
|
|
@ -92,7 +92,7 @@ async def api_myextension_create(
|
||||||
@myextension_api_router.put("/api/v1/myex/{myextension_id}")
|
@myextension_api_router.put("/api/v1/myex/{myextension_id}")
|
||||||
async def api_myextension_update(
|
async def api_myextension_update(
|
||||||
req: Request, # Withoutthe lnurl stuff this wouldnt be needed
|
req: Request, # Withoutthe lnurl stuff this wouldnt be needed
|
||||||
data: MyExtension,
|
data: CreateMyExtensionData,
|
||||||
myextension_id: str,
|
myextension_id: str,
|
||||||
wallet: WalletTypeInfo = Depends(require_admin_key),
|
wallet: WalletTypeInfo = Depends(require_admin_key),
|
||||||
) -> MyExtension:
|
) -> MyExtension:
|
||||||
|
|
@ -140,6 +140,7 @@ async def api_myextension_delete(
|
||||||
)
|
)
|
||||||
|
|
||||||
await delete_myextension(myextension_id)
|
await delete_myextension(myextension_id)
|
||||||
|
return
|
||||||
|
|
||||||
|
|
||||||
# ANY OTHER ENDPOINTS YOU NEED
|
# ANY OTHER ENDPOINTS YOU NEED
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue