Welcome to DrutoPay Documentation

<?php
use GuzzleHttp\Client;
use GuzzleHttp\Psr7\Request;

$client = new Client();
$headers = [
  'API-KEY'      => 'YOUR_BRAND_KEY',
  'Content-Type' => 'application/json'
];
$body = json_encode([
  'transaction_id' => 'TRX12345678'
]);

$request = new Request('POST', 'https://pay.drutopay.com/api/payment/verify', $headers, $body);
$res = $client->sendAsync($request)->wait();
echo $res->getBody();
?>

const axios = require('axios');

const data = JSON.stringify({
  transaction_id: "TRX12345678"
});

const config = {
  method: 'post',
  url: 'https://pay.drutopay.com/api/payment/verify',
  headers: { 
    'API-KEY': 'YOUR_BRAND_KEY',
    'Content-Type': 'application/json'
  },
  data: data
};

axios(config)
  .then((response) => {
    console.log(response.data);
  })
  .catch((error) => {
    console.error(error);
  });

import requests
import json

url = "https://pay.drutopay.com/api/payment/verify"

payload = json.dumps({
  "transaction_id": "TRX12345678"
})

headers = {
  'API-KEY': 'YOUR_BRAND_KEY',
  'Content-Type': 'application/json'
}

response = requests.post(url, headers=headers, data=payload)
print(response.json())

package main

import (
  "fmt"
  "strings"
  "net/http"
  "io"
)

func main() {
  url := "https://pay.drutopay.com/api/payment/verify"
  payload := strings.NewReader(`{"transaction_id":"TRX12345678"}`)

  req, _ := http.NewRequest("POST", url, payload)
  req.Header.Add("API-KEY", "YOUR_BRAND_KEY")
  req.Header.Add("Content-Type", "application/json")

  res, err := http.DefaultClient.Do(req)
  if err != nil {
    fmt.Println(err)
    return
  }
  defer res.Body.Close()

  body, _ := io.ReadAll(res.Body)
  fmt.Println(string(body))
}

<?php
namespace App\Http\Controllers;

use Illuminate\Http\Request;
use Illuminate\Support\Facades\Http;

class DrutoPayWebhookController extends Controller
{
    public function handle(Request $request)
    {
        $transactionId = $request->input('transactionId');
        $paymentMethod = $request->input('paymentMethod');
        $paymentAmount = $request->input('paymentAmount');
        $cusName       = $request->input('cus_name');
        $cusEmail      = $request->input('cus_email');
        $metadata      = $request->input('metadata');
        $status        = $request->input('status');

        if ($status !== 'completed' || empty($transactionId)) {
            return response()->json(['status' => 'ignored'], 200);
        }

        // Verify transaction authenticity with DrutoPay API
        $verifyRes = Http::withHeaders([
            'API-KEY'      => env('DRUTOPAY_API_KEY'), // Your Brand Secret Key
            'Content-Type' => 'application/json'
        ])->post('https://pay.drutopay.com/api/payment/verify', [
            'transaction_id' => $transactionId
        ]);

        if ($verifyRes->successful() && $verifyRes->json('status')) {
            // TODO: Avoid duplicate credit by checking Order::where('trx_id', $transactionId)->exists()
            // TODO: Mark Order as Paid / credit user wallet

            return response()->json(['status' => 'success'], 200);
        }

        return response()->json(['status' => 'verification_failed'], 400);
    }
}

const express = require('express');
const axios = require('axios');
const app = express();

app.use(express.json());
app.use(express.urlencoded({ extended: true }));

app.post('/api/drutopay-webhook', async (req, res) => {
    const { paymentMethod, transactionId, paymentAmount, paymentFee, cus_name, cus_email, cus_phone, metadata, status } = req.body;

    if (status !== 'completed' || !transactionId) {
        return res.status(200).json({ status: 'ignored' });
    }

    try {
        // Verify transaction with DrutoPay server
        const verifyResponse = await axios.post('https://pay.drutopay.com/api/payment/verify', {
            transaction_id: transactionId
        }, {
            headers: {
                'API-KEY': 'YOUR_BRAND_KEY',
                'Content-Type': 'application/json'
            }
        });

        if (verifyResponse.data && verifyResponse.data.status) {
            // TODO: Check database to prevent duplicate processing
            // TODO: Update order to completed and deliver service
            return res.status(200).json({ status: 'success' });
        }
    } catch (err) {
        console.error('DrutoPay verification error:', err.message);
    }

    res.status(200).json({ status: 'received' });
});

app.listen(3000, () => console.log('Webhook server running on port 3000'));

from flask import Flask, request, jsonify
import requests

app = Flask(__name__)

@app.route('/api/drutopay-webhook', methods=['POST'])
def drutopay_webhook():
    data = request.get_json(silent=True) or request.form.to_dict()
    
    transaction_id = data.get('transactionId')
    status = data.get('status')
    amount = data.get('paymentAmount')
    provider = data.get('paymentMethod')

    if status == 'completed' and transaction_id:
        # Verify transaction with DrutoPay API
        verify_url = "https://pay.drutopay.com/api/payment/verify"
        headers = {
            "API-KEY": "YOUR_BRAND_KEY",
            "Content-Type": "application/json"
        }
        resp = requests.post(verify_url, json={"transaction_id": transaction_id}, headers=headers)
        res_json = resp.json()

        if res_json.get('status'):
            # TODO: Update order in database to Paid
            return jsonify({"status": "success"}), 200

    return jsonify({"status": "received"}), 200

if __name__ == '__main__':
    app.run(port=5000)