14 #include <zypp-media/ng/Provide> 15 #include <zypp-media/ng/ProvideSpec> 16 #include <zypp/ng/Context> 17 #include <zypp/ng/repo/Downloader> 18 #include <zypp-common/PublicKey.h> 30 #undef ZYPP_BASE_LOGGER_LOGGROUP 31 #define ZYPP_BASE_LOGGER_LOGGROUP "zypp::repomanager" 39 template <
class Executor,
class OpType >
40 struct DownloadMasterIndexLogic :
public LogicBase<Executor, OpType>
46 using ZyppContextType =
typename remove_smart_ptr_t<DlContextRefType>::ContextType;
47 using ProvideType =
typename ZyppContextType::ProvideType;
48 using MediaHandle =
typename ProvideType::MediaHandle;
49 using ProvideRes =
typename ProvideType::Res;
53 ,
_media(std::move( mediaHandle ))
58 MaybeAsyncRef<expected<DlContextRefType>> execute( ) {
64 auto providerRef =
_dlContext->zyppContext()->provider();
66 |
and_then( [
this]( ProvideRes && masterres ) {
76 | [
this,masterres=std::move(masterres)]( std::vector<expected<zypp::ManagedFile>> &&res ) {
78 std::for_each( res.begin (), res.end(),
79 [
this]( expected<zypp::ManagedFile> &f){
81 _dlContext->files().push_back( std::move(f.get()));
89 |
and_then( std::bind( &DownloadMasterIndexLogic::pluginVerification,
this, std::placeholders::_1 ) )
92 |
and_then( std::bind( &DownloadMasterIndexLogic::signatureCheck,
this, std::placeholders::_1 ) )
108 allFiles.insert( allFiles.begin (), std::move(masterIndex) );
119 MaybeAsyncRef<expected<ProvideRes>> signatureCheck ( ProvideRes &&res ) {
121 if (
_dlContext->repoInfo().repoGpgCheck() ) {
128 if ( isSigned ||
_dlContext->repoInfo().repoGpgCheckIsMandatory() ) {
139 _dlContext->zyppContext()->keyRing()->importKey( zypp::PublicKey(keypathLocal),
false );
147 verifyCtx.keyContext(
_dlContext->repoInfo() );
149 return getExtraKeysInRepomd( std::move(res ) )
150 |
and_then([
this, vCtx = std::move(verifyCtx) ]( ProvideRes &&res )
mutable {
152 DBG <<
"Keyhint remember buddy " << keyData << std::endl;
153 vCtx.addBuddyKey( keyData.id() );
165 WAR <<
"Accept unsigned repository because repoGpgCheck is not mandatory for " <<
_dlContext->repoInfo().alias() << std::endl;
168 WAR <<
"Signature checking disabled in config of repository " <<
_dlContext->repoInfo().alias() << std::endl;
174 expected<ProvideRes> pluginVerification ( ProvideRes &&prevRes ) {
178 if (
_dlContext->pluginRepoverification() &&
_dlContext->pluginRepoverification()->isNeeded() ) {
180 _dlContext->pluginRepoverification()->getChecker( sigpathLocal, keypathLocal,
_dlContext->repoInfo() )( prevRes.file() );
192 MaybeAsyncRef<expected<ProvideRes>> getExtraKeysInRepomd ( ProvideRes &&res ) {
199 if ( keyhints.empty() )
201 DBG <<
"Check keyhints: " << keyhints.size() << std::endl;
203 auto keyRing {
_dlContext->zyppContext()->keyRing() };
205 |
transform([
this, keyRing]( std::pair<std::string, std::string> val ) {
207 const auto& [ file, keyid ] = val;
208 auto keyData = keyRing->trustedPublicKeyData( keyid );
210 DBG <<
"Keyhint is already trusted: " << keyid <<
" (" << file <<
")" << std::endl;
214 DBG <<
"Keyhint search key " << keyid <<
" (" << file <<
")" << std::endl;
216 keyData = keyRing->publicKeyData( keyid );
224 return zypp::PublicKey::noThrow(cacheFile)
225 | [ keyid = keyid ](
auto &&key ){
226 if ( key.fileProvidesKey( keyid ) )
231 |
or_else ([
this, file = file, keyid = keyid, cacheFile ] (
auto )
mutable -> MaybeAsyncRef<expected<zypp::PublicKey>> {
232 auto providerRef =
_dlContext->zyppContext()->provider();
233 return providerRef->provide(
_media, file, ProvideFileSpec().setOptional(
true) )
238 _dlContext->files().push_back ( std::move(res) );
240 auto key = zypp::PublicKey::noThrow(
_dlContext->files().back() );
241 if ( not key.fileProvidesKey( keyid ) ) {
242 const std::string
str = (
zypp::str::Str() <<
"Keyhint " << file <<
" does not contain a key with id " << keyid <<
". Skipping it.");
249 return providerRef->copyFile( key.path(), cacheFile )
250 | [ key ]( expected<zypp::ManagedFile> res )
mutable {
253 res->resetDispose ();
259 |
and_then( [ keyRing, keyid = keyid ]( zypp::PublicKey key ){
260 keyRing->importKey( key,
false );
264 | [
this, res = res] ( std::vector<expected<zypp::PublicKeyData>> &&keyHints )
mutable {
265 std::for_each( keyHints.begin(), keyHints.end(), [
this]( expected<zypp::PublicKeyData> &keyData ){
266 if ( keyData && *keyData ) {
267 if ( not zypp::PublicKey::isSafeKeyId( keyData->id() ) ) {
268 WAR <<
"Keyhint " << keyData->id() <<
" for " << *keyData <<
" is not strong enough for auto import. Just caching it." << std::endl;
271 _buddyKeys.push_back ( std::move(keyData.get()) );
275 MIL <<
"Check keyhints done. Buddy keys: " <<
_buddyKeys.size() << std::endl;
307 return dl->zyppContext()->provider()->attachMediaIfNeeded( mediaHandle )
316 return dl->zyppContext()->provider()->attachMediaIfNeeded( mediaHandle )
324 template <
class DlContextRefType,
class MediaHandleType>
325 auto statusImpl ( DlContextRefType dlCtx, MediaHandleType &&mediaHandle ) {
327 constexpr
bool isAsync = std::is_same_v<DlContextRefType,repo::AsyncDownloadContextRef>;
333 switch( dlCtx->repoInfo().type().toEnum()) {
349 return statusImpl( dl, std::move(mediaHandle) );
353 return statusImpl( dl, std::move(mediaHandle) );
358 return dl->zyppContext()->provider()->attachMediaIfNeeded( mediaHandle )
366 return dl->zyppContext()->provider()->attachMediaIfNeeded( mediaHandle )
374 template <
class DlContextRefType,
class MediaHandleType>
375 auto downloadImpl ( DlContextRefType dlCtx, MediaHandleType &&mediaHandle, ProgressObserverRef &&progressObserver ) {
377 constexpr
bool isAsync = std::is_same_v<DlContextRefType,repo::AsyncDownloadContextRef>;
379 switch( dlCtx->repoInfo().type().toEnum()) {
381 return RpmmdWorkflows::download( std::move(dlCtx), std::forward<MediaHandleType>(mediaHandle), std::move(progressObserver) );
396 return downloadImpl( dl, std::move(mediaHandle), std::move(progressObserver) );
401 return downloadImpl( dl, std::move(mediaHandle), std::move(progressObserver) );
407 return dl->zyppContext()->provider()->attachMediaIfNeeded( mediaHandle )
409 return downloadImpl( dl, std::move(handle), std::move(po) );
416 return dl->zyppContext()->provider()->attachMediaIfNeeded( mediaHandle )
418 return downloadImpl( dl, std::move(handle), std::move(po) );
AsyncOpRef< expected< repo::AsyncDownloadContextRef > > download(repo::AsyncDownloadContextRef dl, ProvideMediaHandle mediaHandle, ProgressObserverRef progressObserver=nullptr)
boost::logic::tribool TriBool
3-state boolean logic (true, false and indeterminate).
thrown when it was impossible to determine this repo type.
auto transform(Transformation &&transformation)
int assert_dir(const Pathname &path, unsigned mode)
Like 'mkdir -p'.
Store and operate with byte count.
Pathname pubkeyCachePath() const
Path where the pubkey caches.
Pathname extend(const std::string &r) const
Append string r to the last component of the path.
zypp::Pathname _masterIndex
String related utilities and Regular expression matching.
zypp::TriBool _repoSigValidated
static expected< std::decay_t< Type >, Err > make_expected_success(Type &&t)
I/O context for KeyRing::verifyFileSignatureWorkflow.
static const Unit MB
1000^2 Byte
std::string basename() const
Return the last component of this path.
#define ZYPP_EXCPT_PTR(EXCPT)
Drops a logline and returns Exception as a std::exception_ptr.
Pathname repoManagerRoot() const
The RepoManager root directory.
AsyncOpRef< expected< repo::AsyncDownloadContextRef > > download(repo::AsyncDownloadContextRef dl, ProvideMediaHandle mediaHandle, ProgressObserverRef progressObserver)
auto or_else(Fun &&function)
const Pathname & signature() const
Detached signature or empty.
Convenient building of std::string via std::ostringstream Basically a std::ostringstream autoconverti...
bool isExist() const
Return whether valid stat info exists.
Pathname dirname() const
Return all but the last component od this path.
Interim helper class to collect global options and settings.
#define ZYPP_ENABLE_LOGIC_BASE(Executor, OpType)
AsyncOpRef< expected< repo::AsyncDownloadContextRef > > downloadMasterIndex(repo::AsyncDownloadContextRef dl, ProvideMediaHandle mediaHandle, zypp::filesystem::Pathname masterIndex_r)
AsyncOpRef< expected< zypp::RepoStatus > > repoStatus(repo::AsyncDownloadContextRef dl, ProvideMediaHandle mediaHandle)
DlContextRefType _dlContext
typename conditional< B, T, F >::type conditional_t
std::conditional_t< isAsync, AsyncOpRef< T >, T > makeReadyResult(T &&result)
static expected success(ConsParams &&...params)
std::shared_ptr< AsyncOp< T > > AsyncOpRef
Reads through a repomd.xml file and collects type, location, checksum and other data about metadata f...
AsyncOpRef< expected< zypp::RepoStatus > > repoStatus(repo::AsyncDownloadContextRef dl, ProvideMediaHandle mediaHandle)
Base class for Exception.
expected< zypp::keyring::VerifyFileContext > verifySignature(SyncContextRef ctx, zypp::keyring::VerifyFileContext context)
AsyncOpRef< expected< zypp::RepoStatus > > repoStatus(repo::AsyncDownloadContextRef dl, ProvideMediaHandle mediaHandle)
auto and_then(Fun &&function)
Wrapper class for ::stat/::lstat.
Interface of repomd.xml file reader.
AsyncOpRef< expected< repo::AsyncDownloadContextRef > > download(repo::AsyncDownloadContextRef dl, ProvideMediaHandle mediaHandle, ProgressObserverRef progressObserver)
ResultType and_then(const expected< T, E > &exp, Function &&f)
Track changing files or directories.
#define ZYPP_FWD_CURRENT_EXCPT()
Drops a logline and returns the current Exception as a std::exception_ptr.
std::vector< zypp::PublicKeyData > _buddyKeys