DRS

topic = "deferred.receipts.sync"

class InvoiceReceiptModel(Base):
    __tablename__ = "invoice_receipts"

    invoice_id = Column(pg.UUID(True), primary_key=True)
    cashier_id = Column(pg.UUID(True), index=True)
    cash_register_id = Column(pg.UUID(True))
    receipt = Column(JSON)
    status = Column(CustomEnum(InvoiceStatus))
    error_message = Column(Text)
    deferred_ttl = Column(DateTime(True))
    created_at = Column(DateTime(True), server_default=func.now())
    updated_at = Column(DateTime(True), onupdate=func.now(), server_onupdate=func.now())


class InvoiceStatus(Enum):
    PENDING = "PENDING"
    DONE = "DONE"
    ERROR = "ERROR"
    CANCELLED = "CANCELLED"