Create PowerOfAttorneyFormSubmissionJob (#101919)

.github/CODEOWNERS

@@ -623,6 +623,7 @@ app/uploaders/vets_shrine.rb @department-of-veterans-affairs/va-api-engineers @d
 app/validators/token_util.rb @department-of-veterans-affairs/backend-review-group
 app/uploaders/simple_forms_api/ @department-of-veterans-affairs/platform-va-product-forms @department-of-veterans-affairs/va-api-engineers @department-of-veterans-affairs/backend-review-group
 app/sidekiq/account_login_statistics_job.rb @department-of-veterans-affairs/octo-identity
+app/sidekiq/accredited_representative_portal/power_of_attorney_form_submission_job.rb @department-of-veterans-affairs/benefits-accredited-rep-facing-engineers @department-of-veterans-affairs/backend-review-group
 app/sidekiq/benefits_intake_remediation_status_job.rb @department-of-veterans-affairs/platform-va-product-forms @department-of-veterans-affairs/va-api-engineers @department-of-veterans-affairs/backend-review-group
 app/sidekiq/benefits_intake_status_job.rb @department-of-veterans-affairs/platform-va-product-forms @department-of-veterans-affairs/Disability-Experience @department-of-veterans-affairs/va-api-engineers @department-of-veterans-affairs/backend-review-group
 app/sidekiq/bgs @department-of-veterans-affairs/benefits-dependents-management @department-of-veterans-affairs/va-api-engineers @department-of-veterans-affairs/backend-review-group

app/sidekiq/accredited_representative_portal/power_of_attorney_form_submission_job.rb

@@ -0,0 +1,52 @@
+# frozen_string_literal: true
+
+require 'sentry_logging'
+
+module AccreditedRepresentativePortal
+  class PowerOfAttorneyFormSubmissionJob
+    include Sidekiq::Job
+    include SentryLogging
+
+    sidekiq_options retry: 2
+
+    attr_reader :response
+
+    def perform(poa_form_submission_id)
+      @id = poa_form_submission_id
+      service = BenefitsClaims::Service.new(poa_form_submission.power_of_attorney_request.claimant.icn)
+      @response = service.get_2122_submission(poa_form_submission.service_id)
+      poa_form_submission.update(
+        status: (non_error_response? ? :succeeded : :failed),
+        service_response: response.to_json,
+        status_updated_at: DateTime.current,
+        error_message: error_data.to_json
+      )
+    rescue => e
+      handle_errors(e, poa_form_submission)
+    end
+
+    sidekiq_retries_exhausted do |job, _ex|
+      poa_form_submission_id = job['args'].first
+      poa_form_submission = PowerOfAttorneyFormSubmission.find(poa_form_submission_id)
+      poa_form_submission.update(status: :failed, status_updated_at: DateTime.current)
+    end
+
+    def handle_errors(e, poa_form_submission)
+      log_exception_to_sentry(e)
+      poa_form_submission.update(error_message: e.message, status: :enqueue_failed)
+      raise e
+    end
+
+    def non_error_response?
+      response.dig('data', 'attributes', 'status') != 'errored'
+    end
+
+    def error_data
+      response.dig('data', 'attributes', 'errors')
+    end
+
+    def poa_form_submission
+      @poa_form_submission ||= PowerOfAttorneyFormSubmission.find(@id)
+    end
+  end
+end

modules/accredited_representative_portal/app/services/accredited_representative_portal/power_of_attorney_request_service/accept.rb

@@ -38,8 +38,8 @@ def call
           service_id: response.body.dig('data', 'id'),
           service_response: response.body.to_json
         )
+        PowerOfAttorneyFormSubmissionJob.perform_async(form_submission.id)
         form_submission
-      # TODO: call PowerOfAttorneyFormSubmissionJob.perform_async(poa_form_submission)
       # Invalid record - return error message with 400
       rescue ActiveRecord::RecordInvalid => e
         raise Error.new(e.message, :bad_request)

modules/accredited_representative_portal/spec/factories/power_of_attorney_form_submission.rb

@@ -0,0 +1,12 @@
+# frozen_string_literal: true
+
+FactoryBot.define do
+  factory :power_of_attorney_form_submission,
+          class: 'AccreditedRepresentativePortal::PowerOfAttorneyFormSubmission' do
+    association :power_of_attorney_request
+    service_id { SecureRandom.uuid }
+    service_response { '{}' }
+    status { :enqueue_succeeded }
+    status_updated_at { DateTime.now }
+  end
+end

modules/accredited_representative_portal/spec/fixtures/power_of_attorney_form_submission/error.json

@@ -0,0 +1,45 @@
+{
+  "data": {
+    "id": "a4dd5bb0-d47b-4ca9-9afc-d7ce6a820985",
+    "type": "claimsApiPowerOfAttorneys",
+    "attributes": {
+      "dateRequestAccepted": "2025-01-16",
+      "previousPoa": "-",
+      "representative": {
+        "veteran": {
+          "address": {
+            "addressLine1": "123",
+            "addressLine2": "2a",
+            "city": "city",
+            "countryCode": "US",
+            "stateCode": "OR",
+            "zipCode": "12345",
+            "zipCodeSuffix": "6789"
+          }
+        },
+        "representative": {
+          "poaCode": "067",
+          "registrationNumber": "999999999999",
+          "type": "ATTORNEY",
+          "address": {
+            "addressLine1": "123",
+            "addressLine2": "2a",
+            "city": "city",
+            "countryCode": "US",
+            "stateCode": "OR",
+            "zipCode": "12345",
+            "zipCodeSuffix": "6789"
+          }
+        }
+      },
+      "status": "errored",
+      "errors": [
+        {
+          "title": "some error",
+          "detail": "error detail",
+          "code": "PDF_SUBMISSION"
+        }
+      ]
+    }
+  }
+}

modules/accredited_representative_portal/spec/fixtures/power_of_attorney_form_submission/success.json

@@ -0,0 +1,38 @@
+{
+  "data": {
+    "id": "a4dd5bb0-d47b-4ca9-9afc-d7ce6a820985",
+    "type": "claimsApiPowerOfAttorneys",
+    "attributes": {
+      "dateRequestAccepted": "2025-01-16",
+      "previousPoa": "-",
+      "representative": {
+        "veteran": {
+          "address": {
+            "addressLine1": "123",
+            "addressLine2": "2a",
+            "city": "city",
+            "countryCode": "US",
+            "stateCode": "OR",
+            "zipCode": "12345",
+            "zipCodeSuffix": "6789"
+          }
+        },
+        "representative": {
+          "poaCode": "067",
+          "registrationNumber": "999999999999",
+          "type": "ATTORNEY",
+          "address": {
+            "addressLine1": "123",
+            "addressLine2": "2a",
+            "city": "city",
+            "countryCode": "US",
+            "stateCode": "OR",
+            "zipCode": "12345",
+            "zipCodeSuffix": "6789"
+          }
+        }
+      },
+      "status": "pending"
+    }
+  }
+}

spec/sidekiq/accredited_representative_portal/power_of_attorney_form_submission_job_spec.rb

@@ -0,0 +1,90 @@
+# frozen_string_literal: true
+
+require 'rails_helper'
+require 'sidekiq/testing'
+
+RSpec.describe AccreditedRepresentativePortal::PowerOfAttorneyFormSubmissionJob, type: :job do
+  subject { described_class.new }
+
+  let(:poa_form_submission) do
+    create(:power_of_attorney_form_submission, service_id: '29b7c214-4a61-425e-97f2-1a56de869524')
+  end
+
+  before do
+    allow_any_instance_of(Auth::ClientCredentials::Service).to receive(:get_token).and_return('fake_access_token')
+    poa_form_submission.power_of_attorney_request.claimant.update(icn: '123498767V234859')
+  end
+
+  describe '#perform' do
+    context 'successful LH submission' do
+      let(:service_response) do
+        File.read('modules/accredited_representative_portal/spec' \
+                  '/fixtures/power_of_attorney_form_submission/success.json')
+      end
+
+      context 'successful submission' do
+        it 'updates the form submission as successful' do
+          VCR.use_cassette('lighthouse/benefits_claims/power_of_attorney_status/200_response') do
+            subject.perform(poa_form_submission.id)
+          end
+          poa_form_submission.reload
+          expect(poa_form_submission.status).to eq 'succeeded'
+          expect(JSON.parse(poa_form_submission.service_response)).to eq JSON.parse(service_response)
+          expect(poa_form_submission.status_updated_at).not_to be_nil
+        end
+
+        context 'data shows status of errored' do
+          let(:expected_error_message) do
+            '[{"title":"some error","detail":"error detail","code":"PDF_SUBMISSION"}]'
+          end
+          let(:service_response) do
+            File.read('modules/accredited_representative_portal/spec' \
+                      '/fixtures/power_of_attorney_form_submission/error.json')
+          end
+
+          it 'updates the form submission as failed' do
+            VCR.use_cassette('lighthouse/benefits_claims/power_of_attorney_status/200_errored_response') do
+              subject.perform(poa_form_submission.id)
+            end
+            poa_form_submission.reload
+            expect(poa_form_submission.status).to eq 'failed'
+            expect(JSON.parse(poa_form_submission.service_response)).to eq JSON.parse(service_response)
+            expect(poa_form_submission.error_message).to eq expected_error_message
+            expect(poa_form_submission.status_updated_at).not_to be_nil
+          end
+        end
+
+        context 'the job fails 3 times' do
+          let(:lh_service) { double }
+
+          it 'updates the status as failed' do
+            subject.sidekiq_retries_exhausted_block.call({ 'args' => [poa_form_submission.id] })
+            poa_form_submission.reload
+            expect(poa_form_submission.status).to eq('failed')
+          end
+        end
+      end
+    end
+
+    context 'submission not found' do
+      let(:rails_logger) { double }
+
+      it 'updates the form submission and submits the error to sentry and logger' do
+        Settings.sentry = OpenStruct.new(dsn: 'test')
+        allow(Rails).to receive(:logger).and_return rails_logger
+        poa_form_submission.update(service_id: '491b878a-d977-40b8-8de9-7ba302307a48')
+        expect(Sentry).to receive(:capture_exception)
+        expect(rails_logger).to receive(:send).with('error', 'Resource not found.')
+        expect(rails_logger).to receive(:send)
+        expect do
+          VCR.use_cassette('lighthouse/benefits_claims/power_of_attorney_status/404_response') do
+            subject.perform(poa_form_submission.id)
+          end
+        end.to raise_error(Common::Exceptions::ResourceNotFound)
+        poa_form_submission.reload
+        expect(poa_form_submission.error_message).to eq 'Resource not found'
+        expect(poa_form_submission.status_updated_at).not_to be_nil
+      end
+    end
+  end
+end