Class: ApprovedFileMoveJob

Inherits:
ApplicationJob show all
Defined in:
app/jobs/approved_file_move_job.rb

Instance Method Summary collapse

Instance Method Details

#key ⇒ Object 



52
53
54
 
# File 'app/jobs/approved_file_move_job.rb', line 52

def key
  @key ||= "/#{@source_bucket}/#{@source_key}"
end

#perform(work_id:, source_bucket:, source_key:, target_bucket:, target_key:, size:, snapshot_id:) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'app/jobs/approved_file_move_job.rb', line 6

def perform(work_id:, source_bucket:, source_key:, target_bucket:, target_key:, size:, snapshot_id:)
  @work_id = work_id
  @snapshot_id = snapshot_id
  @source_bucket = source_bucket
  @source_key = source_key

  begin
    resp = service.copy_file(source_key: key, target_bucket:, target_key:, size:)
    unless resp.successful?
      raise "Error copying #{key} to #{target_bucket}/#{target_key} Response #{resp.to_json}"
    end
  rescue Aws::S3::Errors::NoSuchKey => error
    status = service.check_file(bucket: source_bucket, key:)
    unless status
      raise "Missing source file #{key} can not copy to #{target_bucket}/#{target_key} Error: #{error}"
    end
  end

  status = service.check_file(bucket: target_bucket, key: target_key)
  unless status
    raise "File check was not valid #{source_key} to #{target_bucket}/#{target_key} Response #{status.to_json}"
  end
  etag = if resp.respond_to? :copy_object_result
           resp.copy_object_result.etag
         else
           resp.etag
         end.delete('"')

  # raise("Failed to resolve the ApprovedUploadSnapshot for #{@snapshot_id}") if snapshot.nil?

  snapshot.with_lock do
    snapshot.reload
    snapshot.mark_complete(target_key, etag)
  end
  service.delete_s3_object(source_key, bucket: source_bucket)

  # Once the last file has been deleted...
  if service.client_s3_files(reload: true, bucket_name: source_bucket).count == 0
    # delete the source directory...
    service.delete_s3_object(work.s3_object_key, bucket: source_bucket)

    # ...and create the preservation files
    work_preservation.preserve!
  end
end

#service ⇒ Object 



60
61
62
 
# File 'app/jobs/approved_file_move_job.rb', line 60

def service
  @service ||= S3QueryService.new(work, "postcuration")
end

#snapshot ⇒ Object 



64
65
66
 
# File 'app/jobs/approved_file_move_job.rb', line 64

def snapshot
  @snapshot ||= ApprovedUploadSnapshot.find(@snapshot_id)
end

#work ⇒ Object 



56
57
58
 
# File 'app/jobs/approved_file_move_job.rb', line 56

def work
  @work ||= Work.find(@work_id)
end

#work_path ⇒ Object 



68
69
70
 
# File 'app/jobs/approved_file_move_job.rb', line 68

def work_path
  @work_path ||= "#{work.doi}/#{work.id}"
end

#work_preservation ⇒ Object 



72
73
74
 
# File 'app/jobs/approved_file_move_job.rb', line 72

def work_preservation
  @work_preservation ||= WorkPreservationService.new(work_id: @work_id, path: work_path)
end