Sha256: a5b2f7c93d4bd6bf5d2ba54cecbceb78671890027eb606b7cabc2dfcfbe38d8b

Contents?: true

Size: 1.52 KB

Versions: 12

Compression:

Stored size: 1.52 KB

Contents

# frozen_string_literal: true

require_dependency "renalware/feeds"

module Renalware
  module Feeds
    module Files
      module PracticeMemberships
        class ImportJob < ApplicationJob
          include StringLogging
          include Feeds::Job
          FILE_TO_EXTRACT_FROM_ARCHIVE = /epracmem.csv/.freeze

          # rubocop:disable Metrics/AbcSize
          # TODO: refactor
          def perform(file)
            logging_to_stringio(strio = StringIO.new)
            log "Before upload there are #{practice_membership_count} practice memberships"
            file.update!(status: :processing, attempts: file.attempts + 1)
            status = :success
            elapsed_ms = Benchmark.ms { process_archive(file.location) }
            log "After upload there are #{practice_membership_count} practice memberships"
          rescue StandardError => e
            Rails.logger.error(formatted_exception(e))
            status = :failure
            raise e
          ensure
            file.update!(status: status, result: strio.string, time_taken: elapsed_ms)
          end
          # rubocop:enable Metrics/AbcSize

          private

          def process_archive(location)
            ZipArchive.new(location).unzip do |files|
              csv_path = find_file_in(files, FILE_TO_EXTRACT_FROM_ARCHIVE)
              PracticeMemberships::ImportCSV.new(csv_path).call
            end
          end

          def practice_membership_count
            Patients::PracticeMembership.count
          end
        end
      end
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version Path
renalware-core-2.0.136 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.135 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.134 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.133 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.132 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.131 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.130 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.129 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.128 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.127 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.126 app/models/renalware/feeds/files/practice_memberships/import_job.rb
renalware-core-2.0.125 app/models/renalware/feeds/files/practice_memberships/import_job.rb