FarmBot/Farmbot-Web-App

def check_for_digests
  Log
    .where(sent_at: nil, created_at: 1.day.ago...Time.now)
    .where(Log::IS_EMAIL_ISH)
    .where
    .not(Log::IS_FATAL_EMAIL)
    .pluck(:device_id)
    .uniq
    .map do |id|
    device = Device.find(id)
    puts "Sending log digest to device \##{id} (#{device.name})"
    LogDeliveryMailer.log_digest(device).deliver
  end
  sleep 10.minutes
end

def hard_reset_api
  sh "sudo docker stop $(sudo docker ps -a -q)"
  sh "sudo docker rm $(sudo docker ps -a -q)"
  sh "sudo docker system prune -af --volumes"
  sh "sudo rm -rf docker_volumes/"
rescue => exception
  puts exception.message
  puts "Reset failed. Was there nothing to destroy?"
end

def rebuild_deps
  sh "sudo docker compose run web bundle install"
  sh "sudo docker compose run web npm install"
  sh "sudo docker compose run web bundle exec rails db:setup"
  sh "sudo docker compose run web rake keys:generate"
  sh "sudo docker compose run web npm run build"
end

def user_typed?(word)
  STDOUT.flush
  STDIN.gets.chomp.downcase.include?(word.downcase)
end

namespace :api do
  desc "Runs pending email digests. " \
       "Use the `FOREVER` ENV var to continually check."
  task log_digest: :environment do
    puts "Running log digest loop..."
    ENV["FOREVER"] ? loop { check_for_digests } : check_for_digests
  end

  desc "Run Rails _ONLY_. No parcel."
  task only: :environment do
    sh "sudo docker compose up --scale parcel=0"
  end

  def parcel(cmd, opts = " ")
    intro = [
      "NODE_ENV=#{Rails.env}",
      "node_modules/.bin/parcel",
      cmd,
      DashboardController::PARCEL_ASSET_LIST,
      "--dist-dir",
      DashboardController::PUBLIC_OUTPUT_DIR,
      "--public-url",
      DashboardController::OUTPUT_URL,
      cmd == "build" ? "--no-scope-hoist" : "",
    ].join(" ")
    sh [intro, opts].join(" ")
  end

  def clean_assets
    # Clear out cache and previous builds on initial load.
    sh [
      "rm -rf",
      DashboardController::CACHE_DIR,
      DashboardController::PUBLIC_OUTPUT_DIR,
      "public/assets/monaco",
      ".parcel-cache",
    ].join(" ") unless ENV["NO_CLEAN"]
  end

  def add_monaco
    src = "node_modules/monaco-editor/min/vs"
    dst = "public/assets/monaco"
    lua = "basic-languages/lua"
    sh "mkdir -p public/assets/"
    sh "cp -r #{src} #{dst}"
    sh "rm -rf #{dst}/*language*"
    sh "mkdir #{dst}/basic-languages"
    sh "cp -r #{src}/#{lua} #{dst}/#{lua}"
  end

  desc "Serve javascript assets (via Parcel bundler)."
  task serve_assets: :environment do
    clean_assets
    add_monaco
    parcel "watch", DashboardController::PARCEL_HMR_OPTS
  end

  desc "Don't call this directly. Use `rake assets:precompile`."
  task parcel_compile: :environment do
    add_monaco
    parcel "build"
  end

  desc "Clean out old demo accounts"
  task clean_demo_accounts: :environment do
    users = User
      .where("email ILIKE '%@farmbot.guest%'")
      .where("updated_at < ?", 1.hour.ago)
    Device
      .where(id: users.pluck(:device_id))
      .update_all(mounted_tool_id: nil)
    users.map { |u| u.device.folders.update_all(parent_id: nil) }
    users.destroy_all
  end

  desc "Reset _everything_, including your database"
  task :reset do
    puts "This is going to destroy _ALL_ of your local Farmbot SQL data and " \
         "configs. Type 'destroy' to continue, enter to abort."
    if user_typed?("destroy")
      hard_reset_api
      puts "Done. Type 'build' to re-install dependencies, enter to abort."
      rebuild_deps if user_typed?("build")
    end
  end

  RELEASES_URL = "https://api.github.com/repos/farmbot/farmbot_os/releases"
  VERSION = "tag_name"
  TIMESTAMP = "created_at"
  PRERELEASE = "prerelease"

  def deprecate!
    # Get current version
    version_str = GlobalConfig.dump.fetch("FBOS_END_OF_LIFE_VERSION")
    # Convert it to Gem::Version for easy comparisons (>, <, ==, etc)
    current_version = Gem::Version::new(version_str)
    # 60 days is the current policy.
    cutoff = 60.days.ago
    # Download release data from github
    string_page_1 = URI.parse("#{RELEASES_URL}?per_page=100&page=1").open.read
    string_page_2 = URI.parse("#{RELEASES_URL}?per_page=100&page=2").open.read
    data = JSON.parse(string_page_1).push(*JSON.parse(string_page_2))
      .map { |x| x.slice(VERSION, TIMESTAMP, PRERELEASE) } # Only grab keys that matter
      .reject { |x| x.fetch(VERSION).include?("-") } # Remove RC/Beta releases
      .reject { |x| x.fetch(PRERELEASE) } # Remove pre-releases
      .map do |x|
      # Convert string-y version/timestamps to Real ObjectsTM
      version = Gem::Version::new(x.fetch(VERSION).gsub("v", ""))
      time = DateTime.parse(x.fetch(TIMESTAMP))
      Pair.new(version, time)
    end
      .select do |pair|
      # Grab versions that are > current version and outside of cutoff window
      (pair.head >= current_version) && (pair.tail < cutoff)
    end
      .sort_by { |p| p.tail } # Sort by release date
      .last(2) # Grab 2 latest versions (closest to cutoff)
      .first # Give 'em some leeway, grabbing the 2nd most outdated version.
      .try(:head) # We might already be up-to-date?
    if data # ...or not
      puts "Setting new support target to #{data.to_s}"
      GlobalConfig # Set the new oldest support version.
        .find_by(key: "FBOS_END_OF_LIFE_VERSION")
        .update!(value: data.to_s)
    end
  end

  def trim_logs
    Device.all.map{ |device| device.trim_excess_logs }
  end

  desc "Deprecate old FBOS version, delete inactive accounts, etc.."
  task tidy: :environment do
    deprecate!
    InactiveAccountJob.perform_later
    trim_logs
  end
end
Rake::Task["assets:precompile"].enhance ["api:parcel_compile"]