Update routes/subscription.py

routes/subscription.py

@@ -408,37 +408,57 @@ async def stripe_webhook(request: Request):
                         "client_id": user_id
                     }
                     
+                    # Criar novo chat com Prefer: return=representation header
+                    create_chat_headers = SUPABASE_ROLE_HEADERS.copy()
+                    create_chat_headers["Prefer"] = "return=representation"
+                    
                     response_chat = requests.post(
                         f"{SUPABASE_URL}/rest/v1/chats",
-                        headers=SUPABASE_ROLE_HEADERS,
+                        headers=create_chat_headers,
                         json=chat_data
                     )
 
                     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}")
+                        try:
+                            # Pegando o ID do chat recém-criado
+                            new_chat_data = response_chat.json()
+                            if isinstance(new_chat_data, list) and len(new_chat_data) > 0:
+                                chat_id = new_chat_data[0].get('id')
+                            else:
+                                chat_id = new_chat_data.get('id')
+
+                            logger.info(f"✅ Chat created for stylist {stylist_id} and client {user_id}")
+                            logger.info(f"📝 Chat ID: {chat_id}")
+                            
+                            if chat_id:
+                                # 🔹 Criando mensagem inicial
+                                message_data = {
+                                    "chat_id": chat_id,
+                                    "sender_id": user_id,
+                                    "content": "subscribed for 1 month",
+                                    "type": "warning"
+                                }
+                                
+                                # Criar mensagem com Prefer: return=representation header
+                                create_message_headers = SUPABASE_ROLE_HEADERS.copy()
+                                create_message_headers["Prefer"] = "return=representation"
+                                
+                                response_message = requests.post(
+                                    f"{SUPABASE_URL}/rest/v1/messages",
+                                    headers=create_message_headers,
+                                    json=message_data
+                                )
+
+                                if response_message.status_code == 201:
+                                    logger.info(f"✅ Initial message created for chat {chat_id}")
+                                    logger.info(f"📝 Message response: {response_message.text}")
+                                else:
+                                    logger.error(f"❌ Failed to create initial message: {response_message.status_code} - {response_message.text}")
+                            else:
+                                logger.error("❌ Failed to get chat_id from response")
+                        except Exception as e:
+                            logger.error(f"❌ Error processing chat creation response: {str(e)}")
+                            logger.error(f"Response content: {response_chat.text}")
                     else:
                         logger.error(f"❌ Failed to create chat: {response_chat.status_code} - {response_chat.text}")
                 else: