dbcf21a555
Update app/dashboards/archive_dashboard.rb Co-authored-by: LeSim <mail@simon.lehericey.net>
80 lines
2 KiB
Ruby
80 lines
2 KiB
Ruby
# == Schema Information
|
|
#
|
|
# Table name: archives
|
|
#
|
|
# id :bigint not null, primary key
|
|
# key :text not null
|
|
# month :date
|
|
# status :string not null
|
|
# time_span_type :string not null
|
|
# created_at :datetime not null
|
|
# updated_at :datetime not null
|
|
#
|
|
class Archive < ApplicationRecord
|
|
include AASM
|
|
|
|
RETENTION_DURATION = 4.days
|
|
MAX_SIZE = 100.gigabytes
|
|
|
|
has_and_belongs_to_many :groupe_instructeurs
|
|
|
|
has_one_attached :file
|
|
|
|
scope :stale, -> { where('updated_at < ?', (Time.zone.now - RETENTION_DURATION)) }
|
|
scope :for_groupe_instructeur, -> (groupe_instructeur) {
|
|
joins(:archives_groupe_instructeurs)
|
|
.where(
|
|
archives_groupe_instructeurs: { groupe_instructeur: groupe_instructeur }
|
|
)
|
|
}
|
|
|
|
enum time_span_type: {
|
|
everything: 'everything',
|
|
monthly: 'monthly'
|
|
}
|
|
|
|
enum status: {
|
|
pending: 'pending',
|
|
generated: 'generated',
|
|
failed: 'failed'
|
|
}
|
|
|
|
aasm whiny_persistence: true, column: :status, enum: true do
|
|
state :pending, initial: true
|
|
state :generated
|
|
state :failed
|
|
|
|
event :make_available do
|
|
transitions from: :pending, to: :generated
|
|
end
|
|
event :restart do
|
|
transitions from: :failed, to: :pending
|
|
end
|
|
event :fail do
|
|
transitions from: :pending, to: :failed
|
|
end
|
|
end
|
|
|
|
def available?
|
|
status == 'generated' && file.attached?
|
|
end
|
|
|
|
def filename(procedure)
|
|
if time_span_type == 'everything'
|
|
"procedure-#{procedure.id}.zip"
|
|
else
|
|
"procedure-#{procedure.id}-mois-#{I18n.l(month, format: '%Y-%m')}.zip"
|
|
end
|
|
end
|
|
|
|
def self.find_or_create_archive(time_span_type, month, groupe_instructeurs)
|
|
create_with(groupe_instructeurs: groupe_instructeurs)
|
|
.create_or_find_by(time_span_type: time_span_type, month: month, key: generate_cache_key(groupe_instructeurs))
|
|
end
|
|
|
|
private
|
|
|
|
def self.generate_cache_key(groupe_instructeurs)
|
|
groupe_instructeurs.map(&:id).sort.join('-')
|
|
end
|
|
end
|