Upload 77 files

app/config.py

@@ -23,12 +23,15 @@ class Settings(BaseSettings):
     # Cerebras API for LLM-based entity extraction
     cerebras_api_key: str = ""
     
-    # CORS
-    cors_origins: list[str] = ["*"]
-
-    # Session cookie
-    cookie_secure: bool = True
-    cookie_samesite: str = "none"
+    # NumVerify API for phone lookup (free tier: 100 req/month)
+    numverify_api_key: str = ""
+    
+    # CORS
+    cors_origins: list[str] = ["*"]
+
+    # Session cookie
+    cookie_secure: bool = True
+    cookie_samesite: str = "none"
     
     class Config:
         env_file = ".env"

app/services/investigator_agent.py

@@ -117,6 +117,23 @@ TOOLS = [
             }
         }
     },
+    {
+        "type": "function",
+        "function": {
+            "name": "lookup_phone",
+            "description": "Consultar informações de um número de telefone. Retorna país, operadora, tipo de linha (fixo/móvel) e validade.",
+            "parameters": {
+                "type": "object",
+                "properties": {
+                    "phone": {
+                        "type": "string",
+                        "description": "Número de telefone com código do país (ex: 5511999998888)"
+                    }
+                },
+                "required": ["phone"]
+            }
+        }
+    },
     {
         "type": "function",
         "function": {
@@ -304,6 +321,9 @@ class InvestigatorAgent:
             elif tool_name == "lookup_cnpj":
                 return await self._lookup_cnpj(arguments.get("cnpj", ""))
             
+            elif tool_name == "lookup_phone":
+                return await self._lookup_phone(arguments.get("phone", ""))
+            
             elif tool_name == "web_search":
                 return await self._web_search(
                     arguments.get("query", ""),
@@ -404,6 +424,53 @@ class InvestigatorAgent:
         
         return "CNPJ não encontrado."
     
+    async def _lookup_phone(self, phone: str) -> str:
+        """Lookup phone number via NumVerify API"""
+        # Clean phone number - keep only digits
+        phone_clean = "".join(c for c in phone if c.isdigit())
+        
+        # NumVerify API key (free tier: 100 req/month)
+        numverify_key = getattr(settings, 'numverify_api_key', None)
+        
+        if not numverify_key:
+            # Fallback: just do a web search for the number
+            return await self._web_search(f'"{phone_clean}" telefone', "any")
+        
+        try:
+            async with httpx.AsyncClient(timeout=10.0) as client:
+                response = await client.get(
+                    "http://apilayer.net/api/validate",
+                    params={
+                        "access_key": numverify_key,
+                        "number": phone_clean,
+                        "country_code": "",  # Auto-detect
+                        "format": 1
+                    }
+                )
+                
+                if response.status_code == 200:
+                    data = response.json()
+                    
+                    if data.get("valid"):
+                        result = {
+                            "numero": data.get("international_format"),
+                            "valido": True,
+                            "pais": data.get("country_name"),
+                            "codigo_pais": data.get("country_code"),
+                            "operadora": data.get("carrier"),
+                            "tipo_linha": data.get("line_type"),  # mobile, landline, etc
+                            "localizacao": data.get("location")
+                        }
+                        return json.dumps(result, ensure_ascii=False, indent=2)
+                    else:
+                        return f"Número {phone_clean} não é válido ou não foi encontrado."
+                
+                return "Erro ao consultar número."
+                
+        except Exception as e:
+            # Fallback to web search
+            return await self._web_search(f'"{phone_clean}" telefone', "any")
+    
     async def _web_search(self, query: str, freshness: str) -> str:
         """Web search via Lancer"""
         try: