Class: Service::StorjS3Service

Inherits:
StorjService
  • Object
show all
Defined in:
lib/active_storage/service/storj_s3_service.rb

Defined Under Namespace

Classes: S3GatewayConfigRequiredError

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(access_grant:, bucket:, upload_chunk_size: nil, download_chunk_size: nil, multipart_upload_threshold: nil, auth_service_address: nil, link_sharing_address: nil, public: false, **config) ⇒ StorjS3Service

Returns a new instance of StorjS3Service.

Raises:



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/active_storage/service/storj_s3_service.rb', line 12

def initialize(access_grant:, bucket:, upload_chunk_size: nil, download_chunk_size: nil, multipart_upload_threshold: nil,
  auth_service_address: nil, link_sharing_address: nil, public: false, **config)
  super(access_grant: access_grant, bucket: bucket, upload_chunk_size: upload_chunk_size, download_chunk_size: download_chunk_size,
    multipart_upload_threshold: multipart_upload_threshold, auth_service_address: auth_service_address, link_sharing_address: link_sharing_address,
    public: public, **config)

  s3_config = config[:s3_gateway]
  raise S3GatewayConfigRequiredError.new, "S3 Gateway configuration is required" if s3_config.blank?

  @s3_client = Aws::S3::Resource.new(
    access_key_id: s3_config[:access_key_id],
    secret_access_key: s3_config[:secret_access_key],
    region: s3_config[:region],
    endpoint: s3_config[:endpoint]
  )
  @s3_bucket = @s3_client.bucket(bucket)

  upload = s3_config[:upload] || {}
  @s3_upload_options = upload
  @s3_upload_options[:acl] = "public-read" if public?
end

Instance Attribute Details

#s3_bucket ⇒ Object (readonly)

Returns the value of attribute s3_bucket.



10
11
12
 
# File 'lib/active_storage/service/storj_s3_service.rb', line 10

def s3_bucket
  @s3_bucket
end

Instance Method Details

#url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:, custom_metadata: {}) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/active_storage/service/storj_s3_service.rb', line 34

def url_for_direct_upload(key, expires_in:, content_type:, content_length:, checksum:, custom_metadata: {})
  instrument :url, key: key do |payload|
    generated_url = @s3_bucket.object(key).presigned_url :put, expires_in: expires_in.to_i,
      content_type: content_type, content_length: content_length, content_md5: checksum,
      metadata: custom_metadata, whitelist_headers: ["content-length"], **@s3_upload_options

    payload[:url] = generated_url

    generated_url
  end
end