WhatsApp для сайта: заявки с формы — в WhatsApp менеджеру и клиенту

<?php
// lead.php — заявка с формы → WhatsApp менеджеру и клиенту
const MANAGER_PHONE = "77010000001";

function wapi_send(string $to, string $text): bool {
    $ch = curl_init("https://wapi.kz/api/v1/messages/send");
    curl_setopt_array($ch, [
        CURLOPT_POST => true,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => [
            "Authorization: Bearer " . getenv("WAPI_KEY"),
            "Content-Type: application/json",
        ],
        CURLOPT_POSTFIELDS => json_encode(["to" => $to, "text" => $text], JSON_UNESCAPED_UNICODE),
        CURLOPT_TIMEOUT => 15,
    ]);
    $data = json_decode((string) curl_exec($ch), true);
    $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    if ($code !== 200) error_log("wapi: " . ($data["code"] ?? $code) . " — " . ($data["error"] ?? ""));
    return $code === 200;
}

function normalize_phone(string $raw): ?string {
    $d = preg_replace('/\D/', '', $raw);
    if (strlen($d) === 11 && $d[0] === "8") $d = "7" . substr($d, 1);
    if (strlen($d) === 10) $d = "7" . $d;
    return (strlen($d) >= 11 && strlen($d) <= 15) ? $d : null;
}

if ($_SERVER["REQUEST_METHOD"] !== "POST") { http_response_code(405); exit; }
if (!empty($_POST["website"])) exit("ok");                 // honeypot: бот

$file = sys_get_temp_dir() . "/lead_" . md5($_SERVER["REMOTE_ADDR"]);
$hits = json_decode(@file_get_contents($file) ?: "[]", true) ?: [];
$hits = array_filter($hits, fn($t) => $t > time() - 600);
if (count($hits) >= 3) { http_response_code(429); exit("Слишком много заявок, попробуйте позже"); }
$hits[] = time();
file_put_contents($file, json_encode(array_values($hits)));

$name  = mb_substr(trim($_POST["name"] ?? ""), 0, 100);
$phone = normalize_phone($_POST["phone"] ?? "");
$msg   = mb_substr(trim($_POST["message"] ?? ""), 0, 1000);
if ($name === "" || $phone === null) { http_response_code(400); exit("Проверьте имя и телефон"); }

wapi_send(MANAGER_PHONE, "Заявка с сайта\nИмя: $name\nТелефон: +$phone\nВопрос: $msg");
if (!empty($_POST["consent"])) {
    sleep(2);                                                // не чаще 1 сообщения в секунду
    wapi_send($phone, "Здравствуйте, $name! Получили вашу заявку, менеджер свяжется в рабочее время.");
}
echo "ok";

import express from "express";

const app = express();
const hits = new Map();
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));

const normalizePhone = (raw) => {
  let d = String(raw || "").replace(/\D/g, "");
  if (d.length === 11 && d.startsWith("8")) d = "7" + d.slice(1);
  if (d.length === 10) d = "7" + d;
  return d.length >= 11 && d.length <= 15 ? d : null;
};

async function send(to, text) {
  try {
    const res = await fetch("https://wapi.kz/api/v1/messages/send", {
      method: "POST",
      headers: { Authorization: `Bearer ${process.env.WAPI_KEY}`, "Content-Type": "application/json" },
      body: JSON.stringify({ to, text }),
    });
    if (!res.ok) console.error("wapi:", res.status, await res.text());
  } catch (err) {
    console.error("wapi:", err.message);
  }
}

app.post("/lead", express.urlencoded({ extended: false }), async (req, res) => {
  const { name = "", phone: raw, message = "", consent, website } = req.body;
  if (website) return res.send("ok");                       // honeypot
  const recent = (hits.get(req.ip) || []).filter((t) => t > Date.now() - 600_000);
  if (recent.length >= 3) return res.status(429).send("Слишком много заявок");
  hits.set(req.ip, [...recent, Date.now()]);

  const phone = normalizePhone(raw);
  if (!name.trim() || !phone) return res.status(400).send("Проверьте имя и телефон");
  res.send("ok");                                           // не держим посетителя

  await send(process.env.MANAGER_PHONE, `Заявка с сайта\nИмя: ${name}\nТелефон: +${phone}\nВопрос: ${message}`);
  if (consent) {
    await sleep(2000);
    await send(phone, `Здравствуйте, ${name}! Получили вашу заявку, менеджер свяжется в рабочее время.`);
  }
});

app.listen(3000);

import os, re, time
import requests
from flask import Flask, request

app = Flask(__name__)
H = {"Authorization": f"Bearer {os.environ['WAPI_KEY']}"}
hits = {}


def normalize_phone(raw):
    d = re.sub(r"\D", "", raw or "")
    if len(d) == 11 and d.startswith("8"):
        d = "7" + d[1:]
    if len(d) == 10:
        d = "7" + d
    return d if 11 <= len(d) <= 15 else None


def send(to, text):
    try:
        r = requests.post("https://wapi.kz/api/v1/messages/send", headers=H,
                          json={"to": to, "text": text}, timeout=15)
        if r.status_code != 200:
            app.logger.error("wapi: %s %s", r.status_code, r.text[:300])
    except requests.RequestException as e:
        app.logger.error("wapi: %s", e)


@app.post("/lead")
def lead():
    f = request.form
    if f.get("website"):
        return "ok"  # honeypot
    ip = request.remote_addr
    recent = [t for t in hits.get(ip, []) if t > time.time() - 600]
    if len(recent) >= 3:
        return "Слишком много заявок", 429
    hits[ip] = recent + [time.time()]

    name, phone = f.get("name", "").strip(), normalize_phone(f.get("phone"))
    if not name or not phone:
        return "Проверьте имя и телефон", 400
    send(os.environ["MANAGER_PHONE"], f"Заявка с сайта\nИмя: {name}\nТелефон: +{phone}\nВопрос: {f.get('message', '')}")
    if f.get("consent"):
        time.sleep(2)
        send(phone, f"Здравствуйте, {name}! Получили вашу заявку, менеджер свяжется в рабочее время.")
    return "ok"