-#include <ctime>
-#include <iostream>
#include "Tools.h"
#include <zypp/base/PtrTypes.h>
#include <zypp/base/Exception.h>
+#include <zypp/base/LogTools.h>
#include <zypp/base/ProvideNumericId.h>
+#include <zypp/AutoDispose.h>
#include "zypp/ZYppFactory.h"
#include "zypp/ResPoolProxy.h"
-#include <zypp/SourceManager.h>
-#include <zypp/SourceFactory.h>
+#include <zypp/CapMatchHelper.h>
#include "zypp/ZYppCallbacks.h"
#include "zypp/NVRAD.h"
#include "zypp/Package.h"
#include "zypp/Pattern.h"
#include "zypp/Language.h"
+#include "zypp/Digest.h"
+#include "zypp/PackageKeyword.h"
#include "zypp/NameKindProxy.h"
#include "zypp/pool/GetResolvablesToInsDel.h"
+#include "zypp/parser/TagParser.h"
+#include "zypp/parser/susetags/PackagesFileReader.h"
+#include "zypp/parser/susetags/PackagesLangFileReader.h"
+#include "zypp/parser/susetags/PatternFileReader.h"
+#include "zypp/parser/susetags/ContentFileReader.h"
+#include "zypp/parser/susetags/RepoIndex.h"
+#include "zypp/parser/susetags/RepoParser.h"
+#include "zypp/cache/CacheStore.h"
+#include "zypp/RepoManager.h"
+#include "zypp/RepoInfo.h"
+
+#include "zypp/ui/PatchContents.h"
using namespace std;
using namespace zypp;
-using namespace zypp::ui;
using namespace zypp::functor;
+using zypp::parser::TagParser;
+
///////////////////////////////////////////////////////////////////
static const Pathname sysRoot( "/Local/ROOT" );
///////////////////////////////////////////////////////////////////
+struct Xprint
+{
+ bool operator()( const PoolItem & obj_r )
+ {
+ //handle( asKind<Package>( obj_r ) );
+ //handle( asKind<Patch>( obj_r ) );
+ handle( asKind<Pattern>( obj_r ) );
+ handle( asKind<Product>( obj_r ) );
+ return true;
+ }
+
+ void handle( const Package_constPtr & p )
+ {
+ if ( !p )
+ return;
+
+ MIL << p->diskusage() << endl;
+ }
+
+ void handle( const Patch_constPtr & p )
+ {
+ if ( !p )
+ return;
+ }
+
+ void handle( const Pattern_constPtr & p )
+ {
+ if ( !p )
+ return;
+
+ if ( p->vendor().empty() )
+ ERR << p << endl;
+ else if ( p->vendor() == "SUSE (assumed)" )
+ SEC << p << endl;
+ }
+
+ void handle( const Product_constPtr & p )
+ {
+ if ( !p )
+ return;
+
+ USR << p << endl;
+ USR << p->vendor() << endl;
+ USR << p->type() << endl;
+ }
+
+ template<class _C>
+ bool operator()( const _C & obj_r )
+ {
+ return true;
+ }
+};
+
+///////////////////////////////////////////////////////////////////
+struct SetTransactValue
+{
+ SetTransactValue( ResStatus::TransactValue newVal_r, ResStatus::TransactByValue causer_r )
+ : _newVal( newVal_r )
+ , _causer( causer_r )
+ {}
+
+ ResStatus::TransactValue _newVal;
+ ResStatus::TransactByValue _causer;
+
+ bool operator()( const PoolItem & pi ) const
+ {
+ bool ret = pi.status().setTransactValue( _newVal, _causer );
+ if ( ! ret )
+ ERR << _newVal << _causer << " " << pi << endl;
+ return ret;
+ }
+};
+
+struct StatusReset : public SetTransactValue
+{
+ StatusReset()
+ : SetTransactValue( ResStatus::KEEP_STATE, ResStatus::USER )
+ {}
+};
+
+struct StatusInstall : public SetTransactValue
+{
+ StatusInstall()
+ : SetTransactValue( ResStatus::TRANSACT, ResStatus::USER )
+ {}
+};
+
+inline bool g( const NameKindProxy & nkp, Arch arch = Arch() )
+{
+ if ( nkp.availableEmpty() )
+ {
+ ERR << "No Item to select: " << nkp << endl;
+ return false;
+ ZYPP_THROW( Exception("No Item to select") );
+ }
+
+ if ( arch != Arch() )
+ {
+ typeof( nkp.availableBegin() ) it = nkp.availableBegin();
+ for ( ; it != nkp.availableEnd(); ++it )
+ {
+ if ( (*it)->arch() == arch )
+ return (*it).status().setTransact( true, ResStatus::USER );
+ }
+ }
+
+ return nkp.availableBegin()->status().setTransact( true, ResStatus::USER );
+}
+
+///////////////////////////////////////////////////////////////////
+
+bool solve( bool establish = false )
+{
+ if ( establish )
+ {
+ bool eres = false;
+ {
+ zypp::base::LogControl::TmpLineWriter shutUp;
+ eres = getZYpp()->resolver()->establishPool();
+ }
+ if ( ! eres )
+ {
+ ERR << "establish " << eres << endl;
+ return false;
+ }
+ MIL << "establish " << eres << endl;
+ }
+
+ bool rres = false;
+ {
+ zypp::base::LogControl::TmpLineWriter shutUp;
+ rres = getZYpp()->resolver()->resolvePool();
+ }
+ if ( ! rres )
+ {
+ ERR << "resolve " << rres << endl;
+ return false;
+ }
+ MIL << "resolve " << rres << endl;
+ return true;
+}
+
+///////////////////////////////////////////////////////////////////
+
struct ConvertDbReceive : public callback::ReceiveReport<target::ScriptResolvableReport>
{
virtual void start( const Resolvable::constPtr & script_r,
}
};
+///////////////////////////////////////////////////////////////////
+
+struct DigestReceive : public callback::ReceiveReport<DigestReport>
+{
+ DigestReceive()
+ {
+ connect();
+ }
+
+ virtual bool askUserToAcceptNoDigest( const zypp::Pathname &file )
+ {
+ USR << endl;
+ return false;
+ }
+ virtual bool askUserToAccepUnknownDigest( const Pathname &file, const std::string &name )
+ {
+ USR << endl;
+ return false;
+ }
+ virtual bool askUserToAcceptWrongDigest( const Pathname &file, const std::string &requested, const std::string &found )
+ {
+ USR << "fle " << PathInfo(file) << endl;
+ USR << "req " << requested << endl;
+ USR << "fnd " << found << endl;
+
+ waitForInput();
+
+ return false;
+ }
+};
+
+struct KeyRingSignalsReceive : public callback::ReceiveReport<KeyRingSignals>
+{
+ KeyRingSignalsReceive()
+ {
+ connect();
+ }
+ virtual void trustedKeyAdded( const PublicKey &/*key*/ )
+ {
+ USR << endl;
+ }
+ virtual void trustedKeyRemoved( const PublicKey &/*key*/ )
+ {
+ USR << endl;
+ }
+};
///////////////////////////////////////////////////////////////////
struct MediaChangeReceive : public callback::ReceiveReport<media::MediaChangeReport>
{
- virtual Action requestMedia( Source_Ref source
+ virtual Action requestMedia( Url & source
, unsigned mediumNr
, Error error
, const std::string & description )
///////////////////////////////////////////////////////////////////
-struct PoolItemSelect
-{
- void operator()( const PoolItem & pi ) const
- {
- if ( pi->source().numericId() == 2 )
- pi.status().setTransact( true, ResStatus::USER );
- }
-};
-
-///////////////////////////////////////////////////////////////////
-///////////////////////////////////////////////////////////////////
-
struct AddResolvables
{
- bool operator()( const Source_Ref & src ) const
+ bool operator()( const Repository & src ) const
{
getZYpp()->addResolvables( src.resolvables() );
return true;
///////////////////////////////////////////////////////////////////
-struct SetTransactValue
+
+std::ostream & operator<<( std::ostream & str, const iostr::EachLine & obj )
{
- SetTransactValue( ResStatus::TransactValue newVal_r, ResStatus::TransactByValue causer_r )
- : _newVal( newVal_r )
- , _causer( causer_r )
- {}
+ str << "(" << obj.valid() << ")[" << obj.lineNo() << "|" << obj.lineStart() << "]{" << *obj << "}";
+ return str;
- ResStatus::TransactValue _newVal;
- ResStatus::TransactByValue _causer;
+}
- bool operator()( const PoolItem & pi ) const
- { return pi.status().setTransactValue( _newVal, _causer ); }
-};
+///////////////////////////////////////////////////////////////////
-struct StatusReset : public SetTransactValue
-{
- StatusReset()
- : SetTransactValue( ResStatus::KEEP_STATE, ResStatus::USER )
- {}
-};
+#define for_(IT,BEG,END) for ( typeof(BEG) IT = BEG; IT != END; ++IT )
+///////////////////////////////////////////////////////////////////
+namespace zypp
+{ /////////////////////////////////////////////////////////////////
-inline bool selectForTransact( const NameKindProxy & nkp, Arch arch = Arch() )
-{
- if ( nkp.availableEmpty() ) {
- ERR << "No Item to select: " << nkp << endl;
- return false;
- ZYPP_THROW( Exception("No Item to select") );
- }
- if ( arch != Arch() )
- {
- typeof( nkp.availableBegin() ) it = nkp.availableBegin();
- for ( ; it != nkp.availableEnd(); ++it )
- {
- if ( (*it)->arch() == arch )
- return (*it).status().setTransact( true, ResStatus::USER );
- }
- }
+ void Vtst( const std::string & lhs, const std::string & rhs )
+ {
+ (VendorAttr::instance().equivalent( lhs, rhs )?MIL:ERR) << lhs << " <==> "<< rhs << endl;
- return nkp.availableBegin()->status().setTransact( true, ResStatus::USER );
-}
+ }
-void seltest( const NameKindProxy & nks )
-{
- SEC << nks << endl;
- PoolItem av( *nks.availableBegin() );
- SEC << av << endl;
- Pattern::constPtr pat( asKind<Pattern>(av.resolvable()) );
- SEC << pat << endl;
- WAR << pat->install_packages() << endl;
- MIL << pat->deps() << endl;
- MIL << pat->includes() << endl;
- MIL << pat->extends() << endl;
-}
+ /////////////////////////////////////////////////////////////////
+} // namespace zypp
+///////////////////////////////////////////////////////////////////
-void showProd( const PoolItem & prod )
-{
- Product::constPtr p( asKind<Product>(prod) );
- DBG << prod << endl;
- MIL << p << endl;
- MIL << p->distributionName() << endl;
- MIL << p->distributionEdition() << endl;
- MIL << p->installtime() << endl;
-}
+using namespace zypp;
-///////////////////////////////////////////////////////////////////
/******************************************************************
**
** FUNCTION NAME : main
{
//zypp::base::LogControl::instance().logfile( "log.restrict" );
INT << "===[START]==========================================" << endl;
+ setenv( "ZYPP_CONF", "/Local/ROOT/zypp.conf", 1 );
- ConvertDbReceive cr;
- cr.connect();
- MediaChangeReceive mr;
- mr.connect();
-
- ResPool pool( getZYpp()->pool() );
-
- if ( 1 )
- {
- zypp::base::LogControl::TmpLineWriter shutUp;
- Source_Ref src( createSource( "dir:/Local/SLES10" ) );
- getZYpp()->addResolvables( src.resolvables() );
- }
- MIL << pool << endl;
+ DigestReceive foo;
+ KeyRingSignalsReceive baa;
- PoolItem prod( *pool.byKindBegin<Product>() );
- showProd( prod );
- PoolItem pac( *pool.byNameBegin("java-1_4_2-sun-plugin") );
+ RepoManager repoManager( makeRepoManager( "/Local/ROOT" ) );
+ RepoInfoList repos = repoManager.knownRepositories();
+ SEC << repos << endl;
- if ( 1 )
- {
- zypp::base::LogControl::TmpLineWriter shutUp;
- getZYpp()->initTarget( sysRoot );
- USR << "Added target: " << pool << endl;
- }
-
- prod.status().setTransact( true, ResStatus::USER );
- pac.status().setTransact( true, ResStatus::USER );
- ZYppCommitPolicy policy;
- policy.rpmNoSignature();
- ZYppCommitResult res( getZYpp()->commit( policy ) );
-
- SEC << res << endl;
-
- zypp::base::LogControl::instance().logNothing();
- return 0;
+ if ( repos.empty() )
+ {
+ RepoInfo nrepo;
+ nrepo
+ .setAlias( "factorytest" )
+ .setName( "Test Repo for factory." )
+ .setEnabled( true )
+ .setAutorefresh( false )
+ .addBaseUrl( Url("http://dist.suse.de/install/stable-x86/") );
+
+ repoManager.addRepository( nrepo );
+ SEC << "refreshMetadat" << endl;
+ repoManager.refreshMetadata( nrepo );
+ SEC << "buildCache" << endl;
+ repoManager.buildCache( nrepo );
+ SEC << "------" << endl;
+ repos = repoManager.knownRepositories();
+ }
+ ResPool pool( getZYpp()->pool() );
+ vdumpPoolStats( USR << "Initial pool:" << endl,
+ pool.begin(),
+ pool.end() ) << endl;
+ for ( RepoInfoList::iterator it = repos.begin(); it != repos.end(); ++it )
+ {
+ RepoInfo & nrepo( *it );
+ if ( ! nrepo.enabled() )
+ continue;
- if ( 1 )
+ if ( ! repoManager.isCached( nrepo ) || 0 )
{
-#define selt(K,N) selectForTransact( nameKindProxy<K>( pool, #N ) )
- selt( Script, fetchmsttfonts.sh-patch-fetchmsttfonts.sh-2 );
-#undef selt
+ if ( repoManager.isCached( nrepo ) )
+ {
+ SEC << "cleanCache" << endl;
+ repoManager.cleanCache( nrepo );
+ }
+ SEC << "refreshMetadata" << endl;
+ repoManager.refreshMetadata( nrepo, RepoManager::RefreshForced );
+ SEC << "buildCache" << endl;
+ repoManager.buildCache( nrepo );
}
- vdumpPoolStats( USR << "Transacting:"<< endl,
- make_filter_begin<resfilter::ByTransact>(pool),
- make_filter_end<resfilter::ByTransact>(pool) ) << endl;
+ SEC << nrepo << endl;
+ Repository nrep( repoManager.createFromCache( nrepo ) );
+ const zypp::ResStore & store( nrep.resolvables() );
- if ( 1 ) {
- bool eres, rres;
- {
- //zypp::base::LogControl::TmpLineWriter shutUp;
- //zypp::base::LogControl::instance().logfile( "SOLVER" );
- eres = getZYpp()->resolver()->establishPool();
- rres = getZYpp()->resolver()->resolvePool();
- }
- MIL << "est " << eres << " slv " << rres << endl;
+ dumpPoolStats( SEC << "Store: " << endl,
+ store.begin(), store.end() ) << endl;
+ getZYpp()->addResolvables( store );
}
- dumpPoolStats( USR << "Transacting:"<< endl,
- make_filter_begin<resfilter::ByTransact>(pool),
- make_filter_end<resfilter::ByTransact>(pool) ) << endl;
-
+ USR << "pool: " << pool << endl;
+ SEC << pool.knownRepositoriesSize() << endl;
if ( 1 )
+ {
{
- ZYppCommitPolicy policy;
- policy.rpmNoSignature();
- ZYppCommitResult res( getZYpp()->commit( policy ) );
+ zypp::base::LogControl::TmpLineWriter shutUp;
+ //getZYpp()->initTarget( sysRoot );
+ getZYpp()->initTarget( "/" );
}
+ MIL << "Added target: " << pool << endl;
+ }
+
+ std::for_each( pool.begin(), pool.end(), Xprint() );
+ ///////////////////////////////////////////////////////////////////
INT << "===[END]============================================" << endl << endl;
zypp::base::LogControl::instance().logNothing();
return 0;
projects / platform / upstream / libzypp.git / blobdiff