Connexus/Bulletin Connect API Migration

<?php
// Register webhook first
$ch = curl_init('https://websms.co.nz/api/connexus/sms/status');
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query([
    'userId' => 'user@domain.co.nz',
    'password' => 'yourpassword',
    'url' => 'https://yoursite.com/webhook/status.php'
]));
curl_exec($ch);
curl_close($ch);

// Then in your webhook handler (status.php):
$data = json_decode(file_get_contents('php://input'), true);

if ($data['status'] == 'DELIVRD') {
    // Message was delivered
    error_log("Message {$data['messageId']} delivered");
} elseif ($data['status'] == 'UNDELIV') {
    // Message failed
    error_log("Message {$data['messageId']} failed");
}
?>

<?php
// Register webhook first
$ch = curl_init('https://websms.co.nz/api/connexus/sms/in');
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query([
    'userId' => 'user@domain.co.nz',
    'password' => 'yourpassword',
    'url' => 'https://yoursite.com/webhook/incoming.php'
]));
curl_exec($ch);
curl_close($ch);

// Then in your webhook handler (incoming.php):
$data = json_decode(file_get_contents('php://input'), true);

// Process incoming message
$from = $data['from'];
$message = $data['body'];

// Reply to the message
$ch = curl_init('https://websms.co.nz/api/connexus/sms/out');
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query([
    'userId' => 'user@domain.co.nz',
    'password' => 'yourpassword',
    'to' => ltrim($from, '+'),  // Remove + prefix
    'body' => 'Thank you for your message!'
]));
curl_exec($ch);
curl_close($ch);
?>

<?php
// Query incoming messages
$ch = curl_init('https://websms.co.nz/api/connexus/mo/query');
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query([
    'userId' => 'user@domain.co.nz',
    'password' => 'yourpassword',
    'from' => '6421234567',
    'start_date' => '2025-01-01',
    'end_date' => '2025-01-31',
    'limit' => 100,
    'page' => 1
]));
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);

if ($httpCode == 200) {
    $data = json_decode($response, true);

    echo "Total messages: " . $data['pagination']['totalRecords'] . "\n";

    foreach ($data['messages'] as $msg) {
        echo "From: {$msg['from']}, Message: {$msg['body']}\n";
    }

    // Fetch next page if available
    if ($data['pagination']['hasNextPage']) {
        // Query with page=2
    }
} else {
    echo "Error: HTTP $httpCode";
}
?>

<?php
// Check account balance
$ch = curl_init('https://websms.co.nz/api/connexus/sms/balance');
curl_setopt($ch, CURLOPT_POST, 1);
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query([
    'userId' => 'user@domain.co.nz',
    'password' => 'yourpassword'
]));
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);

if ($httpCode == 200) {
    $data = json_decode($response, true);
    echo "Current balance: $" . $data['balance'] . " " . $data['currency'];
} else {
    echo "Error: HTTP $httpCode";
}
?>

<?php
// Send OTP code
function sendOTP($phone, $company) {
    $ch = curl_init('https://websms.co.nz/api/connexus/sms/otp');
    curl_setopt($ch, CURLOPT_POST, 1);
    curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query([
        'userId' => 'user@domain.co.nz',
        'password' => 'yourpassword',
        'to' => $phone,
        'msgCompany' => $company,
        'msgComment' => 'Valid for 5 minutes.'
    ]));
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    if ($httpCode == 200) {
        $data = json_decode($response, true);

        // Store the code in your database/session for verification
        $_SESSION['otp_code'] = $data['code'];
        $_SESSION['otp_expires'] = time() + 300; // 5 minutes

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

    return ['success' => false, 'error' => "HTTP $httpCode"];
}

// Verify OTP code
function verifyOTP($userInput) {
    if (!isset($_SESSION['otp_code']) || !isset($_SESSION['otp_expires'])) {
        return false;
    }

    if (time() > $_SESSION['otp_expires']) {
        unset($_SESSION['otp_code'], $_SESSION['otp_expires']);
        return false; // Expired
    }

    if ($userInput === $_SESSION['otp_code']) {
        unset($_SESSION['otp_code'], $_SESSION['otp_expires']);
        return true; // Valid
    }

    return false; // Invalid
}

// Usage:
$result = sendOTP('6421234567', 'MyApp');
if ($result['success']) {
    echo "OTP sent! Code: " . $result['code'];
}

// Later, when user submits code:
if (verifyOTP($_POST['otp_input'])) {
    echo "Verified!";
} else {
    echo "Invalid or expired code";
}
?>