remove_cdr_export_file_job.rb

require 'net/http'

module Worker
  class RemoveCdrExportFileJob < ActiveJob::Base
    class TryAgainError < RuntimeError
    end

    queue_as 'cdr_export'

    def perform(cdr_export_id)
      cdr_export = CdrExport.find(cdr_export_id)
      raise 'status should be completed' unless cdr_export.completed?
      url = URI.parse(delete_url(cdr_export))
      req = Net::HTTP::Delete.new(url.to_s)
      res = Net::HTTP.start(
        url.host,
        url.port,
        use_ssl: url.scheme == 'https',
        verify_mode: OpenSSL::SSL::VERIFY_NONE
      ) do |http|
        http.request(req)
      end
      raise TryAgainError if (res.code.to_i != 200) && (res.code.to_i != 404)
      cdr_export.update!(status: CdrExport::STATUS_DELETED)
    end

    private

    def delete_url(cdr_export)
      [
        Rails.configuration.yeti_web.fetch('cdr_export').fetch('delete_url').chomp('/'),
        "#{cdr_export.id}.csv"
      ].join('/')
    end
  end
end