RES Library file copied from VRE and updated

lib/res/ch31_form.rb

@@ -0,0 +1,158 @@
+# frozen_string_literal: true
+
+require_relative 'service'
+require_relative 'errors/ch31_errors'
+require 'sentry_logging'
+
+# Modified VRE code to new RES service
+module RES
+  class Ch31Form < RES::Service
+    include SentryLogging
+    configuration RES::Configuration
+    STATSD_KEY_PREFIX = 'api.res'
+    SENTRY_TAG = { team: 'vfs-ebenefits' }.freeze
+
+    def initialize(user:, claim:)
+      super
+      @user = user
+      @claim = claim
+    end
+
+    # Submits prepared data derived from VeteranReadinessEmploymentClaim#form
+    #
+    # @return [Hash] the student's address
+    #
+    def submit
+      raise Ch31NilClaimError if @claim.nil?
+
+      response = send_to_res(payload: format_payload_for_res)
+      response_body = response.body
+
+      raise Ch31Error if response_body['error_occurred'] == true
+
+      log_message_to_sentry(
+        'Temp message for testing',
+        :warn,
+        { application_intake_id: response_body['application_intake'] },
+        SENTRY_TAG
+      )
+      response_body
+    rescue Ch31Error => e
+      process_ch_31_error(e, response_body)
+
+      response_body
+    rescue Ch31NilClaimError => e
+      process_nil_claim_error(e)
+    end
+
+    private
+
+    def format_payload_for_res
+      form_data = claim_form_hash
+
+      res_payload = {
+        useEva: form_data['useEva'],
+        useTelecounseling: form_data['useTelecounseling'],
+        appointmentTimePreferences: form_data['appointmentTimePreferences'],
+        yearsOfEducation: form_data['yearsOfEducation'],
+        isMoving: form_data['isMoving'],
+        mainPhone: form_data['mainPhone'],
+        cellNumber: form_data['cellPhone'],
+        # internationalNumber: form_data['internationalNumber'],
+        email: form_data['email'],
+        documentId: form_data.dig('supportingDocuments', 0, 'documentId'), # or @claim.guid
+        receivedDate: @claim.created_at
+      }
+
+      res_payload[:data].merge!(veteran_address(form_data))
+      res_payload[:data].merge!({ veteranInformation: adjusted_veteran_information })
+      res_payload[:data].merge!(new_address) if form_data['newAddress'].present?
+
+      res_payload.to_json
+    end
+
+    def veteran_address(form_data)
+      vet_address = mapped_address_hash(form_data['veteranAddress'])
+
+      adjusted_address = {
+        veteranAddress: vet_address
+      }
+
+      return adjusted_address if adjusted_address.dig(:veteranAddress, :isForeign) == false
+
+      # RES/CMSA expects different keys for postal and state for foreign addresses
+      # internationPostalCode misspelling is correct
+      international_address = adjusted_address[:veteranAddress]
+      international_address[:internationPostalCode] = international_address.delete(:zipCode)
+      international_address[:province] = international_address.delete(:stateCode)
+
+      adjusted_address
+    end
+
+    def claim_form_hash
+      @claim.parsed_form
+    end
+
+    def adjusted_veteran_information
+      vet_info = claim_form_hash['veteranInformation']
+
+      vet_info['VAFileNumber'] = vet_info.delete('vaFileNumber') if vet_info.key?('vaFileNumber')
+
+      vet_info
+    end
+
+    def new_address
+      new_address = mapped_address_hash(claim_form_hash['newAddress'])
+
+      adjusted_new_address = {
+        newAddress: new_address
+      }
+
+      return adjusted_new_address unless new_address[:isForeign]
+
+      # RES/CMSA expects different keys for postal and state for foreign addresses
+      new_address[:internationalPostalCode] = new_address.delete(:zipCode)
+      new_address[:province] = new_address.delete(:stateCode)
+
+      adjusted_new_address
+    end
+
+    def mapped_address_hash(client_hash)
+      {
+        # isForeign: client_hash['country'] != 'USA',
+        # isMilitary: client_hash['isMilitary'] || false,
+        country: client_hash['country'],
+        street: client_hash['street'],
+        # addressLine1: client_hash['street'],
+        # addressLine2: client_hash['street2'],
+        # addressLine3: client_hash['street3'],
+        city: client_hash['city'],
+        state: client_hash['state'],
+        postalCode: client_hash['postalCode']
+      }
+    end
+
+    def process_ch_31_error(e, response_body)
+      log_exception_to_sentry(
+        e,
+        {
+          intake_id: response_body['ApplicationIntake'],
+          error_message: response_body['ErrorMessage']
+        },
+        SENTRY_TAG
+      )
+    end
+
+    def process_nil_claim_error(e)
+      log_exception_to_sentry(
+        e,
+        {
+          icn: @user.icn
+        },
+        SENTRY_TAG
+      )
+
+      { 'error_occurred' => true, 'error_message' => 'Claim cannot be null' }
+    end
+  end
+end

lib/res/configuration.rb

@@ -0,0 +1,30 @@
+# frozen_string_literal: true
+
+require 'common/client/configuration/rest'
+
+module RES
+  class Configuration < Common::Client::Configuration::REST
+    def connection
+      @conn ||= Faraday.new(base_path, headers: base_request_headers, request: request_options) do |faraday|
+        faraday.use :breakers
+        faraday.use Faraday::Response::RaiseError
+        faraday.response :betamocks if mock_enabled?
+        faraday.response :snakecase, symbolize: false
+        faraday.response :json, content_type: /\bjson/
+        faraday.adapter Faraday.default_adapter
+      end
+    end
+
+    def mock_enabled?
+      Settings.readiness_and_employment_system.mock_ch_31 || false
+    end
+
+    def base_path
+      Settings.readiness_and_employment_system.base_url
+    end
+
+    def service_name
+      'ReadinessAndEmployementSystem'
+    end
+  end
+end

lib/res/errors/ch31_errors.rb

@@ -0,0 +1,4 @@
+# frozen_string_literal: true
+
+class Ch31Error < StandardError; end
+class Ch31NilClaimError < StandardError; end

lib/res/service.rb

@@ -0,0 +1,50 @@
+# frozen_string_literal: true
+
+require 'vre/configuration'
+require 'common/client/base'
+
+# The RES::Service class is where we keep RES related endpoint calls and common methods
+module RES
+  class Service < Common::Client::Base
+    include Common::Client::Concerns::Monitoring
+
+    # Makes call to RES and retrieves a token. Token is valid for 3 minutes so we just fire this on every api call
+    #
+    # @return [Hash] the student's address
+    #
+    def get_token
+      with_monitoring do
+        conn = Faraday.new(
+          Settings.readiness_and_employment_system.auth_endpoint,
+          headers: { 'Authorization' => "Basic #{Settings.readiness_and_employment_system.credentials}" }
+        )
+
+        request = conn.post
+        JSON.parse(request.body)['access_token']
+      end
+    end
+
+    def send_to_res(payload:)
+      with_monitoring do
+        perform(
+          :post,
+          end_point,
+          payload,
+          request_headers
+        ) # see lib/common/client/base.rb#L94
+      end
+    end
+
+    def request_headers
+      {
+        Authorization: "Bearer #{get_token}"
+      }
+    end
+
+    private
+
+    def end_point
+      "#{Settings.veteran_readiness_and_employment.base_url}/api/endpoints/vaGov/new_application"
+    end
+  end
+end