Contents

require 'longleaf/services/application_config_deserializer'
require 'longleaf/events/register_event'
require 'longleaf/models/file_record'
require 'longleaf/events/event_names'
require 'longleaf/events/event_status_tracking'

module Longleaf
  # Command for registering files with longleaf
  class RegisterCommand
    include Longleaf::EventStatusTracking

    def initialize(app_manager)
      @app_manager = app_manager
    end

    # Execute the register command on the given parameters
    # @param file_selector [FileSelector] selector for files to register
    # @param force [Boolean] force flag
    # @param digest_provider [ManifestDigestProvider] object which provides digests for files being registered
    # @param physical_provider [PhysicalPathProvider] object which provides physical paths for files being registered
    # @return [Integer] status code
    def execute(file_selector:, force: false, digest_provider: nil, physical_provider: nil)
      start_time = Time.now
      logger.info('Performing register command')
      begin
        # Perform register events on each of the file paths provided
        loop do
          f_path = file_selector.next_path
          break if f_path.nil?

          storage_location = @app_manager.location_manager.get_location_by_path(f_path)

          phys_path = physical_provider.get_physical_path(f_path)
          file_rec = FileRecord.new(f_path, storage_location, nil, phys_path)

          register_event = RegisterEvent.new(file_rec: file_rec, force: force, app_manager: @app_manager,
              digest_provider: digest_provider)
          track_status(register_event.perform)
        end
      rescue InvalidStoragePathError, StorageLocationUnavailableError => err
        record_failure(EventNames::REGISTER, nil, err.message)
      rescue => err
        record_failure(EventNames::REGISTER, error: err)
      end

      logger.info("Completed register command in #{Time.now - start_time}s")
      return_status
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
longleaf-1.1.1	lib/longleaf/commands/register_command.rb
longleaf-1.1.0	lib/longleaf/commands/register_command.rb