Rakefile

# frozen_string_literal: true
require 'rake/testtask'

task :default do
  puts `rake -T`
end

Rake::TestTask.new(:spec) do |t|
  t.pattern = 'spec/*_spec.rb'
  t.warning = false
end
namespace :run do
  task :dev do
    sh 'rerun "rackup -p 9292"'
  end

  task :test do
    loop do
      puts 'Setting up test environment'
      ENV['RACK_ENV'] = 'test'
      Rake::Task['db:_setup'].execute
      Rake::Task['db:reset'].execute
      puts 'Populating test database'
      url_request = { city: 'Taipei', country_code: 'TW' }
      LoadCityFromMeetup.call(url_request.to_json)
      sh 'rerun "rackup -p 3000"'
    end
  end
end

namespace :db do
  task :_setup do
    require 'sequel'
    require_relative 'init'
    Sequel.extension :migration
  end

  desc 'Run database migrations'
  task migrate: [:_setup] do
    puts "Migrating to latest for: #{ENV['RACK_ENV'] || 'development'}"
    Sequel::Migrator.run(DB, 'db/migrations')
    Rake::Task['db:schema'].execute
  end

  desc 'Reset migrations (full rollback and migration)'
  task reset: [:_setup] do
    puts "Rolling back #{ENV['RACK_ENV'] || 'development'} database"
    Sequel::Migrator.run(DB, 'db/migrations', target: 0)
    Rake::Task['db:migrate'].execute
  end

  desc 'Print out final schema to file'
  task schema: [:_setup] do
    DB.extension :schema_dumper
    File.open('db/schema.rb', 'w') do |file|
      header = <<~END
        # This schema file is automatically generated by `rake db:schema`.
        # It will be overwritten periodically so do not make changes.
      END
      puts 'Writing schema to db/schema.rb'
      file.write(header)
      file.write(DB.dump_schema_migration)
    end
  end
end

desc 'delete cassette fixtures'
task :wipe do
  sh 'rm spec/fixtures/cassettes/*.yml' do |ok, _|
    puts(ok ? 'Cassettes deleted' : 'No casseettes found')
  end
end

namespace :quality do
  CODE = 'app.rb'

  desc 'run all quality checks'
  task all: [:rubocop, :flog, :flay]

  task :flog do
    sh "flog #{CODE}"
  end

  task :flay do
    sh "flay #{CODE}"
  end

  task :rubocop do
    sh 'rubocop'
  end
end
namespace :queue do
  require 'aws-sdk'
  require_relative 'init'
  desc "Create SQS queue for Shoryuken"
  task :create do
    config = EventsLocatorAPI.config
    sqs = Aws::SQS::Client.new(region: config.AWS_REGION,
                               access_key_id: config.AWS_ACCESS_KEY_ID,
                               secret_access_key: config.AWS_SECRET_ACCESS_KEY)
    begin
      queue = sqs.create_queue(queue_name: config.NEW_CITY_QUEUE)
      puts "Queue #{config.NEW_CITY_QUEUE} created on #{config.AWS_REGION}"
    rescue => e
      puts "Error creating queue: #{e}"
    end
  end

  task :purge do
    config = FaceGroupAPI.config
    sqs = Aws::SQS::Client.new(region: config.AWS_REGION,
                               access_key_id: config.AWS_ACCESS_KEY_ID,
                               secret_access_key: config.AWS_SECRET_ACCESS_KEY)
    begin
      url = sqs.get_queue_url({ queue_name: config.NEW_CITY_QUEUE })
      queue = sqs.purge_queue({ queue_url: url.queue_url})
      puts "Queue #{config.NEW_CITY_QUEUE} purged"
    rescue => e
      puts "Error purging queue: #{e}"
    end
  end
end