worker.js

const { Manager } = require("socket.io-client");
require('./config.js').getConfig();
let lastMinuteData = [];

const manager = new Manager("http://localhost:3001", {
  reconnectionDelayMax: 10000,
});

const socket = manager.socket("/", {
  auth: {
    token: require('./config.js').config.preferences?.token?.toString(),
  }
});

socket.on("connect", () => {
  console.log('Connected to server');
});
socket.on("welcome_message", (data) => {
  console.log(`Server says: ${data.message}`);
});

const weekdays = ['Sunday', 'Monday', 'Tuesday', 'Wednesday', 'Thursday', 'Friday', 'Saturday'];
const filterScheduleEventsToWaterToday = () => {
  const allScheduleEvents = require('./utils/filesUtils').getScheduleFile().events;
  return allScheduleEvents
    // Filter out events that are not scheduled to run today
    .filter(event => {
      if (new Date(event.startDate) <= new Date()) {
        if (!event.endDate) return true;
        if (new Date(event.endDate) >= new Date()) {
          return true;
        }
      }
      return false;
    })
    // Filter out events that are scheduled to run only once and already ran
    .filter(event => {
      if (event.type === 'once') {
        const startDatePlusOneDay = new Date(event.startDate);
        startDatePlusOneDay.setDate(startDatePlusOneDay.getDate() + 1);
        if (startDatePlusOneDay < new Date()) {
          return false;
        }
      }
      return true;
    })
    // Filter out events that days are not today
    .filter(event => {
      if (!event.days) return true;
      if (event.days) {
        if (event.days.includes(weekdays[new Date().getDay()])) {
          return true;
        }
      }
      return false;
    })
    // Filter out events that do not repeat today
    .filter(event => {
      if (!event.repeatEvery) return true;
      if (event.repeatEvery) {
        const eventDate = new Date(event.startDate);
        eventDate.setHours(0, 0, 0, 0);
        const today = new Date();
        today.setHours(0, 0, 0, 0);
        const diffTime = Math.abs(today - eventDate);
        const diffDays = Math.ceil(diffTime / (1000 * 60 * 60 * 24));
        if (diffDays % event.repeatEvery === 0) {
          return true;
        }
      }
      return false;
    })
}

const getDataForStartWaterNow = (events) => {
  const data = [];
  events.forEach(event => {
    event.watering.forEach((watering, index) => {
      if (lastMinuteData.find(item => item[1] === `${event.id}-${index}`)) return;
      if (watering.time === require('./utils/dateUtils').getTimeString()) {
        data.push({
          device: event.device.toString(),
          output: event.output.toString(),
          volume: watering.volume,
          dateTime: new Date(),
          eventId: event.id,
          wateringIndex: index,
        });
      }
    })
  })
  return data;
}

const removeOlderThanOneMinuteData = (lastMinuteData) => {
  const date = new Date();
  date.setMinutes(date.getMinutes() - 1);
  return lastMinuteData.filter(data => data[0] >= date);
}

setInterval(() => {
  const events = filterScheduleEventsToWaterToday();
  const data = getDataForStartWaterNow(events);
  data.forEach(data => {
    lastMinuteData.push([new Date(), `${data.eventId}-${data.wateringIndex}`]);
    socket.emit('message', { action: 'startWater', ...data, type: 'scheduled', context: {scheduleEventId: data.eventId} });
  });
  lastMinuteData = removeOlderThanOneMinuteData(lastMinuteData);
  const used = process.memoryUsage().heapUsed / 1024 / 1024;
  socket.emit('message', { action: 'heartbeat', process: 'worker', memory: `${Math.round(used * 100) / 100} MB` });
}, 5000);

socket.on("disconnect", () => {
  console.log('Disconnected from server');
});