Authentication

/**
* Refactored Cepta Adapter Test Client
* Tested with Node.js 18+
*/

const axios = require('axios');
const crypto = require('crypto');
const FormData = require('form-data');

// App credentials and base URL
const APP_PUBLIC_KEY = 'test_pubk_xxx';
const APP_SECRET_KEY = 'test_scrk_xxxx';
const APP_BASE_URL = 'https://adapter.cepta.co';

// Axios client
const apiClient = axios.create({
baseURL: APP_BASE_URL,
headers: {
'Accept': 'application/json',
'X-Access-Key': APP_PUBLIC_KEY,
},
});

// 🔐 Interceptor for automatic signing
apiClient.interceptors.request.use(
(config) => {
console.log(`[REQUEST] ${config.method.toUpperCase()} ${config.url}`);
return createSignature(config);
},
(error) => {
console.error('Request interceptor error:', error.message);
return Promise.reject(error);
}
);

// Function to create HMAC signature
function createSignature(config) {
console.log('🔑 Creating a signature for the request...');

const ts = Math.floor(Date.now() / 1000); // Unix timestamp (seconds)
const urlObj = new URL(config.url, config.baseURL || APP_BASE_URL);
const path = urlObj.pathname;

// Create HMAC SHA256 signature
const hmac = crypto.createHmac('sha256', APP_SECRET_KEY);

// Base string format: timestamp + method + path + (body if present)
hmac.update(ts + config.method.toUpperCase() + path);

if (config.data instanceof FormData) {
// For multipart/form-data
hmac.update(config.data.getBuffer());
} else if (config.data) {
// For JSON or text
const dataString =
typeof config.data === 'string' ? config.data : JSON.stringify(config.data);
hmac.update(dataString);
}

const signature = hmac.digest('hex');

// Inject headers
config.headers['X-Access-Ts'] = ts;
config.headers['X-Access-Signature'] = signature;

console.log(`🕒 Timestamp: ${ts}`);
console.log(`🔏 Signature: ${signature}`);
console.log('----------------------------------');

return config;
}

// 💳 Purchase API
async function purchase(reqBody) {
console.log('🚀 Initiating purchase request...');
return apiClient.post('/api/v1/pay', reqBody, {
headers: {
'Content-Type': 'application/json',
},
});
}

// 📦 Confirm status API
async function confirmStatus(transactionRef) {
console.log('📡 Getting transaction status...');
return apiClient.get('/api/v1/pay/confirm-status', {
params: { TransactionRef: transactionRef },
});
}

// 🧭 Entry point
async function main() {
try {
const purchaseRequest = {
amount: 100,
currency: 'NGN',
description: 'test sample',
pageName: '',
transactionReference: 'TX12345ABZIRITCZ',
customerEmail: '[email protected]',
customUrlText: 'callback',
callbackUrl: 'https://api.example.com',

};

const purchaseResponse = await purchase(purchaseRequest);
console.log('✅ Purchase Response:\n', purchaseResponse.data);

const sampleRef = 'xgdadfdvcdfdsddgd';
const statusResponse = await confirmStatus(sampleRef);
console.log('✅ Status Response:\n', statusResponse.data);
} catch (error) {
console.error('❌ Error--:', error.message);
if (error.response) {
console.error('Response Data:', error.response.data);
console.error('Status:', error.response.status);
}
}
}

main();