webhook_kiwify.php

<?php
// Configurações
header("Content-Type: application/json");

// Incluir funções de cliente
require_once dirname(__FILE__) . "/funcoes_cliente.php";

// Caminho para o arquivo de clientes
$clientesJsonFile = dirname(__FILE__) . "/clientes.json";

// Função para registrar logs
function logWebhook($mensagem) {
    file_put_contents("webhook_kiwify_log.txt", date("Y-m-d H:i:s") . " - " . $mensagem . "\n", FILE_APPEND);
}

// Função para responder ao webhook
function responderWebhook($sucesso, $mensagem, $codigo = 200) {
    http_response_code($codigo);
    echo json_encode(["sucesso" => $sucesso, "mensagem" => $mensagem]);
    exit;
}

// Obter o payload JSON da requisição
$payload = file_get_contents("php://input");
logWebhook("Payload bruto recebido: " . $payload);

if (empty($payload)) {
    logWebhook("Payload vazio recebido");
    responderWebhook(false, "Payload vazio", 400);
}

$data = json_decode($payload, true);

// Verificar se o payload é válido
if (json_last_error() !== JSON_ERROR_NONE) {
    logWebhook("Payload JSON inválido: " . $payload);
    responderWebhook(false, "Payload JSON inválido", 400);
}

// Tenta extrair o 'body' se o payload for do n8n
if (isset($data["body"]) && is_array($data["body"])) {
    $dadosVenda = $data["body"];
} else {
    // Se não for do n8n, assume que é o payload direto da Kiwify
    $dadosVenda = $data;
}

// Verificar se os dados essenciais estão presentes no $dadosVenda
if (!isset($dadosVenda["webhook_event_type"])) {
    logWebhook("Dados essenciais ausentes (webhook_event_type).");
    responderWebhook(false, "Dados essenciais ausentes", 400);
}

$evento = $dadosVenda["webhook_event_type"] ?? null;

logWebhook("Evento: " . $evento);
logWebhook("Dados da Venda: " . json_encode($dadosVenda));

// Processar apenas eventos de venda aprovada
if ($evento === "order_approved") {
    $emailCliente = $dadosVenda["Customer"]["email"] ?? null;
    $productId = $dadosVenda["Product"]["product_id"] ?? null;

    if (!$emailCliente || !$productId) {
        logWebhook("Dados essenciais ausentes (email do cliente ou ID do produto).");
        responderWebhook(false, "Dados essenciais ausentes", 400);
    }

    // Mapeamento de produtos Kiwify para limites de eventos
    // ESTE MAPEAMENTO DEVE SER CONFIGURADO POR VOCÊ DE ACORDO COM SEUS PRODUTOS/PLANOS
    $limitesPlanos = [
        "94413b13-96cb-4575-b2e4-8b7ff3890883" => 1,    // Exemplo baseado no webhook fornecido
        "22" => 8,
        "88" => 10,
        // Adicione mais mapeamentos conforme seus planos
    ];

    $novoLimite = $limitesPlanos[$productId] ?? null;

    if ($novoLimite === null) {
        logWebhook("ID de produto Kiwify não mapeado para limite de eventos: " . $productId);
        responderWebhook(false, "Produto não reconhecido ou sem limite associado", 400);
    }

    // Adicionar ou atualizar cliente com token
    $token = adicionarOuAtualizarClienteComToken($emailCliente, $novoLimite, "ativo");
    
    logWebhook("Cliente processado: " . $emailCliente . " com limite de " . $novoLimite . " eventos. Token: " . $token);
    responderWebhook(true, "Limite de eventos do cliente atualizado com sucesso.  Token:$token  Limite:$novoLimite e-mail:$emailCliente");

} else {
    logWebhook("Evento Kiwify não processado: " . $evento);
    responderWebhook(true, "Evento recebido, mas não processado (não é order_approved).");
}
?>