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

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

    error ActiveRecord::RecordNotFound do
      content_type :json
      status 404
      { error: true, message: 'event not found' }.to_json
    end

    error StandardError do
      content_type :json
      error = env['sinatra.error']
      { error: true, message: error.message }.to_json
    end

    get '/ping' do
      'PONG'
    end

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

    post "/#{VERSION}/events/:id/retry" do
      content_type :json
      event = PhobosDBCheckpoint::Event.find(params['id'])
      metadata = {
        listener_id: 'events_api/retry',
        group_id: event.group_id,
        topic: event.topic,
        retry_count: 0
      }

      event_action =
        begin
          event
            .configured_handler
            .new
            .consume(event.payload, metadata)
        rescue ListenerNotFoundError => e
          status 422
          return { error: true, message: e.message }.to_json
        end

      { acknowledged: event_action.is_a?(PhobosDBCheckpoint::Ack) }.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(event_time: :desc)
        .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(event_time: :desc)
        .limit(limit)
        .offset(offset)
        .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 => e
          status 422
          return { error: true, message: e.message }.to_json
        end

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