Class: PackageDataBase
Instance Method Summary collapse
- #available?(package) ⇒ Boolean
- #get_available_packages ⇒ Object
- #get_data(package) ⇒ Object
- #get_files(package) ⇒ Object
- #get_group_repo(group) ⇒ Object
- #get_installed_packages ⇒ Object
- #get_remove_script(package) ⇒ Object
- #get_repo(package) ⇒ Object
- #get_repodata(repo) ⇒ Object
- #get_repos ⇒ Object
- #get_root ⇒ Object
- #get_sync_data(package) ⇒ Object
- #get_url(repo) ⇒ Object
-
#initialize(root = '/') ⇒ PackageDataBase
constructor
A new instance of PackageDataBase.
- #install_package(package_data, remove_file, installed_files) ⇒ Object
- #installed?(package) ⇒ Boolean
- #normalise(data) ⇒ Object
- #remove_package(package) ⇒ Object
- #set_root(root) ⇒ Object
- #update_database ⇒ Object
- #upgrade?(package) ⇒ Boolean
Constructor Details
#initialize(root = '/') ⇒ PackageDataBase
Returns a new instance of PackageDataBase.
43 44 45 46 |
# File 'lib/packagedata.rb', line 43 def initialize(root = '/') @repos = [] set_root(root) end |
Instance Method Details
#available?(package) ⇒ Boolean
198 199 200 |
# File 'lib/packagedata.rb', line 198 def available?(package) true if get_available_packages.include?(package) end |
#get_available_packages ⇒ Object
162 163 164 165 166 167 168 169 |
# File 'lib/packagedata.rb', line 162 def get_available_packages() list = [] for repo in get_repos list += Dir["#{@sync_database}/#{repo}/*"].map() { |package| File.basename(package) } list.delete("repo.yaml") end return list end |
#get_data(package) ⇒ Object
63 64 65 66 67 68 69 70 71 72 |
# File 'lib/packagedata.rb', line 63 def get_data(package) begin package_data = File.join(@install_database, package, 'packageData') data = normalise(YAML::load_file(package_data)) rescue data = {} data['version'] = "0" end return data end |
#get_files(package) ⇒ Object
127 128 129 130 131 132 133 134 |
# File 'lib/packagedata.rb', line 127 def get_files(package) file = File.join(@install_database, package, 'files') file_list = [] IO.readlines(file).each do |entry| file_list.push(entry) end return file_list end |
#get_group_repo(group) ⇒ Object
171 172 173 174 175 176 177 178 179 180 |
# File 'lib/packagedata.rb', line 171 def get_group_repo(group) group_repo = nil for repo in get_repos data = YAML::load_file("#{@sync_database}/#{repo}/repo.yaml") unless data[group] == nil group_repo = repo end end return group_repo end |
#get_installed_packages ⇒ Object
190 191 192 |
# File 'lib/packagedata.rb', line 190 def get_installed_packages() Dir["#{@install_database}/*"].map() { |package| File.basename(package) } end |
#get_remove_script(package) ⇒ Object
136 137 138 139 |
# File 'lib/packagedata.rb', line 136 def get_remove_script(package) remove_script = File.join(@install_database, package, 'remove') File.read(remove_script) end |
#get_repo(package) ⇒ Object
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/packagedata.rb', line 90 def get_repo(package) package_repo = "" version = "0" get_repos.each do |repo| data = Dir["#{@sync_database}/#{repo}/*"].map { |pack| File.basename(pack) } data.each do |member| if member == package package_repo = repo package_data = File.join(@sync_database + "/" + repo, package) data = normalise(YAML::load_file(package_data)) unless (runs_on_this?(data['architecture'].to_s)) data['version'] = "0" end if version >= data['version'] version = data['version'] package_repo = repo end end end end return package_repo end |
#get_repodata(repo) ⇒ Object
182 183 184 185 186 187 188 |
# File 'lib/packagedata.rb', line 182 def get_repodata(repo) if get_repos.include?(repo) return YAML::load_file("#{@sync_database}/#{repo}/repo.yaml") else return {} end end |
#get_repos ⇒ Object
83 84 85 86 87 88 |
# File 'lib/packagedata.rb', line 83 def get_repos() list = Dir.entries("/etc/post/repos.d") list.delete('.') list.delete('..') return list end |
#get_root ⇒ Object
48 49 50 |
# File 'lib/packagedata.rb', line 48 def get_root() @root end |
#get_sync_data(package) ⇒ Object
116 117 118 119 120 121 122 123 124 125 |
# File 'lib/packagedata.rb', line 116 def get_sync_data(package) repo = File.join(@sync_database, get_repo(package)) package_data = File.join(repo, package) data = normalise(YAML::load_file(package_data)) unless (runs_on_this?(data['architecture'].to_s)) data['version'] = "0" end return data end |
#get_url(repo) ⇒ Object
206 207 208 209 |
# File 'lib/packagedata.rb', line 206 def get_url(repo) data = YAML::load_file("/etc/post/repos.d/#{repo}") return data['url'] end |
#install_package(package_data, remove_file, installed_files) ⇒ Object
141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 |
# File 'lib/packagedata.rb', line 141 def install_package(package_data, remove_file, installed_files) data = YAML::load_file(package_data) dir_name = File.join(@install_database, data['name']) file_name = File.join(dir_name, 'files') package_data_name = File.join(dir_name, 'packageData') remove_file_name = File.join(dir_name, 'remove') mkdir_p(dir_name) install(package_data, package_data_name) install(remove_file, remove_file_name) file = open(file_name, 'w') file.puts(installed_files) end |
#installed?(package) ⇒ Boolean
194 195 196 |
# File 'lib/packagedata.rb', line 194 def installed?(package) true if get_installed_packages.include?(package) end |
#normalise(data) ⇒ Object
74 75 76 77 78 79 80 81 |
# File 'lib/packagedata.rb', line 74 def normalise(data) data['version'] = data['version'].to_s() data['conflicts'] = [] if data['conflicts'] == nil data['dependencies'] = [] if data['dependencies'] == nil data['version'] = "0" if data['version'].empty? return data end |
#remove_package(package) ⇒ Object
157 158 159 160 |
# File 'lib/packagedata.rb', line 157 def remove_package(package) dir_name = File.join(@install_database, package) rm_r(dir_name) end |
#set_root(root) ⇒ Object
52 53 54 55 56 57 58 59 60 61 |
# File 'lib/packagedata.rb', line 52 def set_root(root) @root = root @database_location = "#{@root}/var/lib/post/" @install_database = File.join(@database_location, "installed") @sync_database = File.join(@database_location, "available") unless File.exist?(@database_location) mkdir_p(@install_database) mkdir_p(@sync_database) end end |
#update_database ⇒ Object
211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 |
# File 'lib/packagedata.rb', line 211 def update_database() rm_r("/tmp/post") if (File.exists?("/tmp/post")) rm_r(@sync_database) if (File.exists?(@sync_database)) mkdir_p("/tmp/post") cd("/tmp/post") mkdir_p(@sync_database) for repo in get_repos source_url = get_url(repo) + '/info.tar' if source_url.include?("file://") source_url.sub!("file://", '') cp(source_url, 'info.tar') else File.open('info.tar', 'w') do |file| file.puts(open(source_url).read) end end system("tar xf info.tar") cp_r('info', "#{@sync_database}/#{repo}") source_url = get_url(repo) + '/repo.yaml' if source_url.include?("file://") source_url.sub!("file://", '') cp(source_url, 'repo.yaml') else File.open('repo.yaml', 'w') do |file| file.puts(open(source_url).read) end end cp_r('repo.yaml', "#{@sync_database}/#{repo}/repo.yaml") rm('repo.yaml') rm('info.tar') rm_r('info') end end |
#upgrade?(package) ⇒ Boolean
202 203 204 |
# File 'lib/packagedata.rb', line 202 def upgrade?(package) true if (available?(package)) and (get_sync_data(package)['version'] > get_data(package)['version']) end |