feat: Dynamic threshold system for sensor-based watering
- Detect all threshold_* nodes from kontrol_1 - Support unlimited threshold configurations - Each threshold: batas_bawah, batas_atas, smart_mode, pot_aktif[], pompa settings - Smart mode: water until batas_atas reached - Fixed mode: water for fixed duration - Setup script: setup-firebase-threshold.js for auto Firebase initialization - Improved logging: show threshold ID, mode, and pot info on trigger
This commit is contained in:
Wizznu
parent
6f4b7c25f1
commit
91cb3eaaea
|
|
@ -0,0 +1,108 @@
|
|||
/**
|
||||
* Script untuk setup Firebase Threshold System
|
||||
* Run: node setup-firebase-threshold.js
|
||||
*/
|
||||
|
||||
require('dotenv').config();
|
||||
const admin = require('firebase-admin');
|
||||
|
||||
// Initialize Firebase Admin
|
||||
try {
|
||||
admin.initializeApp({
|
||||
credential: admin.credential.cert({
|
||||
projectId: process.env.FIREBASE_PROJECT_ID,
|
||||
clientEmail: process.env.FIREBASE_CLIENT_EMAIL,
|
||||
privateKey: process.env.FIREBASE_PRIVATE_KEY?.replace(/\\n/g, '\n'),
|
||||
}),
|
||||
databaseURL: process.env.FIREBASE_DATABASE_URL,
|
||||
});
|
||||
console.log('✅ Firebase Admin initialized');
|
||||
} catch (error) {
|
||||
console.error('❌ Firebase initialization failed:', error.message);
|
||||
process.exit(1);
|
||||
}
|
||||
|
||||
const db = admin.database();
|
||||
|
||||
// Data threshold yang akan di-setup
|
||||
// Akan merge dengan data yang sudah ada (jadwal_1, jadwal_2, dll)
|
||||
const thresholdData = {
|
||||
threshold_1: {
|
||||
aktif: true,
|
||||
batas_bawah: 30, // Kelembaban minimum 30%
|
||||
batas_atas: 70, // Target kelembaban 70% (untuk smart mode)
|
||||
durasi: 600, // 10 menit (untuk fixed mode)
|
||||
smart_mode: true, // Smart mode: siram sampai mencapai batas_atas
|
||||
pot_aktif: [1, 2, 3], // Pot 1, 2, 3 pakai threshold ini
|
||||
pompa_air: true,
|
||||
pompa_pupuk: false
|
||||
},
|
||||
|
||||
threshold_2: {
|
||||
aktif: true,
|
||||
batas_bawah: 40, // Kelembaban minimum 40%
|
||||
batas_atas: 80, // Target kelembaban 80%
|
||||
durasi: 300, // 5 menit
|
||||
smart_mode: false, // Fixed mode: siram selama durasi saja
|
||||
pot_aktif: [4, 5], // Pot 4, 5 pakai threshold ini
|
||||
pompa_air: true,
|
||||
pompa_pupuk: true
|
||||
},
|
||||
|
||||
threshold_3: {
|
||||
aktif: false,
|
||||
batas_bawah: 25, // Untuk tanaman yang butuh kelembaban lebih tinggi
|
||||
batas_atas: 75,
|
||||
durasi: 480, // 8 menit
|
||||
smart_mode: true,
|
||||
pot_aktif: [3], // Hanya pot 3
|
||||
pompa_air: true,
|
||||
pompa_pupuk: false
|
||||
}
|
||||
};
|
||||
|
||||
async function setupThreshold() {
|
||||
try {
|
||||
console.log('\n📦 Starting Threshold System setup...');
|
||||
console.log('📍 Target path: /kontrol_1\n');
|
||||
|
||||
// Get existing data di kontrol_1
|
||||
const existingSnapshot = await db.ref('kontrol_1').get();
|
||||
const existingData = existingSnapshot.val() || {};
|
||||
|
||||
console.log('📋 Existing data keys:', Object.keys(existingData).join(', '));
|
||||
|
||||
// Merge threshold baru dengan data yang sudah ada
|
||||
const mergedData = {
|
||||
...existingData,
|
||||
...thresholdData
|
||||
};
|
||||
|
||||
// Push ke Firebase
|
||||
await db.ref('kontrol_1').set(mergedData);
|
||||
|
||||
console.log('\n✅ Threshold system setup completed!');
|
||||
console.log('\n📊 Summary:');
|
||||
console.log(` Total keys in kontrol_1: ${Object.keys(mergedData).length}`);
|
||||
console.log(` Jadwal nodes: ${Object.keys(mergedData).filter(k => k.startsWith('jadwal_')).length}`);
|
||||
console.log(` Threshold nodes: ${Object.keys(mergedData).filter(k => k.startsWith('threshold_')).length}`);
|
||||
|
||||
console.log('\n🎯 Threshold details:');
|
||||
Object.keys(thresholdData).forEach(key => {
|
||||
const t = thresholdData[key];
|
||||
console.log(` ${key}: ${t.aktif ? '✅' : '❌'} | ${t.batas_bawah}-${t.batas_atas}% | ${t.smart_mode ? 'Smart' : 'Fixed'} | Pot ${t.pot_aktif.join(',')}`);
|
||||
});
|
||||
|
||||
console.log('\n✨ Firebase updated successfully!');
|
||||
console.log('🔗 Check: https://console.firebase.google.com/u/0/project/YOUR_PROJECT/database');
|
||||
|
||||
process.exit(0);
|
||||
} catch (error) {
|
||||
console.error('\n❌ Setup failed:', error.message);
|
||||
console.error('Stack:', error.stack);
|
||||
process.exit(1);
|
||||
}
|
||||
}
|
||||
|
||||
// Run the setup
|
||||
setupThreshold();
|
||||
127
worker.js
127
worker.js
|
|
@ -787,7 +787,7 @@ setTimeout(async () => {
|
|||
let sensorCheckCounter = 0;
|
||||
|
||||
async function setupSensorMonitoring() {
|
||||
console.log('✅ Sensor Mode monitoring started');
|
||||
console.log('✅ Sensor Mode (Threshold System) monitoring started');
|
||||
|
||||
db.ref('data').on('value', async (snapshot) => {
|
||||
sensorCheckCounter++;
|
||||
|
|
@ -802,65 +802,98 @@ async function setupSensorMonitoring() {
|
|||
const configSnapshot = await fetchWithTimeout(db.ref(FIREBASE_PATHS.kontrol), 10000);
|
||||
const kontrolConfig = configSnapshot.val();
|
||||
|
||||
// Log sensor check (verbose hanya setiap 10 kali)
|
||||
if (sensorCheckCounter % 10 === 0) {
|
||||
console.log(`\n🌡️ SENSOR CHECK #${sensorCheckCounter} | Mode Otomatis: ${kontrolConfig?.otomatis ? '✅' : '❌'}`);
|
||||
}
|
||||
|
||||
if (!kontrolConfig || !kontrolConfig.otomatis) {
|
||||
// Sensor mode disabled
|
||||
if (!kontrolConfig) {
|
||||
return;
|
||||
}
|
||||
|
||||
const batasBawah = kontrolConfig.batas_bawah || 40;
|
||||
const batasAtas = kontrolConfig.batas_atas || 100;
|
||||
const durasiSensor = kontrolConfig.durasi_sensor || 60;
|
||||
const modeSensor = kontrolConfig.mode_sensor || 'fixed'; // 'fixed' or 'smart'
|
||||
// Detect all threshold_* nodes
|
||||
const allThresholds = Object.keys(kontrolConfig).filter(key => key.startsWith('threshold_'));
|
||||
|
||||
// Check each pot
|
||||
for (let i = 1; i <= 5; i++) {
|
||||
const soilKey = `soil_${i}`;
|
||||
const soilValue = parseInt(sensorData[soilKey]) || 0;
|
||||
// Log sensor check (verbose hanya setiap 10 kali)
|
||||
if (sensorCheckCounter % 10 === 0) {
|
||||
console.log(`\n🌡️ SENSOR CHECK #${sensorCheckCounter} | Total Thresholds: ${allThresholds.length}`);
|
||||
}
|
||||
|
||||
if (soilValue < batasBawah) {
|
||||
const potKey = `pot_${i}`;
|
||||
const lastTime = lastWateringTime[potKey];
|
||||
if (allThresholds.length === 0) {
|
||||
// No thresholds configured
|
||||
return;
|
||||
}
|
||||
|
||||
// Debounce: minimum 2 menit antar penyiraman
|
||||
if (lastTime && Date.now() - lastTime < config.worker.sensorDebounce) {
|
||||
const remainingSeconds = Math.ceil((config.worker.sensorDebounce - (Date.now() - lastTime)) / 1000);
|
||||
console.log(`⏳ POT ${i}: Cooldown active (${remainingSeconds}s remaining)`);
|
||||
continue;
|
||||
}
|
||||
// Process each threshold
|
||||
for (const thresholdKey of allThresholds) {
|
||||
const threshold = kontrolConfig[thresholdKey];
|
||||
|
||||
// Skip if threshold is not active or invalid
|
||||
if (!threshold || !threshold.aktif) continue;
|
||||
|
||||
console.log(`\n🌡️ SENSOR TRIGGERED: POT ${i}`);
|
||||
console.log(` Soil moisture: ${soilValue}% < ${batasBawah}%`);
|
||||
console.log(` Mode: ${modeSensor}, Duration: ${durasiSensor}s`);
|
||||
const batasBawah = threshold.batas_bawah || 30;
|
||||
const batasAtas = threshold.batas_atas || 70;
|
||||
const durasi = threshold.durasi || 600;
|
||||
const smartMode = threshold.smart_mode === true;
|
||||
const potAktif = threshold.pot_aktif || [];
|
||||
const pompaAir = threshold.pompa_air === true;
|
||||
const pompaPupuk = threshold.pompa_pupuk === true;
|
||||
|
||||
const jobId = `sensor-pot-${i}-${Date.now()}`;
|
||||
await wateringQueue.add(
|
||||
`sensor-pot-${i}`,
|
||||
{
|
||||
type: 'sensor_threshold',
|
||||
potNumbers: [i],
|
||||
pompaAir: true,
|
||||
pompaPupuk: false, // No pupuk for sensor mode
|
||||
duration: durasiSensor,
|
||||
scheduleId: jobId,
|
||||
sensorData: { soilValue, batasBawah, batasAtas, mode: modeSensor },
|
||||
},
|
||||
{
|
||||
jobId,
|
||||
removeOnComplete: true,
|
||||
priority: 1, // Higher priority for sensor-triggered
|
||||
// Check each pot in this threshold
|
||||
for (const potNumber of potAktif) {
|
||||
if (potNumber < 1 || potNumber > 5) continue;
|
||||
|
||||
const soilKey = `soil_${potNumber}`;
|
||||
const soilValue = parseInt(sensorData[soilKey]) || 0;
|
||||
|
||||
// Check if below threshold
|
||||
if (soilValue < batasBawah) {
|
||||
const potKey = `pot_${potNumber}`;
|
||||
const lastTime = lastWateringTime[potKey];
|
||||
|
||||
// Debounce: minimum 2 menit antar penyiraman
|
||||
if (lastTime && Date.now() - lastTime < config.worker.sensorDebounce) {
|
||||
const remainingSeconds = Math.ceil((config.worker.sensorDebounce - (Date.now() - lastTime)) / 1000);
|
||||
if (sensorCheckCounter % 10 === 0) {
|
||||
console.log(`⏳ ${thresholdKey.toUpperCase()} - POT ${potNumber}: Cooldown (${remainingSeconds}s)`);
|
||||
}
|
||||
continue;
|
||||
}
|
||||
);
|
||||
|
||||
console.log(` 📌 Added to queue: ${jobId}`);
|
||||
console.log(`\n🌡️ THRESHOLD TRIGGERED: ${thresholdKey.toUpperCase()}`);
|
||||
console.log(` POT ${potNumber}: ${soilValue}% < ${batasBawah}%`);
|
||||
console.log(` Mode: ${smartMode ? 'Smart' : 'Fixed'}, Target: ${smartMode ? batasAtas + '%' : durasi + 's'}`);
|
||||
console.log(` Pumps: Air=${pompaAir}, Pupuk=${pompaPupuk}`);
|
||||
|
||||
const jobId = `${thresholdKey}-pot-${potNumber}-${Date.now()}`;
|
||||
await wateringQueue.add(
|
||||
`threshold-pot-${potNumber}`,
|
||||
{
|
||||
type: 'sensor_threshold',
|
||||
potNumbers: [potNumber],
|
||||
pompaAir: pompaAir,
|
||||
pompaPupuk: pompaPupuk,
|
||||
duration: durasi,
|
||||
scheduleId: jobId,
|
||||
thresholdId: thresholdKey,
|
||||
sensorData: {
|
||||
soilValue,
|
||||
batasBawah,
|
||||
batasAtas,
|
||||
mode: smartMode ? 'smart' : 'fixed'
|
||||
},
|
||||
},
|
||||
{
|
||||
jobId,
|
||||
removeOnComplete: true,
|
||||
priority: 1, // Higher priority for sensor-triggered
|
||||
}
|
||||
);
|
||||
|
||||
console.log(` 📌 Added to queue: ${jobId}`);
|
||||
|
||||
// Update last watering time to prevent rapid re-triggering
|
||||
lastWateringTime[potKey] = Date.now();
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('❌ Error in sensor monitoring:', error.message);
|
||||
console.error('❌ Error in threshold monitoring:', error.message);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue