9 def initialize(name, type, attribs = {})
12 @attribs = attribs.dup
17 return @attribs['enabled'].to_i != 0
21 return @attribs['autorefresh'].to_i != 0
25 return @handle ? @handle.id : 0
29 chksum = Solv::Chksum.new(Solv::REPOKEY_TYPE_SHA256)
35 def calc_cookie_file(filename)
36 chksum = Solv::Chksum.new(Solv::REPOKEY_TYPE_SHA256)
38 chksum.add_stat(filename)
42 def calc_cookie_ext(f, cookie)
43 chksum = Solv::Chksum.new(Solv::REPOKEY_TYPE_SHA256)
46 chksum.add_fstat(f.fileno)
50 def cachepath(ext = nil)
51 path = @name.sub(/^\./, '_')
52 path += ext ? "_#{ext}.solvx" : '.solv'
53 return '/var/cache/solv/' + path.gsub(/\//, '_')
57 @handle = pool.add_repo(@name)
58 @handle.appdata = self
59 @handle.priority = 99 - @attribs['priority'].to_i if @attribs['priority']
60 dorefresh = autorefresh?
63 s = File.stat(cachepath)
64 dorefresh = false if s && (@attribs['metadata_expire'].to_i == -1 || Time.now - s.mtime < @attribs['metadata_expire'].to_i)
65 rescue SystemCallError
70 if !dorefresh && usecachedrepo(nil)
71 puts "repo: '#{@name}' cached"
77 def load_ext(repodata)
81 def download(file, uncompress, chksum, markincomplete = false)
82 url = @attribs['baseurl']
84 puts "%{@name}: no baseurl"
87 url = url.sub(/\/$/, '') + "/#{file}"
88 f = Tempfile.new('rbsolv')
90 st = system('curl', '-f', '-s', '-L', '-o', "/dev/fd/" + f.fileno.to_s, '--', url)
91 return nil if f.stat.size == 0 && (st || !chksum)
93 puts "#{file}: download error #{$? >> 8}"
94 @incomplete = true if markincomplete
98 fchksum = Solv::Chksum.new(chksum.type)
99 fchksum.add_fd(f.fileno)
100 if !fchksum == chksum
101 puts "#{file}: checksum error"
102 @incomplete = true if markincomplete
108 rf = Solv::xfopen_fd(file, f.fileno)
110 rf = Solv::xfopen_fd('', f.fileno)
116 def usecachedrepo(ext, mark = false)
117 cookie = ext ? @extcookie : @cookie
119 repopath = cachepath(ext)
120 f = File.new(repopath, "r")
121 f.sysseek(-32, IO::SEEK_END)
122 fcookie = f.sysread(32)
123 return false if fcookie.length != 32
124 return false if cookie && fcookie != cookie
125 if !ext && @type != 'system'
126 f.sysseek(-32 * 2, IO::SEEK_END)
127 fextcookie = f.sysread(32)
128 return false if fextcookie.length != 32
130 f.sysseek(0, IO::SEEK_SET)
131 nf = Solv::xfopen_fd('', f.fileno)
133 flags = ext ? Solv::Repo::REPO_USE_LOADING|Solv::Repo::REPO_EXTEND_SOLVABLES : 0
134 flags |= Solv::Repo::REPO_LOCALPOOL if ext && ext != 'DL'
135 if ! @handle.add_solv(nf, flags)
140 @cookie = fcookie unless ext
141 @extcookie = fextcookie if !ext && @type != 'system'
144 File::utime(now, now, repopath) if mark
145 rescue SystemCallError
148 rescue SystemCallError
154 def writecachedrepo(ext, repodata = nil)
155 return if @incomplete
157 Dir::mkdir("/var/cache/solv", 0755) unless FileTest.directory?("/var/cache/solv")
158 f = Tempfile.new('.newsolv-', '/var/cache/solv')
160 sf = Solv::xfopen_fd('', f.fileno)
166 @handle.write_first_repodata(sf)
169 f.sysseek(0, IO::SEEK_END)
170 if @type != 'system' && !ext
171 @extcookie = calc_cookie_ext(f, @cookie) unless @extcookie
172 f.syswrite(@extcookie)
174 f.syswrite(ext ? @extcookie : @cookie)
176 if @handle.iscontiguous?
177 sf = Solv::xfopen(f.path)
181 abort("internal error, cannot reload solv file") unless @handle.add_solv(sf, repodata ? 0 : Solv::Repo::SOLV_ADD_NO_STUBS)
183 repodata.extend_to_repo()
184 flags = Solv::Repo::REPO_EXTEND_SOLVABLES
185 flags |= Solv::Repo::REPO_LOCALPOOL if ext != 'DL'
186 repodata.add_solv(sf, flags)
191 File.rename(f.path, cachepath(ext))
194 rescue SystemCallError
199 def updateaddedprovides(addedprovides)
200 return if @incomplete
201 return unless @handle && !@handle.isempty?
202 repodata = @handle.first_repodata()
203 return unless repodata
204 oldaddedprovides = repodata.lookup_idarray(Solv::SOLVID_META, Solv::REPOSITORY_ADDEDFILEPROVIDES)
205 return if (oldaddedprovides | addedprovides) == oldaddedprovides
206 for id in addedprovides
207 repodata.add_idarray(Solv::SOLVID_META, Solv::REPOSITORY_ADDEDFILEPROVIDES, id)
209 repodata.internalize()
210 writecachedrepo(nil, repodata)
218 Solv::SOLVABLE_SUMMARY => Solv::REPOKEY_TYPE_STR,
219 Solv::SOLVABLE_DESCRIPTION => Solv::REPOKEY_TYPE_STR,
220 Solv::SOLVABLE_EULA => Solv::REPOKEY_TYPE_STR,
221 Solv::SOLVABLE_MESSAGEINS => Solv::REPOKEY_TYPE_STR,
222 Solv::SOLVABLE_MESSAGEDEL => Solv::REPOKEY_TYPE_STR,
223 Solv::SOLVABLE_CATEGORY => Solv::REPOKEY_TYPE_ID,
226 def add_ext_keys(ext, repodata, h)
228 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, Solv::REPOSITORY_DELTAINFO)
229 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, Solv::REPOKEY_TYPE_FLEXARRAY)
231 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, Solv::SOLVABLE_DISKUSAGE)
232 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, Solv::REPOKEY_TYPE_DIRNUMNUMARRAY)
234 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, Solv::SOLVABLE_FILELIST)
235 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, Solv::REPOKEY_TYPE_DIRSTRARRAY)
237 @@langtags.sort.each do |langid, langtype|
238 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, @handle.pool.id2langid(langid, ext, true))
239 repodata.add_idarray(h, Solv::REPOSITORY_KEYS, langtype)
245 class Repo_rpmmd < Repo_generic
248 di = @handle.Dataiterator_meta(Solv::REPOSITORY_REPOMD_TYPE, what, Solv::Dataiterator::SEARCH_STRING)
249 di.prepend_keyname(Solv::REPOSITORY_REPOMD)
252 filename = dp.lookup_str(Solv::REPOSITORY_REPOMD_LOCATION)
254 checksum = dp.lookup_checksum(Solv::REPOSITORY_REPOMD_CHECKSUM)
256 puts "no #{filename} checksum!"
259 return filename, checksum
265 return true if super(pool)
266 print "rpmmd repo '#{@name}: "
267 f = download("repodata/repomd.xml", false, nil, nil)
269 puts "no repomd.xml file, skipped"
274 @cookie = calc_cookie_fp(f)
275 if usecachedrepo(nil, true)
280 @handle.add_repomdxml(f, 0)
283 filename, filechksum = find('primary')
285 f = download(filename, true, filechksum, true)
287 @handle.add_rpmmd(f, nil, 0)
290 return false if @incomplete
292 filename, filechksum = find('updateinfo')
294 f = download(filename, true, filechksum, true)
296 @handle.add_updateinfoxml(f, 0)
302 @handle.create_stubs()
306 def add_ext(repodata, what, ext)
307 filename, filechksum = find(what)
308 filename, filechksum = find('prestodelta') if !filename && what == 'deltainfo'
309 return unless filename
310 h = repodata.new_handle()
311 repodata.set_poolstr(h, Solv::REPOSITORY_REPOMD_TYPE, what)
312 repodata.set_str(h, Solv::REPOSITORY_REPOMD_LOCATION, filename)
313 repodata.set_checksum(h, Solv::REPOSITORY_REPOMD_CHECKSUM, filechksum)
314 add_ext_keys(ext, repodata, h)
315 repodata.add_flexarray(Solv::SOLVID_META, Solv::REPOSITORY_EXTERNAL, h)
319 repodata = @handle.add_repodata(0)
320 add_ext(repodata, 'deltainfo', 'DL')
321 add_ext(repodata, 'filelists', 'FL')
322 repodata.internalize()
325 def load_ext(repodata)
326 repomdtype = repodata.lookup_str(Solv::SOLVID_META, Solv::REPOSITORY_REPOMD_TYPE)
327 if repomdtype == 'filelists'
329 elsif repomdtype == 'deltainfo'
334 print "[#{@name}:#{ext}: "
336 if usecachedrepo(ext)
341 filename = repodata.lookup_str(Solv::SOLVID_META, Solv::REPOSITORY_REPOMD_LOCATION)
342 filechksum = repodata.lookup_checksum(Solv::SOLVID_META, Solv::REPOSITORY_REPOMD_CHECKSUM)
343 f = download(filename, true, filechksum)
344 return false unless f
346 @handle.add_rpmmd(f, 'FL', Solv::Repo::REPO_USE_LOADING|Solv::Repo::REPO_EXTEND_SOLVABLES|Solv::Repo::REPO_LOCALPOOL)
348 @handle.add_deltainfoxml(f, Solv::Repo::REPO_USE_LOADING)
351 writecachedrepo(ext, repodata)
357 class Repo_susetags < Repo_generic
360 di = @handle.Dataiterator_meta(Solv::SUSETAGS_FILE_NAME, what, Solv::Dataiterator::SEARCH_STRING)
361 di.prepend_keyname(Solv::SUSETAGS_FILE)
364 checksum = dp.lookup_checksum(Solv::SUSETAGS_FILE_CHECKSUM)
365 return what, checksum
371 return true if super(pool)
372 print "susetags repo '#{@name}: "
373 f = download("content", false, nil, nil)
375 puts "no content file, skipped"
380 @cookie = calc_cookie_fp(f)
381 if usecachedrepo(nil, true)
386 @handle.add_content(f, 0)
389 defvendorid = @handle.meta.lookup_id(Solv::SUSETAGS_DEFAULTVENDOR)
390 descrdir = @handle.meta.lookup_str(Solv::SUSETAGS_DESCRDIR)
391 descrdir = "suse/setup/descr" unless descrdir
392 (filename, filechksum) = find('packages.gz')
393 (filename, filechksum) = find('packages') unless filename
395 f = download("#{descrdir}/#{filename}", true, filechksum, true)
397 @handle.add_susetags(f, defvendorid, nil, Solv::Repo::REPO_NO_INTERNALIZE|Solv::Repo::SUSETAGS_RECORD_SHARES)
399 (filename, filechksum) = find('packages.en.gz')
400 (filename, filechksum) = find('packages.en') unless filename
402 f = download("#{descrdir}/#{filename}", true, filechksum, true)
404 @handle.add_susetags(f, defvendorid, nil, Solv::Repo::REPO_NO_INTERNALIZE|Solv::Repo::REPO_REUSE_REPODATA|Solv::Repo::REPO_EXTEND_SOLVABLES)
408 @handle.internalize()
413 @handle.create_stubs()
417 def add_ext(repodata, what, ext)
418 (filename, filechksum) = find(what)
419 h = repodata.new_handle()
420 repodata.set_str(h, Solv::SUSETAGS_FILE_NAME, filename)
421 repodata.set_checksum(h, Solv::SUSETAGS_FILE_CHECKSUM, filechksum)
422 add_ext_keys(ext, repodata, h)
423 repodata.add_flexarray(Solv::SOLVID_META, Solv::REPOSITORY_EXTERNAL, h)
427 repodata = @handle.add_repodata(0)
428 di = @handle.Dataiterator_meta(Solv::SUSETAGS_FILE_NAME, nil, 0)
429 di.prepend_keyname(Solv::SUSETAGS_FILE)
432 next unless filename && filename =~ /^packages\.(..)(?:\..*)$/
433 next if $1 == 'en' || $1 == 'gz'
434 add_ext(repodata, filename, $1)
436 repodata.internalize()
439 def load_ext(repodata)
440 filename = repodata.lookup_str(Solv::SOLVID_META, Solv::SUSETAGS_FILE_NAME)
442 print "[#{@name}:#{ext}: "
444 if usecachedrepo(ext)
449 defvendorid = @handle.meta.lookup_id(Solv::SUSETAGS_DEFAULTVENDOR)
450 descrdir = @handle.meta.lookup_str(Solv::SUSETAGS_DESCRDIR)
451 descrdir = "suse/setup/descr" unless descrdir
452 filechksum = repodata.lookup_checksum(Solv::SOLVID_META, Solv::SUSETAGS_FILE_CHECKSUM)
453 f = download("#{descrdir}/#{filename}", true, filechksum)
454 return false unless f
455 flags = Solv::Repo::REPO_USE_LOADING|Solv::Repo::REPO_EXTEND_SOLVABLES
456 flags |= Solv::Repo::REPO_LOCALPOOL if ext != 'DL'
457 @handle.add_susetags(f, defvendorid, ext, flags)
459 writecachedrepo(ext, repodata)
464 datadir = @handle.meta.lookup_str(Solv::SUSETAGS_DATADIR)
465 datadir = "suse" unless datadir
470 class Repo_unknown < Repo_generic
472 puts "unsupported repo '#{@name}: skipped"
477 class Repo_system < Repo_generic
479 @handle = pool.add_repo(@name)
480 @handle.appdata = self
481 pool.installed = @handle
482 print "rpm database: "
483 @cookie = calc_cookie_file("/var/lib/rpm/Packages")
484 if usecachedrepo(nil)
489 if @handle.respond_to? :add_products
490 @handle.add_products("/etc/products.d", Solv::Repo::REPO_NO_INTERNALIZE)
492 f = Solv::xfopen(cachepath())
493 @handle.add_rpmdb_reffp(f, Solv::Repo::REPO_REUSE_REPODATA)
503 cmdabbrev = { 'ls' => 'list', 'in' => 'install', 'rm' => 'erase',
504 've' => 'verify', 'se' => 'search' }
505 cmd = cmdabbrev[cmd] if cmdabbrev.has_key?(cmd)
508 'install' => Solv::Job::SOLVER_INSTALL,
509 'erase' => Solv::Job::SOLVER_ERASE,
510 'up' => Solv::Job::SOLVER_UPDATE,
511 'dup' => Solv::Job::SOLVER_DISTUPGRADE,
512 'verify' => Solv::Job::SOLVER_VERIFY,
519 if FileTest.directory?('/etc/zypp/repos.d')
520 reposdirs = [ '/etc/zypp/repos.d' ]
522 reposdirs = [ '/etc/yum/repos.d' ]
524 for reposdir in reposdirs do
525 next unless FileTest.directory?(reposdir)
526 for reponame in Dir["#{reposdir}/*.repo"].sort do
527 cfg = IniFile.load(reponame)
528 cfg.each_section do |ali|
529 repoattr = { 'alias' => ali, 'enabled' => 0, 'priority' => 99, 'autorefresh' => 1, 'type' => 'rpm-md', 'metadata_expire' => 900}
530 repoattr.update(cfg[ali])
531 if repoattr['type'] == 'rpm-md'
532 repo = Repo_rpmmd.new(ali, 'repomd', repoattr)
533 elsif repoattr['type'] == 'yast2'
534 repo = Repo_susetags.new(ali, 'susetags', repoattr)
536 repo = Repo_unknown.new(ali, 'unknown', repoattr)
543 pool = Solv::Pool.new()
546 pool.set_loadcallback { |repodata|
547 repo = repodata.repo.appdata
548 repo ? repo.load_ext(repodata) : false
551 sysrepo = Repo_system.new('@System', 'system')
554 repo.load(pool) if repo.enabled?
558 pool.createwhatprovides()
560 for di in pool.Dataiterator(Solv::SOLVABLE_NAME, args[0], Solv::Dataiterator::SEARCH_SUBSTRING | Solv::Dataiterator::SEARCH_NOCASE)
561 sel.add_raw(Solv::Job::SOLVER_SOLVABLE, di.solvid)
563 for s in sel.solvables
564 puts "- #{s.str} [#{s.repo.name}]: #{s.lookup_str(Solv::SOLVABLE_SUMMARY)}"
569 abort("unknown command '#{cmd}'\n") unless cmdactionmap.has_key?(cmd)
571 addedprovides = pool.addfileprovides_queue()
572 if !addedprovides.empty?
573 sysrepo.updateaddedprovides(addedprovides)
575 repo.updateaddedprovides(addedprovides)
578 pool.createwhatprovides()
582 flags = Solv::Selection::SELECTION_NAME | Solv::Selection::SELECTION_PROVIDES | Solv::Selection::SELECTION_GLOB
583 flags |= Solv::Selection::SELECTION_CANON | Solv::Selection::SELECTION_DOTARCH | Solv::Selection::SELECTION_REL
585 flags |= Solv::Selection::SELECTION_FILELIST
586 flags |= Solv::Selection::SELECTION_INSTALLED_ONLY if cmd == 'erase'
588 sel = pool.select(arg, flags)
590 sel = pool.select(arg, flags | Solv::Selection::SELECTION_NOCASE)
591 puts "[ignoring case for '#{arg}']" unless sel.isempty?
593 puts "[using file list match for '#{arg}']" if sel.flags & Solv::Selection::SELECTION_FILELIST != 0
594 puts "[using capability match for '#{arg}']" if sel.flags & Solv::Selection::SELECTION_PROVIDES != 0
595 jobs += sel.jobs(cmdactionmap[cmd])
598 if jobs.empty? && (cmd == 'up' || cmd == 'dup' || cmd == 'verify')
599 sel = pool.Selection_all()
600 jobs += sel.jobs(cmdactionmap[cmd])
603 abort("no package matched.") if jobs.empty?
605 if cmd == 'list' || cmd == 'info'
607 for s in job.solvables()
609 puts "Name: #{s.str}"
610 puts "Repo: #{s.repo.name}"
611 puts "Summary: #{s.lookup_str(Solv::SOLVABLE_SUMMARY)}"
612 str = s.lookup_str(Solv::SOLVABLE_URL)
613 puts "Url: #{str}" if str
614 str = s.lookup_str(Solv::SOLVABLE_LICENSE)
615 puts "License: #{str}" if str
616 puts "Description:\n#{s.lookup_str(Solv::SOLVABLE_DESCRIPTION)}"
619 puts " - #{s.str} [#{s.repo.name}]"
620 puts " #{s.lookup_str(Solv::SOLVABLE_SUMMARY)}"
628 job.how ^= Solv::Job::SOLVER_UPDATE ^ Solv::Job::SOLVER_INSTALL if cmd == 'up' and job.isemptyupdate?
632 solver.set_flag(Solv::Solver::SOLVER_FLAG_SPLITPROVIDES, 1)
633 solver.set_flag(Solv::Solver::SOLVER_FLAG_ALLOW_UNINSTALL, 1) if cmd == 'erase'
634 #pool.set_debuglevel(1)
637 problems = solver.solve(jobs)
638 break if problems.empty?
639 for problem in problems
640 puts "Problem #{problem.id}/#{problems.count}:"
642 solutions = problem.solutions
643 for solution in solutions
644 puts " Solution #{solution.id}:"
645 elements = solution.elements(true)
646 for element in elements
647 puts " - #{element.str}"
653 print "Please choose a solution: "
655 sol = STDIN.gets.strip
656 break if sol == 's' || sol == 'q'
657 break if sol =~ /^\d+$/ && sol.to_i >= 1 && sol.to_i <= solutions.length
661 solution = solutions[sol.to_i - 1]
662 for element in solution.elements
663 newjob = element.Job()
664 if element.type == Solv::Solver::SOLVER_SOLUTION_JOB
665 jobs[element.jobidx] = newjob
667 jobs.push(newjob) if newjob && !jobs.include?(newjob)
673 trans = solver.transaction
676 puts "Nothing to do."
680 puts "\nTransaction summary:\n"
681 for cl in trans.classify(Solv::Transaction::SOLVER_TRANSACTION_SHOW_OBSOLETES | Solv::Transaction::SOLVER_TRANSACTION_OBSOLETE_IS_UPGRADE)
682 if cl.type == Solv::Transaction::SOLVER_TRANSACTION_ERASE
683 puts "#{cl.count} erased packages:"
684 elsif cl.type == Solv::Transaction::SOLVER_TRANSACTION_INSTALL
685 puts "#{cl.count} installed packages:"
686 elsif cl.type == Solv::Transaction::SOLVER_TRANSACTION_REINSTALLED
687 puts "#{cl.count} reinstalled packages:"
688 elsif cl.type == Solv::Transaction::SOLVER_TRANSACTION_DOWNGRADED
689 puts "#{cl.count} downgraded packages:"
690 elsif cl.type == Solv::Transaction::SOLVER_TRANSACTION_CHANGED
691 puts "#{cl.count} changed packages:"
692 elsif cl.type == Solv::Transaction::SOLVER_TRANSACTION_UPGRADED
693 puts "#{cl.count} upgraded packages:"
694 elsif cl.type == Solv::Transaction::SOLVER_TRANSACTION_VENDORCHANGE
695 puts "#{cl.count} vendor changes from '#{cl.fromstr}' to '#{cl.tostr}':"
696 elsif cl.type == Solv::Transaction::SOLVER_TRANSACTION_ARCHCHANGE
697 puts "#{cl.count} arch changes from '#{cl.fromstr}' to '#{cl.tostr}':"
701 for p in cl.solvables
702 if cl.type == Solv::Transaction::SOLVER_TRANSACTION_UPGRADED || cl.type == Solv::Transaction::SOLVER_TRANSACTION_DOWNGRADED
703 puts " - #{p.str} -> #{trans.othersolvable(p).str}"
710 puts "install size change: #{trans.calc_installsizechange()} K\n\n"
713 print("OK to continue (y/n)? ")
715 yn = STDIN.gets.strip
717 abort if yn == 'n' || yn == 'q'
720 newpkgs = trans.newsolvables()
725 downloadsize += p.lookup_num(Solv::SOLVABLE_DOWNLOADSIZE)
727 puts "Downloading #{newpkgs.length} packages, #{downloadsize / 1024} K"
729 repo = p.repo.appdata
730 location, medianr = p.lookup_location()
732 location = repo.packagespath + location
733 chksum = p.lookup_checksum(Solv::SOLVABLE_CHECKSUM)
734 f = repo.download(location, false, chksum)
735 abort("\n#{@name}: #{location} not found in repository\n") unless f
743 puts "Committing transaction:"
747 steptype = trans.steptype(p, Solv::Transaction::SOLVER_TRANSACTION_RPM_ONLY)
748 if steptype == Solv::Transaction::SOLVER_TRANSACTION_ERASE
749 puts "erase #{p.str}"
750 next unless p.lookup_num(Solv::RPM_RPMDBID)
751 evr = p.evr.sub(/^[0-9]+:/, '')
752 system('rpm', '-e', '--nodeps', '--nodigest', '--nosignature', "#{p.name}-#{evr}.#{p.arch}") || abort("rpm failed: #{$? >> 8}")
753 elsif (steptype == Solv::Transaction::SOLVER_TRANSACTION_INSTALL || steptype == Solv::Transaction::SOLVER_TRANSACTION_MULTIINSTALL)
754 puts "install #{p.str}"
755 f = newpkgsfp.delete(p.id)
757 mode = steptype == Solv::Transaction::SOLVER_TRANSACTION_INSTALL ? '-U' : '-i'
759 system('rpm', mode, '--force', '--nodeps', '--nodigest', '--nosignature', "/dev/fd/#{f.fileno().to_s}") || abort("rpm failed: #{$? >> 8}")