queue.rb

# frozen_string_literal: true

require 'logger'
require 'rufus-scheduler'
require 'require_all'
require 'sequel'
require_relative 'models'
require_rel './models'
require_relative 'lib/assets'
require_relative 'lib/bus'
require_relative 'lib/hooks'
require_relative 'lib/mail'
require_relative 'lib/user_stats'

Sequel.extension :pg_json_ops

PRODUCTION = ENV['RACK_ENV'] == 'production'

QUEUE_LOGGER = Logger.new($stdout)

Bus.configure

ASSETS = Assets.new(precompiled: PRODUCTION)

scheduler = Rufus::Scheduler.new

# give latest pins a chance to be used before they get cleaned up
UNUSED_RECENT_PINS_TO_KEEP = 2
PINS_DIR = File.join(File::SEPARATOR, '18xx', 'public', 'pinned')

def days_ago(days)
  Time.now - (86_400 * days)
end

scheduler.cron '00 09 * * *' do
  QUEUE_LOGGER.info('Calculating user stats')
  UserStats.calculate_stats

  QUEUE_LOGGER.info('Archiving Games')

  filter = <<~SQL
    (status = 'finished' AND created_at <= :finished) OR
    (status = 'active' AND updated_at <= :active)
  SQL

  Game.where(
    Sequel.lit(filter, finished: days_ago(365), active: days_ago(90))
  ).all.each(&:archive!)

  # clean up unused pins, except for the newest few
  pins = Dir.glob("#{PINS_DIR}/*.js.gz")
           .sort_by { |f| File.mtime(f) }[0..-(1 + UNUSED_RECENT_PINS_TO_KEEP)]
           .map { |f| f.split(%r{[./]})[-3] }
  pins.each do |pin|
    where_kwargs = {
      Sequel.pg_jsonb_op(:settings).get_text('pin') => pin,
      :status => %w[active finished],
    }
    if Game.where(**where_kwargs).count.zero?
      file = "#{PINS_DIR}/#{pin}.js.gz"
      FileUtils.rm(file)
    end
  end

  Game.where(status: 'new').all.each do |game|
    if game.settings['unlisted']
      game.destroy if game.created_at < days_ago(180)
    elsif game.created_at < days_ago(14)
      game.destroy
    end
  end
end

def send_webhook_notification(user, message)
  return if user.settings['notifications'] != 'webhook'
  return if (user.settings['webhook_user_id']&.strip || '') == ''

  begin
    Hooks.send(user, message)
  rescue Exception => e # rubocop:disable Lint/RescueException
    puts e.backtrace
    puts e
  end
end

MessageBus.subscribe '/test_notification' do |msg|
  user_id = msg.data
  user = User[user_id]
  send_webhook_notification(user, 'This is a test notification from 18xx.games.')
end

MessageBus.subscribe '/delete_user' do |msg|
  user_id = msg.data
  user = User[user_id]
  Game.where(id: user.game_users.map(&:game_id)).delete
  user.destroy
end

MessageBus.subscribe '/turn' do |msg|
  data = msg.data

  users = User.where(id: data['user_ids']).all
  game = Game[data['game_id']]
  minute_ago = (Time.now - 60).to_i

  message = "#{data['type']} in #{game.title} \"#{game.description}\" " \
            "(#{game.round} #{game.turn})\n#{data['game_url']}"
  users.each { |user| send_webhook_notification(user, message) }

  users = users.reject do |user|
    notifications = user.settings['notifications'] || 'none'
    next true if notifications == 'none'
    next true if /@(msn|hotmail|outlook|live|passport)/.match?(user.email.downcase)
    next true if notifications != 'email'
    next false if data['force']
    next true if (Bus[Bus::USER_TS % user.id].to_i || minute_ago) > minute_ago

    email_sent = user.settings['email_sent'] || 0
    email_sent > minute_ago
  end

  next if users.empty?

  html = ASSETS.html(
    'assets/app/mail/turn.rb',
    game_id: game.id,
    game_url: data['game_url'],
  )

  users.each do |user|
    Mail.send(user, "18xx.games Game: #{game.title} - #{game.id} - #{data['type']}", html)
    QUEUE_LOGGER.info("mail sent for game: #{game.id} to user: #{user.id}")
    user.settings['email_sent'] = Time.now.to_i
    user.save
  end
rescue Exception => e # rubocop:disable Lint/RescueException
  puts e.backtrace
  puts e
end

sleep