تطبيق يبيع بلا إنترنت ثم يزامن: صندوق الصادر ومفتاح التكرار

import { openDB } from 'idb';

export interface OutboxOp {
  seq?: number;         // ترتيب الإدخال، يولّده المتصفح
  id: string;           // معرّف يولّده الجهاز، وهو مفتاح التكرار عند الخادم
  type: 'sale.create' | 'payment.add' | 'order.void';
  payload: unknown;
  deviceTime: string;   // وقت الجهاز، للعرض فقط
}

export const dbp = openDB('pos', 1, {
  upgrade(db) {
    db.createObjectStore('outbox', { keyPath: 'seq', autoIncrement: true });
    db.createObjectStore('sales', { keyPath: 'id' });
  },
});

// البيع يُحفظ محلياً، والعملية تدخل الصادر، في معاملة واحدة
export async function recordSale(sale: { id: string; items: unknown[]; total: number }) {
  const db = await dbp;
  const tx = db.transaction(['sales', 'outbox'], 'readwrite');
  await tx.objectStore('sales').put({ ...sale, synced: false });
  await tx.objectStore('outbox').add({
    id: crypto.randomUUID(),
    type: 'sale.create',
    payload: sale,
    deviceTime: new Date().toISOString(),
  } satisfies OutboxOp);
  await tx.done;
}

// كل عملية تُنفَّذ مرة واحدة مهما تكرر إرسالها
app.post('/api/sync', async (req) => {
  const accepted = [];

  for (const op of req.body.ops) {
    const client = await pool.connect();
    try {
      await client.query('BEGIN');
      const { rowCount } = await client.query(
        `INSERT INTO processed_ops (op_id, device_id, received_at)
         VALUES ($1, $2, now())
         ON CONFLICT (op_id) DO NOTHING`,
        [op.id, req.deviceId]);
      if (rowCount === 1) await apply(client, op); // جديدة: نطبّقها
      await client.query('COMMIT');
      accepted.push(op.id);                          // جديدة أو مكررة: كلتاهما «مقبولة»
    } catch (err) {
      await client.query('ROLLBACK');
      if (isPermanent(err)) {                        // بيانات خاطئة: لا تسدّ الطابور
        await saveRejected(op, err);
        accepted.push(op.id);
      } else {
        break;                                       // خطأ مؤقت: نتوقف ونحاول لاحقاً بالترتيب
      }
    } finally {
      client.release();
    }
  }

  return { accepted };
});

import { dbp, type OutboxOp } from './outbox';

const BATCH = 50;
let backoff = 2_000;

export async function syncLoop(): Promise<void> {
  const db = await dbp;
  const ops: OutboxOp[] = await db.getAll('outbox', null, BATCH); // بالترتيب
  if (ops.length === 0) return schedule(10_000);

  try {
    const res = await fetch('/api/sync', {
      method: 'POST',
      headers: { 'content-type': 'application/json' },
      body: JSON.stringify({ ops }),
    });
    if (!res.ok) throw new Error('sync ' + res.status);

    const { accepted } = (await res.json()) as { accepted: string[] };
    const done = new Set(accepted);
    const tx = db.transaction('outbox', 'readwrite');
    for (const op of ops) if (done.has(op.id)) await tx.store.delete(op.seq!);
    await tx.done;

    backoff = 2_000;
    schedule(ops.length === BATCH ? 0 : 5_000); // بقي غيرها؟ أكمل فوراً
  } catch {
    backoff = Math.min(backoff * 2, 60_000);
    schedule(backoff + Math.random() * 1_000);  // تأخير متزايد مع عشوائية
  }
}

function schedule(ms: number) {
  setTimeout(syncLoop, ms);
}

-- تعديل صنف من جهازين: نقبل التعديل فقط إن لم يتغيّر منذ قرأه الجهاز
UPDATE menu_items
   SET price = $1, version = version + 1, updated_at = now()
 WHERE id = $2 AND version = $3;
-- إن لم يتغيّر أي صف فهذا تعارض: أعِد للجهاز النسخة الحالية ليقرر المستخدم