ba98352f-e38b-4e19-b115-71f85a83f0e0

# frozen_string_literal: true

class S3MoveService
  attr_reader :source_bucket, :source_key, :target_bucket, :target_key, :size, :service, :copy_source

  def initialize(work_id:, source_bucket:, source_key:, target_bucket:, target_key:, size:)
    @copy_source = [source_bucket,source_key].join("/")
    @source_key = source_key
    @source_bucket = source_bucket
    @target_bucket = target_bucket
    @target_key = target_key
    @size = size
    @service = S3QueryService.new(Work.find(work_id), bucket_name: source_bucket)
  end

  def move
    etag = copy_file # will raise exception if there is an error
    check_file # will raise exception if there is an error
    service.delete_s3_object(source_key, bucket: source_bucket)
    etag
  end

  private

    def copy_file
      resp = service.copy_file(source_key: copy_source, target_bucket:, target_key:, size:)
      unless resp.successful?
        raise "Error copying #{copy_source} to #{target_bucket}/#{target_key} Response #{resp.to_json}"
      end
      etag(resp)
    rescue Aws::S3::Errors::NoSuchKey => error
      if service.check_file(bucket: target_bucket, key: target_key)
        Rails.logger.log("Trying to move a file that was already moved... #{copy_source} can not copy to #{target_bucket}/#{target_key}")
      else
        raise "Missing source file #{copy_source} can not copy to #{target_bucket}/#{target_key} Error: #{error}"
      end
    end

    def check_file
      status = service.check_file(bucket: target_bucket, key: target_key)
      unless status
        raise "File check was not valid #{copy_source} to #{target_bucket}/#{target_key} Response #{status.to_json}"
      end
    end

    def etag(resp)
      if resp.respond_to? :copy_object_result
        resp.copy_object_result.etag
      else
        resp.etag
      end.delete('"')
    end
end

1	# frozen_string_literal: true
2
3	class S3MoveService	2✔
4	attr_reader :source_bucket, :source_key, :target_bucket, :target_key, :size, :service, :copy_source	2✔
5
6	def initialize(work_id:, source_bucket:, source_key:, target_bucket:, target_key:, size:)	2✔
7	@copy_source = [source_bucket,source_key].join("/")	22✔
8	@source_key = source_key	22✔
9	@source_bucket = source_bucket	22✔
10	@target_bucket = target_bucket	22✔
11	@target_key = target_key	22✔
12	@size = size	22✔
13	@service = S3QueryService.new(Work.find(work_id), bucket_name: source_bucket)	22✔
14	end
15
16	def move	2✔
17	etag = copy_file # will raise exception if there is an error	22✔
18	check_file # will raise exception if there is an error	18✔
19	service.delete_s3_object(source_key, bucket: source_bucket)	12✔
20	etag	12✔
21	end
22
23	private	2✔
24
25	def copy_file	2✔
26	resp = service.copy_file(source_key: copy_source, target_bucket:, target_key:, size:)	22✔
27	unless resp.successful?	20✔
28	raise "Error copying #{copy_source} to #{target_bucket}/#{target_key} Response #{resp.to_json}"	2✔
29	end
30	etag(resp)	18✔
31	rescue Aws::S3::Errors::NoSuchKey => error
32	if service.check_file(bucket: target_bucket, key: target_key)	2✔
NEW 33	Rails.logger.log("Trying to move a file that was already moved... #{copy_source} can not copy to #{target_bucket}/#{target_key}")	×
34	else
35	raise "Missing source file #{copy_source} can not copy to #{target_bucket}/#{target_key} Error: #{error}"	2✔
36	end
37	end
38
39	def check_file	2✔
40	status = service.check_file(bucket: target_bucket, key: target_key)	18✔
41	unless status	18✔
42	raise "File check was not valid #{copy_source} to #{target_bucket}/#{target_key} Response #{status.to_json}"	6✔
43	end
44	end
45
46	def etag(resp)	2✔
47	if resp.respond_to? :copy_object_result	18✔
48	resp.copy_object_result.etag	18✔
49	else
50	resp.etag	×
51	end.delete('"')
52	end
53	end

pulibrary / pdc_describe / ba98352f-e38b-4e19-b115-71f85a83f0e0

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous