Class: Morpheus::StorageProvidersInterface
- Inherits:
-
APIClient
- Object
- APIClient
- Morpheus::StorageProvidersInterface
show all
- Defined in:
- lib/morpheus/api/storage_providers_interface.rb
Constant Summary
Constants inherited
from APIClient
APIClient::CLIENT_ID
Instance Attribute Summary
Attributes inherited from APIClient
#client_id
Instance Method Summary
collapse
-
#create(payload) ⇒ Object
-
#destroy(id, params = {}) ⇒ Object
-
#download_file(id, file_path, params = {}) ⇒ Object
-
#download_file_chunked(id, file_path, outfile, params = {}) ⇒ Object
-
#download_zip_chunked(id, outfile, params = {}) ⇒ Object
-
#get(id, params = {}) ⇒ Object
-
#initialize(access_token, refresh_token, expires_at = nil, base_url = nil) ⇒ StorageProvidersInterface
constructor
A new instance of StorageProvidersInterface.
-
#list(params = {}) ⇒ Object
-
#list_files(id, file_path, params = {}) ⇒ Object
-
#update(id, payload) ⇒ Object
-
#upload_file(id, local_file, destination, params = {}) ⇒ Object
upload a file without multipart.
Methods inherited from APIClient
#account_groups, #accounts, #activity, #appliance_settings, #approvals, #apps, #archive_buckets, #archive_files, #auth, #authorization_required?, #backup_jobs, #backup_settings, #backups, #billing, #blueprints, #budgets, #catalog, #catalog_item_types, #cloud_datastores, #cloud_folders, #cloud_policies, #cloud_resource_pools, #clouds, #clusters, #common_interface_options, #containers, #custom_instance_types, #cypher, #dashboard, #datastores, #default_content_type, #default_timeout, #deploy, #deployments, #doc, #dry, #dry_run, #environments, #execute, #execute_schedules, #execution_request, #file_copy_request, #forgot, #group_policies, #groups, #guidance, #health, #image_builder, #inspect, #instance_types, #instances, #integrations, #invoice_line_items, #invoices, #jobs, #key_pairs, #library_cluster_layouts, #library_container_scripts, #library_container_templates, #library_container_types, #library_container_upgrades, #library_instance_types, #library_layouts, #library_spec_template_types, #library_spec_templates, #license, #load_balancers, #log_settings, #logged_in?, #login, #logout, #logs, #monitoring, #network_domain_records, #network_domains, #network_groups, #network_pool_ips, #network_pool_servers, #network_pools, #network_proxies, #network_routers, #network_security_servers, #network_services, #network_types, #networks, #old_cypher, #option_type_lists, #option_types, #options, #packages, #ping, #policies, #power_schedules, #price_sets, #prices, #processes, #projects, #provision_types, #provisioning_license_types, #provisioning_licenses, #provisioning_settings, #reports, #roles, #search, #security_group_rules, #security_groups, #server_types, #servers, #service_plans, #set_ssl_verification_enabled, #setopts, #setup, #ssl_verification_enabled?, #storage_providers, #subnet_types, #subnets, #task_sets, #tasks, #to_s, #url, #usage, #use_refresh_token, #user_groups, #user_settings, #user_sources, #users, #virtual_images, #whitelabel_settings, #whoami, #wiki, #withopts
Constructor Details
#initialize(access_token, refresh_token, expires_at = nil, base_url = nil) ⇒ StorageProvidersInterface
Returns a new instance of StorageProvidersInterface.
5
6
7
8
9
10
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 5
def initialize(access_token, refresh_token,expires_at = nil, base_url=nil)
@access_token = access_token
@refresh_token = refresh_token
@base_url = base_url
@expires_at = expires_at
end
|
Instance Method Details
#create(payload) ⇒ Object
27
28
29
30
31
32
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 27
def create(payload)
url = "#{@base_url}/api/storage/buckets"
= { :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
opts = {method: :post, url: url, headers: , payload: payload.to_json}
execute(opts)
end
|
#destroy(id, params = {}) ⇒ Object
41
42
43
44
45
46
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 41
def destroy(id, params={})
url = "#{@base_url}/api/storage/buckets/#{id}"
= { :params => params, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
opts = {method: :delete, url: url, headers: }
execute(opts)
end
|
#download_file(id, file_path, params = {}) ⇒ Object
88
89
90
91
92
93
94
95
96
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 88
def download_file(id, file_path, params={})
raise "#{self.class}.download_file() passed a blank id!" if id.to_s == ''
raise "#{self.class}.download_file() passed a blank file path!" if file_path.to_s == ''
escaped_file_path = file_path.split("/").collect {|it| URI.escape(it) }.join("/")
url = "#{@base_url}/api/storage/buckets/#{URI.escape(id.to_s)}" + "/download-file/#{escaped_file_path}".squeeze('/')
= { params: params, authorization: "Bearer #{@access_token}" }
opts = {method: :get, url: url, headers: }
execute(opts, false)
end
|
#download_file_chunked(id, file_path, outfile, params = {}) ⇒ Object
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
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 98
def download_file_chunked(id, file_path, outfile, params={})
raise "#{self.class}.download_file() passed a blank id!" if id.to_s == ''
raise "#{self.class}.download_file() passed a blank file path!" if file_path.to_s == ''
escaped_file_path = file_path.split("/").collect {|it| URI.escape(it) }.join("/")
url = "#{@base_url}/api/storage/buckets/#{URI.escape(id.to_s)}" + "/download-file/#{escaped_file_path}".squeeze('/')
= { params: params, authorization: "Bearer #{@access_token}" }
opts = {method: :get, url: url, headers: }
if Dir.exists?(outfile)
raise "outfile is invalid. It is the name of an existing directory: #{outfile}"
end
if @dry_run
return opts
end
http_response = nil
File.open(outfile, 'w') {|f|
block = proc { |response|
response.read_body do |chunk|
f.write chunk
end
}
opts[:block_response] = block
http_response = Morpheus::RestClient.execute(opts)
}
return http_response
end
|
#download_zip_chunked(id, outfile, params = {}) ⇒ Object
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 129
def download_zip_chunked(id, outfile, params={})
url = "#{@base_url}/api/storage/buckets/#{URI.escape(id.to_s)}/download-zip"
= { params: params, authorization: "Bearer #{@access_token}" }
opts = {method: :get, url: url, headers: }
if Dir.exists?(outfile)
raise "outfile is invalid. It is the name of an existing directory: #{outfile}"
end
if @dry_run
return opts
end
http_response = nil
File.open(outfile, 'w') {|f|
block = proc { |response|
response.read_body do |chunk|
f.write chunk
end
}
opts[:block_response] = block
http_response = Morpheus::RestClient.execute(opts)
}
return http_response
end
|
#get(id, params = {}) ⇒ Object
12
13
14
15
16
17
18
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 12
def get(id, params={})
raise "#{self.class}.get() passed a blank id!" if id.to_s == ''
url = "#{@base_url}/api/storage/buckets/#{id}"
= { params: params, authorization: "Bearer #{@access_token}" }
opts = {method: :get, url: url, headers: }
execute(opts)
end
|
#list(params = {}) ⇒ Object
20
21
22
23
24
25
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 20
def list(params={})
url = "#{@base_url}/api/storage/buckets"
= { params: params, authorization: "Bearer #{@access_token}" }
opts = {method: :get, url: url, headers: }
execute(opts)
end
|
#list_files(id, file_path, params = {}) ⇒ Object
48
49
50
51
52
53
54
55
56
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 48
def list_files(id, file_path, params={})
if file_path.to_s.strip == "/"
file_path = ""
end
url = "#{@base_url}/api/storage/buckets/#{URI.escape(id.to_s)}" + "/files/#{URI.escape(file_path)}".squeeze('/')
= { params: params, authorization: "Bearer #{@access_token}" }
opts = {method: :get, url: url, headers: }
execute(opts)
end
|
#update(id, payload) ⇒ Object
34
35
36
37
38
39
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 34
def update(id, payload)
url = "#{@base_url}/api/storage/buckets/#{id}"
= { :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
opts = {method: :put, url: url, headers: , payload: payload.to_json}
execute(opts)
end
|
#upload_file(id, local_file, destination, params = {}) ⇒ Object
upload a file without multipart
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
|
# File 'lib/morpheus/api/storage_providers_interface.rb', line 59
def upload_file(id, local_file, destination, params={})
path = destination.to_s.squeeze("/")
if !path || path == "" || path == "/" || path == "."
raise "#{self.class}.upload_file() passed a bad destination: '#{destination}'"
end
if path[0].chr == "/"
path = path[1..-1]
end
path_chunks = path.split("/")
filename = path_chunks.pop
safe_dirname = path_chunks.collect {|it| URI.escape(it) }.join("/")
url = "#{@base_url}/api/storage/buckets/#{URI.escape(id.to_s)}" + "/files/#{safe_dirname}".squeeze('/')
= { :params => params, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/octet-stream'}
[:params][:filename] = filename if !local_file.kind_of?(File)
local_file = File.new(local_file, 'rb')
end
payload = local_file
['Content-Length'] = local_file.size execute(method: :post, url: url, headers: , payload: payload)
end
|