Files
elcaribe/vendor/osenco/mpesa

Mpesa PHP SDK

Intuitive, Dynamic Mpesa PHP SDK

Supported APIs

API Type Application Scenario
STK - SIM Tool Kit Prompt Customer Online Checkout
C2B - Customer To Business Reconciling Manual Payments
B2C - Business To Customer Salary Payments, Disbursals, Reversals
Account Balance Check Accounting Purposes
Transaction Status Check Failed Transactions
Transaction Reversal Wrongful Payment

Installation

Install via composer by typing in your terminal

composer require osenco/mpesa

If you do not use composer you can just download this library from the releases, unzip it in your project and include the autoload.php file in your project.

require_once("path/to/autoload.php");

For Laravel Users, there is a detailed guide here as well as a sample controller

Usage

Import Class With Namespace

Import the class namespace into your class or app to make it available for use. Replace STK with your API of choice. We will be using STK here. See how to set up C2B here, B2C here and B2B here.

use Osen\Mpesa\STK;

Instantiating The Class

The class uses static methods and does not need to be instantiated. This is to persist configuration in memory troughout execution of the script. To pass configuration options to the object, use the init() method at the top of your script. The headoffice key is only required for Till Numbers. Paybill users can ignore it.

STK::init(
    array(
        "env"               => "sandbox",
        "type"              => 4, // For Paybill, or, 2 for Till, 1	for MSISDN
        "shortcode"         => "174379",
        "headoffice"        => "174379", // Ignore if using Paybill
        "key"               => "Your Consumer Key",
        "secret"            => "Your Consumer Secret",
        "username"          => "", // Required for B2B and B2C APIs only
        "password"          => "", // Required for B2B and B2C APIs only
        "passkey"           => "Your Online Passkey",
        "validation_url"    => url("mpesa/validate"),
        "confirmation_url"  => url("mpesa/confirm"),
        "callback_url"      => url("mpesa/reconcile"),
        "results_url"       => url("mpesa/results"),
    )
);

TIP: You can just pass your URL endpoints for testing on sandbox, the system will use the test credentials provided from Daraja.

Making A Payment Request

Wrap your request in a try catch to ensure proper error handling

try {
    return $res = STK::send($phone, $amount, $reference);

    // Do something with $res, like save to DB with the $res["MerchantRequestID"] as key.
} catch (\Throwable $th) {
    return $th;
}

Reconciling The Payment

The Mpesa transaction requests are asynchronous, and as such the payment details are not instantaneous. To get the transaction data and update the payment, use the reconcile() method. A callback function may be supplied to process the data. The callback function can either be a defined funtion or a closure(anonymous). If ommited, the method will return a successful response by default.

STK::reconcile();
STK::reconcile(function ($response){
    $response                   = $response["Body"];
    $resultCode 			    = $response["stkCallback"]["ResultCode"];
    $resultDesc 			    = $response["stkCallback"]["ResultDesc"];
    $merchantRequestID 			= $response["stkCallback"]["MerchantRequestID"];
    
    if(isset($response["stkCallback"]["CallbackMetadata"])){
        $CallbackMetadata       = $response["stkCallback"]["CallbackMetadata"]["Item"];

        $amount                 = $CallbackMetadata[0]["Value"];
        $mpesaReceiptNumber     = $CallbackMetadata[1]["Value"];
        $balance                = $CallbackMetadata[2]["Value"];
        $transactionDate        = $CallbackMetadata[3]["Value"];
        $phone                  = $CallbackMetadata[4]["Value"];
    
        $payment->status        = "Paid";
        $payment->amount        = $amount;
        $payment->receipt       = $mpesaReceiptNumber;
    }

    return true;
});

Processing Timeouts

When a valid M-Pesa API request is received by the API Gateway, it is sent to M-Pesa where it is added to a queue. M-Pesa then processes the requests in the queue and sends a response to the API Gateway which then forwards the response to the URL registered in the CallBackURL or ResultURL request parameter. Whenever M-Pesa receives more requests than the queue can handle, M-Pesa responds by rejecting any more requests and the API Gateway sends a queue timeout response to the URL registered in the QueueTimeOutURL request parameter. Use the timeout() method to process this response.

STK::timeout();

This function takes the data sent by Safaricom, and returns a response. You can pass an optional argument to process the data and return true.

