Code Snippets

<?php
/**
 * Daraja API - Callback Handler
 * Process STK Push callbacks
 */

// mpesa-callback.php
header("Content-Type: application/json");

// Get the callback data
$callbackData = file_get_contents("php://input");
$data = json_decode($callbackData, true);

// Log the callback for debugging
file_put_contents("mpesa_log.txt", date("Y-m-d H:i:s") . " - Callback received: " . $callbackData . PHP_EOL, FILE_APPEND);

// Check if this is an STK Push callback
if (isset($data["Body"]["stkCallback"])) {
    $callback = $data["Body"]["stkCallback"];
    
    $merchantRequestID = $callback["MerchantRequestID"] ?? "";
    $checkoutRequestID = $callback["CheckoutRequestID"] ?? "";
    $resultCode = $callback["ResultCode"] ?? "";
    $resultDesc = $callback["ResultDesc"] ?? "";
    
    // Process based on result code
    if ($resultCode == 0) {
        // Successful payment
        $metadata = $callback["CallbackMetadata"]["Item"] ?? [];
        
        $amount = 0;
        $mpesaReceiptNumber = "";
        $transactionDate = "";
        $phoneNumber = "";
        
        foreach ($metadata as $item) {
            switch ($item["Name"]) {
                case "Amount":
                    $amount = $item["Value"];
                    break;
                case "MpesaReceiptNumber":
                    $mpesaReceiptNumber = $item["Value"];
                    break;
                case "TransactionDate":
                    $transactionDate = $item["Value"];
                    break;
                case "PhoneNumber":
                    $phoneNumber = $item["Value"];
                    break;
            }
        }
        
        // TODO: Update your database with successful transaction
        
        $response = [
            "ResultCode" => 0,
            "ResultDesc" => "Success"
        ];
    } else {
        // Failed payment
        $response = [
            "ResultCode" => $resultCode,
            "ResultDesc" => $resultDesc
        ];
    }
    
    echo json_encode($response);
} else {
    // Handle other callback types
    echo json_encode(["ResultCode" => 0, "ResultDesc" => "Success"]);
}
?>

<?php
$host = "localhost";
$dbname = "database";
$user = "username";
$pass = "password";

try {
    $pdo = new PDO("mysql:host=$host;dbname=$dbname", $user, $pass);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
    echo "Connected successfully";
} catch(PDOException $e) {
    echo "Connection failed: " . $e->getMessage();
}
?>