22

✏️ Editing: v3.php

<?php
declare(strict_types=1);

function generateReferenceId($prefix = 'REF')
{
    // Current timestamp
    $timestamp = date('YmdHis');

// Microseconds
    $micro = substr(str_replace('.', '', microtime(true)), -6);

// Random unique string
    $random = strtoupper(substr(md5(uniqid((string) mt_rand(), true)), 0, 6));

// Final Reference
    return strtoupper($prefix) . '-' . $timestamp . '-' . $micro . '-' . $random;
}

function getCampaignMapping(
    $host,
    $username,
    $password,
    $database,
    $adname,
    $campaign,
    $campaignactivity
) {
    // Create connection
    $mysqli = new mysqli($host, $username, $password, $database);

// Check connection
    if ($mysqli->connect_error) {
        return [
            'success' => false,
            'message' => 'Database connection failed: ' . $mysqli->connect_error
        ];
    }

$sql = "
        SELECT *
        FROM xx_deepal_campaign_activity
        WHERE LOWER(Adname) = LOWER(?)
          AND LOWER(campaign) = LOWER(?)
          AND LOWER(campaignactivity) = LOWER(?)
        LIMIT 1
    ";

$stmt = $mysqli->prepare($sql);

if (!$stmt) {
        $mysqli->close();
        return [
            'success' => false,
            'message' => 'Failed to prepare statement.'
        ];
    }

$stmt->bind_param(
        "sss",
        $adname,
        $campaign,
        $campaignactivity
    );

$stmt->execute();
    $result = $stmt->get_result();

if ($result->num_rows > 0) {
        $data = $result->fetch_assoc();

$stmt->close();
        $mysqli->close();

return [
            'success' => true,
            'data' => $data
        ];
    }

$stmt->close();
    $mysqli->close();

return [
        'success' => false,
        'message' => 'No matching record found.'
    ];
}

function extractCampaignCode($string) {
    if (preg_match('/\b(CAMP-\d+)\b/', $string, $matches)) {
        return $matches[1];
    }
    return null;
}

function transformFieldName($string) {
    $parts = explode('_', $string);

$result = array_shift($parts); // G318

foreach ($parts as $part) {
        $result .= ucfirst(strtolower($part));
    }

return $result;
}

function sendLeadAndLogToMySQL2(array $payload, array $opts): array
{
    // -----------------------------
    // 1) Required options
    // -----------------------------
    $endpoint = $opts['endpoint'] ?? '';
    if ($endpoint === '') {
        throw new InvalidArgumentException("Missing opts['endpoint'].");
    }

/** @var PDO $pdo */
    $pdo = $opts['pdo'] ?? null;
    if (!$pdo instanceof PDO) {
        throw new InvalidArgumentException("Missing opts['pdo'] (PDO instance).");
    }

// Basic Auth (as per your Postman request)
    $basicUser = $opts['basic_user'] ?? '';
    $basicPass = $opts['basic_pass'] ?? '';
    if ($basicUser === '' || $basicPass === '') {
        throw new InvalidArgumentException("Missing Basic Auth creds opts['basic_user'] and opts['basic_pass'].");
    }

// Optional headers
    // If you also need an extra Authorization header (Bearer/Token), pass it in opts['auth_header'].
    // It will be sent, but redacted in DB logs.
    $authHeader = $opts['auth_header'] ?? null; // e.g. "Bearer xxxxx" or "Basic xxxxx"
    $timeout    = (int)($opts['timeout'] ?? 30);
    $provider   = $opts['provider'] ?? 'almajdouie-soa';
    $method     = 'POST';

// -----------------------------
    // 2) Prepare request
    // -----------------------------
    
    $payload2 = [
    "lead_details" => [
        $payload
    ]
];
    
    $jsonBody = json_encode($payload2, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
    if ($jsonBody === false) {
        throw new RuntimeException("JSON encode failed: " . json_last_error_msg());
    }

$requestHeaders = [
        'Content-Type: application/json',
        'Accept: application/json',
    ];

if (is_string($authHeader) && trim($authHeader) !== '') {
        $requestHeaders[] = 'Authorization: ' . trim($authHeader);
    }

// For DB log: redact sensitive headers
    $headersForLog = [];
    foreach ($requestHeaders as $h) {
        if (stripos($h, 'Authorization:') === 0) {
            $headersForLog[] = 'Authorization: [REDACTED]';
        } else {
            $headersForLog[] = $h;
        }
    }

$requestHeadersJson = json_encode($headersForLog, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);

// -----------------------------
    // 3) cURL call
    // -----------------------------
    $ch = curl_init($endpoint);

// Capture response headers too
    $responseHeadersRaw = '';
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_POST           => true,
        CURLOPT_POSTFIELDS     => $jsonBody,
        CURLOPT_HTTPHEADER     => $requestHeaders,

// Basic auth
        CURLOPT_HTTPAUTH       => CURLAUTH_BASIC,
        CURLOPT_USERPWD        => $basicUser . ':' . $basicPass,

// timeouts
        CURLOPT_CONNECTTIMEOUT => $timeout,
        CURLOPT_TIMEOUT        => $timeout,

// SSL (keep verify true in production)
        CURLOPT_SSL_VERIFYPEER => true,
        CURLOPT_SSL_VERIFYHOST => 2,

// response headers capture
        CURLOPT_HEADERFUNCTION => function($curl, $headerLine) use (&$responseHeadersRaw) {
            $responseHeadersRaw .= $headerLine;
            return strlen($headerLine);
        },
    ]);

