Building an SMS Notification System with an API

const Queue = require('bull');const axios = require('axios');const smsQueue = new Queue('sms', { redis: { host: 'localhost' } });// Your event handler: queue the messageapp.post('/webhooks/order-placed', async (req, res) => {  const { phone, orderId } = req.body;  await smsQueue.add({    to: phone,    // example link only; links in SMS must be whitelisted on your DLT portal    message: `Order ${orderId} confirmed. Track: https://example.com/t/${orderId}`,  }, { attempts: 3, backoff: { type: 'exponential', delay: 1000 } });  res.json({ queued: true });});// Queue worker: one call to the SMS endpoint per job.// A retry after a timeout can send twice, so record each send first.smsQueue.process(async (job) => {  await axios.post('https://api.notifytechai.com/v1/sms/send', {    to: job.data.to,    message: job.data.message,    sender_id: 'YOUR_SENDER_ID',    dlt_entity_id: 'YOUR_ENTITY_ID',    dlt_template_id: 'YOUR_TEMPLATE_ID',  }, {    headers: { Authorization: 'Bearer YOUR_API_KEY' },  });});

import requestsdef send_sms():    url = "https://api.notifytechai.com/v1/sms/send"    headers = {        "Authorization": "Bearer YOUR_API_KEY",        "Content-Type": "application/json"    }    payload = {        "to": "+919876543210",        "message": "Your OTP is 123456",        "sender_id": "YOUR_SENDER_ID",        "dlt_entity_id": "1234567890123456",        "dlt_template_id": "1234567890123456789"    }    response = requests.post(        url, json=payload, headers=headers    )    return response.json()result = send_sms()print(result)

<?php// webhook.php - Handle delivery reports$payload = file_get_contents('php://input');$data = json_decode($payload, true);$signature =  $_SERVER['HTTP_X_NOTIFYTECH_SIGNATURE'];$secret = 'your_webhook_secret';if (!verifySignature($payload, $signature, $secret)) {    http_response_code(401);    exit('Invalid signature');}switch ($data['event']) {    case 'message.delivered':        updateMessageStatus(          $data['message_id'], 'delivered'        );        break;    case 'message.failed':        updateMessageStatus(          $data['message_id'], 'failed'        );        logError($data['error']);        break;}http_response_code(200);echo json_encode(['status' => 'processed']);