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

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,28 @@
 from lnbits.helpers import urlsafe_short_hash
 
 from .models import (
+    Basket,
     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 +39,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 +119,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 +134,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 +148,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 +165,85 @@ async def get_event_tickets(event_id: str) -> list[Ticket]:
         {"event": event_id},
         Ticket,
     )
+
+
+async def get_ticket_types(event_id: str) -> list[TicketType]:
+    return await db.fetchall(
+        "SELECT * FROM events.ticket_types WHERE event_id = :event_id"
+        " ORDER BY sort_order ASC",
+        {"event_id": event_id},
+        TicketType,
+    )
+
+
+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.

migrations.py

@@ -195,3 +195,104 @@ async def m008_add_fiat_currency(db):
         ALTER TABLE events.events
         ADD COLUMN fiat_currency TEXT NOT NULL DEFAULT 'GBP';
         """)
+
+
+async def m009_ticket_types_and_baskets(db):
+    from sqlalchemy.exc import OperationalError
+
+    await db.execute("""
+        CREATE TABLE IF NOT EXISTS events.ticket_types (
+            id TEXT PRIMARY KEY,
+            event_id TEXT NOT NULL,
+            name TEXT NOT NULL,
+            description TEXT NOT NULL DEFAULT '',
+            image_url TEXT,
+            price REAL NOT NULL DEFAULT 0,
+            max_tickets INTEGER NOT NULL DEFAULT 0,
+            sold INTEGER NOT NULL DEFAULT 0,
+            available_from TEXT NOT NULL,
+            available_to TEXT NOT NULL,
+            sort_order INTEGER NOT NULL DEFAULT 0,
+            extra TEXT
+        );
+    """)
+    await db.execute("""
+        CREATE TABLE IF NOT EXISTS events.baskets (
+            id TEXT PRIMARY KEY,
+            event_id TEXT NOT NULL,
+            wallet TEXT NOT NULL,
+            email TEXT NOT NULL,
+            name TEXT NOT NULL,
+            promo_codes TEXT,
+            payment_method TEXT,
+            fiat_provider TEXT,
+            nostr_identifier TEXT,
+            refund_address TEXT,
+            satspay_charge_id TEXT,
+            paid BOOLEAN NOT NULL DEFAULT FALSE,
+            time TIMESTAMP NOT NULL DEFAULT """
+        + db.timestamp_now
+        + """
+        );
+    """)
+    for alter in [
+        "ALTER TABLE events.events ADD COLUMN admin_email TEXT;",
+        "ALTER TABLE events.events DROP COLUMN closing_date;",
+        "ALTER TABLE events.ticket ADD COLUMN ticket_type_id TEXT;",
+        "ALTER TABLE events.ticket ADD COLUMN basket_id TEXT;",
+    ]:
+        try:
+            await db.execute(alter)
+        except OperationalError:
+            pass
+
+    import json
+
+    events_rows = await db.fetchall("SELECT id, extra FROM events.events")
+    for row in events_rows:
+        event_id = row["id"]
+        extra_str = row["extra"]
+        if not extra_str:
+            continue
+        try:
+            extra = json.loads(extra_str)
+        except (json.JSONDecodeError, TypeError):
+            continue
+        ticket_waves = extra.get("ticket_waves", []) or []
+        sort_order = 0
+        for wave in ticket_waves:
+            await db.execute(
+                """
+                INSERT INTO events.ticket_types (
+                    id, event_id, name, description,
+                    image_url, price, max_tickets, sold,
+                    available_from, available_to,
+                    sort_order, extra
+                )
+                VALUES (:id, :event_id, :name, :description,
+                    :image_url, :price, :max_tickets, :sold,
+                    :available_from, :available_to,
+                    :sort_order, :extra)
+                """,
+                {
+                    "id": wave.get("id", ""),
+                    "event_id": event_id,
+                    "name": wave.get("title", "General Admission"),
+                    "description": "",
+                    "image_url": wave.get("ticket_image_id"),
+                    "price": wave.get("price_per_ticket", 0),
+                    "max_tickets": wave.get("amount_tickets", 0),
+                    "sold": 0,
+                    "available_from": wave.get("opening_date", ""),
+                    "available_to": wave.get("closing_date", ""),
+                    "sort_order": sort_order,
+                    "extra": "{}",
+                },
+            )
+            sort_order += 1
+
+        extra.pop("ticket_waves", None)
+        await db.execute(
+            "UPDATE events.events SET extra = :extra WHERE id = :id",
+            {"extra": json.dumps(extra), "id": event_id},
+        )