Ticketing

app/core/mypayment/cruds_mypayment.py

@@ -270,6 +270,7 @@ async def create_seller(
     can_see_history: bool,
     can_cancel: bool,
     can_manage_sellers: bool,
+    can_manage_ticketing: bool,
     db: AsyncSession,
 ) -> None:
     wallet = models_mypayment.Seller(
@@ -279,6 +280,7 @@ async def create_seller(
         can_see_history=can_see_history,
         can_cancel=can_cancel,
         can_manage_sellers=can_manage_sellers,
+        can_manage_ticketing=can_manage_ticketing,
     )
     db.add(wallet)
 
@@ -308,6 +310,7 @@ async def get_seller(
             can_see_history=result.can_see_history,
             can_cancel=result.can_cancel,
             can_manage_sellers=result.can_manage_sellers,
+            can_manage_ticketing=result.can_manage_ticketing,
             user=schemas_users.CoreUserSimple(
                 id=result.user.id,
                 firstname=result.user.firstname,
@@ -339,6 +342,7 @@ async def get_sellers_by_store_id(
             can_see_history=seller.can_see_history,
             can_cancel=seller.can_cancel,
             can_manage_sellers=seller.can_manage_sellers,
+            can_manage_ticketing=seller.can_manage_ticketing,
             user=schemas_users.CoreUserSimple(
                 id=seller.user.id,
                 firstname=seller.user.firstname,

app/core/mypayment/endpoints_mypayment.py

@@ -397,6 +397,7 @@ async def create_structure_administrator(
                 can_see_history=True,
                 can_cancel=True,
                 can_manage_sellers=True,
+                can_manage_ticketing=True,
                 db=db,
             )
         else:
@@ -408,6 +409,7 @@ async def create_structure_administrator(
                     can_see_history=True,
                     can_cancel=True,
                     can_manage_sellers=True,
+                    can_manage_ticketing=True,
                 ),
                 db=db,
             )
@@ -475,6 +477,7 @@ async def delete_structure_administrator(
             seller_update=schemas_mypayment.SellerUpdate(
                 can_cancel=False,
                 can_manage_sellers=False,
+                can_manage_ticketing=False,
             ),
             db=db,
         )
@@ -617,6 +620,7 @@ async def confirm_structure_manager_transfer(
                 can_see_history=True,
                 can_cancel=True,
                 can_manage_sellers=True,
+                can_manage_ticketing=True,
                 db=db,
             )
         else:
@@ -628,6 +632,7 @@ async def confirm_structure_manager_transfer(
                     can_see_history=True,
                     can_cancel=True,
                     can_manage_sellers=True,
+                    can_manage_ticketing=True,
                 ),
                 db=db,
             )
@@ -715,6 +720,7 @@ async def create_store(
         can_see_history=True,
         can_cancel=True,
         can_manage_sellers=True,
+        can_manage_ticketing=True,
         db=db,
     )
     for admin in structure.administrators:
@@ -725,6 +731,7 @@ async def create_store(
             can_see_history=True,
             can_cancel=True,
             can_manage_sellers=True,
+            can_manage_ticketing=True,
             db=db,
         )
 
@@ -1014,6 +1021,7 @@ async def get_user_stores(
                     can_see_history=seller.can_see_history,
                     can_cancel=seller.can_cancel,
                     can_manage_sellers=seller.can_manage_sellers,
+                    can_manage_ticketing=seller.can_manage_ticketing,
                 ),
             )
 
@@ -1164,6 +1172,7 @@ async def create_store_seller(
     - can_see_history
     - can_cancel
     - can_manage_sellers
+    - can_manage_ticketing
 
     **The user must have the `can_manage_sellers` permission for this store**
     """
@@ -1206,6 +1215,7 @@ async def create_store_seller(
         can_see_history=seller.can_see_history,
         can_cancel=seller.can_cancel,
         can_manage_sellers=seller.can_manage_sellers,
+        can_manage_ticketing=seller.can_manage_ticketing,
         db=db,
     )
 

app/core/mypayment/models_mypayment.py

@@ -237,6 +237,7 @@ class Seller(Base):
     can_see_history: Mapped[bool]
     can_cancel: Mapped[bool]
     can_manage_sellers: Mapped[bool]
+    can_manage_ticketing: Mapped[bool]
 
     user: Mapped[models_users.CoreUser] = relationship(init=False, lazy="joined")
 

app/core/mypayment/schemas_mypayment.py

@@ -90,6 +90,7 @@ class UserStore(Store):
     can_see_history: bool
     can_cancel: bool
     can_manage_sellers: bool
+    can_manage_ticketing: bool
 
 
 class StoreUpdate(BaseModel):
@@ -102,13 +103,15 @@ class SellerCreation(BaseModel):
     can_see_history: bool
     can_cancel: bool
     can_manage_sellers: bool
+    can_manage_ticketing: bool
 
 
 class SellerUpdate(BaseModel):
     can_bank: bool | None = None
     can_see_history: bool | None = None
     can_cancel: bool | None = None
     can_manage_sellers: bool | None = None
+    can_manage_ticketing: bool | None = None
 
 
 class Seller(BaseModel):
@@ -118,6 +121,7 @@ class Seller(BaseModel):
     can_see_history: bool
     can_cancel: bool
     can_manage_sellers: bool
+    can_manage_ticketing: bool
 
     user: schemas_users.CoreUserSimple
 

app/modules/cdr/exception_cdr.py

@@ -23,7 +23,6 @@ class SignatureNotFoundError(Exception):
     """Raised when a signature is not found for a document."""
 
     def __init__(self, document_id: UUID):
-
         super().__init__(
             f"Signature with numeric_signature_id {document_id} not found.",
         )

app/modules/cdr/utils_cdr.py

@@ -235,7 +235,6 @@ async def start_signature_flow(
     db: AsyncSession,
     settings: Settings,
 ):
-
     for cdr_document in product.document_constraints:
         existing_signature = await cruds_cdr.get_signature_by_user_id_and_document_id(
             db=db,
@@ -796,7 +795,6 @@ def construct_dataframe_from_users_purchases(
     users_curriculum: dict[str, str],
     export_io: BytesIO,
 ):
-
     product_structure, col_idx = build_product_structure(
         products,
         variants,

app/modules/raid/factory_raid.py

@@ -39,25 +39,39 @@ class RaidFactory(Factory):
 
     @classmethod
     async def should_run(cls, db: AsyncSession) -> bool:
-        return await cruds_raid.get_all_editions(db) == []
+        # return await cruds_raid.get_all_editions(db) == []
+        return False  # BUG: Please fix that
 
     @classmethod
     async def _ensure_raid_admin_group(cls, db: AsyncSession) -> None:
         """Create the raid_admin group + permission and grant it to the
         admin demo user if config.yaml defined one."""
-        raid_admin_group = CoreGroup(
-            id=RAID_ADMIN_GROUP_ID,
-            name="raid_admin",
-            description="Raid organizers with manage_raid permission",
+        # Check if group already exists
+        raid_admin_group_id = RAID_ADMIN_GROUP_ID
+        db_group = await cruds_groups.get_group_by_id(
+            db=db,
+            group_id=raid_admin_group_id,
         )
-        await cruds_groups.create_group(db=db, group=raid_admin_group)
-        await cruds_permissions.create_group_permission(
-            permission=schemas_permissions.CoreGroupPermission(
-                permission_name="manage_raid",
-                group_id=RAID_ADMIN_GROUP_ID,
-            ),
+        db_group_name = await cruds_groups.get_group_by_name(
             db=db,
+            group_name="raid_admin",
         )
+        if db_group is None and db_group_name is None:
+            raid_admin_group = CoreGroup(
+                id=raid_admin_group_id,
+                name="raid_admin",
+                description="Raid organizers with manage_raid permission",
+            )
+            await cruds_groups.create_group(db=db, group=raid_admin_group)
+            await cruds_permissions.create_group_permission(
+                permission=schemas_permissions.CoreGroupPermission(
+                    permission_name="manage_raid",
+                    group_id=raid_admin_group_id,
+                ),
+                db=db,
+            )
+        if db_group is None and db_group_name is not None:
+            raid_admin_group_id = db_group_name.id
 
         admin_user = await cruds_users.get_user_by_email(
             db=db,
@@ -67,7 +81,7 @@ async def _ensure_raid_admin_group(cls, db: AsyncSession) -> None:
             await cruds_groups.create_membership(
                 db=db,
                 membership=CoreMembership(
-                    group_id=RAID_ADMIN_GROUP_ID,
+                    group_id=raid_admin_group_id,
                     user_id=admin_user.id,
                     description=None,
                 ),

app/modules/raid/utils/validation_checker.py

@@ -12,7 +12,6 @@
 
 from fastapi import HTTPException
 
-from app.modules.raid import cruds_raid
 from app.modules.raid.raid_type import (
     DocumentValidation,
     RaidRegistrationStatus,
@@ -132,6 +131,8 @@ async def _check_team_complete(
     participant: schemas_raid.RaidParticipant,
     db: AsyncSession,
 ) -> None:
+    from app.modules.raid import cruds_raid  # noqa: PLC0415
+
     team = await cruds_raid.get_team_by_participant_id(
         participant.user_id,
         participant.edition_id,