phobos/phobos_db_checkpoint

# frozen_string_literal: true

require 'json'
require 'rack'
require 'sinatra/base'

require 'phobos_db_checkpoint/middleware/logger'
require 'phobos_db_checkpoint/middleware/database'

module PhobosDBCheckpoint
  class EventsAPI < Sinatra::Base
    VERSION = :v1
    set :logging, nil

    configure do
      set(:raise_errors, false)
    end

    not_found do
      content_type :json
      { error: true, message: 'not found' }.to_json
    end

    error do
      content_type :json
      exception = env['sinatra.error']
      case exception
      when ActiveRecord::RecordNotFound
        status 404
        type = env['sinatra.route'].match(%r{\/.+\/(.+)\/:})[1].chop
        { error: true, message: "#{type} not found" }.to_json
      else
        status 500
        { error: true, message: exception.message }.to_json
      end
    end

    get '/ping' do
      'PONG'
    end

    get "/#{VERSION}/events/:id" do
      content_type :json
      PhobosDBCheckpoint::Event
        .find(params['id'])
        .to_json
    end

    get "/#{VERSION}/events" do
      content_type :json
      limit = (params['limit'] || 20).to_i
      offset = (params['offset'] || 0).to_i

      query = PhobosDBCheckpoint::Event
      query = query.where(topic: params['topic']) if params['topic']
      query = query.where(group_id: params['group_id']) if params['group_id']
      query = query.where(entity_id: params['entity_id']) if params['entity_id']
      query = query.where(event_type: params['event_type']) if params['event_type']

      query
        .order_by_event_time_and_created_at
        .limit(limit)
        .offset(offset)
        .to_json
    end

    get "/#{VERSION}/failures" do
      content_type :json

      limit = (params['limit'] || 20).to_i
      offset = (params['offset'] || 0).to_i

      query = PhobosDBCheckpoint::Failure
      query = query.where(topic: params['topic']) if params['topic']
      query = query.where(group_id: params['group_id']) if params['group_id']
      query = query.where(entity_id: params['entity_id']) if params['entity_id']
      query = query.where(event_type: params['event_type']) if params['event_type']

      query
        .order_by_event_time_and_created_at
        .limit(limit)
        .offset(offset)
        .to_json
    end

    get "/#{VERSION}/failures/count" do
      content_type :json
      count = PhobosDBCheckpoint::Failure
              .all
              .count

      { count: count }.to_json
    end

    get "/#{VERSION}/failures/:id" do
      content_type :json
      PhobosDBCheckpoint::Failure
        .find(params['id'])
        .to_json
    end

    delete "/#{VERSION}/failures/:id" do
      content_type :json

      PhobosDBCheckpoint::Failure
        .find(params['id'])
        .destroy

      { acknowledged: true }.to_json
    end

    post "/#{VERSION}/failures/:id/retry" do
      content_type :json
      failure = PhobosDBCheckpoint::Failure.find(params['id'])

      failure_action =
        begin
          PhobosDBCheckpoint::RetryFailure
            .new(failure)
            .perform
        rescue StandardError => e
          status 422
          return { error: true, message: e.message }.to_json
        end

      { acknowledged: failure_action.is_a?(PhobosDBCheckpoint::Ack) }.to_json
    end
  end
end