49 const Arch & arch_r )
const 82 template <
class TPackage>
110 if ( ! ( ret->empty() ||
_package->repoInfo().keepPackages() ) )
153 policy.
progressCB( bind( &Base::progressPackageDownload,
this, _1 ) );
171 _target = getZYpp()->getTarget();
177 ret =
_target->rpmDb().checkPackageSignature( path_r, detail );
180 WAR <<
"Relax CHK_NOSIG: Config says unsigned packages are OK" << endl;
185 detail.push_back( RpmDb::CheckPackageDetail::value_type( ret,
"OOps. Target is not initialized!" ) );
187 userData.
set(
"CheckPackageResult", ret );
188 userData.
set(
"CheckPackageDetail", std::move(detail) );
203 WAR <<
_package->asUserString() <<
": " <<
"User requested to accept insecure file" << endl;
207 ZYPP_THROW(AbortRequestException(
"User requested to abort"));
216 msg <<
_package->asUserString() <<
": " <<
_(
"Signature verification failed") <<
" " << ret;
217 if ( ! detail_r.empty() )
218 msg <<
"\n" << detail_r;
236 return shared_ptr<void>(
static_cast<void*
>(0),
237 bind( mem_fun_ref(
static_cast<void (shared_ptr<Report>::*)()
>(&shared_ptr<Report>::reset) ),
247 template <
class TPackage>
254 if ( ! ret->empty() )
256 MIL <<
"provided Package from cache " << _package <<
" at " << ret << endl;
257 report()->infoInCache( _package, ret );
262 RepoInfo info = _package->repoInfo();
270 if ( ! loc.checksum().empty() )
273 if ( pi.isExist() && loc.checksum() ==
CheckSum( loc.checksum().type(), std::ifstream( pi.c_str() ) ) )
275 report()->start( _package, pi.path().asFileUrl() );
283 MIL <<
"provided Package from toplevel cache " << _package <<
" at " << ret << endl;
296 MIL <<
"provide Package " << _package << endl;
301 if ( ! ret->empty() )
309 ret = doProvidePackage();
315 userData.
set(
"ResObject", roptr );
316 userData.
set(
"Package", roptr->asKind<
Package>() );
317 userData.
set(
"Localpath", ret.
value() );
334 pkgGpgCheckIsMandatory =
false;
341 report()->pkgGpgCheck( userData );
343 if ( res != RpmDb::CHK_OK )
345 if ( userData.
hasvalue(
"Action" ) )
349 else if ( userData.
haskey(
"Action" ) )
351 defaultReportSignatureError( res );
360 case RpmDb::CHK_NOKEY:
361 case RpmDb::CHK_NOTFOUND:
362 case RpmDb::CHK_FAIL:
363 case RpmDb::CHK_NOTTRUSTED:
364 case RpmDb::CHK_ERROR:
365 case RpmDb::CHK_NOSIG:
377 ERR <<
"Failed to provide Package " << _package << endl;
383 ERR <<
"Failed to provide Package " << _package << endl;
386 const std::string & package_str = _package->asUserString();
394 ZYPP_THROW(SkipRequestException(
"User requested skip of corrupted file"));
397 ZYPP_THROW(AbortRequestException(
"User requested to abort"));
406 ERR <<
"Failed to provide Package " << _package << endl;
410 const std::string & package_str = _package->asUserString();
413 std::string detail_str(
str::form(
_(
"Failed to provide Package %s. Do you want to retry retrieval?"), package_str.c_str() ) );
422 ZYPP_THROW(SkipRequestException(
"User requested skip of file", excpt));
425 ZYPP_THROW(AbortRequestException(
"User requested to abort", excpt));
440 if ( ! ret->empty() )
446 MIL <<
"provided Package " << _package <<
" at " << ret << endl;
475 {
return report()->progressDeltaDownload( value ); }
478 {
return report()->progressDeltaApply( value ); }
502 std::list<DeltaRpm> deltaRpms;
507 for_( it, deltaRpms.begin(), deltaRpms.end())
509 DBG <<
"tryDelta " << *it << endl;
511 if ( ! ret->empty() )
544 report()->finishDeltaDownload();
546 report()->startDeltaApply( delta );
549 report()->problemDeltaApply(
_(
"applydeltarpm check failed.") );
559 report()->problemDeltaApply(
_(
"applydeltarpm failed.") );
562 report()->finishDeltaApply();
606 : _pimpl( factory::
make( access_r, pi_r, deltas_r, policy_r ) )
611 : _pimpl( factory::
make( access_r, pi_r, policy_r ) )
619 : _pimpl( factory::
make( access_r, package_r, deltas_r, policy_r ) )
PackageProvider implementation interface.
Candidate delta and patches for a package.
const BaseVersion & baseversion() const
int assert_dir(const Pathname &path, unsigned mode)
Like 'mkdir -p'.
Pathname path() const
Repository path.
Interface to the rpm program.
bool download_use_deltarpm_always() const
Whether to consider using a deltarpm even when rpm is local.
#define ZYPP_THROW(EXCPT)
Drops a logline and throws the Exception.
static ZConfig & instance()
Singleton ctor.
callback::SendReport< repo::DownloadResolvableReport > Report
void reset()
Reset to default Ctor values.
void defaultReportSignatureError(RpmDb::CheckPackageResult ret, const std::string &detail_r=std::string()) const
Default signature verification error handling.
virtual ~PackageProviderImpl()
bool isCached() const
Whether the package is cached.
Policies and options for PackageProvider.
ManagedFile tryDelta(const DeltaRpm &delta_r) const
bool haveApplydeltarpm()
Test whether an execuatble applydeltarpm program is available.
bool pkgGpgCheckIsMandatory() const
Mandatory check (pkgGpgCheck is not off) must ask to confirm using unsigned packages.
void progressDeltaApply(int value) const
ManagedFile providePackageFromCache() const
Provide the package if it is cached.
What is known about a repository.
AutoDispose< const Pathname > ManagedFile
A Pathname plus associated cleanup code to be executed when path is no longer needed.
#define for_(IT, BEG, END)
Convenient for-loops using iterator.
Edition represents [epoch:]version[-release]
virtual ManagedFile providePackage() const
Provide the package.
std::string basename() const
Return the last component of this path.
ManagedFile providePackage() const
Provide the package.
TraitsType::constPtrType constPtr
std::string form(const char *format,...) __attribute__((format(printf
Printf style construction of std::string.
RpmDb::CheckPackageResult packageSigCheck(const Pathname &path_r, bool isMandatory_r, UserData &userData) const
RepoMediaAccess & _access
std::list< packagedelta::DeltaRpm > deltaRpms(const Package::constPtr &package) const
bool repoGpgCheck() const
Whether the signature of repo metadata should be checked for this repo.
PackageProvider implementation for Package and SrcPackage.
urls_const_iterator baseUrlsBegin() const
iterator that points at begin of repository urls
TPackage::constPtr TPackagePtr
bool baseUrlsEmpty() const
whether repository urls are available
QueryInstalledCB _queryInstalledCB
PackageProvider(RepoMediaAccess &access, const PoolItem &pi_r, const PackageProviderPolicy &policy_r=PackageProviderPolicy())
Ctor taking the package to provide.
#define ZYPP_RETHROW(EXCPT)
Drops a logline and rethrows, updating the CodeLocation.
RW_pointer< Impl > _pimpl
Implementation class.
packagedelta::DeltaRpm DeltaRpm
boost::noncopyable NonCopyable
Ensure derived classes cannot be copied.
bool keepPackages() const
Whether packages downloaded from this repository will be kept in local cache.
virtual bool isCached() const =0
Whether the package is cached.
shared_ptr< Report > _report
Convenient building of std::string via std::ostringstream Basically a std::ostringstream autoconverti...
bool pkgGpgCheck() const
Whether the signature of rpm packages should be checked for this repo.
int unlink(const Pathname &path)
Like 'unlink'.
bool set(const std::string &key_r, AnyType val_r)
Set the value for key (nonconst version always returns true).
PackageProviderImpl(RepoMediaAccess &access_r, const TPackagePtr &package_r, const PackageProviderPolicy &policy_r)
Ctor taking the Package to provide.
const OnMediaLocation & location() const
std::string asUserHistory() const
A single (multiline) string composed of asUserString and historyAsString.
Pathname dirname() const
Return all but the last component od this path.
PackageProviderImpl< TPackage > Base
void resolveSignatureErrorAction(repo::DownloadResolvableReport::Action action_r) const
React on signature verification error user action.
Detailed rpm signature check log messages A single multiline message if CHK_OK.
const Edition & edition() const
RepoInfo info() const
Return any associated RepoInfo.
bool queryInstalled(const Edition &ed_r=Edition()) const
bool startsWith(const C_Str &str_r, const C_Str &prefix_r)
alias for hasPrefix
bool gpgCheck() const
Whether default signature checking should be performed.
ResTraits< TRes >::PtrType make(const sat::Solvable &solvable_r)
Directly create a certain kind of ResObject from sat::Solvable.
int hardlinkCopy(const Pathname &oldpath, const Pathname &newpath)
Create newpath as hardlink or copy of oldpath.
bool progressPackageDownload(int value) const
Redirect ProvideFilePolicy package download progress to this.
Report & report() const
Access to the DownloadResolvableReport.
RpmPackageProvider(RepoMediaAccess &access_r, const Package::constPtr &package_r, const DeltaCandidates &deltas_r, const PackageProviderPolicy &policy_r)
callback::UserData UserData
ScopedGuard newReport() const
virtual bool isCached() const
Whether the package is cached.
std::string asUserString() const
void setDispose(const Dispose &dispose_r)
Set a new dispose function.
shared_ptr< void > ScopedGuard
virtual ManagedFile doProvidePackage() const
Actually provide the final rpm.
Base class for Exception.
ProvideFilePolicy & progressCB(ProgressCB progressCB_r)
Set callback.
reference value() const
Reference to the Tp object.
const Tp & get(const std::string &key_r) const
Pass back a const Tp & reference to key_r value.
virtual ManagedFile providePackageFromCache() const =0
Provide the package if it is cached.
Typesafe passing of user data via callbacks.
PackageProviderPolicy _policy
Reference counted access to a Tp object calling a custom Dispose function when the last AutoDispose h...
bool progressDeltaDownload(int value) const
RPM PackageProvider implementation (with deltarpm processing).
Pathname repoPackagesCachePath
Pathname packagesPath() const
Path where this repo packages are cached.
Wrapper class for ::stat/::lstat.
bool haskey(const std::string &key_r) const
Whether key_r is in data.
CheckPackageResult
checkPackage result
bool quickcheck(const std::string &sequenceinfo_r)
Quick via check sequence info.
bool check(const std::string &sequenceinfo_r, bool quick_r)
Check via sequence info.
virtual ManagedFile doProvidePackage() const
Actually provide the final rpm.
Combining sat::Solvable and ResStatus.
virtual ManagedFile providePackage() const =0
Provide the package.
bool queryInstalled(const std::string &name_r, const Edition &ed_r, const Arch &arch_r) const
Evaluate callback.
bool isKind(const ResKind &kind_r) const
Base for exceptions caused by explicit user request.
bool hasvalue(const std::string &key_r) const
Whether key_r is in data and value is not empty.
Easy-to use interface to the ZYPP dependency resolver.
PackageProvider::Impl * make(RepoMediaAccess &access_r, const PoolItem &pi_r, const DeltaCandidates &deltas_r, const PackageProviderPolicy &policy_r)
ManagedFile doProvidePackageFromCache() const
Lookup the final rpm in cache.
const std::string & sequenceinfo() const
bool provide(const Pathname &delta_r, const Pathname &new_r, const Progress &report_r)
Apply a binary delta to on-disk data to re-create a new rpm.
TraitsType::constPtrType constPtr
static const Edition noedition
Value representing noedition ("") This is in fact a valid Edition.
virtual ManagedFile providePackageFromCache() const
Provide the package if it is cached.
const Repository & repository() const