21 #include <solv/solvversion.h> 61 #define OPT_PROGRESS const ProgressData::ReceiverFnc & = ProgressData::ReceiverFnc() 90 class UrlCredentialExtractor
93 UrlCredentialExtractor( Pathname & root_r )
97 ~UrlCredentialExtractor()
101 bool collect(
const Url & url_r )
103 bool ret = url_r.hasCredentialsInAuthority();
107 _cmPtr->addUserCred( url_r );
112 template<
class TContainer>
113 bool collect(
const TContainer & urls_r )
114 {
bool ret =
false;
for (
const Url &
url : urls_r ) {
if ( collect(
url ) && !ret ) ret =
true; }
return ret; }
117 bool extract( Url & url_r )
119 bool ret = collect( url_r );
121 url_r.setPassword( std::string() );
125 template<
class TContainer>
126 bool extract( TContainer & urls_r )
127 {
bool ret =
false;
for ( Url &
url : urls_r ) {
if ( extract(
url ) && !ret ) ret =
true; }
return ret; }
131 scoped_ptr<media::CredentialManager>
_cmPtr;
146 MediaMounter(
const Url & url_r )
148 media::MediaManager mediamanager;
149 _mid = mediamanager.open( url_r );
150 mediamanager.attach(
_mid );
156 media::MediaManager mediamanager;
157 mediamanager.release(
_mid );
158 mediamanager.close(
_mid );
165 Pathname getPathName(
const Pathname & path_r = Pathname() )
const 167 media::MediaManager mediamanager;
168 return mediamanager.localPath(
_mid, path_r );
177 template <
class Iterator>
178 inline bool foundAliasIn(
const std::string & alias_r, Iterator begin_r, Iterator end_r )
180 for_( it, begin_r, end_r )
181 if ( it->alias() == alias_r )
186 template <
class Container>
187 inline bool foundAliasIn(
const std::string & alias_r,
const Container & cont_r )
188 {
return foundAliasIn( alias_r, cont_r.begin(), cont_r.end() ); }
191 template <
class Iterator>
192 inline Iterator findAlias(
const std::string & alias_r, Iterator begin_r, Iterator end_r )
194 for_( it, begin_r, end_r )
195 if ( it->alias() == alias_r )
200 template <
class Container>
201 inline typename Container::iterator findAlias(
const std::string & alias_r, Container & cont_r )
202 {
return findAlias( alias_r, cont_r.begin(), cont_r.end() ); }
204 template <
class Container>
205 inline typename Container::const_iterator findAlias(
const std::string & alias_r,
const Container & cont_r )
206 {
return findAlias( alias_r, cont_r.begin(), cont_r.end() ); }
210 inline std::string filenameFromAlias(
const std::string & alias_r,
const std::string & stem_r )
212 std::string filename( alias_r );
216 filename = Pathname(filename).extend(
"."+stem_r).asString();
217 MIL <<
"generating filename for " << stem_r <<
" [" << alias_r <<
"] : '" << filename <<
"'" << endl;
241 RepoCollector(
const std::string & targetDistro_)
245 bool collect(
const RepoInfo &repo )
249 && !repo.targetDistribution().empty()
253 <<
"Skipping repository meant for '" << repo.targetDistribution()
254 <<
"' distribution (current distro is '" 260 repos.push_back(repo);
274 std::list<RepoInfo> repositories_in_file(
const Pathname & file )
276 MIL <<
"repo file: " << file << endl;
277 RepoCollector collector;
278 parser::RepoFileReader parser( file, bind( &RepoCollector::collect, &collector, _1 ) );
279 return std::move(collector.repos);
292 std::list<RepoInfo> repositories_in_dir(
const Pathname &dir )
294 MIL <<
"directory " << dir << endl;
295 std::list<RepoInfo>
repos;
296 bool nonroot( geteuid() != 0 );
297 if ( nonroot && ! PathInfo(dir).userMayRX() )
299 JobReport::warning( str::FormatNAC(
_(
"Cannot read repo directory '%1%': Permission denied")) % dir );
303 std::list<Pathname> entries;
310 str::regex allowedRepoExt(
"^\\.repo(_[0-9]+)?$");
311 for ( std::list<Pathname>::const_iterator it = entries.begin(); it != entries.end(); ++it )
315 if ( nonroot && ! PathInfo(*it).userMayR() )
317 JobReport::warning( str::FormatNAC(
_(
"Cannot read repo file '%1%': Permission denied")) % *it );
321 const std::list<RepoInfo> & tmp( repositories_in_file( *it ) );
322 repos.insert( repos.end(), tmp.begin(), tmp.end() );
332 inline void assert_alias(
const RepoInfo & info )
334 if ( info.alias().empty() )
338 if ( info.alias()[0] ==
'.')
340 info,
_(
"Repository alias cannot start with dot.")));
343 inline void assert_alias(
const ServiceInfo & info )
345 if ( info.alias().empty() )
349 if ( info.alias()[0] ==
'.')
351 info,
_(
"Service alias cannot start with dot.")));
356 inline void assert_urls(
const RepoInfo & info )
358 if ( info.baseUrlsEmpty() )
362 inline void assert_url(
const ServiceInfo & info )
364 if ( ! info.url().isValid() )
374 inline Pathname rawcache_path_for_repoinfo(
const RepoManagerOptions &opt,
const RepoInfo &info )
377 return opt.repoRawCachePath / info.escaped_alias();
388 inline Pathname rawproductdata_path_for_repoinfo(
const RepoManagerOptions &opt,
const RepoInfo &info )
391 return opt.repoRawCachePath / info.escaped_alias() / info.path();
397 inline Pathname packagescache_path_for_repoinfo(
const RepoManagerOptions &opt,
const RepoInfo &info )
400 return opt.repoPackagesCachePath / info.escaped_alias();
406 inline Pathname solv_path_for_repoinfo(
const RepoManagerOptions &opt,
const RepoInfo &info)
409 return opt.repoSolvCachePath / info.escaped_alias();
415 class ServiceCollector
418 typedef std::set<ServiceInfo> ServiceSet;
420 ServiceCollector( ServiceSet & services_r )
424 bool operator()(
const ServiceInfo & service_r )
const 448 DBG <<
"reading repo file " << repo_file <<
", local path: " << local << endl;
450 return repositories_in_file(local);
461 repoCachePath = Pathname::assertprefix( root_r,
ZConfig::instance().repoCachePath() );
462 repoRawCachePath = Pathname::assertprefix( root_r,
ZConfig::instance().repoMetadataPath() );
463 repoSolvCachePath = Pathname::assertprefix( root_r,
ZConfig::instance().repoSolvfilesPath() );
464 repoPackagesCachePath = Pathname::assertprefix( root_r,
ZConfig::instance().repoPackagesPath() );
465 knownReposPath = Pathname::assertprefix( root_r,
ZConfig::instance().knownReposPath() );
466 knownServicesPath = Pathname::assertprefix( root_r,
ZConfig::instance().knownServicesPath() );
467 pluginsPath = Pathname::assertprefix( root_r,
ZConfig::instance().pluginsPath() );
489 #define OUTS(X) str << " " #X "\t" << obj.X << endl 490 str <<
"RepoManagerOptions (" << obj.
rootDir <<
") {" << endl;
491 OUTS( repoRawCachePath );
492 OUTS( repoSolvCachePath );
493 OUTS( repoPackagesCachePath );
494 OUTS( knownReposPath );
495 OUTS( knownServicesPath );
513 init_knownServices();
514 init_knownRepositories();
520 if ( _reposDirty && geteuid() == 0 && ( _options.rootDir.empty() || _options.rootDir ==
"/" ) )
523 std::list<Pathname> entries;
525 if ( ! entries.empty() )
528 cmd.push_back(
"<" );
529 cmd.push_back(
">" );
530 cmd.push_back(
"PROGRAM" );
531 for (
const auto & rinfo :
repos() )
533 if ( ! rinfo.enabled() )
535 cmd.push_back(
"-R" );
536 cmd.push_back( rinfo.alias() );
537 cmd.push_back(
"-t" );
538 cmd.push_back( rinfo.type().asString() );
539 cmd.push_back(
"-p" );
540 cmd.push_back( rinfo.metadataPath().asString() );
543 for_( it, entries.begin(), entries.end() )
547 if ( pi.isFile() && pi.userMayRX() )
550 cmd[2] = pi.asString();
566 bool hasRepo(
const std::string & alias )
const 567 {
return foundAliasIn( alias,
repos() ); }
577 {
return rawcache_path_for_repoinfo( _options, info ); }
580 {
return packagescache_path_for_repoinfo( _options, info ); }
594 repo::RepoType probe(
const Url & url,
const Pathname & path = Pathname() )
const;
602 {
return PathInfo(solv_path_for_repoinfo( _options, info ) /
"solv").isExist(); }
627 {
return foundAliasIn( alias,
_services ); }
640 void removeService(
const std::string & alias );
642 { removeService( service.
alias() ); }
648 { refreshService( service.
alias(), options_r ); }
650 void modifyService(
const std::string & oldAlias,
const ServiceInfo & newService );
657 Pathname generateNonExistingName(
const Pathname & dir,
const std::string & basefilename )
const;
660 {
return filenameFromAlias( info.
alias(),
"repo" ); }
663 {
return filenameFromAlias( info.
alias(),
"service" ); }
667 Pathname base = solv_path_for_repoinfo( _options, info );
672 void touchIndexFile(
const RepoInfo & info );
674 template<
typename OutputIterator>
679 boost::make_filter_iterator( filter,
repos().end(),
repos().end() ),
684 void init_knownServices();
685 void init_knownRepositories();
698 friend Impl * rwcowClone<Impl>(
const Impl * rhs );
701 {
return new Impl( *
this ); }
707 {
return str <<
"RepoManager::Impl"; }
714 Pathname servfile = generateNonExistingName( _options.knownServicesPath,
715 generateFilename( service ) );
718 MIL <<
"saving service in " << servfile << endl;
720 std::ofstream file( servfile.c_str() );
727 MIL <<
"done" << endl;
746 const std::string & basefilename )
const 748 std::string final_filename = basefilename;
750 while ( PathInfo(dir + final_filename).isExist() )
755 return dir + Pathname(final_filename);
762 Pathname dir = _options.knownServicesPath;
763 std::list<Pathname> entries;
764 if (PathInfo(dir).isExist())
773 for_(it, entries.begin(), entries.end() )
789 inline void cleanupNonRepoMetadtaFolders(
const Pathname & cachePath_r,
790 const Pathname & defaultCachePath_r,
791 const std::list<std::string> & repoEscAliases_r )
793 if ( cachePath_r != defaultCachePath_r )
796 std::list<std::string> entries;
800 std::set<std::string> oldfiles;
801 set_difference( entries.begin(), entries.end(), repoEscAliases_r.begin(), repoEscAliases_r.end(),
802 std::inserter( oldfiles, oldfiles.end() ) );
803 for (
const std::string & old : oldfiles )
815 MIL <<
"start construct known repos" << endl;
817 if ( PathInfo(_options.knownReposPath).isExist() )
819 std::list<std::string> repoEscAliases;
820 std::list<RepoInfo> orphanedRepos;
821 for (
RepoInfo & repoInfo : repositories_in_dir(_options.knownReposPath) )
824 repoInfo.setMetadataPath( rawcache_path_for_repoinfo(_options, repoInfo) );
826 repoInfo.setPackagesPath( packagescache_path_for_repoinfo(_options, repoInfo) );
828 _reposX.insert( repoInfo );
831 const std::string & serviceAlias( repoInfo.service() );
832 if ( ! ( serviceAlias.empty() || hasService( serviceAlias ) ) )
834 WAR <<
"Schedule orphaned service repo for deletion: " << repoInfo << endl;
835 orphanedRepos.push_back( repoInfo );
839 repoEscAliases.push_back(repoInfo.escaped_alias());
843 if ( ! orphanedRepos.empty() )
845 for (
const auto & repoInfo : orphanedRepos )
847 MIL <<
"Delete orphaned service repo " << repoInfo.alias() << endl;
853 % repoInfo.alias() );
855 removeRepository( repoInfo );
869 repoEscAliases.sort();
871 cleanupNonRepoMetadtaFolders( _options.repoRawCachePath, defaultCache.
repoRawCachePath, repoEscAliases );
872 cleanupNonRepoMetadtaFolders( _options.repoSolvCachePath, defaultCache.
repoSolvCachePath, repoEscAliases );
873 cleanupNonRepoMetadtaFolders( _options.repoPackagesCachePath, defaultCache.
repoPackagesCachePath, repoEscAliases );
875 MIL <<
"end construct known repos" << endl;
882 Pathname mediarootpath = rawcache_path_for_repoinfo( _options, info );
883 Pathname productdatapath = rawproductdata_path_for_repoinfo( _options, info );
888 repokind = probeCache( productdatapath );
891 switch ( repokind.
toEnum() )
894 status =
RepoStatus( productdatapath/
"repodata/repomd.xml");
898 status =
RepoStatus( productdatapath/
"content" ) &&
RepoStatus( mediarootpath/
"media.1/media" );
917 Pathname productdatapath = rawproductdata_path_for_repoinfo( _options, info );
922 repokind = probeCache( productdatapath );
928 switch ( repokind.
toEnum() )
931 p = Pathname(productdatapath +
"/repodata/repomd.xml");
935 p = Pathname(productdatapath +
"/content");
939 p = Pathname(productdatapath +
"/cookie");
957 MIL <<
"Going to try to check whether refresh is needed for " << url << endl;
960 Pathname mediarootpath = rawcache_path_for_repoinfo( _options, info );
962 RepoStatus oldstatus = metadataStatus( info );
964 if ( oldstatus.
empty() )
966 MIL <<
"No cached metadata, going to refresh" << endl;
967 return REFRESH_NEEDED;
973 MIL <<
"never refresh CD/DVD" << endl;
974 return REPO_UP_TO_DATE;
978 policy = RefreshIfNeededIgnoreDelay;
983 if (policy != RefreshForced && policy != RefreshIfNeededIgnoreDelay)
986 double diff = difftime(
992 DBG <<
"last refresh = " << diff <<
" minutes ago" << endl;
998 WAR <<
"Repository '" << info.
alias() <<
"' was refreshed in the future!" << endl;
1002 MIL <<
"Repository '" << info.
alias()
1003 <<
"' has been refreshed less than repo.refresh.delay (" 1005 <<
") minutes ago. Advising to skip refresh" << endl;
1006 return REPO_CHECK_DELAYED;
1014 repokind = probe( url, info.
path() );
1018 switch ( repokind.
toEnum() )
1035 newstatus =
RepoStatus( MediaMounter(url).getPathName(info.
path()) );
1045 bool refresh =
false;
1046 if ( oldstatus == newstatus )
1048 MIL <<
"repo has not changed" << endl;
1049 if ( policy == RefreshForced )
1051 MIL <<
"refresh set to forced" << endl;
1057 MIL <<
"repo has changed, going to refresh" << endl;
1062 touchIndexFile(info);
1064 return refresh ? REFRESH_NEEDED : REPO_UP_TO_DATE;
1070 ERR <<
"refresh check failed for " << url << endl;
1074 return REFRESH_NEEDED;
1084 RepoException rexception( info,
PL_(
"Valid metadata not found at specified URL",
1085 "Valid metadata not found at specified URLs",
1100 if (checkIfToRefreshMetadata(info, url, policy)!=REFRESH_NEEDED)
1103 MIL <<
"Going to refresh metadata from " << url << endl;
1111 repokind = probe( *it, info.
path() );
1118 for_( it, repoBegin(), repoEnd() )
1120 if ( info.
alias() == (*it).alias() )
1123 modifiedrepo.
setType( repokind );
1124 modifyRepository( info.
alias(), modifiedrepo );
1131 Pathname mediarootpath = rawcache_path_for_repoinfo( _options, info );
1142 Exception ex(
_(
"Can't create metadata cache directory."));
1150 shared_ptr<repo::Downloader> downloader_ptr;
1152 MIL <<
"Creating downloader for [ " << info.
alias() <<
" ]" << endl;
1165 for_( it, repoBegin(), repoEnd() )
1167 Pathname cachepath(rawcache_path_for_repoinfo( _options, *it ));
1168 if ( PathInfo(cachepath).isExist() )
1169 downloader_ptr->addCachePath(cachepath);
1172 downloader_ptr->download( media, tmpdir.
path() );
1176 MediaMounter media( url );
1179 Pathname productpath( tmpdir.
path() / info.
path() );
1199 ERR <<
"Trying another url..." << endl;
1208 ERR <<
"No more urls..." << endl;
1217 progress.
sendTo(progressfnc);
1227 progress.
sendTo(progressfnc);
1237 Pathname mediarootpath = rawcache_path_for_repoinfo( _options, info );
1238 Pathname productdatapath = rawproductdata_path_for_repoinfo( _options, info );
1245 RepoStatus raw_metadata_status = metadataStatus(info);
1246 if ( raw_metadata_status.
empty() )
1251 refreshMetadata(info, RefreshIfNeeded, progressrcv );
1252 raw_metadata_status = metadataStatus(info);
1255 bool needs_cleaning =
false;
1256 if ( isCached( info ) )
1258 MIL << info.
alias() <<
" is already cached." << endl;
1261 if ( cache_status == raw_metadata_status )
1263 MIL << info.
alias() <<
" cache is up to date with metadata." << endl;
1264 if ( policy == BuildIfNeeded )
1267 const Pathname & base = solv_path_for_repoinfo( _options, info);
1268 if ( ! PathInfo(base/
"solv.idx").isExist() )
1274 MIL << info.
alias() <<
" cache rebuild is forced" << endl;
1278 needs_cleaning =
true;
1292 MIL << info.
alias() <<
" building cache..." << info.
type() << endl;
1294 Pathname base = solv_path_for_repoinfo( _options, info);
1302 if( ! PathInfo(base).userMayW() )
1304 Exception ex(
str::form(
_(
"Can't create cache at %s - no writing permissions."), base.c_str()) );
1307 Pathname solvfile = base /
"solv";
1313 switch ( repokind.
toEnum() )
1317 repokind = probeCache( productdatapath );
1323 MIL <<
"repo type is " << repokind << endl;
1325 switch ( repokind.
toEnum() )
1333 scoped_ptr<MediaMounter> forPlainDirs;
1336 cmd.push_back(
"repo2solv.sh" );
1338 cmd.push_back(
"-o" );
1339 cmd.push_back( solvfile.asString() );
1340 cmd.push_back(
"-X" );
1344 forPlainDirs.reset(
new MediaMounter( *info.
baseUrlsBegin() ) );
1346 cmd.push_back(
"-R" );
1348 cmd.push_back( forPlainDirs->getPathName( info.
path() ).c_str() );
1351 cmd.push_back( productdatapath.asString() );
1354 std::string errdetail;
1357 WAR <<
" " << output;
1358 if ( errdetail.empty() ) {
1362 errdetail += output;
1365 int ret = prog.
close();
1383 setCacheStatus(info, raw_metadata_status);
1384 MIL <<
"Commit cache.." << endl;
1399 MIL <<
"going to probe the repo type at " << url <<
" (" << path <<
")" << endl;
1405 MIL <<
"Probed type NONE (not exists) at " << url <<
" (" << path <<
")" << endl;
1417 bool gotMediaException =
false;
1425 MIL <<
"Probed type RPMMD at " << url <<
" (" << path <<
")" << endl;
1432 DBG <<
"problem checking for repodata/repomd.xml file" << endl;
1434 gotMediaException =
true;
1441 MIL <<
"Probed type YAST2 at " << url <<
" (" << path <<
")" << endl;
1448 DBG <<
"problem checking for content file" << endl;
1450 gotMediaException =
true;
1456 MediaMounter media( url );
1457 if ( PathInfo(media.getPathName()/path).isDir() )
1460 MIL <<
"Probed type RPMPLAINDIR at " << url <<
" (" << path <<
")" << endl;
1474 if (gotMediaException)
1477 MIL <<
"Probed type NONE at " << url <<
" (" << path <<
")" << endl;
1488 MIL <<
"going to probe the cached repo at " << path_r << endl;
1492 if ( PathInfo(path_r/
"/repodata/repomd.xml").isFile() )
1494 else if ( PathInfo(path_r/
"/content").isFile() )
1496 else if ( PathInfo(path_r).isDir() )
1499 MIL <<
"Probed cached type " << ret <<
" at " << path_r << endl;
1507 MIL <<
"Going to clean up garbage in cache dirs" << endl;
1510 progress.
sendTo(progressrcv);
1513 std::list<Pathname> cachedirs;
1514 cachedirs.push_back(_options.repoRawCachePath);
1515 cachedirs.push_back(_options.repoPackagesCachePath);
1516 cachedirs.push_back(_options.repoSolvCachePath);
1518 for_( dir, cachedirs.begin(), cachedirs.end() )
1520 if ( PathInfo(*dir).isExist() )
1522 std::list<Pathname> entries;
1527 unsigned sdircount = entries.size();
1528 unsigned sdircurrent = 1;
1529 for_( subdir, entries.begin(), entries.end() )
1533 for_( r, repoBegin(), repoEnd() )
1534 if ( subdir->basename() == r->escaped_alias() )
1535 { found =
true;
break; }
1540 progress.
set( progress.
val() + sdircurrent * 100 / sdircount );
1545 progress.
set( progress.
val() + 100 );
1555 progress.
sendTo(progressrcv);
1558 MIL <<
"Removing raw metadata cache for " << info.
alias() << endl;
1569 Pathname solvfile = solv_path_for_repoinfo(_options, info) /
"solv";
1571 if ( ! PathInfo(solvfile).isExist() )
1581 if ( toolversion != LIBSOLV_TOOLVERSION )
1590 MIL <<
"Try to handle exception by rebuilding the solv-file" << endl;
1591 cleanCache( info, progressrcv );
1592 buildCache( info, BuildIfNeeded, progressrcv );
1610 MIL <<
"Try adding repo " << info << endl;
1617 if ( _options.probe )
1619 DBG <<
"unknown repository type, probing" << endl;
1637 Pathname repofile = generateNonExistingName(
1638 _options.knownReposPath, generateFilename(tosave));
1640 MIL <<
"Saving repo in " << repofile << endl;
1642 std::ofstream file(repofile.c_str());
1656 RepoInfo & oinfo( const_cast<RepoInfo &>(info) );
1660 reposManip().insert(tosave);
1665 UrlCredentialExtractor( _options.rootDir ).collect( tosave.
baseUrls() );
1670 MIL <<
"done" << endl;
1677 for ( std::list<RepoInfo>::const_iterator it = repos.begin();
1682 for_ ( kit, repoBegin(), repoEnd() )
1684 if ( (*it).alias() == (*kit).alias() )
1686 ERR <<
"To be added repo " << (*it).alias() <<
" conflicts with existing repo " << (*kit).alias() << endl;
1692 std::string filename = Pathname(url.
getPathName()).basename();
1694 if ( filename == Pathname() )
1703 Pathname repofile = generateNonExistingName(_options.knownReposPath, filename);
1705 MIL <<
"Saving " << repos.size() <<
" repo" << ( repos.size() ?
"s" :
"" ) <<
" in " << repofile << endl;
1707 std::ofstream file(repofile.c_str());
1714 for ( std::list<RepoInfo>::iterator it = repos.begin();
1718 MIL <<
"Saving " << (*it).alias() << endl;
1719 it->setFilepath(repofile.asString());
1720 it->dumpAsIniOn(file);
1721 reposManip().insert(*it);
1726 MIL <<
"done" << endl;
1738 MIL <<
"Going to delete repo " << info.
alias() << endl;
1740 for_( it, repoBegin(), repoEnd() )
1745 if ( (!info.
alias().empty()) && ( info.
alias() != (*it).alias() ) )
1760 std::list<RepoInfo> filerepos = repositories_in_file(todelete.
filepath());
1761 if ( filerepos.size() == 0
1762 ||(filerepos.size() == 1 && filerepos.front().alias() == todelete.
alias() ) )
1766 if ( ! ( ret == 0 || ret == ENOENT ) )
1771 MIL << todelete.
alias() <<
" successfully deleted." << endl;
1783 std::ofstream file(todelete.
filepath().c_str());
1789 for ( std::list<RepoInfo>::const_iterator fit = filerepos.begin();
1790 fit != filerepos.end();
1793 if ( (*fit).alias() != todelete.
alias() )
1794 (*fit).dumpAsIniOn(file);
1802 if ( isCached(todelete) )
1803 cleanCache( todelete, cSubprogrcv);
1805 cleanMetadata( todelete, mSubprogrcv );
1806 cleanPackages( todelete, pSubprogrcv );
1807 reposManip().erase(todelete);
1808 MIL << todelete.
alias() <<
" successfully deleted." << endl;
1822 RepoInfo toedit = getRepositoryInfo(alias);
1826 if ( alias != newinfo.
alias() && hasRepo( newinfo.
alias() ) )
1838 std::list<RepoInfo> filerepos = repositories_in_file(toedit.
filepath());
1848 std::ofstream file(toedit.
filepath().c_str());
1854 for ( std::list<RepoInfo>::const_iterator fit = filerepos.begin();
1855 fit != filerepos.end();
1860 if ( (*fit).alias() != toedit.
alias() )
1861 (*fit).dumpAsIniOn(file);
1869 const Pathname & solvidx = solv_path_for_repoinfo(_options, newinfo)/
"solv.idx";
1870 if ( PathInfo(solvidx).isExist() )
1875 reposManip().erase(toedit);
1876 reposManip().insert(newinfo);
1878 UrlCredentialExtractor( _options.rootDir ).collect( newinfo.
baseUrls() );
1880 MIL <<
"repo " << alias <<
" modified" << endl;
1889 if ( it !=
repos().end() )
1899 for_( it, repoBegin(), repoEnd() )
1901 for_( urlit, (*it).baseUrlsBegin(), (*it).baseUrlsEnd() )
1903 if ( (*urlit).asString(urlview) == url.
asString(urlview) )
1920 assert_alias( service );
1923 if ( hasService( service.
alias() ) )
1929 saveService( toSave );
1933 UrlCredentialExtractor( _options.rootDir ).collect( toSave.
url() );
1935 MIL <<
"added service " << toSave.
alias() << endl;
1942 MIL <<
"Going to delete service " << alias << endl;
1944 const ServiceInfo & service = getService( alias );
1946 Pathname location = service.
filepath();
1947 if( location.empty() )
1956 if ( tmpSet.size() == 1 )
1963 MIL << alias <<
" successfully deleted." << endl;
1969 std::ofstream file(location.c_str());
1976 for_(it, tmpSet.begin(), tmpSet.end())
1978 if( it->alias() != alias )
1979 it->dumpAsIniOn(file);
1982 MIL << alias <<
" successfully deleted from file " << location << endl;
1986 RepoCollector rcollector;
1987 getRepositoriesInService( alias,
1988 boost::make_function_output_iterator( bind( &RepoCollector::collect, &rcollector, _1 ) ) );
1990 for_(rit, rcollector.repos.begin(), rcollector.repos.end())
1991 removeRepository(*rit);
2000 ServiceSet services( serviceBegin(), serviceEnd() );
2001 for_( it, services.begin(), services.end() )
2003 if ( !it->enabled() )
2007 refreshService(*it, options_r);
2017 assert_alias( service );
2018 assert_url( service );
2019 MIL <<
"Going to refresh service '" << service.
alias() <<
"', url: " << service.
url() <<
", opts: " << options_r << endl;
2021 if ( service.
ttl() && !( options_r.testFlag( RefreshService_forceRefresh) || options_r.testFlag( RefreshService_restoreStatus ) ) )
2030 if ( (lrf+=service.
ttl()) > now )
2032 MIL <<
"Skip: '" << service.
alias() <<
"' metadata valid until " << lrf << endl;
2037 WAR <<
"Force: '" << service.
alias() <<
"' metadata last refresh in the future: " << lrf << endl;
2044 bool serviceModified =
false;
2055 serviceModified =
true;
2060 std::string servicesTargetDistro = _options.servicesTargetDistro;
2061 if ( servicesTargetDistro.empty() )
2065 DBG <<
"ServicesTargetDistro: " << servicesTargetDistro << endl;
2069 RepoCollector collector(servicesTargetDistro);
2076 ServiceRepos( service, bind( &RepoCollector::collect, &collector, _1 ) );
2081 uglyHack.first =
true;
2082 uglyHack.second = e;
2084 if ( service.
ttl() != origTtl )
2086 if ( !service.
ttl() )
2088 serviceModified =
true;
2096 for_( it, collector.repos.begin(), collector.repos.end() )
2099 it->setAlias(
str::form(
"%s:%s", service.
alias().c_str(), it->alias().c_str() ) );
2101 it->setService( service.
alias() );
2104 newRepoStates[it->alias()] = *it;
2112 if ( !it->path().empty() )
2114 if ( it->path() !=
"/" )
2119 if ( it->baseUrlsEmpty() )
2122 if ( !path.empty() )
2124 it->setBaseUrl( std::move(url) );
2126 else if ( !path.empty() )
2129 for (
Url & url : urls )
2133 it->setBaseUrls( std::move(urls) );
2140 RepoInfoList oldRepos;
2141 getRepositoriesInService( service.
alias(), std::back_inserter( oldRepos ) );
2145 for_( oldRepo, oldRepos.begin(), oldRepos.end() )
2147 if ( ! foundAliasIn( oldRepo->alias(), collector.repos ) )
2149 if ( oldRepo->enabled() )
2152 const auto & last = service.
repoStates().find( oldRepo->alias() );
2153 if ( last != service.
repoStates().end() && ! last->second.enabled )
2155 DBG <<
"Service removes user enabled repo " << oldRepo->alias() << endl;
2157 serviceModified =
true;
2160 DBG <<
"Service removes enabled repo " << oldRepo->alias() << endl;
2163 DBG <<
"Service removes disabled repo " << oldRepo->alias() << endl;
2165 removeRepository( *oldRepo );
2171 UrlCredentialExtractor urlCredentialExtractor( _options.rootDir );
2172 for_( it, collector.repos.begin(), collector.repos.end() )
2178 TriBool toBeEnabled( indeterminate );
2179 DBG <<
"Service request to " << (it->enabled()?
"enable":
"disable") <<
" service repo " << it->alias() << endl;
2181 if ( options_r.testFlag( RefreshService_restoreStatus ) )
2183 DBG <<
"Opt RefreshService_restoreStatus " << it->alias() << endl;
2195 DBG <<
"User request to enable service repo " << it->alias() << endl;
2201 serviceModified =
true;
2205 DBG <<
"User request to disable service repo " << it->alias() << endl;
2206 toBeEnabled =
false;
2210 RepoInfoList::iterator oldRepo( findAlias( it->alias(), oldRepos ) );
2211 if ( oldRepo == oldRepos.end() )
2216 if ( ! indeterminate(toBeEnabled) )
2217 it->setEnabled( toBeEnabled );
2219 DBG <<
"Service adds repo " << it->alias() <<
" " << (it->enabled()?
"enabled":
"disabled") << endl;
2220 addRepository( *it );
2225 bool oldRepoModified =
false;
2227 if ( indeterminate(toBeEnabled) )
2231 if ( oldRepo->enabled() == it->enabled() )
2232 toBeEnabled = it->enabled();
2233 else if (options_r.testFlag( RefreshService_restoreStatus ) )
2235 toBeEnabled = it->enabled();
2236 DBG <<
"Opt RefreshService_restoreStatus " << it->alias() <<
" forces " << (toBeEnabled?
"enabled":
"disabled") << endl;
2240 const auto & last = service.
repoStates().find( oldRepo->alias() );
2241 if ( last == service.
repoStates().end() || last->second.enabled != it->enabled() )
2242 toBeEnabled = it->enabled();
2245 toBeEnabled = oldRepo->enabled();
2246 DBG <<
"User modified service repo " << it->alias() <<
" may stay " << (toBeEnabled?
"enabled":
"disabled") << endl;
2252 if ( toBeEnabled == oldRepo->enabled() )
2254 DBG <<
"Service repo " << it->alias() <<
" stays " << (oldRepo->enabled()?
"enabled":
"disabled") << endl;
2256 else if ( toBeEnabled )
2258 DBG <<
"Service repo " << it->alias() <<
" gets enabled" << endl;
2259 oldRepo->setEnabled(
true );
2260 oldRepoModified =
true;
2264 DBG <<
"Service repo " << it->alias() <<
" gets disabled" << endl;
2265 oldRepo->setEnabled(
false );
2266 oldRepoModified =
true;
2272 if ( oldRepo->rawName() != it->rawName() )
2274 DBG <<
"Service repo " << it->alias() <<
" gets new NAME " << it->rawName() << endl;
2275 oldRepo->setName( it->rawName() );
2276 oldRepoModified =
true;
2280 if ( oldRepo->autorefresh() != it->autorefresh() )
2282 DBG <<
"Service repo " << it->alias() <<
" gets new AUTOREFRESH " << it->autorefresh() << endl;
2283 oldRepo->setAutorefresh( it->autorefresh() );
2284 oldRepoModified =
true;
2288 if ( oldRepo->priority() != it->priority() )
2290 DBG <<
"Service repo " << it->alias() <<
" gets new PRIORITY " << it->priority() << endl;
2291 oldRepo->setPriority( it->priority() );
2292 oldRepoModified =
true;
2298 urlCredentialExtractor.extract( newUrls );
2299 if ( oldRepo->rawBaseUrls() != newUrls )
2301 DBG <<
"Service repo " << it->alias() <<
" gets new URLs " << newUrls << endl;
2302 oldRepo->setBaseUrls( std::move(newUrls) );
2303 oldRepoModified =
true;
2313 oldRepo->getRawGpgChecks( ogpg[0], ogpg[1], ogpg[2] );
2314 it-> getRawGpgChecks( ngpg[0], ngpg[1], ngpg[2] );
2315 #define Z_CHKGPG(I,N) \ 2316 if ( ! sameTriboolState( ogpg[I], ngpg[I] ) ) \ 2318 DBG << "Service repo " << it->alias() << " gets new "#N"Check " << ngpg[I] << endl; \ 2319 oldRepo->set##N##Check( ngpg[I] ); \ 2320 oldRepoModified = true; \ 2329 if ( oldRepoModified )
2331 modifyRepository( oldRepo->alias(), *oldRepo );
2340 serviceModified =
true;
2347 serviceModified =
true;
2354 if ( service.
ttl() )
2357 serviceModified =
true;
2360 if ( serviceModified )
2363 modifyService( service.
alias(), service );
2367 if ( uglyHack.first )
2369 throw( uglyHack.second );
2377 MIL <<
"Going to modify service " << oldAlias << endl;
2388 const ServiceInfo & oldService = getService(oldAlias);
2390 Pathname location = oldService.
filepath();
2391 if( location.empty() )
2401 std::ofstream file(location.c_str());
2402 for_(it, tmpSet.begin(), tmpSet.end())
2404 if( *it != oldAlias )
2405 it->dumpAsIniOn(file);
2414 UrlCredentialExtractor( _options.rootDir ).collect( service.
url() );
2418 if ( oldAlias != service.
alias()
2421 std::vector<RepoInfo> toModify;
2422 getRepositoriesInService(oldAlias, std::back_inserter(toModify));
2423 for_( it, toModify.begin(), toModify.end() )
2430 const auto & last = service.
repoStates().find( it->alias() );
2432 it->setEnabled( last->second.enabled );
2435 it->setEnabled(
false );
2438 if ( oldAlias != service.
alias() )
2439 it->setService(service.
alias());
2441 modifyRepository(it->alias(), *it);
2485 : _pimpl( new
Impl(opt) )
2517 std::string host( url_r.
getHost() );
2518 if ( ! host.empty() )
2640 {
return str << *obj.
_pimpl; }
void saveToCookieFile(const Pathname &path_r) const
Save the status information to a cookie file.
Pathname packagesPath(const RepoInfo &info) const
RepoManager(const RepoManagerOptions &options=RepoManagerOptions())
static const ValueType day
int assert_dir(const Pathname &path, unsigned mode)
Like 'mkdir -p'.
void removeService(const std::string &alias)
Removes service specified by its name.
thrown when it was impossible to match a repository
Thrown when the repo alias is found to be invalid.
RepoManagerOptions(const Pathname &root_r=Pathname())
Default ctor following ZConfig global settings.
bool hasService(const std::string &alias) const
std::string alias() const
unique identifier for this source.
static const std::string & sha1()
sha1
int exchange(const Pathname &lpath, const Pathname &rpath)
Exchanges two files or directories.
static bool error(const std::string &msg_r, const UserData &userData_r=UserData())
send error text
RepoStatus status(MediaSetAccess &media)
Status of the remote repository.
void setCacheStatus(const RepoInfo &info, const RepoStatus &status)
std::string generateFilename(const ServiceInfo &info) const
thrown when it was impossible to determine this repo type.
std::string digest()
get hex string representation of the digest
Retrieval of repository list for a service.
virtual std::ostream & dumpAsIniOn(std::ostream &str) const
Write this RepoInfo object into str in a .repo file format.
void refreshServices(const RefreshServiceOptions &options_r)
Pathname repoRawCachePath
bool serviceEmpty() const
Gets true if no service is in RepoManager (so no one in specified location)
void modifyService(const std::string &oldAlias, const ServiceInfo &service)
Modifies service file (rewrites it with new values) and underlying repositories if needed...
std::string asString(const DefaultIntegral< Tp, TInitial > &obj)
Read service data from a .service file.
void sendTo(const ReceiverFnc &fnc_r)
Set ReceiverFnc.
#define ZYPP_THROW(EXCPT)
Drops a logline and throws the Exception.
Date timestamp() const
The time the data were changed the last time.
ServiceConstIterator serviceBegin() const
static ZConfig & instance()
Singleton ctor.
static TmpDir makeSibling(const Pathname &sibling_r)
Provide a new empty temporary directory as sibling.
void refreshService(const std::string &alias, const RefreshServiceOptions &options_r)
scoped_ptr< media::CredentialManager > _cmPtr
RWCOW_pointer< Impl > _pimpl
Pointer to implementation.
void cleanCacheDirGarbage(const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Remove any subdirectories of cache directories which no longer belong to any of known repositories...
RepoConstIterator repoBegin() const
Pathname filepath() const
File where this repo was read from.
bool isCached(const RepoInfo &info) const
void refreshServices(const RefreshServiceOptions &options_r=RefreshServiceOptions())
Refreshes all enabled services.
Service plugin is immutable.
RepoStatus metadataStatus(const RepoInfo &info) const
Status of local metadata.
std::string getPathName(EEncoding eflag=zypp::url::E_DECODED) const
Returns the path name from the URL.
bool empty() const
Test for an empty path.
std::string getHost(EEncoding eflag=zypp::url::E_DECODED) const
Returns the hostname or IP from the URL authority.
RefreshCheckStatus
Possibly return state of checkIfRefreshMEtadata function.
Pathname metadataPath(const RepoInfo &info) const
Path where the metadata is downloaded and kept.
const std::string & command() const
The command we're executing.
urls_const_iterator baseUrlsBegin() const
iterator that points at begin of repository urls
RepoSet::size_type RepoSizeType
bool empty() const
Whether the status is empty (default constucted)
void loadFromCache(const RepoInfo &info, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Load resolvables into the pool.
ServiceConstIterator serviceEnd() const
Iterator to place behind last service in internal storage.
repo::RepoType probe(const Url &url, const Pathname &path) const
Probe repo metadata type.
std::string generateFilename(const RepoInfo &info) const
RepoConstIterator repoBegin() const
void refreshMetadata(const RepoInfo &info, RawMetadataRefreshPolicy policy=RefreshIfNeeded, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Refresh local raw cache.
Pathname packagesPath(const RepoInfo &info) const
Path where the rpm packages are downloaded and kept.
void addService(const std::string &alias, const Url &url)
void touchIndexFile(const RepoInfo &info)
void setAlias(const std::string &alias)
set the repository alias
void init_knownRepositories()
String related utilities and Regular expression matching.
void addRepoToEnable(const std::string &alias_r)
Add alias_r to the set of ReposToEnable.
void removeRepository(const RepoInfo &info, OPT_PROGRESS)
RefreshServiceFlags RefreshServiceOptions
Options tuning RefreshService.
void modifyService(const std::string &oldAlias, const ServiceInfo &newService)
bool toMax()
Set counter value to current max value (unless no range).
void setProbedType(const repo::RepoType &t) const
This allows to adjust the RepoType lazy, from NONE to some probed value, even for const objects...
void refreshService(const std::string &alias, const RefreshServiceOptions &options_r=RefreshServiceOptions())
Refresh specific service.
void setFilepath(const Pathname &filename)
set the path to the .repo file
What is known about a repository.
static bool warning(const std::string &msg_r, const UserData &userData_r=UserData())
send warning text
void removeRepository(const RepoInfo &info, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Remove the best matching repository from known repos list.
const RepoSet & repos() const
#define for_(IT, BEG, END)
Convenient for-loops using iterator.
const RepoStates & repoStates() const
Access the remembered repository states.
Pathname knownServicesPath
void setBaseUrl(const Url &url)
Clears current base URL list and adds url.
bool enabled() const
If enabled is false, then this repository must be ignored as if does not exists, except when checking...
void reposErase(const std::string &alias_r)
Remove a Repository named alias_r.
Service already exists and some unique attribute can't be duplicated.
void refreshService(const ServiceInfo &service, const RefreshServiceOptions &options_r)
bool repo_add_probe() const
Whether repository urls should be probed.
urls_const_iterator baseUrlsEnd() const
iterator that points at end of repository urls
std::string targetDistribution() const
This is register.target attribute of the installed base product.
std::string form(const char *format,...) __attribute__((format(printf
Printf style construction of std::string.
static RepoStatus fromCookieFile(const Pathname &path)
Reads the status from a cookie file.
Service without alias was used in an operation.
RepoStatus metadataStatus(const RepoInfo &info) const
RepoSet::const_iterator RepoConstIterator
function< bool(const ProgressData &)> ReceiverFnc
Most simple version of progress reporting The percentage in most cases.
Url::asString() view options.
void cleanMetadata(const RepoInfo &info, OPT_PROGRESS)
repo::RepoType probeCache(const Pathname &path_r) const
Probe Metadata in a local cache directory.
#define PL_(MSG1, MSG2, N)
void modifyRepository(const std::string &alias, const RepoInfo &newinfo, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Modify repository attributes.
Pathname repoSolvCachePath
std::vector< std::string > Arguments
RepoManagerOptions _options
std::string asString() const
Returns a default string representation of the Url object.
ServiceInfo getService(const std::string &alias) const
RepoSizeType repoSize() const
boost::logic::tribool TriBool
3-state boolean logic (true, false and indeterminate).
void remember(const Exception &old_r)
Store an other Exception as history.
std::string & replaceAll(std::string &str_r, const std::string &from_r, const std::string &to_r)
Replace all occurrences of from_r with to_r in str_r (inplace).
void removeService(const ServiceInfo &service)
transform_iterator< repo::RepoVariablesUrlReplacer, url_set::const_iterator > urls_const_iterator
Progress callback from another progress.
std::map< std::string, RepoState > RepoStates
std::string label() const
Label for use in messages for the user interface.
void addRepository(const RepoInfo &info, OPT_PROGRESS)
static const ServiceType RIS
Repository Index Service (RIS) (formerly known as 'Novell Update' (NU) service)
RepoManager implementation.
#define ZYPP_RETHROW(EXCPT)
Drops a logline and rethrows, updating the CodeLocation.
void setPathName(const std::string &path, EEncoding eflag=zypp::url::E_DECODED)
Set the path name.
std::set< RepoInfo > RepoSet
RepoInfo typedefs.
bool toMin()
Set counter value to current min value.
RepoInfo getRepositoryInfo(const std::string &alias, OPT_PROGRESS)
boost::noncopyable NonCopyable
Ensure derived classes cannot be copied.
Store and operate on date (time_t).
static Pool instance()
Singleton ctor.
bool serviceEmpty() const
static RepoManagerOptions makeTestSetup(const Pathname &root_r)
Test setup adjusting all paths to be located below one root_r directory.
Pathname rootDir
remembers root_r value for later use
void removeRepository(const RepoInfo &repo)
Log recently removed repository.
Provide a new empty temporary directory and recursively delete it when no longer needed.
Convenient building of std::string via std::ostringstream Basically a std::ostringstream autoconverti...
void clearReposToDisable()
Clear the set of ReposToDisable.
Lightweight repository attribute value lookup.
std::string asCompleteString() const
Returns a complete string representation of the Url object.
RepoConstIterator repoEnd() const
Execute a program and give access to its io An object of this class encapsulates the execution of an ...
void cleanCacheDirGarbage(OPT_PROGRESS)
int unlink(const Pathname &path)
Like 'unlink'.
thrown when it was impossible to determine one url for this repo.
static const ServiceType NONE
No service set.
static const SolvAttr repositoryToolVersion
Service type enumeration.
void modifyRepository(const std::string &alias, const RepoInfo &newinfo_r, OPT_PROGRESS)
ServiceSet::const_iterator ServiceConstIterator
void setRepoStates(RepoStates newStates_r)
Remember a new set of repository states.
std::ostream & operator<<(std::ostream &str, const DeltaCandidates &obj)
repo::ServiceType probeService(const Url &url) const
Probe the type or the service.
int recursive_rmdir(const Pathname &path)
Like 'rm -r DIR'.
void setMetadataPath(const Pathname &path)
set the path where the local metadata is stored
void setType(const repo::RepoType &t)
set the repository type
Maintain [min,max] and counter (value) for progress counting.
Date::Duration ttl() const
Sugested TTL between two metadata auto-refreshs.
RepoStatus cacheStatus(const RepoInfo &info) const
Pathname generateNonExistingName(const Pathname &dir, const std::string &basefilename) const
Generate a non existing filename in a directory, using a base name.
void addRepository(const RepoInfo &repo)
Log a newly added repository.
void updateSolvFileIndex(const Pathname &solvfile_r)
Create solv file content digest for zypper bash completion.
RepoInfo getRepo(const std::string &alias) const
Writing the zypp history fileReference counted signleton for writhing the zypp history file...
static bool schemeIsVolatile(const std::string &scheme_r)
cd dvd
void addRepository(const RepoInfo &info, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Adds a repository to the list of known repositories.
RepoInfo getRepositoryInfo(const std::string &alias, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Find a matching repository info.
static const ServiceType PLUGIN
Plugin services are scripts installed on your system that provide the package manager with repositori...
Base Exception for service handling.
std::string receiveLine()
Read one line from the input stream.
void init_knownServices()
void delRepoToEnable(const std::string &alias_r)
Remove alias_r from the set of ReposToEnable.
static std::string makeStupidAlias(const Url &url_r=Url())
Some stupid string but suitable as alias for your url if nothing better is available.
RefreshCheckStatus checkIfToRefreshMetadata(const RepoInfo &info, const Url &url, RawMetadataRefreshPolicy policy=RefreshIfNeeded)
Checks whether to refresh metadata for specified repository and url.
void cleanCache(const RepoInfo &info, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
clean local cache
void cleanCache(const RepoInfo &info, OPT_PROGRESS)
std::string numstring(char n, int w=0)
ServiceSet::size_type ServiceSizeType
bool reposToDisableEmpty() const
static const RepoType NONE
int touch(const Pathname &path)
Change file's modification and access times.
void resetDispose()
Set no dispose function.
ServiceInfo getService(const std::string &alias) const
Finds ServiceInfo by alias or return ServiceInfo::noService.
void getRepositoriesInService(const std::string &alias, OutputIterator out) const
void setPackagesPath(const Pathname &path)
set the path where the local packages are stored
url_set baseUrls() const
The complete set of repository urls.
std::ostream & copy(std::istream &from_r, std::ostream &to_r)
Copy istream to ostream.
int close()
Wait for the progamm to complete.
bool hasRepo(const std::string &alias) const
Return whether there is a known repository for alias.
void setLrf(Date lrf_r)
Set date of last refresh.
static const RepoType RPMMD
creates and provides information about known sources.
#define ZYPP_CAUGHT(EXCPT)
Drops a logline telling the Exception was caught (in order to handle it).
RepoStatus cacheStatus(const RepoInfo &info) const
Status of metadata cache.
repo::RepoType type() const
Type of repository,.
int readdir(std::list< std::string > &retlist_r, const Pathname &path_r, bool dots_r)
Return content of directory via retlist.
RepoSizeType repoSize() const
void addService(const ServiceInfo &service)
std::list< RepoInfo > readRepoFile(const Url &repo_file)
Parses repo_file and returns a list of RepoInfo objects corresponding to repositories found within th...
RepoInfo getRepo(const std::string &alias) const
Find RepoInfo by alias or return RepoInfo::noRepo.
Url rawUrl() const
The service raw url (no variables replaced)
static const RepoType YAST2
thrown when it was impossible to determine an alias for this repo.
void buildCache(const RepoInfo &info, CacheBuildPolicy policy=BuildIfNeeded, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Refresh local cache.
Base class for Exception.
void addRepositories(const Url &url, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Adds repositores from a repo file to the list of known repositories.
std::set< ServiceInfo > ServiceSet
ServiceInfo typedefs.
Exception for repository handling.
void saveService(ServiceInfo &service) const
Impl(const RepoManagerOptions &opt)
media::MediaAccessId _mid
static Date now()
Return the current time.
repo::RepoType probe(const Url &url, const Pathname &path=Pathname()) const
Probe the metadata type of a repository located at url.
DefaultIntegral< bool, false > _reposDirty
ServiceConstIterator serviceEnd() const
Functor thats filter RepoInfo by service which it belongs to.
bool isCached(const RepoInfo &info) const
Whether a repository exists in cache.
bool hasRepo(const std::string &alias) const
Reference counted access to a Tp object calling a custom Dispose function when the last AutoDispose h...
The repository cache is not built yet so you can't create the repostories from the cache...
void eraseFromPool()
Remove this Repository from it's Pool.
Pathname repoPackagesCachePath
std::string asUserHistory() const
A single (multiline) string composed of asUserString and historyAsString.
static const ServiceInfo noService
Represents an empty service.
RepoConstIterator repoEnd() const
bool hasService(const std::string &alias) const
Return whether there is a known service for alias.
void removeService(const std::string &alias)
void buildCache(const RepoInfo &info, CacheBuildPolicy policy, OPT_PROGRESS)
bool repoToDisableFind(const std::string &alias_r) const
Whether alias_r is mentioned in ReposToDisable.
static const RepoInfo noRepo
Represents no Repository (one with an empty alias).
bool regex_match(const std::string &s, smatch &matches, const regex ®ex)
regex ZYPP_STR_REGEX regex ZYPP_STR_REGEX
Thrown when the repo alias is found to be invalid.
friend std::ostream & operator<<(std::ostream &str, const RepoManager &obj)
ServiceSizeType serviceSize() const
Gets count of service in RepoManager (in specified location)
static const RepoType RPMPLAINDIR
static const std::string & systemRepoAlias()
Reserved system repository alias .
bool repoToEnableFind(const std::string &alias_r) const
Whether alias_r is mentioned in ReposToEnable.
ServiceSizeType serviceSize() const
Track changing files or directories.
void cleanPackages(const RepoInfo &info, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Clean local package cache.
unsigned repo_refresh_delay() const
Amount of time in minutes that must pass before another refresh.
Repository already exists and some unique attribute can't be duplicated.
ServiceConstIterator serviceBegin() const
Iterator to first service in internal storage.
bool set(value_type val_r)
Set new counter value.
std::string getScheme() const
Returns the scheme name of the URL.
Url url() const
The service url.
static bool schemeIsDownloading(const std::string &scheme_r)
http https ftp sftp tftp
void modifyRepository(const RepoInfo &oldrepo, const RepoInfo &newrepo)
Log certain modifications to a repository.
std::ostream & operator<<(std::ostream &str, const RepoManager::Impl &obj)
Impl * clone() const
clone for RWCOW_pointer
urls_size_type baseUrlsSize() const
number of repository urls
Repository addRepoSolv(const Pathname &file_r, const std::string &name_r)
Load Solvables from a solv-file into a Repository named name_r.
void name(const std::string &name_r)
Set counter name.
Downloader for YUM (rpm-nmd) repositories Encapsulates all the knowledge of which files have to be do...
Pathname metadataPath(const RepoInfo &info) const
Easy-to use interface to the ZYPP dependency resolver.
void setProbedType(const repo::ServiceType &t) const
Lazy init service type.
void cleanPackages(const RepoInfo &info, OPT_PROGRESS)
void loadFromCache(const RepoInfo &info, OPT_PROGRESS)
std::string hexstring(char n, int w=4)
void addService(const std::string &alias, const Url &url)
Adds new service by it's alias and url.
void refreshMetadata(const RepoInfo &info, RawMetadataRefreshPolicy policy, OPT_PROGRESS)
Service has no or invalid url defined.
static bool schemeIsLocal(const std::string &scheme_r)
hd cd dvd dir file iso
Date lrf() const
Date of last refresh (if known).
void addRepositories(const Url &url, OPT_PROGRESS)
void cleanMetadata(const RepoInfo &info, const ProgressData::ReceiverFnc &progressrcv=ProgressData::ReceiverFnc())
Clean local metadata.
Pathname path() const
Repository path.
virtual std::ostream & dumpAsIniOn(std::ostream &str) const
Writes ServiceInfo to stream in ".service" format.
repo::ServiceType type() const
Service type.
Repository type enumeration.
RefreshCheckStatus checkIfToRefreshMetadata(const RepoInfo &info, const Url &url, RawMetadataRefreshPolicy policy)
repo::ServiceType probeService(const Url &url) const