unifiedpayment/app/Library/AirtelMoneyMw/testing.php

<?php
$incoming=file_get_contents("php://input");
$data=json_decode($incoming,true);


$subscriber_country = $data['subscriber']['country'];
$subscriber_currency = $data['subscriber']['currency'];
$subscriber_msisdn = $data['subscriber']['msisdn'];

$transaction_amount = $data['transaction']['amount'];
$transaction_country = $data['transaction']['country'];
$transaction_currency = $data['transaction']['currency'];
$transaction_id = $data['transaction']['id'];


$authURL="https://openapiuat.airtel.africa/auth/oauth2/token";
/*CEDAR CAPITAL
$clientID="94351d4d-4909-4056-ad9d-8052a332d6b9";
$clientSecret="bf665590-2519-49af-8d1f-7cd0dce1dc7a";*/


//CONTINENTAL CAPITAL
$clientID="9ff18a6d-331e-4ec5-9ecc-4e512e13747c";
$clientSecret="40f44254-10e7-4eb8-b161-38125117f4ba"; 


$res=authenticate($authURL, $clientID, $clientSecret);

if($res['success']){
	$bearerToken=$res['token'];
	
	//send a ussd push
	$res=sendUSSDPush($bearerToken, $data);
	$data = json_decode($res, true);

	// Check if the response has a status and success flag  
	if (isset($data['status']['success']) && $data['status']['success'] === true) {
		// Success case
		$transactionId = $data['data']['transaction']['id'];
		$transactionStatus = $data['data']['transaction']['status'];
		$message = $data['status']['message'];

		echo "✅ Transaction Successful!\n";
		echo "Transaction ID: $transactionId\n";
		echo "Status: $transactionStatus\n";
		echo "Message: $message\n"; 
	} else {
		// Failure case
		$errorCode = $data['status']['result_code'] ?? 'N/A';
		$errorMessage = $data['status']['message'] ?? 'Unknown error';
		
		echo "❌ Transaction Failed!\n";
		echo "Error Code: $errorCode\n";
		echo "Message: $errorMessage\n";
	}
	
	
}else{
	echo(print_r($res,true));
	exit();
}




function sendUSSDPush($token, $data) {
    // Endpoint
    $url = "https://openapiuat.airtel.africa/merchant/v1/payments/"; 

    // Initialize cURL
    $ch = curl_init($url);

    // Set cURL options
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        "Authorization: Bearer " . $token,
        "Content-Type: application/json",
		"X-Country: MW",
		"X-Currency: MWK"
    ]);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));

    // Execute request
    $response = curl_exec($ch);

    // Check for cURL errors
    if (curl_errno($ch)) {
        echo "cURL Error: " . curl_error($ch);
        curl_close($ch);
        return false;
    }

    // Close connection
    curl_close($ch);

    // Decode and return response
    return $response;
}

function changePassword($baseURL, $token,$newPassword, $newPasswordConfirmation) {
    // Endpoint URL
    $url = rtrim($baseURL, "/") . "/password";

    // Prepare data
    $data = [
        "new_password" => $newPassword,
        "new_password_confirmation" => $newPasswordConfirmation
    ];

    // Initialize cURL
    $ch = curl_init($url);

    // Set cURL options
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "PATCH"); // PATCH request
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        "Authorization: Bearer " . $token,
        "Content-Type: application/json"
    ]);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));

    // Execute and capture response
    $response = curl_exec($ch);

    // Check for errors
    if (curl_errno($ch)) {
        echo "cURL Error: " . curl_error($ch);
        curl_close($ch);
        return false;
    }

    // Close connection
    curl_close($ch);

    // Decode JSON response
    return json_decode($response, true);
}

function validate_msisdn($baseURL, $msisdn, $bearerToken)
{
    // Ensure proper endpoint format
    $url = rtrim($baseURL, '/') . '/payments/validate/' . urlencode($msisdn);

    // Initialize cURL
    $ch = curl_init($url);

    // Set cURL options
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPGET, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $bearerToken,
        'Accept: application/json'
    ]);

    // Execute the request
    $response = curl_exec($ch);

    // Handle cURL error
    if (curl_errno($ch)) {
        curl_close($ch);
        return [
            'success' => false,
            'error' => 'Curl error: ' . curl_error($ch)
        ];
    }

    // Get HTTP status code
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    // Decode JSON response
    $result = json_decode($response, true);

    if ($httpCode === 200 && isset($result['data']['full_name'])) {
        return [
            'success' => true,
            'full_name' => $result['data']['full_name']
        ];
    } else {
        return [
            'success' => false,
            'error' => $result['message'] ?? 'Unknown error',
            'details' => $result['errors'] ?? []
        ];
    }
}



function authenticate($baseURL, $wallet, $password)
{
    // JSON payload
    $postData = json_encode([
        'client_id' => $wallet,
        'client_secret' => $password,
		'grant_type' => "client_credentials"
    ]);

    // Initialize cURL
    $ch = curl_init($baseURL);

    // Set cURL options
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // Return the response
    curl_setopt($ch, CURLOPT_POST, true);           // Use POST method
    curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);// Set the request body
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Content-Type: application/json',
        'Content-Length: ' . strlen($postData)
    ]);

    // Execute the request
    $response = curl_exec($ch);

    // Check for cURL errors
    if (curl_errno($ch)) {
        curl_close($ch);
        return [
            'success' => false,
            'error' => 'Curl error: ' . curl_error($ch)
        ];
    }

    // Get HTTP status code
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    // Decode JSON response
    $result = json_decode($response, true);

    // Check if token is present
    if ($httpCode === 200 && isset($result['access_token'])) {
        return [
            'success' => true,
            'token' => $result['access_token']
        ];
    } else {
        return [
            'success' => false,
            'error' => $result['error_description'] ?? 'Unknown error',
            'details' => $result['error'] ?? []
        ];
    }
}

?>