Sage/lib/features/household/services/inventory_sync_service.dart

import 'dart:async';
import 'package:cloud_firestore/cloud_firestore.dart';
import '../../../data/local/hive_database.dart';
import '../../inventory/models/food_item.dart';

/// Service for syncing inventory items with Firebase in real-time
class InventorySyncService {
  final FirebaseFirestore _firestore = FirebaseFirestore.instance;
  StreamSubscription? _itemsSubscription;

  /// Start listening to household items from Firebase
  Future<void> startSync(String householdId) async {
    await stopSync(); // Stop any existing subscription

    _itemsSubscription = _firestore
        .collection('households')
        .doc(householdId)
        .collection('items')
        .snapshots()
        .listen((snapshot) async {
      await _handleItemsUpdate(snapshot, householdId);
    });
  }

  /// Stop listening to Firebase updates
  Future<void> stopSync() async {
    await _itemsSubscription?.cancel();
    _itemsSubscription = null;
  }

  /// Handle updates from Firebase
  Future<void> _handleItemsUpdate(
    QuerySnapshot snapshot,
    String householdId,
  ) async {
    final box = await HiveDatabase.getFoodBox();

    // Track Firebase item IDs
    final firebaseItemIds = <String>{};

    for (final doc in snapshot.docs) {
      firebaseItemIds.add(doc.id);
      final data = doc.data() as Map<String, dynamic>;

      // Check if item exists in local Hive
      final itemKey = int.tryParse(doc.id);
      if (itemKey != null) {
        final existingItem = box.get(itemKey);

        // Create or update item
        final item = _createFoodItemFromData(data, householdId);

        if (existingItem == null) {
          // New item from Firebase - add to local Hive with specific key
          await box.put(itemKey, item);
        } else {
          // Update existing item if Firebase version is newer
          final firebaseModified = DateTime.parse(data['lastModified'] as String);
          final localModified = existingItem.lastModified ?? DateTime(2000);

          if (firebaseModified.isAfter(localModified)) {
            // Firebase version is newer - update local
            await box.put(itemKey, item);
          }
        }
      }
    }

    // Delete items that no longer exist in Firebase
    final itemsToDelete = <int>[];
    for (final item in box.values) {
      if (item.householdId == householdId && item.key != null) {
        if (!firebaseItemIds.contains(item.key.toString())) {
          itemsToDelete.add(item.key!);
        }
      }
    }

    for (final key in itemsToDelete) {
      await box.delete(key);
    }
  }

  /// Create FoodItem from Firebase data
  FoodItem _createFoodItemFromData(Map<String, dynamic> data, String householdId) {
    return FoodItem()
      ..name = data['name'] as String
      ..barcode = data['barcode'] as String?
      ..quantity = data['quantity'] as int
      ..unit = data['unit'] as String?
      ..purchaseDate = DateTime.parse(data['purchaseDate'] as String)
      ..expirationDate = DateTime.parse(data['expirationDate'] as String)
      ..locationIndex = data['locationIndex'] as int
      ..category = data['category'] as String?
      ..photoUrl = data['photoUrl'] as String?
      ..notes = data['notes'] as String?
      ..userId = data['userId'] as String?
      ..householdId = householdId
      ..lastModified = DateTime.parse(data['lastModified'] as String)
      ..syncedToCloud = true;
  }
}