STK::timeout(function ($response){
    // Do something with $response
    return true;
});

Check Transaction Status

You can check for the status of a transaction by calling the `status" method at your endpoint.

STK::status($transaction, $command = "TransactionStatusQuery", $remarks = "Transaction Status Query", $occassion = "Transaction Status Query");

You can pass an optional fifth argument that is a callback for processing the response from the request and returning true.

STK::status($transaction, $command, $remarks, $occassion, function ($response){
    // Do something with $response
    return true;
});

Reverse Transaction

To reverse a transaction, call the reverse method at your endpoint.

STK::reverse($transaction, $amount, $receiver, $receiver_type = 3, $remarks = "Transaction Reversal", $occassion = "Transaction Reversal");

You can pass an optional seventh argument that is a callback for processing the response from the request and returning true.

STK::reverse($transaction, $amount, $receiver, $receiver_type = 3, $remarks = "Transaction Reversal", $occassion = "", function ($response){
    // Do something with $response
    return true;
});

Check Account Balance

To reverse a transaction, call the reverse method at your endpoint.

STK::balance($command, $remarks = "Balance Query", $occassion = "");

You can pass an optional callback for processing the response from the request and returning true.

STK::balance($command, $remarks = "Balance Query", function ($response){
    // Do something with $response
    return true;
});

Processing Results

To process results from a transaction statuscheck, or a reversal, or an account balance check, call the result method at your endpoint.

STK::result();

You can pass an optional callback for processing the response from the request and returning true.

STK::result(function ($response){
    // Process account balance check results
    $result                     = $response["Result"];
    $ResultType                 = $result["ResultType"];
	$ResultCode                 = $result["ResultCode"];
	$ResultDesc                 = $result["ResultDesc"];
	$OriginatorConversationID   = $result["OriginatorConversationID"];
	$ConversationID             = $result["ConversationID"];
	$TransactionID              = $result["TransactionID"];
	$ResultParameters           = $result["ResultParameters"];
	
    $ResultParameter            = $ResultParameters["ResultParameter"];
	$ReceiptNo                  = $ResultParameter[0]["Value"];
	$Conversation               = $ResultParameter[1]["Value"];
	$FinalisedTime              = $ResultParameter[2]["Value"];
	$Amount                     = $ResultParameter[3]["Value"];
	$TransactionStatus          = $ResultParameter[4]["Value"];
	$ReasonType                 = $ResultParameter[5]["Value"];
    $TransactionReason          = $ResultParameter[6]["Value"];
    $DebitPartyCharges          = $ResultParameter[7]["Value"];
    $DebitAccountType           = $ResultParameter[8]["Value"];
    $InitiatedTime              = $ResultParameter[9]["Value"];
    $OriginatorConversationID   = $ResultParameter[10]["Value"];
    $CreditPartyName            = $ResultParameter[11]["Value"];
    $DebitPartyName             = $ResultParameter[12]["Value"];
    
    $ReferenceData              = $result["ReferenceData"];
    $ReferenceItem              = $ReferenceData["ReferenceItem"];
	$Occasion                   = $ReferenceItem["Value"];


    // Process transaction reversal results
    $Result                     = $response["Result"];
	$ResultType                 = $Result["ResultType"];
	$ResultCode                 = $Result["ResultCode"];
	$ResultDesc                 = $Result["ResultDesc"];
	$OriginatorConversationID   = $Result["OriginatorConversationID"];
	$ConversationID             = $Result["ConversationID"];
	$TransactionID              = $Result["TransactionID"];
	$ReferenceData              = $Result["ReferenceData"];
	$ReferenceItem              = $Result["ReferenceItem"];
	$QueueTimeoutURL            = $ReferenceItem["Value"];

    // Process transaction status check results
    $Result                     = $response["Result"];
	$ResultType                 = $Result["ResultType"];
	$ResultCode                 = $Result["ResultCode"];
	$ResultDesc                 = $Result["ResultDesc"];
	$OriginatorConversationID   = $Result["OriginatorConversationID"];
	$ConversationID             = $Result["ConversationID"];
	$TransactionID              = $Result["TransactionID"];
	$ResultParameters           = $Result["ResultParameters"];
	$ResultParameter            = $ResultParameters["ResultParameter"];
	$ReceiptNo                  = $ResultParameter[0]["Value"];
	$ConversationID             = $ResultParameter[1]["Value"];
	$FinalisedTime              = $ResultParameter[2]["Value"];
	$Amount                     = $ResultParameter[3]["Value"];
	$TransactionStatus          = $ResultParameter[4]["Value"];
	$ReasonType                 = $ResultParameter[5]["Value"];
	$TransactionReason          = $ResultParameter[6]["Value"];
	$DebitPartyCharges          = $ResultParameter[7]["Value"];
	$DebitAccountType           = $ResultParameter[8]["Value"];
	$InitiatedTime              = $ResultParameter[9]["Value"];
	$OriginatorConversationID   = $ResultParameter[10]["Value"];
	$CreditPartyName            = $ResultParameter[11]["Value"];
	$DebitPartyName             = $ResultParameter[12]["Value"];

    $ReferenceData              = $result["ReferenceData"];
    $ReferenceItem              = $ReferenceData["ReferenceItem"];
	$Occasion                   = $ReferenceItem["Value"];


    //TIP: You can differentiate between responses by checking value of $ResultType
    return true;
});

Available Command IDs

Command ID Description
TransactionReversal Reversal for an erroneous C2B transaction.
SalaryPayment Used to send money from an employer to employees e.g. salaries
BusinessPayment Used to send money from business to client e.g. refunds
PromotionPayment Used to send money when promotions take place e.g. raffle winners
AccountBalance Used to check the balance in a paybill/buy goods account (includes utility, MMF, Merchant, Charges paid account).
CustomerPayBillOnline Used to simulate a transaction taking place in the case of C2B Simulate Transaction or to initiate a transaction on behalf of the client (STK Push).
TransactionStatusQuery Used to query the details of a transaction.
CheckIdentity Similar to STK push, uses M-Pesa PIN as a service.
BusinessPayBill Sending funds from one paybill to another paybill
BusinessBuyGoods sending funds from buy goods to another buy goods.
DisburseFundsToBusiness Transfer of funds from utility to MMF account.
BusinessToBusinessTransfer Transferring funds from one paybills MMF to another paybills MMF account.
BusinessTransferFromMMFToUtility Transferring funds from paybills MMF to another paybills utility account.

Helper Functions

You can use the helper function s for more concise code

To configure the class, use the mpesa_setup_config function , passing your configuration options as the first argument, and the API you wish to setup(STK, C2B, B2C, B2B) as the second argument. The API is set to STK by default.

$config = array(
    "env"               => "sandbox",
    "type"              => 4, // For Paybill, or, 2 for Till, 1	for MSISDN
    "shortcode"         => "174379",
    "headoffice"          => "174379",
    "key"               => "Your Consumer Key",
    "secret"            => "Your Consumer Secret",
    "username"          => "",
    "passkey"           => "Your Online Passkey",
    "validation_url"    => url("mpesa/validate"),
    "confirmation_url"  => url("mpesa/confirm"),
    "callback_url"      => url("mpesa/reconcile"),
    "results_url"       => url("mpesa/results"),
);
mpesa_setup_config($config, "STK");

Optionally, you could configure with the mpesa_setup_* function s

mpesa_setup_stk($config);
mpesa_setup_c2b($config);
mpesa_setup_b2c($config);
mpesa_setup_b2b($config);

To make a STK Prompt request, pass the user"s phone number, the amount due, and an optional reference(shows up on the user"s phone) respectively

mpesa_stk_push($phone, $amount, $reference);

To simulate a c2b transaction, call the function as follows, passing the user"s phone number, the amount due, and an optional reference respectively

mpesa_c2b_request($phone, $amount, $reference);

To send funds to a client

mpesa_b2c_request();

Transfer funds between one business to another

mpesa_b2b_request();

Validate Or Confirm Transaction Details. Call this function at your validation/confirmation endpoint.

mpesa_validate();
mpesa_confirm()

Credits & Acknowledgements

Mpesa is a service and registered trademark of Safaricom PLC.

Licensing

This software is released under MIT License.

Usage & Contribution

This library is free and open source software. You can copy, modify and distribute it as you so wish. If you have any ideas on how to improve it, shoot us an email at hi@osen.co.ke or raise an issue here.