pesafyM-PESA Daraja SDK

Type-safe, framework-agnostic SDK for Safaricom Daraja 2.0 — built for Node.js, Bun, Deno, Cloudflare Workers, Next.js, Fastify, Hono, and Express.

Get Started →

API Reference

GitHub

🔒

Fully Type-Safe

Complete TypeScript types for every Daraja API — requests, responses, webhook payloads, and result codes. Catch mistakes at compile time with branded primitives like KesAmount and MsisdnKE.

Branded Types →

⚡

Every Daraja API

STK Push, C2B, B2C, B2B Express Checkout, B2B Buy Goods, B2B Pay Bill, B2C Disbursement, Account Balance, Transaction Status, Reversal, Tax Remittance, Dynamic QR, Bill Manager.

API Reference →

🔌

Framework Adapters

Drop-in adapters for Express, Hono, Next.js App Router, and Fastify. Mount all M-PESA routes with a single function call — webhook handlers, result callbacks, and health checks included.

Adapters →

🖥️

Powerful CLI

Scaffold .env interactively, test STK Pushes, query transactions, encrypt credentials, validate phone numbers, and run a health check — all from npx pesafy.

CLI Reference →

🔄

Auto Retry & Resilience

Exponential backoff with ±25% jitter on transient Daraja 5xx errors. Up to 4 retries by default, configurable per client. 4xx errors are never retried.

Error Handling →

🧩

Result — No Exceptions

Use stkPushSafe() and accountBalanceSafe() for Result discriminated unions. Composable, pipeable, and zero try/catch required.

Result Type →

Zero boilerplate. Production-ready.

import { Mpesa } from 'pesafy'

const mpesa = new Mpesa({
  consumerKey: process.env.MPESA_CONSUMER_KEY!,
  consumerSecret: process.env.MPESA_CONSUMER_SECRET!,
  environment: 'sandbox',
  lipaNaMpesaShortCode: process.env.MPESA_SHORTCODE!,
  lipaNaMpesaPassKey: process.env.MPESA_PASSKEY!,
})

// STK Push — prompt customer on their phone
const response = await mpesa.stkPush({
  amount: 100,
  phoneNumber: '0712345678',
  callbackUrl: 'https://yourapp.com/api/mpesa/callback',
  accountReference: 'INV-001',
  transactionDesc: 'Payment',
})

console.log(response.CheckoutRequestID)