from FIAS_RU import SPAS

# Укажите токен из письма
spas = SPAS(token="ваш_токен_из_письма")

# Готово! Можно работать
address = spas.search("Москва, Тверская 1")
print(address.full_name)

# Регистрация: https://dadata.ru/
# Получите API ключ сразу после регистрации

import requests

api_key = "your_dadata_token"
url = "https://suggestions.dadata.ru/suggestions/api/4_1/rs/suggest/fias"

response = requests.post(
    url,
    headers={
        "Authorization": f"Token {api_key}",
        "Content-Type": "application/json"
    },
    json={"query": "Москва, Тверская"}
)

print(response.json())

# ✅ Безопасно: валидация перед отправкой
spas.search("Москва")  

# ❌ Блокируется: пустой запрос
spas.search("")  # → FIASValidationError

# ❌ Блокируется: некорректный ID
spas.search(-1)  # → FIASValidationError

from FIAS_RU import SPAS

# Токен автоматически читается из переменной окружения
spas = SPAS()

# Или явно
import os
spas = SPAS(token=os.getenv("FIAS_TOKEN"))

from dotenv import load_dotenv
from FIAS_RU import SPAS

load_dotenv()  # Загружает .env файл

spas = SPAS()  # Токен автоматически подтянется

# AWS Secrets Manager
import boto3
import json

def get_fias_token():
    client = boto3.client('secretsmanager', region_name='eu-west-1')
    response = client.get_secret_value(SecretId='prod/fias/token')
    return json.loads(response['SecretString'])['token']

spas = SPAS(token=get_fias_token())

# Azure Key Vault
from azure.identity import DefaultAzureCredential
from azure.keyvault.secrets import SecretClient

credential = DefaultAzureCredential()
vault_url = "https://your-vault.vault.azure.net"
client = SecretClient(vault_url=vault_url, credential=credential)

token = client.get_secret("fias-token").value
spas = SPAS(token=token)

# HashiCorp Vault
import hvac

client = hvac.Client(url='http://127.0.0.1:8200')
client.token = 'your-vault-token'

secret = client.secrets.kv.v2.read_secret_version(path='fias')
token = secret['data']['data']['token']

spas = SPAS(token=token)

# ❌ НЕ ХРАНИТЕ ТОКЕН В КОДЕ!
spas = SPAS(token="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9...")

# ❌ НЕ КОММИТЬТЕ ТОКЕНЫ В GIT!
# ❌ НЕ ПУБЛИКУЙТЕ ТОКЕНЫ В ПУБЛИЧНЫХ РЕПОЗИТОРИЯХ!
# ❌ НЕ ЛОГИРУЙТЕ ТОКЕНЫ!
# ❌ НЕ ОТПРАВЛЯЙТЕ ТОКЕНЫ В SLACK/TELEGRAM/EMAIL БЕЗ ШИФРОВАНИЯ!

# Rate limiting включён по умолчанию
spas = SPAS(
    token=os.getenv("FIAS_TOKEN"),
    rate_limit_requests=100,    # Макс. 100 запросов
    rate_limit_window=60.0      # За 60 секунд
)

spas = SPAS(
    token=os.getenv("FIAS_TOKEN"),
    max_connections=100,              # Макс. соединений
    max_keepalive_connections=20      # Макс. keep-alive
)

spas = SPAS(
    token=os.getenv("FIAS_TOKEN"),
    timeout=30.0  # 30 секунд максимум
)

# ✅ Разрешено
SPAS(token=token)  # По умолчанию HTTPS

# ❌ Заблокировано
SPAS(base_url="http://fias-public-service.nalog.ru", token=token)  
# → FIASValidationError: "URL должен использовать HTTPS"

import logging

logging.basicConfig(level=logging.DEBUG)

spas = SPAS(token="secret_token_12345")

# ✅ В логах токен будет скрыт:
# INFO: Request to /api/spas/v2.0/SearchAddressItem
# DEBUG: Headers: {'master-token': '***'}

try:
    spas.search("test")
except FIASAPIError as e:
    # ✅ Безопасное сообщение
    print(e)  # "❌ Доступ запрещён. Проверьте токен."
    
    # ❌ Внутренние детали НЕ раскрываются
    # Не логируется: SQL запросы, внутренние пути, токены

# ⏰ Рекомендуемая частота: каждые 90 дней
# 
# 1. Запросите новый токен на api.fias@tax.gov.ru
# 2. Обновите в Secret Manager / .env
# 3. Отзовите старый токен
# 4. Проверьте работу всех сервисов

# Development
FIAS_TOKEN_DEV=dev_token_...

# Staging
FIAS_TOKEN_STAGING=staging_token_...

# Production
FIAS_TOKEN_PROD=prod_token_...

import logging
from datetime import datetime

logger = logging.getLogger(__name__)

class TokenUsageMonitor:
    def __init__(self):
        self.requests_count = 0
        self.last_reset = datetime.now()
    
    def log_request(self):
        self.requests_count += 1
        logger.info(f"FIAS requests today: {self.requests_count}")
        
        # Alert если близко к лимиту
        if self.requests_count > 9000:
            logger.warning("⚠️ Approaching daily limit!")

monitor = TokenUsageMonitor()

spas = SPAS(token=os.getenv("FIAS_TOKEN"))
result = spas.search("Москва")
monitor.log_request()

from FIAS_RU import SPAS, FIASValidationError

def safe_address_search(user_input: str):
    # Очистка
    user_input = user_input.strip()
    
    # Валидация длины
    if len(user_input) < 3:
        raise ValueError("Адрес слишком короткий")
    
    if len(user_input) > 500:
        raise ValueError("Адрес слишком длинный")
    
    # Запрещённые символы
    forbidden = ['<', '>', '{', '}', '|', '\\', '^', '`']
    if any(char in user_input for char in forbidden):
        raise ValueError("Адрес содержит запрещённые символы")
    
    # Поиск
    try:
        spas = SPAS(token=os.getenv("FIAS_TOKEN"))
        return spas.search(user_input)
    except FIASValidationError as e:
        logger.warning(f"Invalid input: {user_input}")
        raise ValueError(f"Некорректный адрес: {e}")

from FIAS_RU import SPAS, FIASError, FIASValidationError, FIASAPIError

def search_address_safe(query: str):
    try:
        spas = SPAS(token=os.getenv("FIAS_TOKEN"))
        return spas.search(query)
        
    except FIASValidationError as e:
        # ✅ Логируем, показываем общее сообщение
        logger.info(f"Validation error for query: {query}")
        return {"error": "Некорректный запрос"}
        
    except FIASAPIError as e:
        # ✅ Не раскрываем детали API
        logger.error(f"API error: {type(e).__name__}")
        return {"error": "Временная ошибка сервиса"}
        
    except FIASError as e:
        # ✅ Общая обработка
        logger.error(f"FIAS error: {e}")
        return {"error": "Ошибка поиска адреса"}
        
    except Exception as e:
        # ✅ Критические ошибки
        logger.exception("Unexpected error")
        return {"error": "Внутренняя ошибка сервера"}