[DBX-82245] implement LH getPDF for 526 backup path

.gitignore

@@ -109,3 +109,7 @@ clamav_tmp/*
 
 # Ignore development setup (native, docker, hybrid)
 .developer-setup
+
+# ignore DBEX LH migration debug tools
+lib/TREX
+staging.benefits_claims.pem

lib/disability_compensation/factories/api_provider_factory.rb

@@ -172,7 +172,7 @@ def generate_pdf_service_provider
       # for instance, in the backup process
       EvssGeneratePdfProvider.new(@options[:auth_headers], breakered: @options[:breakered])
     when API_PROVIDER[:lighthouse]
-      LighthouseGeneratePdfProvider.new({})
+      LighthouseGeneratePdfProvider.new(@current_user[:icn])
     else
       raise NotImplementedError, 'No known Generate Pdf Api Provider type provided'
     end

lib/disability_compensation/providers/generate_pdf/lighthouse_generate_pdf_provider.rb

@@ -3,13 +3,20 @@
 require 'disability_compensation/providers/generate_pdf/generate_pdf_provider'
 
 class LighthouseGeneratePdfProvider
-  include GeneratePdfProvider
+  def initialize(icn)
+    @icn = icn
+  end
+
+  def generate_526_pdf(form_content)
+    body = transform_service.transform(JSON.parse(form_content))
+    service.submit526(body, nil, nil, { generate_pdf: true })
+  end
 
-  def initialize(_auth_headers)
-    # TODO: Implement in Ticket#
+  def transform_service
+    @transform_service ||= EVSS::DisabilityCompensationForm::Form526ToLighthouseTransform.new
   end
 
-  def generate_526_pdf(_form_content)
-    # TODO: Implement in Ticket#
+  def service
+    @service ||= BenefitsClaims::Service.new(@icn)
   end
 end

lib/sidekiq/form526_backup_submission_process/processor.rb

@@ -69,6 +69,8 @@ class Processor
       def initialize(submission_id, docs = [], get_upload_location_on_instantiation: true, ignore_expiration: false)
         @submission_id = submission_id
         @submission = Form526Submission.find(submission_id)
+        @user_account = UserAccount.find_by(id: submission.user_uuid) ||
+                        Account.lookup_by_user_uuid(submission.user_uuid)
         @docs = docs
         @docs_gathered = false
         @initial_upload_fetched = false
@@ -120,8 +122,6 @@ def upload_pdf_submission_to_s3(return_url: false, url_life_length: 1.week.to_i)
         generate_zip_and_upload(params_docs, zipname, metadata, return_url, url_life_length)
       end
 
-      private
-
       def instantiate_upload_info_from_lighthouse
         initial_upload = @lighthouse_service.get_location_and_uuid
         @initial_upload_uuid = initial_upload[:uuid]
@@ -303,8 +303,6 @@ def submit_ancillary_payloads(docs)
       end
 
       def determine_zip
-        # TODO: Figure out if I need to use currentMailingAddress or changeOfAddress zip?
-        # TODO: I dont think it matters too much though
         z = submission.form.dig('form526', 'form526', 'veteran', 'currentMailingAddress')
         if z.nil? || z['country']&.downcase != 'usa'
           @zip = '00000'
@@ -328,22 +326,26 @@ def write_to_tmp_file(content, ext = 'pdf')
       def get_form526_pdf
         headers = submission.auth_headers
         submission_create_date = submission.created_at.iso8601
-        form_json = JSON.parse(submission.form_json)[FORM_526]
+        form_json = submission.form[FORM_526]
         form_json[FORM_526]['claimDate'] ||= submission_create_date
         form_json[FORM_526]['applicationExpirationDate'] = 365.days.from_now.iso8601 if @ignore_expiration
-        resp = get_form_from_external_api(headers, form_json.to_json)
-        b64_enc_body = resp.body['pdf']
-        content = Base64.decode64(b64_enc_body)
+
+        if submission.claims_api?
+          resp = get_form_from_external_api(headers, ApiProviderFactory::API_PROVIDER[:lighthouse], form_json.to_json)
+          content = resp.env.response_body
+        else
+          resp = get_form_from_external_api(headers, ApiProviderFactory::API_PROVIDER[:evss], form_json.to_json)
+          b64_enc_body = resp.body['pdf']
+          content = Base64.decode64(b64_enc_body)
+        end
         file = write_to_tmp_file(content)
-        docs << {
-          type: FORM_526_DOC_TYPE,
-          file:
-        }
+        docs << { type: FORM_526_DOC_TYPE, file: }
       end
 
-      def get_form_from_external_api(headers, form_json)
+      # 82245 - Adding provider to method. this should be removed when toxic exposure flipper is removed
+      def get_form_from_external_api(headers, provider, form_json)
         # get the "breakered" version
-        service = choose_provider(headers, breakered: true)
+        service = choose_provider(headers, provider, breakered: true)
 
         service.generate_526_pdf(form_json)
       end
@@ -408,7 +410,6 @@ def convert_docs_to_pdf
           'Complete 526 PDF Generating for Backup Submission',
           { submission_id:, initial_upload_uuid: }
         )
-
         result
       end
 
@@ -428,14 +429,14 @@ def convert_doc_to_pdf(doc, klass)
         end
       end
 
-      def choose_provider(headers, breakered: true)
+      # 82245 - Adding provider to method. this should be removed when toxic exposure flipper is removed
+      def choose_provider(headers, provider, breakered: true)
         ApiProviderFactory.call(
           type: ApiProviderFactory::FACTORIES[:generate_pdf],
-          # let Flipper - the feature toggle - choose which provider
-          provider: nil,
+          provider:,
           # this sends the auth headers and if we want the "breakered" or "non-breakered" version
           options: { auth_headers: headers, breakered: },
-          current_user: OpenStruct.new({ flipper_id: submission.user_uuid }),
+          current_user: OpenStruct.new({ flipper_id: submission.user_uuid, icn: @user_account.icn }),
           feature_toggle: ApiProviderFactory::FEATURE_TOGGLE_GENERATE_PDF
         )
       end
@@ -445,12 +446,18 @@ class NonBreakeredProcessor < Processor
       def get_form526_pdf
         headers = submission.auth_headers
         submission_create_date = submission.created_at.iso8601
-        form_json = JSON.parse(submission.form_json)[FORM_526]
+        form_json = submission.form[FORM_526]
         form_json[FORM_526]['claimDate'] ||= submission_create_date
         form_json[FORM_526]['applicationExpirationDate'] = 365.days.from_now.iso8601 if @ignore_expiration
-        resp = get_from_non_breakered_service(headers, form_json.to_json)
-        b64_enc_body = resp.body['pdf']
-        content = Base64.decode64(b64_enc_body)
+        if submission.claims_api?
+          resp = get_from_non_breakered_service(headers, ApiProviderFactory::API_PROVIDER[:lighthouse],
+                                                form_json.to_json)
+          content = resp.env.response_body
+        else
+          resp = get_from_non_breakered_service(headers, ApiProviderFactory::API_PROVIDER[:evss], form_json.to_json)
+          b64_enc_body = resp.body['pdf']
+          content = Base64.decode64(b64_enc_body)
+        end
         file = write_to_tmp_file(content)
         docs << {
           type: FORM_526_DOC_TYPE,
@@ -459,9 +466,10 @@ def get_form526_pdf
       end
     end
 
-    def get_from_non_breakered_service(headers, form_json)
+    # 82245 - Adding provider to method. this should be removed when toxic exposure flipper is removed
+    def get_from_non_breakered_service(headers, provider, form_json)
       # get the "non-breakered" version
-      service = choose_provider(headers, breakered: false)
+      service = choose_provider(headers, provider, breakered: false)
 
       service.get_form526(form_json)
     end

spec/lib/sidekiq/form526_backup_submission_process/processor_spec.rb

@@ -26,4 +26,26 @@
       end
     end
   end
+
+  describe '#choose_provider' do
+    let(:account) { create(:account) }
+    let(:submission) { create(:form526_submission, user_uuid: account.idme_uuid, submit_endpoint: 'claims_api') }
+
+    it 'delegates to the ApiProviderFactory with the correct data' do
+      auth_headers = {}
+      expect(ApiProviderFactory).to receive(:call).with(
+        {
+          type: ApiProviderFactory::FACTORIES[:generate_pdf],
+          provider: ApiProviderFactory::API_PROVIDER[:lighthouse],
+          options: { auth_headers:, breakered: true },
+          current_user: OpenStruct.new({ flipper_id: submission.user_uuid, icn: account.icn }),
+          feature_toggle: ApiProviderFactory::FEATURE_TOGGLE_GENERATE_PDF
+        }
+      )
+
+      subject
+        .new(submission.id, get_upload_location_on_instantiation: false)
+        .choose_provider(auth_headers, ApiProviderFactory::API_PROVIDER[:lighthouse])
+    end
+  end
 end