Dev - prod

.gitignore

@@ -65,6 +65,7 @@ media/
 # Celery beat schedule file
 celerybeat-schedule
 dump.rdb
+celerybeat-schedule.db
 
 # Flask stuff:
 instance/
@@ -135,3 +136,5 @@ dmypy.json
 # static
 
 /static/
+
+.DS_Store

README.md

@@ -207,3 +207,5 @@ Returns:
 - `total_donations_count`
 - `total_donors_count`
 - `total_recipients_count`
+
+..

api/sync.py

@@ -19,7 +19,7 @@
 import base64
 import json
 import logging
-from datetime import datetime
+from datetime import datetime, timezone
 
 import requests
 from django.conf import settings
@@ -209,7 +209,7 @@ def post(self, request, list_id: int):
                 existing_list.cover_image_url = data.get("cover_image_url")
                 existing_list.admin_only_registrations = data.get("admin_only_registrations", False)
                 existing_list.default_registration_status = data.get("default_registration_status", "Pending")
-                existing_list.updated_at = datetime.fromtimestamp(data["updated_at"] / 1000)
+                existing_list.updated_at = datetime.fromtimestamp(data["updated_at"] / 1000, tz=timezone.utc)
                 existing_list.save()
 
                 # Update admins
@@ -233,8 +233,8 @@ def post(self, request, list_id: int):
                 cover_image_url=data.get("cover_image_url"),
                 admin_only_registrations=data.get("admin_only_registrations", False),
                 default_registration_status=data.get("default_registration_status", "Pending"),
-                created_at=datetime.fromtimestamp(data["created_at"] / 1000),
-                updated_at=datetime.fromtimestamp(data["updated_at"] / 1000),
+                created_at=datetime.fromtimestamp(data["created_at"] / 1000, tz=timezone.utc),
+                updated_at=datetime.fromtimestamp(data["updated_at"] / 1000, tz=timezone.utc),
             )
 
             # Create owner account
@@ -303,8 +303,8 @@ def post(self, request, list_id: int):
                     defaults={
                         "registered_by_id": reg.get("registered_by", reg["registrant_id"]),
                         "status": reg.get("status", "Pending"),
-                        "submitted_at": datetime.fromtimestamp(reg["submitted_ms"] / 1000),
-                        "updated_at": datetime.fromtimestamp(reg["updated_ms"] / 1000),
+                        "submitted_at": datetime.fromtimestamp(reg["submitted_ms"] / 1000, tz=timezone.utc),
+                        "updated_at": datetime.fromtimestamp(reg["updated_ms"] / 1000, tz=timezone.utc),
                         "admin_notes": reg.get("admin_notes"),
                         "registrant_notes": reg.get("registrant_notes"),
                     }
@@ -372,8 +372,8 @@ def post(self, request, list_id: int, registrant_id: str):
                 defaults={
                     "registered_by_id": reg.get("registered_by", reg["registrant_id"]),
                     "status": reg.get("status", "Pending"),
-                    "submitted_at": datetime.fromtimestamp(reg["submitted_ms"] / 1000),
-                    "updated_at": datetime.fromtimestamp(reg["updated_ms"] / 1000),
+                    "submitted_at": datetime.fromtimestamp(reg["submitted_ms"] / 1000, tz=timezone.utc),
+                    "updated_at": datetime.fromtimestamp(reg["updated_ms"] / 1000, tz=timezone.utc),
                     "admin_notes": reg.get("admin_notes"),
                     "registrant_notes": reg.get("registrant_notes"),
                 }
@@ -438,10 +438,10 @@ def post(self, request, pot_id: str):
                 existing_pot.description = config.get("pot_description", "")
                 existing_pot.max_approved_applicants = config.get("max_projects", 0)
                 existing_pot.base_currency = config.get("base_currency", "near")
-                existing_pot.application_start = datetime.fromtimestamp(config["application_start_ms"] / 1000)
-                existing_pot.application_end = datetime.fromtimestamp(config["application_end_ms"] / 1000)
-                existing_pot.matching_round_start = datetime.fromtimestamp(config["public_round_start_ms"] / 1000)
-                existing_pot.matching_round_end = datetime.fromtimestamp(config["public_round_end_ms"] / 1000)
+                existing_pot.application_start = datetime.fromtimestamp(config["application_start_ms"] / 1000, tz=timezone.utc)
+                existing_pot.application_end = datetime.fromtimestamp(config["application_end_ms"] / 1000, tz=timezone.utc)
+                existing_pot.matching_round_start = datetime.fromtimestamp(config["public_round_start_ms"] / 1000, tz=timezone.utc)
+                existing_pot.matching_round_end = datetime.fromtimestamp(config["public_round_end_ms"] / 1000, tz=timezone.utc)
                 existing_pot.registry_provider = config.get("registry_provider")
                 existing_pot.min_matching_pool_donation_amount = config.get("min_matching_pool_donation_amount", "0")
                 existing_pot.sybil_wrapper_provider = config.get("sybil_wrapper_provider")
@@ -451,7 +451,7 @@ def post(self, request, pot_id: str):
                 existing_pot.referral_fee_public_round_basis_points = config["referral_fee_public_round_basis_points"]
                 existing_pot.chef_fee_basis_points = config["chef_fee_basis_points"]
                 if config.get("cooldown_end_ms"):
-                    existing_pot.cooldown_end = datetime.fromtimestamp(config["cooldown_end_ms"] / 1000)
+                    existing_pot.cooldown_end = datetime.fromtimestamp(config["cooldown_end_ms"] / 1000, tz=timezone.utc)
                 existing_pot.all_paid_out = config.get("all_paid_out", False)
                 existing_pot.protocol_config_provider = config.get("protocol_config_provider")
                 existing_pot.save()
@@ -468,29 +468,50 @@ def post(self, request, pot_id: str):
                     "pot_id": pot_id
                 })
             else:
-                # Ensure pot factory exists
+                # Auto-create pot factory if missing
                 if not PotFactory.objects.filter(account_id=factory_id).exists():
