Firebase Auth & Firestore untuk Aplikasi IoT

import { collection, doc, setDoc, addDoc, serverTimestamp } from "firebase/firestore";
import { db, auth } from "./firebase-config.js";

// === Metode 1: addDoc() — ID dokumen otomatis ===
async function addDevice(deviceData) {
  try {
    const docRef = await addDoc(collection(db, "devices"), {
      name: deviceData.name,
      type: deviceData.type,
      location: deviceData.location,
      owner_uid: auth.currentUser.uid,
      status: "online",
      created_at: serverTimestamp(),
      updated_at: serverTimestamp()
    });
    console.log("Device ditambahkan dengan ID:", docRef.id);
    return docRef.id;
  } catch (error) {
    console.error("Error menambah device:", error);
    throw error;
  }
}

// === Metode 2: setDoc() — ID manual ===
async function addReading(deviceId, readingData) {
  try {
    const readingId = new Date().toISOString(); // ID berdasarkan timestamp
    const readingRef = doc(db, "devices", deviceId, "readings", readingId);

    await setDoc(readingRef, {
      suhu: readingData.suhu,
      kelembaban: readingData.kelembaban,
      timestamp: serverTimestamp()
    });
    console.log("Data sensor ditambahkan:", readingId);
  } catch (error) {
    console.error("Error menambah data:", error);
    throw error;
  }
}

// Contoh penggunaan
await addDevice({
  name: "Sensor Suhu Gudang",
  type: "temperature",
  location: "Gudang Utama"
});

await addReading("device-001", {
  suhu: 28.5,
  kelembaban: 72.0
});

import { collection, doc, getDoc, getDocs, query, where, orderBy, limit } from "firebase/firestore";
import { db } from "./firebase-config.js";

// === Baca satu dokumen berdasarkan ID ===
async function getDevice(deviceId) {
  const docRef = doc(db, "devices", deviceId);
  const docSnap = await getDoc(docRef);

  if (docSnap.exists()) {
    console.log("Data device:", docSnap.data());
    return { id: docSnap.id, ...docSnap.data() };
  } else {
    console.log("Device tidak ditemukan!");
    return null;
  }
}

// === Baca semua device milik user yang sedang login ===
async function getUserDevices() {
  const q = query(
    collection(db, "devices"),
    where("owner_uid", "==", auth.currentUser.uid),
    orderBy("created_at", "desc"),
    limit(50)
  );

  const querySnapshot = await getDocs(q);
  const devices = [];

  querySnapshot.forEach((doc) => {
    devices.push({ id: doc.id, ...doc.data() });
  });

  console.log(`Ditemukan ${devices.length} device`);
  return devices;
}

// === Baca data sensor dengan filter ===
async function getHighTempReadings(deviceId, minTemp) {
  const q = query(
    collection(db, "devices", deviceId, "readings"),
    where("suhu", ">", minTemp),
    orderBy("suhu", "desc"),
    limit(10)
  );

  const snapshot = await getDocs(q);
  return snapshot.docs.map(doc => ({ id: doc.id, ...doc.data() }));
}

import { doc, updateDoc, deleteDoc, serverTimestamp } from "firebase/firestore";
import { db } from "./firebase-config.js";

// === Update data device ===
async function updateDevice(deviceId, newData) {
  const deviceRef = doc(db, "devices", deviceId);

  await updateDoc(deviceRef, {
    ...newData,
    updated_at: serverTimestamp()
  });

  console.log("Device berhasil diupdate");
}

// Contoh: update status dan lokasi device
await updateDevice("device-001", {
  status: "offline",
  location: "Lantai 3, Ruang Lab"
});

// === Hapus device (termasuk sub-collection) ===
async function deleteDevice(deviceId) {
  // PERINGATAN: Sub-collection tidak otomatis terhapus!
  // Hapus sub-collection "readings" terlebih dahulu
  const readings = await getDocs(collection(db, "devices", deviceId, "readings"));
  const deletePromises = readings.docs.map(d => deleteDoc(d.ref));
  await Promise.all(deletePromises);

  // Hapus dokumen device
  await deleteDoc(doc(db, "devices", deviceId));
  console.log("Device dan semua data sensornya berhasil dihapus");
}

// === Batch write: operasi sekaligus ===
import { writeBatch } from "firebase/firestore";

async function batchUpdateStatus(deviceIds, status) {
  const batch = writeBatch(db);

  deviceIds.forEach(id => {
    const deviceRef = doc(db, "devices", id);
    batch.update(deviceRef, { status, updated_at: serverTimestamp() });
  });

  await batch.commit(); // Commit semua sekaligus
  console.log(`${deviceIds.length} device diupdate sekaligus`);
}