Class: Morpheus::ArchiveBucketsInterface
- Inherits:
-
APIClient
- Object
- APIClient
- Morpheus::ArchiveBucketsInterface
show all
- Defined in:
- lib/morpheus/api/archive_buckets_interface.rb
Constant Summary
Constants inherited
from APIClient
Morpheus::APIClient::CLIENT_ID
Instance Attribute Summary
Attributes inherited from APIClient
#client_id
Instance Method Summary
collapse
-
#create(payload) ⇒ Object
-
#destroy(id, params = {}) ⇒ Object
-
#download_bucket_zip_chunked(bucket_id, outfile, params = {}) ⇒ Object
-
#get(id, params = {}) ⇒ Object
-
#initialize(access_token, refresh_token, expires_at = nil, base_url = nil) ⇒ ArchiveBucketsInterface
constructor
A new instance of ArchiveBucketsInterface.
-
#list(params = {}) ⇒ Object
-
#list_files(id, file_path, params = {}) ⇒ Object
-
#recalc(id, params = {}) ⇒ Object
-
#update(id, payload) ⇒ Object
-
#upload_file(bucket_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_settings, #blueprints, #budgets, #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, #dry, #dry_run, #environments, #execute, #execute_schedules, #execution_request, #file_copy_request, #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, #refresh_token, #reports, #roles, #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, #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) ⇒ ArchiveBucketsInterface
Returns a new instance of ArchiveBucketsInterface.
5
6
7
8
9
10
|
# File 'lib/morpheus/api/archive_buckets_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/archive_buckets_interface.rb', line 27
def create(payload)
url = "#{@base_url}/api/archives/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/archive_buckets_interface.rb', line 41
def destroy(id, params={})
url = "#{@base_url}/api/archives/buckets/#{URI.escape(id.to_s)}"
= { :params => params, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
opts = {method: :delete, url: url, headers: }
execute(opts)
end
|
#download_bucket_zip_chunked(bucket_id, outfile, params = {}) ⇒ Object
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
|
# File 'lib/morpheus/api/archive_buckets_interface.rb', line 88
def download_bucket_zip_chunked(bucket_id, outfile, params={})
url = "#{@base_url}/api/archives/buckets/#{URI.escape(bucket_id.to_s)}" + ".zip"
= { params: params, authorization: "Bearer #{@access_token}" }
opts = {method: :get, url: url, headers: , timeout: 172800}
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/archive_buckets_interface.rb', line 12
def get(id, params={})
raise "#{self.class}.get() passed a blank id!" if id.to_s == ''
url = "#{@base_url}/api/archives/buckets/#{URI.escape(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/archive_buckets_interface.rb', line 20
def list(params={})
url = "#{@base_url}/api/archives/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/archive_buckets_interface.rb', line 48
def list_files(id, file_path, params={})
if file_path.to_s.strip == "/"
file_path = ""
end
url = "#{@base_url}/api/archives/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
|
#recalc(id, params = {}) ⇒ Object
116
117
118
119
120
121
|
# File 'lib/morpheus/api/archive_buckets_interface.rb', line 116
def recalc(id, params={})
url = "#{@base_url}/api/archives/buckets/#{URI.escape(id.to_s)}/recalc"
= { :params => params, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
opts = {method: :get, url: url, headers: , payload: payload.to_json}
execute(opts)
end
|
#update(id, payload) ⇒ Object
34
35
36
37
38
39
|
# File 'lib/morpheus/api/archive_buckets_interface.rb', line 34
def update(id, payload)
url = "#{@base_url}/api/archives/buckets/#{URI.escape(id.to_s)}"
= { :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
opts = {method: :put, url: url, headers: , payload: payload.to_json}
execute(opts)
end
|
#upload_file(bucket_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/archive_buckets_interface.rb', line 59
def upload_file(bucket_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/archives/buckets/#{URI.escape(bucket_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, timeout: 172800)
end
|