# polling_service.rb
require "rufus-scheduler"

module Modbus
  class PollingService
    class << self
      def start
        return if @scheduler

        puts "[#{Time.now}] Modbus polling service 시작됨 (Rufus)"
        @scheduler ||= Rufus::Scheduler.new

        @scheduler.cron "0 * * * * *" do
          now = Time.now
          current_time = format("%02d:%02d", now.hour, now.min)
          puts "# current time: #{current_time}.#{now.sec}"
          schedule = Schedule.find_by(hour: now.hour, minute: now.min)
          apply_schedule(schedule) if schedule
        end
      end

      def stop
        if defined?(@scheduler)
          @scheduler.shutdown(:kill)
          @scheduler = nil
          puts "[#{Time.now}] Modbus polling service 중지됨"
        else
          puts "[#{Time.now}] Scheduler 인스턴스 없음"
        end
      end

      def running?
        @scheduler
      end

      private
      def apply_schedule(schedule)
        if schedule.is_active
          run_script("on_off.rb", "0", "[Schedule] ON")
          sleep 2
          run_script(
            "serial.rb",
            (schedule.temperature * 10).to_i.to_s,
            "[Schedule] #{format('%02d:%02d', schedule.hour, schedule.minute)} → #{schedule.temperature}°C"
          )
        else
          run_script("on_off.rb", "1", "[Schedule] OFF")
        end
      end

      def run_script(file, arg, success_msg)
        path = Rails.root.join(file)
        if system("ruby", path.to_s, arg)
          puts success_msg
          Rails.logger.info success_msg
        else
          error_message = "[#{Time.now}] #{file} 실행 실패 (args: #{arg})"
          puts error_message
          Rails.logger.error error_message
        end
      end
    end
  end
end