Robô de WhatsApp com IA

services:
  waha:
    image: ${WAHA_IMAGE:-devlikeapro/waha:latest}   # fixada por digest no .env
    restart: unless-stopped
    ports:
      - "127.0.0.1:3000:3000"        # só este computador enxerga a API
    env_file:
      - .env                         # chave da API, fora do Git
    volumes:
      - waha_sessions:/app/.sessions # a sessão sobrevive ao reinício
      - waha_media:/tmp/whatsapp-files

volumes:
  waha_sessions:
  waha_media:

class Waha:
    def conversas_recentes(self, limite):
        return self._pedir('GET', '/api/%s/chats/overview?limit=%d'
                           % (self.sessao, limite)) or []

    def mensagens(self, chat, limite):
        return self._pedir('GET', '/api/%s/chats/%s/messages?limit=%d'
                           % (self.sessao, quote(chat, safe=''), limite)) or []

    def enviar_texto(self, chat, texto):
        resposta = self._pedir('POST', '/api/sendText', {
            'session': self.sessao, 'chatId': chat, 'text': texto})
        return id_de(resposta)

def ciclo(self):
    self.coletar()                    # lê o WAHA e grava o que é novo
    for conversa in self.estado.vencidas(self.relogio()):
        try:
            self.responder(conversa)  # histórico da conversa -> Claude -> envio
        except Exception:
            # falhou: a pendência é baixada, nunca fica para depois
            self.estado.cancelar(conversa['chat'])
    self.enviar_lembretes()           # o que venceu sai uma única vez

CREATE TABLE IF NOT EXISTS historico (
    n INTEGER PRIMARY KEY AUTOINCREMENT, chat TEXT NOT NULL,
    papel TEXT NOT NULL, texto TEXT NOT NULL, ts INTEGER NOT NULL);
CREATE TABLE IF NOT EXISTS conversas (
    chat TEXT PRIMARY KEY, nome TEXT, numero TEXT,
    pausa_ate REAL NOT NULL DEFAULT 0, responder_em REAL);
CREATE TABLE IF NOT EXISTS lembretes (
    n INTEGER PRIMARY KEY AUTOINCREMENT, chat TEXT NOT NULL,
    quando REAL NOT NULL, texto TEXT NOT NULL,
    estado TEXT NOT NULL DEFAULT 'pendente');
CREATE TABLE IF NOT EXISTS agenda_eventos (
    n INTEGER PRIMARY KEY AUTOINCREMENT, chat TEXT NOT NULL,
    evento_id TEXT NOT NULL UNIQUE, titulo TEXT NOT NULL,
    inicio TEXT NOT NULL, estado TEXT NOT NULL, lembrete_n INTEGER);

SILENCIO = '[SILENCIO]'   # o Claude escreve isto para não mandar nada
PASSAR = '[PASSAR]'       # a conversa precisa do próprio Guilherme
MARCA_LEMBRAR = re.compile(
    r'\[\s*LEMBRAR\s+(\d{4}-\d{2}-\d{2})\s+(\d{1,2}:\d{2})\s*\|\s*([^\]]+)\]')

PAUSA_MANUAL = 3600       # respondi à mão: 1 hora de silêncio naquela conversa
MAX_POR_CONVERSA = 10     # respostas em 10 minutos; acima disso é provável loop
LIMITE_HISTORICO = 40     # mensagens da conversa enviadas ao Claude

codigo = uuid.uuid4().hex[:8]
evento_id = 'robo' + uuid.uuid4().hex   # criado antes de falar com o Google
db.execute('INSERT INTO agenda_propostas VALUES (?,?,?,?,?,?,?,?)',
           (codigo, chat, json.dumps(dados), evento_id,
            agora + 900, 'pendente', calendario, None))
return ('Para confirmar, escreva: confirmar agenda %s '
        '(vale por 15 minutos).' % codigo)

def atender(self, acao):
    if self.headers.get('Host') not in HOSTS:   # só 127.0.0.1
        return self.responder(403, {'erro': 'Acesso so por este PC.'})
    cfg = carregar()
    estado = Estado(cfg.dados / 'robo.sqlite')
    self.responder(200, acao(cfg, estado))      # lê o banco do robô