Production AI Systems

// Atomic lock pattern for preventing duplicate calls
// This prevents race conditions when multiple workflows target the same lead

async function acquireCallLock(leadId) {
  const lockRef = db.collection('call_locks').doc(leadId);

  try {
    await db.runTransaction(async (transaction) => {
      const lockDoc = await transaction.get(lockRef);

      if (lockDoc.exists && lockDoc.data().active) {
        throw new Error('Lead already being called');
      }

      transaction.set(lockRef, {
        active: true,
        timestamp: admin.firestore.FieldValue.serverTimestamp(),
        expiresAt: new Date(Date.now() + 5 * 60 * 1000) // 5 min TTL
      });
    });

    return true;
  } catch (error) {
    console.log(`Lock acquisition failed for ${leadId}: ${error.message}`);
    return false;
  }
}