deploy from github actions

app/main.py

@@ -48,13 +48,21 @@ _migrations = [
     # credit_transactions
     "ALTER TABLE credit_transactions ADD COLUMN IF NOT EXISTS credit_type VARCHAR DEFAULT 'base'",
     "ALTER TABLE credit_transactions ADD COLUMN IF NOT EXISTS reference_id VARCHAR",
-    # Índice único parcial para evitar acreditar 2 veces el mismo pago (solo donaciones)
+    # Índice único para evitar doble acreditación de pagos PayPal
+    # Paso 1: Eliminar filas duplicadas de PayPal manteniendo solo la más antigua por reference_id
+    """DELETE FROM credit_transactions
+       WHERE id IN (
+         SELECT id FROM (
+           SELECT id,
+                  ROW_NUMBER() OVER (PARTITION BY reference_id ORDER BY id ASC) AS rn
+           FROM credit_transactions
+           WHERE reference_id IS NOT NULL AND concept LIKE 'Donación PayPal%'
+         ) t WHERE rn > 1
+       )""",
+    # Paso 2: Crear el índice único (ahora sin duplicados)
     """CREATE UNIQUE INDEX IF NOT EXISTS uq_credit_tx_paypal_reference
        ON credit_transactions (reference_id)
        WHERE reference_id IS NOT NULL AND concept LIKE 'Donación PayPal%'""",
-    """CREATE UNIQUE INDEX IF NOT EXISTS uq_credit_tx_stripe_reference
-       ON credit_transactions (reference_id)
-       WHERE reference_id IS NOT NULL AND concept LIKE 'Donación Stripe%' OR reference_id LIKE 'cs_%'""",
     # workers
     "ALTER TABLE workers ADD COLUMN IF NOT EXISTS user_id INTEGER",
     "ALTER TABLE workers ADD COLUMN IF NOT EXISTS token VARCHAR",
@@ -86,7 +94,20 @@ _migrations = [
     "CREATE INDEX IF NOT EXISTS idx_forum_threads_created_at ON forum_threads(created_at)",
     "CREATE INDEX IF NOT EXISTS idx_forum_replies_thread_id ON forum_replies(thread_id)",
     "CREATE INDEX IF NOT EXISTS idx_forum_replies_is_deleted ON forum_replies(is_deleted)",
-    "CREATE INDEX IF NOT EXISTS idx_forum_replies_created_at ON forum_replies(created_at)"
+    "CREATE INDEX IF NOT EXISTS idx_forum_replies_created_at ON forum_replies(created_at)",
+    # Recalcular créditos de usuarios afectados por duplicados ya limpiados
+    # (cada usuario queda con la suma real de sus transacciones válidas)
+    """UPDATE users
+       SET credits = sub.total
+       FROM (
+         SELECT user_id, SUM(
+           CASE WHEN amount < 0 THEN amount ELSE amount END
+         ) AS total
+         FROM credit_transactions
+         GROUP BY user_id
+       ) sub
+       WHERE users.id = sub.user_id
+         AND sub.total IS NOT NULL"""
 ]
 
 from sqlalchemy import text as _sql_text