1
2
3
4
5
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
module Fog
module Storage
class GoogleJSON
class File < Fog::Model
identity :key, :aliases => ["Key", :name]
attribute :acl
attribute :predefined_acl, :aliases => ["predefinedAcl", :predefined_acl]
attribute :cache_control, :aliases => ["cacheControl", :cache_control]
attribute :content_disposition, :aliases => ["contentDisposition", :content_disposition]
attribute :content_encoding, :aliases => ["contentEncoding", :content_encoding]
attribute :content_length, :aliases => ["size", :size], :type => :integer
attribute :content_md5, :aliases => ["md5Hash", :md5_hash]
attribute :content_type, :aliases => ["contentType", :content_type]
attribute :crc32c
attribute :etag, :aliases => ["etag", :etag]
attribute :time_created, :aliases => ["timeCreated", :time_created]
attribute :last_modified, :aliases => ["updated", :updated]
attribute :generation
attribute :metageneration
attribute :metadata, :aliases => ["metadata", :metadata]
attribute :self_link, :aliases => ["selfLink", :self_link]
attribute :media_link, :aliases => ["mediaLink", :media_link]
attribute :owner
attribute :storage_class, :aliases => "storageClass"
# attribute :body
# https://cloud.google.com/storage/docs/access-control/lists#predefined-acls
VALID_PREDEFINED_ACLS = [
"authenticatedRead",
"bucketOwnerFullControl",
"bucketOwnerRead",
"private",
"projectPrivate",
"publicRead",
"publicReadWrite"
].freeze
def predefined_acl=(new_predefined_acl)
unless VALID_PREDEFINED_ACLS.include?(new_predefined_acl)
raise ArgumentError.new("acl must be one of [#{VALID_PREDEFINED_ACLS.join(', ')}]")
end
@predefined_acl = new_predefined_acl
end
def body
return attributes[:body] if attributes.key?(:body)
file = collection.get(identity)
attributes[:body] =
if file
file.attributes[:body]
else
""
end
end
def body=(new_body)
attributes[:body] = new_body
end
attr_reader :directory
def copy(target_directory_key, target_file_key, options = {})
requires :directory, :key
service.copy_object(directory.key, key, target_directory_key, target_file_key, options)
target_directory = service.directories.new(:key => target_directory_key)
target_directory.files.get(target_file_key)
end
def destroy
requires :directory, :key
service.delete_object(directory.key, key)
true
rescue ::Google::Apis::ClientError => e
raise e unless e.status_code == 404
false
end
def public=(new_public)
unless new_public.nil?
if new_public
@predefined_acl = "publicRead"
else
@predefined_acl = "projectPrivate"
end
end
new_public
end
def public_url
requires :directory, :key
"https://storage.googleapis.com/#{directory.key}/#{key}"
end
FILE_INSERTABLE_FIELDS = %i(
content_type
predefined_acl
cache_control
content_disposition
content_encoding
metadata
).freeze
def save
requires :body, :directory, :key
options = Hash[
FILE_INSERTABLE_FIELDS.map { |k| [k, attributes[k]] }
.reject { |pair| pair[1].nil? }
]
options[:predefined_acl] ||= @predefined_acl
service.put_object(directory.key, key, body, **options)
self.content_length = Fog::Storage.get_body_size(body)
self.content_type ||= Fog::Storage.get_content_type(body)
true
end
# params[:expires] : Eg: Time.now to integer value.
def url(expires, options = {})
requires :key
collection.get_https_url(key, expires, options)
end
private
attr_writer :directory
end
end
end
end
|
