demarches-normaliennes/app/jobs/virus_scanner_job.rb

class VirusScannerJob < ApplicationJob
  # If by the time the job runs the blob has been deleted, ignore the error
  discard_on ActiveRecord::RecordNotFound
  # If the file is deleted during the scan, ignore the error
  discard_on ActiveStorage::FileNotFoundError
  # If for some reason the file appears invalid, retry for a while
  retry_on(ActiveStorage::IntegrityError, attempts: 5, wait: 5.seconds) do |job, _error|
    blob = job.arguments.first
    blob.update_columns(virus_scan_result: ActiveStorage::VirusScanner::INTEGRITY_ERROR, virus_scanned_at: Time.zone.now)
  end

  def perform(blob)
    return if blob.virus_scanner.done?

    blob.update_columns(ActiveStorage::VirusScanner.new(blob).attributes)
  end
end
Save virus scan status to blob metadata 2019-05-02 11:37:35 +02:00			`class VirusScannerJob < ApplicationJob`
jobs: ignore deleted file in Virus Scan We have errors in production where the job starts correctly (i.e. the blob exists), but `blob.open` fails with a `ActiveStorage::FileNotFound` error. When checking later in production, the blob has been deleted. This points to the blob (and the file) being deleted during the virus scan job. In that case, ignore the error (rather than retrying the job). 2020-09-03 11:00:59 +02:00			`# If by the time the job runs the blob has been deleted, ignore the error`
jobs: ignore missing blob during virus scan We currently have many failed VirusScannerJob enqueued, because the underlying blob is missing. This PR fixes the issue by discarding the job in those cases (because if the blob is gone, the job is never going to succeed). The implementation is based on a similar issue encoutered by the ActiveStorage::AnalyzeJob. See https://github.com/rails/rails/commit/06f8baf73c677303353c79609838caaeec3ccc9a 2020-07-13 14:31:21 +02:00			`discard_on ActiveRecord::RecordNotFound`
jobs: ignore deleted file in Virus Scan We have errors in production where the job starts correctly (i.e. the blob exists), but `blob.open` fails with a `ActiveStorage::FileNotFound` error. When checking later in production, the blob has been deleted. This points to the blob (and the file) being deleted during the virus scan job. In that case, ignore the error (rather than retrying the job). 2020-09-03 11:00:59 +02:00			`# If the file is deleted during the scan, ignore the error`
			`discard_on ActiveStorage::FileNotFoundError`
jobs: retry on ActiveStorage::IntegrityError during virus scan This is the same setting than what ActiveStorage::AnalyzeJob uses. 2021-03-11 18:36:25 +01:00			`# If for some reason the file appears invalid, retry for a while`
retry 5 times on integrity error and then block processing 2021-04-06 14:59:12 +02:00			`retry_on(ActiveStorage::IntegrityError, attempts: 5, wait: 5.seconds) do \|job, _error\|`
			`blob = job.arguments.first`
refactor(virus_scan_result): use column instead of metadata on blob 2022-12-22 18:20:58 +01:00			`blob.update_columns(virus_scan_result: ActiveStorage::VirusScanner::INTEGRITY_ERROR, virus_scanned_at: Time.zone.now)`
retry 5 times on integrity error and then block processing 2021-04-06 14:59:12 +02:00			`end`
jobs: retry on ActiveStorage::IntegrityError during virus scan This is the same setting than what ActiveStorage::AnalyzeJob uses. 2021-03-11 18:36:25 +01:00
Save virus scan status to blob metadata 2019-05-02 11:37:35 +02:00			`def perform(blob)`
refactor(virus_scan_result): use column instead of metadata on blob 2022-12-22 18:20:58 +01:00			`return if blob.virus_scanner.done?`
add merge_and_update_metadata method 2021-04-06 18:00:54 +02:00
refactor(virus_scan_result): use column instead of metadata on blob 2022-12-22 18:20:58 +01:00			`blob.update_columns(ActiveStorage::VirusScanner.new(blob).attributes)`
add merge_and_update_metadata method 2021-04-06 18:00:54 +02:00			`end`
Save virus scan status to blob metadata 2019-05-02 11:37:35 +02:00			`end`