💓 Heartbeat e detecção de desconexão

Por padrão, todo MicroService envia um heartbeat periódico e monitora os heartbeats dos demais serviços conhecidos. Isso permite detectar quando um serviço cai sem avisar (crash, queda de rede, etc.), não só quando ele se conecta.

service = MicroService(
    service=MyService(),
    sender_endpoint='tcp://0.0.0.0:3000',
    receiver_endpoint='tcp://0.0.0.0:4000',
    enable_heartbeat=True,       # padrão: True
    heartbeat_interval=5,        # segundos entre heartbeats (padrão: 5)
    heartbeat_timeout=15,        # segundos sem sinal até considerar desconectado (padrão: 3x o intervalo)
)

class MyService:
    async def on_service_disconnect(self, service: str):
        print(f'{service} parou de responder')

🧩 Arquitetura

┌──────────────┐        PUSH        ┌──────────────┐
│ MicroService │ ─────────────────▶ │   Receiver   │
└──────────────┘                    └──────────────┘
     ▲
     │
 SUB │
     ▼
┌──────────────┐
│   Sender     │
└──────────────┘

🔐 Criptografia

O aiofase suporta criptografia e autenticação de ponta a ponta via ZMQ CURVE (Curve25519/libsodium, nativo do pyzmq). É opcional e desligada por padrão.

1. Gerar as chaves

Cada serviço (e o broker) precisa de um par de chaves CURVE. Gere com o CLI do módulo aiofase.security:

python -m aiofase.security --name broker --out ./keys
python -m aiofase.security --name meu_servico --out ./keys

Isso cria broker.key (pública, pode compartilhar) e broker.key_secret.

2. Habilitar no broker

server = Server(
    sender_endpoint='tcp://0.0.0.0:3000',
    receiver_endpoint='tcp://0.0.0.0:4000',
    curve_secretkey_file='./keys/broker.key_secret',
    authorized_clients_dir='./keys/authorized_clients',  # opcional, veja abaixo
)

Ou via CLI: python -m aiofase.server --curve-secretkey-file ./keys/broker.key_secret.

• Com authorized_clients_dir: só clientes cuja chave pública (.key) esteja nesse diretório conseguem conectar — criptografia e autenticação.
• Sem authorized_clients_dir: qualquer par de chaves CURVE válido é aceito — só criptografia, sem controle de quem conecta (CURVE_ALLOW_ANY).

3. Habilitar no MicroService

service = MicroService(
    service=MyService(),
    sender_endpoint='tcp://0.0.0.0:3000',
    receiver_endpoint='tcp://0.0.0.0:4000',
    curve_secretkey_file='./keys/meu_servico.key_secret',
    server_publickey_file='./keys/broker.key',
)

Os dois parâmetros (curve_secretkey_file e server_publickey_file) são obrigatórios em conjunto.

🧪 Testes

A suíte usa pytest + pytest-asyncio, com testes de integração reais (sobem Server e MicroService de verdade sobre sockets ipc:// temporários.

poetry install
pytest tests/ --cov=aiofase --cov-report=term-missing

O --cov-report=term-missing mostra, por arquivo, quais linhas ainda não têm teste. Para um relatório HTML navegável:

pytest tests/ --cov=aiofase --cov-report=html
# abre htmlcov/index.html

🔄 Integração com outros sistemas

• Pode ser facilmente integrado com sensores IoT, bancos de dados, interfaces HTTP ou MQTT.

• Ideal para arquiteturas orientadas a eventos com múltiplos serviços independentes.