-                    return Response({
-                        "error": f"Pot factory {factory_id} not found in database. Sync the factory first."
-                    }, status=404)
+                    try:
+                        factory_config = fetch_from_rpc("get_config", contract_id=factory_id)
+                        if not factory_config:
+                            return Response({
+                                "error": f"Pot factory {factory_id} not found on chain."
+                            }, status=404)
+                        factory_owner, _ = Account.objects.get_or_create(id=factory_config.get("owner", factory_id))
+                        protocol_fee_recipient, _ = Account.objects.get_or_create(
+                            id=factory_config.get("protocol_fee_recipient_account", factory_config.get("owner", factory_id))
+                        )
+                        PotFactory.objects.create(
+                            account_id=factory_id,
+                            owner=factory_owner,
+                            deployed_at=datetime.now(tz=timezone.utc),
+                            protocol_fee_basis_points=factory_config.get("protocol_fee_basis_points", 0),
+                            protocol_fee_recipient=protocol_fee_recipient,
+                            require_whitelist=factory_config.get("require_whitelist", False),
+                        )
+                        logger.info(f"Auto-created PotFactory {factory_id}")
+                    except Exception as e:
+                        logger.error(f"Failed to auto-create PotFactory {factory_id}: {e}")
+                        return Response({
+                            "error": f"Pot factory {factory_id} not found and auto-creation failed: {e}"
+                        }, status=404)
 
                 # Create new pot
                 pot = Pot.objects.create(
                     account_id=pot_id,
                     pot_factory_id=factory_id,
                     deployer=owner,
-                    deployed_at=datetime.now(),
+                    deployed_at=datetime.now(tz=timezone.utc),
                     source_metadata=config.get("source_metadata", {}),
                     owner=owner,
                     chef=chef,
                     name=config.get("pot_name", ""),
                     description=config.get("pot_description", ""),
                     max_approved_applicants=config.get("max_projects", 0),
                     base_currency=config.get("base_currency", "near"),
-                    application_start=datetime.fromtimestamp(config["application_start_ms"] / 1000),
-                    application_end=datetime.fromtimestamp(config["application_end_ms"] / 1000),
-                    matching_round_start=datetime.fromtimestamp(config["public_round_start_ms"] / 1000),
-                    matching_round_end=datetime.fromtimestamp(config["public_round_end_ms"] / 1000),
+                    application_start=datetime.fromtimestamp(config["application_start_ms"] / 1000, tz=timezone.utc),
+                    application_end=datetime.fromtimestamp(config["application_end_ms"] / 1000, tz=timezone.utc),
+                    matching_round_start=datetime.fromtimestamp(config["public_round_start_ms"] / 1000, tz=timezone.utc),
+                    matching_round_end=datetime.fromtimestamp(config["public_round_end_ms"] / 1000, tz=timezone.utc),
                     registry_provider=config.get("registry_provider"),
                     min_matching_pool_donation_amount=config.get("min_matching_pool_donation_amount", "0"),
                     sybil_wrapper_provider=config.get("sybil_wrapper_provider"),
@@ -606,7 +627,8 @@ def post(self, request, pot_id: str):
                     )
 
                 donated_at = datetime.fromtimestamp(
-                    (don.get("donated_at") or don.get("donated_at_ms", 0)) / 1000
+                    (don.get("donated_at") or don.get("donated_at_ms", 0)) / 1000,
+                    tz=timezone.utc,
                 )
 
                 Donation.objects.update_or_create(
@@ -679,8 +701,8 @@ def post(self, request, pot_id: str):
                 # Upsert applicant account
                 applicant, _ = Account.objects.get_or_create(id=app["project_id"])
 
-                submitted_at = datetime.fromtimestamp(app["submitted_at"] / 1000)
-                updated_at = datetime.fromtimestamp(app["updated_at"] / 1000) if app.get("updated_at") else submitted_at
+                submitted_at = datetime.fromtimestamp(app["submitted_at"] / 1000, tz=timezone.utc)
+                updated_at = datetime.fromtimestamp(app["updated_at"] / 1000, tz=timezone.utc) if app.get("updated_at") else submitted_at
 
                 application, created = PotApplication.objects.update_or_create(
                     pot=pot,
@@ -772,7 +794,7 @@ def post(self, request, pot_id: str):
 
             # Also update pot's cooldown_end and all_paid_out from config
             if config.get("cooldown_end_ms"):
-                pot.cooldown_end = datetime.fromtimestamp(config["cooldown_end_ms"] / 1000)
+                pot.cooldown_end = datetime.fromtimestamp(config["cooldown_end_ms"] / 1000, tz=timezone.utc)
             pot.all_paid_out = config.get("all_paid_out", False)
             pot.save()
 
@@ -784,17 +806,28 @@ def post(self, request, pot_id: str):
                 # Parse paid_at if present
                 paid_at = None
                 if payout.get("paid_at"):
-                    paid_at = datetime.fromtimestamp(payout["paid_at"] / 1000)
+                    paid_at = datetime.fromtimestamp(payout["paid_at"] / 1000, tz=timezone.utc)
 
-                PotPayout.objects.update_or_create(
-                    pot=pot,
-                    recipient=recipient,
-                    defaults={
-                        "amount": payout["amount"],
-                        "token": near_token,
-                        "paid_at": paid_at,
-                    }
-                )
+                payout_defaults = {
+                    "amount": payout["amount"],
+                    "token": near_token,
+                    "paid_at": paid_at,
+                }
+
+                # Use on_chain_id as lookup if available, otherwise fall back to (pot, recipient)
+                if payout.get("id") is not None:
+                    payout_defaults["pot"] = pot
+                    payout_defaults["recipient"] = recipient
+                    PotPayout.objects.update_or_create(
+                        on_chain_id=payout["id"],
+                        defaults=payout_defaults,
+                    )
+                else:
+                    PotPayout.objects.update_or_create(
+                        pot=pot,
+                        recipient=recipient,
+                        defaults=payout_defaults,
+                    )
                 synced += 1
 
             return Response({
@@ -862,7 +895,7 @@ def post(self, request, pot_id: str):
             for c in all_challenges:
                 challenger, _ = Account.objects.get_or_create(id=c["challenger_id"])
 
-                created_at = datetime.fromtimestamp(c["created_at"] / 1000)
+                created_at = datetime.fromtimestamp(c["created_at"] / 1000, tz=timezone.utc)
 
                 challenge, _ = PotPayoutChallenge.objects.update_or_create(
                     pot=pot,