qbwc_endpoint.rb

require 'pry-byebug'
require 'nori'
require 'nokogiri'
require 'fast_xs'
require 'sinatra/reloader'

require 'honeybadger'

require 'active_support/core_ext/date/calculations'
require 'active_support/core_ext/numeric/time'

require File.expand_path(File.dirname(__FILE__) + '/lib/quickbooks_desktop_integration')

if File.exist? File.join(File.expand_path(File.dirname(__FILE__)), '.env')
  # TODO check an ENV variable i.e. RACK_ENV
  begin
    require 'dotenv'
    Dotenv.load
  rescue => e
    puts e.message
    puts e.backtrace.join("\n")
  end
end

class QBWCEndpoint < Sinatra::Base
  set :logging, true

  # Force Sinatra to autoreload this file or any file in the lib directory
  # when they change in development
  configure :development do
    register Sinatra::Reloader
    also_reload './lib/**/*'
  end

  unless String.respond_to? :underscore
    class String
      def underscore
        gsub(/::/, '/')
          .gsub(/([A-Z]+)([A-Z][a-z])/, '\1_\2')
          .gsub(/([a-z\d])([A-Z])/, '\1_\2')
          .tr('-', '_')
          .downcase
      end
    end
  end

  get '/support' do
    redirect 'https://flowlink.io'
  end

  get '/:connection_id' do
    'ok'
  end

  post '/:connection_id' do
    content_type 'text/xml'

    body = request.body.read
    doc = Nokogiri::XML(body)
    # nori = Nori.new
    # hash = nori.parse body

    # poor parser / TODO refactor it
    # => {"soapenv:Envelope"=>
    # {"soapenv:Header"=>nil, "soapenv:Body"=>{"fe5:closeConnection"=>{"fe5:ticket"=>"?"}}, "@xmlns:soapenv"=>"http://schemas.xmlsoap.org/soap/envelope/", "@xmlns:fe5"=>"https://fe533b4.ngrok.com/"}}
    # operation = hash['soap:Envelope']['soap:Body'].keys.first.split(':').last.underscore
    #operation = doc.children.first.children.first.children.first.name.underscore
    soap_body_element = doc.xpath('//soap:Body/*',
                                  'soap' => 'http://schemas.xmlsoap.org/soap/envelope/')
    operation = soap_body_element.first.name.underscore

    # server_version
    # client_version
    # authenticate
    # send_request_xml
    # get_last_error
    # close_connection

    puts operation
    # puts body
    # puts params[:connection_id]
    puts '*' * 100

    send operation, params[:connection_id], body
  end

  def server_version(_connection_id, _body)
    erb :'qbwc/server_version'
  end

  def client_version(_connection_id, _body)
    erb :'qbwc/client_version'
  end

  def authenticate(_connection_id, body)
    body = CGI.unescapeHTML(body)

    puts "Authentication for #{_connection_id}: #{body}"

    body.slice! '<?xml version="1.0" ?>'
    parser = Nori.new strip_namespaces: true
    envelope = parser.parse body

    response = envelope['Envelope']['Body']['authenticate']

    username = response['strUserName']
    password = response['strPassword']

    require 'digest/sha1'
    expected_password = Digest::SHA1.hexdigest "#{username}#{ENV['QB_PASSWORD_KEY']}"

    if password == expected_password
      @result = '' # valid password - empty to use the current opened company file
    else
      @result = 'nvu' # invalid password - not valid user
    end

    puts @result

    erb :'qbwc/authenticate'
  end

  def connection_error(_connection_id, _body)
    erb :'qbwc/connection_error'
  end

  def send_request_xml(connection_id, _body)
    @qbxml = <<~XML
      <?xml version="1.0" encoding="utf-8"?>
      <?qbxml version="11.0"?>
      <QBXML>
        <QBXMLMsgsRq onError="continueOnError">
          #{QBWC::Producer.new(connection_id: connection_id).build_available_actions_to_request}
        </QBXMLMsgsRq>
      </QBXML>
    XML
    @qbxml.gsub!("\n", '').gsub!("&", "&amp;")

    puts({connection_id: connection_id, message: "Send Request XML", body: @qbxml.gsub("\n", '')})
    erb :'qbwc/send_request_xml'
  end

  def receive_response_xml(connection_id, body)
    puts "RECEIVING"
    puts({connection_id: connection_id, message: "RECEIVING RESPONSE", body: body.gsub("\n", '')})
    QBWC::Consumer.new(connection_id: connection_id).digest_response_into_actions(body)

    erb :'qbwc/receive_response_xml'
  end

  def get_last_error(_connection_id, _body)
    erb :'qbwc/get_last_error'
  end

  def close_connection(_connection_id, _body)
    erb :'qbwc/close_connection'
  end
end