class TransactionsQueueProcessor
  include Sneakers::Worker

  from_queue 'stats.transactions'.freeze


  def work(msg)
    hash = JSON.parse(msg).with_indifferent_access
    hash[:original_id] = hash[:id]

    create_transaction(hash)
  rescue => e
    Rails.logger.error e.message
  end


  private

    def create_transaction(message_body)
      transaction = Transaction.create(message_body)

      unless transaction.persisted?
        Rails.logger.error "Can't save payment transaction #{transaction.errors.full_messages.join('; ')}"
      end
    end

end