1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 |
- class CreateFailedEmails < ActiveRecord::Migration[7.0]
- OLD_FAILED_EMAIL_DIRECTORY = Rails.root.join('var/spool/unprocessable_mail')
- def up
-
- return if !Setting.exists?(name: 'system_init_done')
- create_table :failed_emails do |t|
- t.binary :data, null: false
- t.integer :retries, null: false, default: 1
- t.text :parsing_error
- t.timestamps limit: 3, null: false
- end
- return if !Dir.exist?(OLD_FAILED_EMAIL_DIRECTORY)
- import_emails
- remove_old_unprocessable_emails
- end
- def down
- drop_table :failed_emails
- end
- private
- def remove_old_unprocessable_emails
- FileUtils.rm_rf OLD_FAILED_EMAIL_DIRECTORY
- rescue
- nil
- end
- def import_emails
- Dir.each_child(OLD_FAILED_EMAIL_DIRECTORY) do |filename|
- next if !filename.ends_with? '.eml'
- import_single_email(filename)
- end
- end
- def import_single_email(filename)
- path = OLD_FAILED_EMAIL_DIRECTORY.join(filename)
- data = File.binread(path)
- FailedEmail.create(data:)
- end
- end
|