Refactor events extensions (#21)

* require admin key
* remove log
* only show paid tickets
* purge tickets
This commit is contained in:
Tiago Vasconcelos 2024-02-05 07:50:39 +00:00 committed by GitHub
parent f468183631
commit 07d2f59bc3
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
5 changed files with 59 additions and 15 deletions

14
crud.py
View file

@ -1,4 +1,5 @@
from typing import List, Optional, Union from typing import List, Optional, Union
from datetime import datetime, timedelta
from lnbits.helpers import urlsafe_short_hash from lnbits.helpers import urlsafe_short_hash
@ -85,6 +86,19 @@ async def delete_event_tickets(event_id: str) -> None:
await db.execute("DELETE FROM events.ticket WHERE event = ?", (event_id,)) await db.execute("DELETE FROM events.ticket WHERE event = ?", (event_id,))
async def purge_unpaid_tickets(event_id: str) -> None:
time_diff = datetime.now() - timedelta(hours=24)
await db.execute(
"""
DELETE FROM events.ticket WHERE event = ? AND paid = false AND time < ?
""",
(
event_id,
time_diff,
),
)
# EVENTS # EVENTS

View file

@ -26,7 +26,8 @@
v-model.trim="formDialog.data.email" v-model.trim="formDialog.data.email"
type="email" type="email"
label="Your email " label="Your email "
:rules="[val => emailValidation(val)]" :rules="[val => !!val || '* Required', val => emailValidation(val)]"
lazy-rules
></q-input> ></q-input>
<div class="row q-mt-lg"> <div class="row q-mt-lg">
@ -121,9 +122,10 @@
} }
} }
}, },
created() { async created() {
this.info = '{{ event_info | tojson }}' this.info = '{{ event_info | tojson }}'
this.info = this.info.substring(1, this.info.length - 1) this.info = this.info.substring(1, this.info.length - 1)
await this.purgeUnpaidTickets()
}, },
computed: { computed: {
formatDescription() { formatDescription() {
@ -152,8 +154,8 @@
) )
}, },
emailValidation(val) { emailValidation(val) {
let regex = /^\w+([\.-]?\w+)*@\w+([\.-]?\w+)*(\.\w{2,3})+$/g let regex = /^[\w\.-]+@[a-zA-Z\d\.-]+\.[a-zA-Z]{2,}$/
return !regex.test(val) || 'Please enter valid email.' return regex.test(val) || 'Please enter valid email.'
}, },
Invoice: function () { Invoice: function () {
@ -226,6 +228,14 @@
.catch(function (error) { .catch(function (error) {
LNbits.utils.notifyApiError(error) LNbits.utils.notifyApiError(error)
}) })
},
async purgeUnpaidTickets() {
try {
await LNbits.api.request('GET', `/events/api/v1/purge/{{ event_id }}`)
} catch (error) {
console.warn(error)
LNbits.utils.notifyApiError(error)
}
} }
} }
}) })

View file

