إرسال شحن الهاتف المحمول

{
  "success": true,
  "data": {
    "topupId": "6901616fe9e88196b4eb64b0",
    "topupRef": "order-001",
    "newBalance": 826.13
  },
  "meta": {
    "timestamp": "2025-10-29T00:35:59.454Z"
  }
}

async function sendTopUpSafe(planCode, phone, amount, orderId) {
  // Use orderId as the ref for idempotency
  const ref = `topup-${orderId}`;

  try {
    const response = await fetch("https://api.oneclickdz.com/v3/mobile/send", {
      method: "POST",
      headers: {
        "X-Access-Token": API_KEY,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({
        plan_code: planCode,
        MSSIDN: phone,
        amount,
        ref,
      }),
    });

    const data = await response.json();

    if (data.success) {
      return { success: true, topupId: data.data.topupId };
    }

    // Handle duplicate ref - order already exists
    if (data.error.code === "DUPLICATED_REF") {
      const status = await checkTopUpByRef(ref);
      return { success: true, topupId: status.data._id, fromExisting: true };
    }

    throw new Error(`${data.error.code}: ${data.error.message}`);
  } catch (networkError) {
    // Network error - check if order was created
    const status = await checkTopUpByRef(ref);
    if (status.success) {
      return { success: true, topupId: status.data._id, fromExisting: true };
    }
    throw networkError;
  }
}

async function processTopUp(userId, planCode, phone, amount) {
  // 1. Validate inputs
  if (!/^0[567]\d{8}$/.test(phone)) {
    throw new Error('Invalid Algerian phone number format');
  }

  // 2. Check balance
  const balance = await getBalance();
  if (balance < amount * 1.05) { // Add buffer for safety
    throw new Error('Insufficient balance');
  }

  // 3. Generate unique ref
  const ref = `topup-${userId}-${Date.now()}`;

  // 4. Send topup
  const result = await sendTopUp({
    plan_code: planCode,
    MSSIDN: phone,
    amount,
    ref
  });

  // 5. Store result
  await saveTransaction({
    ref,
    topupId: result.topupId,
    status: 'PENDING',
    createdAt: new Date()
  });

  // 6. Return success
  return result;
}