octobox/octobox

# frozen_string_literal: true

require 'timeout'

class SyncNotificationsWorker
  include Sidekiq::Worker
  include Sidekiq::Status::Worker
  sidekiq_options queue: :sync_notifications, lock: :until_executed

  TIMEOUT = 5.minutes.to_i

  def perform(user_id)
    user = User.find_by(id: user_id)
    return unless user.present?
    return unless user.effective_access_token.present?

    Timeout.timeout(TIMEOUT) do
      begin
        user.sync_notifications_in_foreground
      rescue Octokit::Unauthorized, Octokit::Forbidden => exception
        handle_exception(exception, user)
      rescue Octokit::BadGateway, Octokit::ServerError, Octokit::ServiceUnavailable => exception
        handle_exception(exception, user)
      rescue Faraday::Error => exception
        handle_exception(exception, user)
      end
    end
  rescue Timeout::Error => exception
    handle_exception(exception, user)
  end

  private

  def handle_exception(exception, user)
    logger.error("[ERROR] SyncNotificationsJob#perform #{user.github_login} - #{exception.class}: #{exception.message}")
    store(exception: exception.message)
  end
end