Class: Morpheus::PackagesInterface

Inherits:
APIClient
  • Object
show all
Defined in:
lib/morpheus/api/packages_interface.rb

Instance Method Summary collapse

Constructor Details

#initialize(access_token, refresh_token, expires_at = nil, base_url = nil) ⇒ PackagesInterface

Returns a new instance of PackagesInterface.



4
5
6
7
8
9
 
# File 'lib/morpheus/api/packages_interface.rb', line 4

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

#destroy(id) ⇒ Object 



56
57
58
59
60
61
 
# File 'lib/morpheus/api/packages_interface.rb', line 56

def destroy(id)
  url = "#{@base_url}/api/packages/#{id}"
  headers = { :params => {}, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
  opts = {method: :delete, url: url, headers: headers}
  execute(opts)
end

#export(params, outfile) ⇒ Object 



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
 
# File 'lib/morpheus/api/packages_interface.rb', line 63

def export(params, outfile)
  url = "#{@base_url}/api/packages/export"
  headers = { params: params, authorization: "Bearer #{@access_token}" }
  opts = {method: :post, url: url, headers: headers}
  # execute(opts, false)
  if Dir.exists?(outfile)
    raise "outfile is invalid. It is the name of an existing directory: #{outfile}"
  end
  # if @verify_ssl == false
  #   opts[:verify_ssl] = OpenSSL::SSL::VERIFY_NONE
  # end
  if @dry_run
    return opts
  end
  http_response = nil
  bad_body = nil
  File.open(outfile, 'w') {|f|
    block = proc { |response|
      if response.code.to_i == 200
        response.read_body do |chunk|
            #puts "writing to #{outfile} ..."
            f.write chunk
        end
      else
        # puts_error (#{response.inspect}) #{chunk} ..."
        bad_body = response.body.to_s
      end
    }
    opts[:block_response] = block
    http_response = RestClient::Request.new(opts).execute
    # RestClient::Request.execute(opts)
  }
  return http_response, bad_body
end

#install(payload) ⇒ Object 



35
36
37
38
39
40
 
# File 'lib/morpheus/api/packages_interface.rb', line 35

def install(payload)
  url = "#{@base_url}/api/packages/install"
  headers = { :params => {}, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
  opts = {method: :post, url: url, headers: headers, payload: payload.to_json}
  execute(opts)
end

#install_file(package_file, params = {}) ⇒ Object 



42
43
44
45
46
47
 
# File 'lib/morpheus/api/packages_interface.rb', line 42

def install_file(package_file, params={})
  url = "#{@base_url}/api/packages/install-file"
  headers = { :params => params, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/octet-stream'}
  payload = package_file
  execute(method: :post, url: url, headers: headers, payload: payload, timeout: 36000)
end

#list(params = {}) ⇒ Object

def get(id) raise "#Morpheus::PackagesInterface.selfself.class.get() passed a blank id!" if id.to_s == '' url = "#@base_url/api/packages/#id" headers = { params: {}, authorization: "Bearer #@access_token" } opts = :get, url: url, headers: headers execute(opts) end



19
20
21
22
23
24
25
 
# File 'lib/morpheus/api/packages_interface.rb', line 19

def list(params={})
  url = "#{@base_url}/api/packages"
  headers = { params: {}, authorization: "Bearer #{@access_token}" }
  headers[:params].merge!(params)
  opts = {method: :get, url: url, headers: headers}
  execute(opts)
end

#search(params = {}) ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/morpheus/api/packages_interface.rb', line 27

def search(params={})
  url = "#{@base_url}/api/packages/search"
  headers = { params: {}, authorization: "Bearer #{@access_token}" }
  headers[:params].merge!(params)
  opts = {method: :get, url: url, headers: headers}
  execute(opts)
end

#update(id, payload) ⇒ Object 



49
50
51
52
53
54
 
# File 'lib/morpheus/api/packages_interface.rb', line 49

def update(id, payload)
  url = "#{@base_url}/api/packages/update/#{id}"
  headers = { :params => {}, :authorization => "Bearer #{@access_token}", 'Content-Type' => 'application/json' }
  opts = {method: :put, url: url, headers: headers, payload: payload.to_json}
  execute(opts)
end