DB Backup job

database_backup_job.rb

require 'aws-sdk-s3'
require 'net/http'
require 'uri'

SENTRY_INGEST = 'https://XXXXXXXXXXXXXXXX.ingest.sentry.io'
SENTRY_CRONS = "#{SENTRY_INGEST}/api/XXXXXXXXXXXXXXXX/cron/daily-db-backup/XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX/"

class DatabaseBackupJob < ApplicationJob
  queue_as :default

  def perform
    timestamp = Time.now.strftime('%Y%m%d%H%M%S')
    backup_file = "tmp/db_backup_#{timestamp}.sql"
    zipped_backup_file = "#{backup_file}.gz"
    bucket = 'backups'
    region = 'us-west-2'

    begin
      # 🟡 Notify Sentry your job is running
      uri = URI.parse("#{SENTRY_CRONS}?status=in_progress")
      Net::HTTP.get(uri)

      # Backup the database
      system "pg_dump --dbname=\"$DATABASE_URL\" > #{backup_file}"

      # Zip the backup
      system "gzip #{backup_file}"

      # Upload to S3
      s3 = Aws::S3::Resource.new(region:,
                                 access_key_id: ENV['S3_ACCESS_KEY'],
                                 secret_access_key: ENV['S3_SECRET_KEY'])
      obj = s3.bucket(bucket).object("db_backups/db_backup_#{timestamp}.sql.gz")
      obj.upload_file(zipped_backup_file)

      uri = URI.parse("#{SENTRY_CRONS}?status=ok")
      Net::HTTP.get(uri)
    rescue StandardError => e
      Rails.logger.error "An error occurred while backing up DB: #{e.message}"

      # 🔴 Notify Sentry your job has failed:
      uri = URI.parse("#{SENTRY_CRONS}?status=error")
      Net::HTTP.get(uri)
    ensure
      # Delete the local backup
      File.delete(zipped_backup_file) if File.exist?(zipped_backup_file)
    end
  end
end