v2.0.0: ticket types, basket checkout, promo codes, fiat, deactivation

.gitignore

@@ -2,3 +2,4 @@ __pycache__
 node_modules
 .mypy_cache
 .venv
+data/

README.md

@@ -14,10 +14,21 @@
 
 ## Sell tickets for events and use the built-in scanner for registering attendees
 
-Events allows you to create tickets for an event. Each ticket is in the form of a unique QR code. After registering and paying, the user gets a QR code to present at registration/entrance.
+Events allows you to create events with multiple ticket types and sell tickets. Each ticket is in the form of a unique QR code. After paying, the user gets a QR code to present at registration/entrance.
 
 Events includes a shareable ticket scanner, which can be used to register attendees.
 
+### Features
+
+- **Multi-ticket basket checkout** — buy multiple tickets of different types in one transaction
+- **Promo codes** — percentage or fixed discounts, combinable or exclusive
+- **Payment methods** — Lightning, on-chain, and fiat (Stripe, PayPal, Square, Revolut) configured per event
+- **Ticket types** — multiple ticket tiers with different pricing, availability windows, and max limits
+- **Email & Nostr delivery** — automatic ticket link delivery via email or Nostr DM
+- **Bulk actions** — resend all ticket emails, send custom messages to all attendees
+- **Ticket management** — deactivation, refunds, registration tracking
+- **Fiat provider** — credentials configured at LNbits server level, authorized per user
+
 ## Usage
 
 1. Create an event\

__init__.py

@@ -4,14 +4,12 @@
 from loguru import logger
 
 from .crud import db
-from .tasks import wait_for_paid_invoices
 from .views import events_generic_router
-from .views_api import events_api_router, qr_api_router, tickets_api_router
+from .views_api import events_api_router, qr_api_router
 
 events_ext: APIRouter = APIRouter(prefix="/events", tags=["Events"])
 events_ext.include_router(events_generic_router)
 events_ext.include_router(events_api_router)
-events_ext.include_router(tickets_api_router)
 events_ext.include_router(qr_api_router)
 
 events_static_files = [
@@ -33,10 +31,7 @@ def events_stop():
 
 
 def events_start():
-    from lnbits.tasks import create_permanent_unique_task
-
-    task = create_permanent_unique_task("ext_events", wait_for_paid_invoices)
-    scheduled_tasks.append(task)
+    pass
 
 
 __all__ = ["db", "events_ext", "events_start", "events_static_files", "events_stop"]

config.json

@@ -1,12 +1,12 @@
 {
   "id": "events",
-  "version": "1.6.9",
+  "version": "2.0.0",
   "name": "Events",
   "repo": "https://github.com/lnbits/events",
   "short_description": "Sell and register event tickets",
   "description": "",
   "tile": "/events/static/image/events.png",
-  "min_lnbits_version": "1.5.5",
+  "min_lnbits_version": "1.5.4",
   "contributors": [
     {
       "name": "talvasconcelos",
@@ -32,6 +32,11 @@
       "name": "motorina0",
       "uri": "https://github.com/motorina0",
       "role": "Developer"
+    },
+    {
+      "name": "Nathan Day",
+      "uri": "https://github.com/dadofsambonzuki",
+      "role": "Developer"
     }
   ],
   "images": [
@@ -58,5 +63,6 @@
   "paid_features": "",
   "tags": ["Fun & Social", "Ticketing"],
   "donate": "",
-  "hidden": false
+  "hidden": false,
+  "dependencies": ["satspay"]
 }

crud.py

@@ -5,19 +5,29 @@
 from lnbits.helpers import urlsafe_short_hash
 
 from .models import (
+    Basket,
+    sold_counts,
     CreateEvent,
     Event,
     Ticket,
     TicketExtra,
     TicketFilters,
-    sync_event_ticket_waves,
+    TicketType,
+    sync_event_from_ticket_types,
 )
 
 db = Database("ext_events")
 
 
 async def create_ticket(
-    payment_hash: str, wallet: str, event: str, name: str, email: str, extra: dict
+    payment_hash: str,
+    wallet: str,
+    event: str,
+    name: str,
+    email: str,
+    extra: dict,
+    ticket_type_id: str | None = None,
+    basket_id: str | None = None,
 ) -> Ticket:
     now = datetime.now(timezone.utc)
     ticket = Ticket(
@@ -30,6 +40,8 @@ async def create_ticket(
         paid=False,
         reg_timestamp=now,
         time=now,
+        ticket_type_id=ticket_type_id,
+        basket_id=basket_id,
         extra=TicketExtra(**extra) if extra else TicketExtra(),
     )
     await db.insert("events.ticket", ticket)
@@ -108,13 +120,11 @@ async def purge_unpaid_tickets(event_id: str) -> None:
 async def create_event(data: CreateEvent) -> Event:
     event_id = urlsafe_short_hash()
     event = Event(id=event_id, time=datetime.now(timezone.utc), **data.dict())
-    event = cast(Event, sync_event_ticket_waves(event))
     await db.insert("events.events", event)
     return event
 
 
 async def update_event(event: Event) -> Event:
-    event = cast(Event, sync_event_ticket_waves(event))
     await db.update("events.events", event)
     return event
 
@@ -125,7 +135,10 @@ async def get_event(event_id: str) -> Event | None:
         {"id": event_id},
         Event,
     )
-    return cast(Event, sync_event_ticket_waves(event)) if event else None
+    if event:
+        ticket_types = await get_ticket_types(event_id)
+        event = cast(Event, sync_event_from_ticket_types(event, ticket_types))
+    return event
 
 
 async def get_events(wallet_ids: str | list[str]) -> list[Event]:
@@ -136,7 +149,11 @@ async def get_events(wallet_ids: str | list[str]) -> list[Event]:
         f"SELECT * FROM events.events WHERE wallet IN ({q})",
         model=Event,
     )
-    return [cast(Event, sync_event_ticket_waves(event)) for event in events]
+    result = []
+    for event in events:
+        ticket_types = await get_ticket_types(event.id)
+        result.append(cast(Event, sync_event_from_ticket_types(event, ticket_types)))
+    return result
 
 
 async def delete_event(event_id: str) -> None:
@@ -149,3 +166,111 @@ async def get_event_tickets(event_id: str) -> list[Ticket]:
         {"event": event_id},
         Ticket,
     )
+
+
+async def get_ticket_types(event_id: str) -> list[TicketType]:
+    ticket_types = await db.fetchall(
+        "SELECT * FROM events.ticket_types WHERE event_id = :event_id"
+        " ORDER BY sort_order ASC",
+        {"event_id": event_id},
+        TicketType,
+    )
+    # `sold` is DERIVED on every read (see models.sold_counts): the stored
+    # column under-counts, and the checkout's availability, its `remaining`
+    # check and the public display filter all trust this value.
+    counts = sold_counts(await get_event_tickets(event_id))
+    for ticket_type in ticket_types:
+        ticket_type.sold = counts.get(ticket_type.id, 0)
+    return ticket_types
+
+
+async def get_all_ticket_types() -> list[TicketType]:
+    """Every ticket type across all events.
+
+    The table is tiny, and a shared cap (``extra.cap_group``) has to be counted
+    across events: one screening has one set of seats, sold from more than one
+    event's checkout.
+    """
+    return await db.fetchall("SELECT * FROM events.ticket_types", {}, TicketType)
+
+
+async def count_tickets_by_type(ticket_type_id: str) -> int:
+    """Committed seats for one ticket type -- same definition as ``sold``."""
+    ticket_type = await get_ticket_type(ticket_type_id)
+    if not ticket_type:
+        return 0
+    counts = sold_counts(await get_event_tickets(ticket_type.event_id))
+    return counts.get(ticket_type_id, 0)
+
+
+async def get_ticket_type(ticket_type_id: str) -> TicketType | None:
+    return await db.fetchone(
+        "SELECT * FROM events.ticket_types WHERE id = :id",
+        {"id": ticket_type_id},
+        TicketType,
+    )
+
+
+async def create_ticket_type(data: TicketType) -> TicketType:
+    await db.insert("events.ticket_types", data)
+    return data
+
+
+async def update_ticket_type(data: TicketType) -> TicketType:
+    await db.update("events.ticket_types", data)
+    return data
+
+
+async def delete_ticket_type(ticket_type_id: str) -> None:
+    await db.execute(
+        "DELETE FROM events.ticket_types WHERE id = :id", {"id": ticket_type_id}
+    )
+
+
+async def delete_event_ticket_types(event_id: str) -> None:
+    await db.execute(
+        "DELETE FROM events.ticket_types WHERE event_id = :event_id",
+        {"event_id": event_id},
+    )
+
+
+async def create_basket(data: Basket) -> Basket:
+    await db.insert("events.baskets", data)
+    return data
+
+
+async def get_basket(basket_id: str) -> Basket | None:
+    return await db.fetchone(
+        "SELECT * FROM events.baskets WHERE id = :id",
+        {"id": basket_id},
+        Basket,
+    )
+
+
+async def update_basket(basket: Basket) -> Basket:
+    await db.update("events.baskets", basket)
+    return basket
+
+
+async def get_event_baskets(event_id: str) -> list[Basket]:
+    return await db.fetchall(
+        "SELECT * FROM events.baskets WHERE event_id = :event_id",
+        {"event_id": event_id},
+        Basket,
+    )
+
+
+async def get_basket_tickets(basket_id: str) -> list[Ticket]:
+    return await db.fetchall(
+        "SELECT * FROM events.ticket WHERE basket_id = :basket_id",
+        {"basket_id": basket_id},
+        Ticket,
+    )
+
+
+async def get_tickets_by_satspay_charge_id(charge_id: str) -> list[Ticket]:
+    return await db.fetchall(
+        "SELECT * FROM events.ticket WHERE json_extract(extra, '$.satspay_charge_id') = :charge_id",
+        {"charge_id": charge_id},
+        Ticket,
+    )

description.md

@@ -2,9 +2,14 @@ Sell tickets for events and manage attendee registration with a built-in QR scan
 
 Its features include:
 
-- Creating events with ticket pricing
+- Creating events with multiple ticket types and pricing
 - Generating unique QR code tickets after payment
 - Providing a shareable ticket scanner for check-in
 - Tracking registered and checked-in attendees
+- Multi-ticket basket checkout with promo codes (percentage or fixed discount)
+- Payment via Lightning, on-chain, or fiat (Stripe, PayPal, Square, Revolut)
+- Email and Nostr notification delivery
+- Bulk email actions (resend tickets, custom messages to all attendees)
+- Ticket deactivation and refund management
 
 A complete ticketing solution for event organizers, meetup hosts, and conference planners who want to sell tickets and manage attendance with Bitcoin.