$start = microtime(true);
    $responseBody = curl_exec($ch);
    $end   = microtime(true);

$durationMs = (int)round(($end - $start) * 1000);

$curlErrNo  = curl_errno($ch);
    $curlErrMsg = curl_error($ch);
    $httpCode   = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE);

curl_close($ch);

// If curl_exec fails, $responseBody can be false
    if ($responseBody === false) {
        $responseBody = '';
    }

// -----------------------------
    // 4) Insert log into MySQL
    // -----------------------------
    $sql = "
        INSERT INTO deepal_api_request_logs2
        (provider, endpoint, method,
         request_headers_json, request_body_json,
         auth_type, auth_username,
         response_http_code, response_headers_raw, response_body,
         curl_errno, curl_error, duration_ms, created_at)
        VALUES
        (:provider, :endpoint, :method,
         :req_headers, :req_body,
         :auth_type, :auth_username,
         :http_code, :resp_headers, :resp_body,
         :curl_errno, :curl_error, :duration_ms, NOW())
    ";

$stmt = $pdo->prepare($sql);
    $stmt->execute([
        ':provider'      => $provider,
        ':endpoint'      => $endpoint,
        ':method'        => $method,

':req_headers'   => $requestHeadersJson,
        ':req_body'      => $jsonBody,

':auth_type'     => 'basic',
        ':auth_username' => $basicUser,

':http_code'     => $httpCode,
        ':resp_headers'  => $responseHeadersRaw,
        ':resp_body'     => (string)$responseBody,

':curl_errno'    => $curlErrNo ?: null,
        ':curl_error'    => ($curlErrNo ? $curlErrMsg : null),
        ':duration_ms'   => $durationMs,
    ]);

$logId = (int)$pdo->lastInsertId();

// -----------------------------
    // 5) Return a clean result
    // -----------------------------
    return [
        'ok'          => ($curlErrNo === 0 && $httpCode >= 200 && $httpCode < 300),
        'log_id'      => $logId,
        'http_code'   => $httpCode,
        'duration_ms' => $durationMs,
        'curl_errno'  => $curlErrNo,
        'curl_error'  => $curlErrNo ? $curlErrMsg : null,
        'response'    => $responseBody, // raw response
    ];
}

function sendLeadAndLogToMySQL(array $payload, array $opts): array
{
    // -----------------------------
    // 1) Required options
    // -----------------------------
    $endpoint = $opts['endpoint'] ?? '';
    if ($endpoint === '') {
        throw new InvalidArgumentException("Missing opts['endpoint'].");
    }

/** @var PDO $pdo */
    $pdo = $opts['pdo'] ?? null;
    if (!$pdo instanceof PDO) {
        throw new InvalidArgumentException("Missing opts['pdo'] (PDO instance).");
    }

// -----------------------------
    // 2) Prepare request
    // -----------------------------
    $jsonBody = json_encode($payload, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
    if ($jsonBody === false) {
        throw new RuntimeException("JSON encode failed: " . json_last_error_msg());
    }