Class: AptlyCli::AptlyRepo

Inherits:
AptlyCommand show all
Includes:
HTTParty
Defined in:
lib/aptly_repo.rb

Overview

Aptly class to work with Repo API

Instance Attribute Summary

Attributes inherited from AptlyCommand

#config

Instance Method Summary collapse

Methods inherited from AptlyCommand

#delete, #get, #initialize, #post, #process_response, #put

Constructor Details

This class inherits a constructor from AptlyCli::AptlyCommand

Instance Method Details

#repo_create(repo_options = { name: nil, comment: nil, DefaultDistribution: nil, DefaultComponent: nil }) ⇒ Object

Raises:

  • (ArgumentError) 


13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/aptly_repo.rb', line 13

def repo_create(repo_options = { name: nil,
                                 comment: nil,
                                 DefaultDistribution: nil,
                                 DefaultComponent: nil })
  raise ArgumentError, 'Repository name is required' if repo_options[:name].nil? || repo_options[:name].empty?

  uri = '/repos'
  name = repo_options[:name]
  comment = repo_options[:comment]
  default_distribution = repo_options[:DefaultDistribution]
  default_component = repo_options[:DefaultComponent]
  post(uri,
                  :body => 
                  { 'Name' => name, 'Comment' => comment,
                    'DefaultDistribution' => default_distribution,
                    'DefaultComponent' => default_component }.to_json,
                  :headers => { 'Content-Type' => 'application/json' })
end

#repo_delete(repo_options = { name: nil, force: nil }) ⇒ Object

Raises:

  • (ArgumentError) 


32
33
34
35
36
37
38
 
# File 'lib/aptly_repo.rb', line 32

def repo_delete(repo_options = { name: nil, force: nil })
  raise ArgumentError, 'Repository name is required' if repo_options[:name].nil? || repo_options[:name].empty?

  uri = '/repos/' + repo_options[:name]
  uri += '?force=1' if repo_options[:force] == true
  delete(uri)
end

#repo_edit(name, repo_options) ⇒ Object

Raises:

  • (ArgumentError) 


40
41
42
43
44
45
46
47
 
# File 'lib/aptly_repo.rb', line 40

def repo_edit(name, repo_options)
  raise ArgumentError, 'Repository name is required' if name.nil? || name.empty?

  uri = "/repos/#{name}"

  put(uri, :body => repo_options.to_json,
                      :headers => { 'Content-Type' => 'application/json' })
end

#repo_list ⇒ Object 



49
50
51
52
53
54
 
# File 'lib/aptly_repo.rb', line 49

def repo_list
  uri = '/repos'
  JSON.parse get(uri).body
rescue JSON::ParserError
  raise "Invalid response from '#{self.class.base_uri}#{uri}'"
end

#repo_package_add(repo_options, packages) ⇒ Object

Raises:

  • (ArgumentError) 


56
57
58
59
60
61
62
63
64
65
 
# File 'lib/aptly_repo.rb', line 56

def repo_package_add(repo_options, packages)
  raise ArgumentError, 'Repository name is required' if repo_options[:name].nil? || repo_options[:name].empty?

  uri = '/repos/' + repo_options[:name] + '/packages'
  post(
    uri,
    :body => { PackageRefs: packages }.to_json,
    :headers => { 'Content-Type' => 'application/json' }
  )
end

#repo_package_delete(repo_options, packages) ⇒ Object

Raises:

  • (ArgumentError) 


67
68
69
70
71
72
73
74
75
76
 
# File 'lib/aptly_repo.rb', line 67

def repo_package_delete(repo_options, packages)
  raise ArgumentError, 'Repository name is required' if repo_options[:name].nil? || repo_options[:name].empty?

  uri = '/repos/' + repo_options[:name] + '/packages'
  delete(
    uri,
    :body => { PackageRefs: packages }.to_json,
    :headers => { 'Content-Type' => 'application/json' }
  )
end

#repo_package_query(repo_options = { name: nil, query: nil, with_deps: false, format: nil }) ⇒ Object

Raises:

  • (ArgumentError) 


78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/aptly_repo.rb', line 78

def repo_package_query(repo_options = { name: nil, query: nil,
                                        with_deps: false,
                                        format: nil })
  raise ArgumentError, 'Repository name is required' if repo_options[:name].nil? || repo_options[:name].empty?

  uri = '/repos/' + repo_options[:name] + '/packages'

  qs_hash = {}
  qs_hash['q'] = repo_options[:query] if repo_options[:query]
  qs_hash['format'] = repo_options[:format] if repo_options[:format]
  qs_hash['withDeps'] = 1 if repo_options[:with_deps]
  uri += '?' + URI.encode_www_form(qs_hash) if qs_hash
  get uri
end

#repo_show(name) ⇒ Object 



93
94
95
96
97
98
99
100
 
# File 'lib/aptly_repo.rb', line 93

def repo_show(name)
  uri = if name.nil?
          '/repos'
        else
          '/repos/' + name
        end
  get uri
end

#repo_upload(repo_options = { name: nil, dir: nil, file: nil, noremove: false, forcereplace: false }) ⇒ Object

Raises:

  • (ArgumentError) 


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
136
137
138
139
 
# File 'lib/aptly_repo.rb', line 102

def repo_upload(repo_options = { name: nil, dir: nil, file: nil,
                                 noremove: false, forcereplace: false })
  raise ArgumentError, 'Repository name is required' if repo_options[:name].nil? || repo_options[:name].empty?

  name = repo_options[:name]
  dir  = repo_options[:dir]
  file = repo_options[:file]
  noremove = repo_options[:noremove]
  forcereplace = repo_options[:forcereplace]
  uri = if file.nil?
          "/repos/#{name}/file/#{dir}"
        else
          "/repos/#{name}/file/#{dir}/#{file}"
        end

  uri += '?forceReplace=1' if forcereplace == true
  uri += '?noRemove=1' if noremove == true
  response = self.class.post(uri)

  case response.code
  when 404
    puts 'repository with such name does not exist'
    return response
  end

  json_response = JSON.parse(response.body)

  unless json_response['FailedFiles'].empty?
    puts "Files that failed to upload... #{json_response['FailedFiles']}"
  end

  unless json_response['Report']['Warnings'].empty?
    puts "File upload warning message[s]...\
         #{json_response['Report']['Warnings']}"
  end

  return response
end