Update routes/subscription.py

routes/subscription.py

@@ -401,7 +401,7 @@ async def stripe_webhook(request: Request):
             if response_check_chat.status_code == 200:
                 existing_chats = response_check_chat.json()
                 
-                # 🔹 Se não existir chat, criar novo
+                # 🔹 Se não existir chat, criar novo e adicionar mensagem inicial
                 if not existing_chats:
                     chat_data = {
                         "stylist_id": stylist_id,
@@ -416,6 +416,29 @@ async def stripe_webhook(request: Request):
 
                     if response_chat.status_code == 201:
                         logger.info(f"✅ Chat created for stylist {stylist_id} and client {user_id}")
+                        
+                        # Pegando o ID do chat recém-criado
+                        new_chat = response_chat.json()
+                        chat_id = new_chat[0].get('id')  # Supabase retorna array com o objeto criado
+                        
+                        # 🔹 Criando mensagem inicial
+                        message_data = {
+                            "chat_id": chat_id,
+                            "sender_id": user_id,
+                            "content": "subscribed for 1 month",
+                            "type": "warning"
+                        }
+                        
+                        response_message = requests.post(
+                            f"{SUPABASE_URL}/rest/v1/messages",
+                            headers=SUPABASE_ROLE_HEADERS,
+                            json=message_data
+                        )
+
+                        if response_message.status_code == 201:
+                            logger.info(f"✅ Initial message created for chat {chat_id}")
+                        else:
+                            logger.error(f"❌ Failed to create initial message: {response_message.status_code} - {response_message.text}")
                     else:
                         logger.error(f"❌ Failed to create chat: {response_chat.status_code} - {response_chat.text}")
                 else:
@@ -429,7 +452,7 @@ async def stripe_webhook(request: Request):
                 "stylist_amount": stylist_amount / 100,
                 "platform_amount": platform_amount / 100
             }
-    
+            
         elif event_type == "customer.subscription.deleted":
             subscription = payload.get("data", {}).get("object", {})
             subscription_id = subscription.get("id")