@ -416,9 +416,11 @@
this.g.user.wallets[0].inkey this.g.user.wallets[0].inkey
) )
.then(function (response) { .then(function (response) {
self.tickets = response.data.map(function (obj) { self.tickets = response.data
return mapEvents(obj) .map(function (obj) {
}) return mapEvents(obj)
})
.filter(e => e.paid)
}) })
}, },
deleteTicket: function (ticketId) { deleteTicket: function (ticketId) {
@ -461,7 +463,6 @@
self.events = response.data.map(function (obj) { self.events = response.data.map(function (obj) {
return mapEvents(obj) return mapEvents(obj)
}) })
console.log(self.events)
}) })
}, },
sendEventData: function () { sendEventData: function () {
@ -480,7 +481,7 @@
createEvent: function (wallet, data) { createEvent: function (wallet, data) {
var self = this var self = this
LNbits.api LNbits.api
.request('POST', '/events/api/v1/events', wallet.inkey, data) .request('POST', '/events/api/v1/events', wallet.adminkey, data)
.then(function (response) { .then(function (response) {
self.events.push(mapEvents(response.data)) self.events.push(mapEvents(response.data))
self.formDialog.show = false self.formDialog.show = false
@ -504,7 +505,7 @@
.request( .request(
'PUT', 'PUT',
'/events/api/v1/events/' + data.id, '/events/api/v1/events/' + data.id,
wallet.inkey, wallet.adminkey,
data data
) )
.then(function (response) { .then(function (response) {
@ -530,7 +531,7 @@
.request( .request(
'DELETE', 'DELETE',
'/events/api/v1/events/' + eventsId, '/events/api/v1/events/' + eventsId,
_.findWhere(self.g.user.wallets, {id: events.wallet}).inkey _.findWhere(self.g.user.wallets, {id: events.wallet}).adminkey
) )
.then(function (response) { .then(function (response) {
self.events = _.reject(self.events, function (obj) { self.events = _.reject(self.events, function (obj) {

View file

@ -152,7 +152,6 @@
}, },
getEventTickets: function () { getEventTickets: function () {
var self = this var self = this
console.log('obj')
LNbits.api LNbits.api
.request( .request(
'GET', 'GET',

View file

@ -5,7 +5,12 @@ from starlette.exceptions import HTTPException
from lnbits.core.crud import get_standalone_payment, get_user from lnbits.core.crud import get_standalone_payment, get_user
from lnbits.core.services import create_invoice from lnbits.core.services import create_invoice
from lnbits.decorators import WalletTypeInfo, get_key_type from lnbits.decorators import (
WalletTypeInfo,
get_key_type,
require_admin_key,
require_invoice_key,
)
from lnbits.utils.exchange_rates import ( from lnbits.utils.exchange_rates import (
currencies, currencies,
fiat_amount_as_satoshis, fiat_amount_as_satoshis,
@ -27,6 +32,7 @@ from .crud import (
reg_ticket, reg_ticket,
set_ticket_paid, set_ticket_paid,
update_event, update_event,
purge_unpaid_tickets,
) )
from .models import CreateEvent, CreateTicket from .models import CreateEvent, CreateTicket
@ -49,7 +55,9 @@ async def api_events(
@events_ext.post("/api/v1/events") @events_ext.post("/api/v1/events")
@events_ext.put("/api/v1/events/{event_id}") @events_ext.put("/api/v1/events/{event_id}")
async def api_event_create( async def api_event_create(
data: CreateEvent, event_id=None, wallet: WalletTypeInfo = Depends(get_key_type) data: CreateEvent,
event_id=None,
wallet: WalletTypeInfo = Depends(require_admin_key),
): ):
if event_id: if event_id:
event = await get_event(event_id) event = await get_event(event_id)
@ -70,7 +78,9 @@ async def api_event_create(
@events_ext.delete("/api/v1/events/{event_id}") @events_ext.delete("/api/v1/events/{event_id}")
async def api_form_delete(event_id, wallet: WalletTypeInfo = Depends(get_key_type)): async def api_form_delete(
event_id, wallet: WalletTypeInfo = Depends(require_admin_key)
):
event = await get_event(event_id) event = await get_event(event_id)
if not event: if not event:
raise HTTPException( raise HTTPException(
@ -193,6 +203,16 @@ async def api_ticket_delete(ticket_id, wallet: WalletTypeInfo = Depends(get_key_
return "", HTTPStatus.NO_CONTENT return "", HTTPStatus.NO_CONTENT
@events_ext.get("/api/v1/purge/{event_id}")
async def api_event_purge_tickets(event_id):
event = await get_event(event_id)
if not event:
raise HTTPException(
status_code=HTTPStatus.NOT_FOUND, detail="Event does not exist."
)
return await purge_unpaid_tickets(event_id)
# Event Tickets # Event Tickets