35 #undef ZYPP_BASE_LOGGER_LOGGROUP 36 #define ZYPP_BASE_LOGGER_LOGGROUP "zypp::posttrans" 51 friend std::ostream &
dumpOn( std::ostream &
str,
const Impl & obj );
54 using ScriptList = std::list< std::pair<std::string,std::string> >;
100 script.autoCleanup(
false );
102 std::ofstream out( script.path().c_str() );
103 out <<
"#! " << pkg->tag_posttransprog() << endl
104 << pkg->tag_posttrans() << endl;
107 _scripts->push_back( std::make_pair( script.path().basename(), pkg->tag_name() ) );
108 MIL <<
"COLLECT posttrans: '" <<
PathInfo( script.path() ) <<
"' for package: '" << pkg->tag_name() <<
"'" << endl;
122 if ( runposttrans_r.empty() ) {
124 MIL <<
"LOST dump_posttrans support" << endl;
135 MIL <<
"COLLECT dump_posttrans to '" <<
_dumpfile->_dumpfile << endl;
138 std::ofstream out(
_dumpfile->_dumpfile.c_str(), std::ios_base::app );
139 for (
const auto & s : runposttrans_r ) {
142 _dumpfile->_numscripts += runposttrans_r.size();
143 MIL <<
"COLLECT " << runposttrans_r.size() <<
" dump_posttrans lines" << endl;
160 MIL <<
"Extract missing %posttrans scripts and prepend them to the scripts." << endl;
163 std::optional<ScriptList> savedscripts;
165 savedscripts = std::move(*
_scripts);
170 recallFromDumpfile(
_dumpfile->_dumpfile, [&](
const std::string& n_r,
const std::string& v_r,
const std::string& r_r,
const std::string& a_r ) ->
void {
171 if ( it.findPackage( n_r, Edition( v_r, r_r ) ) && headerHasPosttrans( *it ) )
172 collectScriptFromHeader( *it );
176 if ( savedscripts ) {
180 _scripts = std::move(*savedscripts);
201 std::string scriptProgressName {
_(
"Running post-transaction scripts") };
203 str::Format fmtScriptProgressRun {
_(
"Running %1% script") };
206 std::string sendRipoff;
211 auto startNewScript = [&] (
const std::string & scriptident_r ) ->
void {
213 sendRipoff = fmtRipoff % scriptident_r;
214 scriptProgress.
name( fmtScriptProgressRun % scriptident_r );
215 scriptProgress.
incr();
219 auto sendScriptOutput = [&] (
const std::string & line_r ) ->
void {
221 if ( not sendRipoff.empty() ) {
222 historylog.
comment( sendRipoff,
true );
234 scriptProgress.
name( scriptProgressName );
235 scriptProgress.
toMin();
241 str::Format fmtScriptFailedMsg {
"warning: %%posttrans(%1%) scriptlet failed, exit status %2%\n" };
247 const auto &scriptPair =
_scripts->front();
248 const std::string & script = scriptPair.first;
249 const std::string & pkgident( script.substr( 0, script.size()-6 ) );
250 startNewScript( fmtPosttrans % pkgident );
253 for ( it.findByName( scriptPair.second ); *it; ++it )
256 MIL <<
"EXECUTE posttrans: " << script <<
" with argument: " << npkgs << endl;
259 (noRootScriptDir/script).
asString(),
265 sendScriptOutput( line );
270 int ret = prog.
close();
273 std::string msg { fmtScriptFailedMsg % pkgident % ret };
275 sendScriptOutput( msg );
285 if ( str::startsWith( line_r,
"RIPOFF:" ) )
286 startNewScript( line_r.substr( 7 ) );
288 sendScriptOutput( line_r );
297 scriptProgress.
name( scriptProgressName );
299 scriptProgress.
toMax();
316 msg <<
"%posttrans scripts skipped while aborting:" << endl;
317 for (
const auto & script : *
_scripts )
319 WAR <<
"UNEXECUTED posttrans: " << script.first << endl;
320 const std::string & pkgident( script.first.substr( 0, script.first.size()-6 ) );
321 msg <<
" " << pkgident <<
"\n";
327 msg <<
"%posttrans and %transfiletrigger scripts are not executed when aborting!" << endl;
332 historylog.
comment( msg,
true );
350 std::string prog( pkg_r->tag_posttransprog() );
351 if ( not prog.empty() && prog !=
"<lua>" )
370 WAR <<
"Unexpectedly this is no package: " << rpmPackage_r << endl;
380 static const str::regex rxInstalled {
"^dump_posttrans: +install +[0-9]+ +(.+)-([^-]+)-([^-]+)\\.([^.]+)" };
384 consume_r( what[1], what[2], what[3], what[4] );
402 {
return str <<
"RpmPostTransCollector::Impl"; }
406 {
return str << obj; }
415 : _pimpl( new
Impl(
std::move(root_r) ) )
std::string asString(const Patch::Category &obj)
Impl & operator=(const Impl &)=delete
Interface to the rpm program.
bool autoCleanup() const
Whether path is valid and deleted when the last reference drops.
Data regarding the dumpfile used if rpm --runposttrans is supported.
size_t _numscripts
Number of scripts we collected (roughly estimated)
JobReport convenience sending this instance of UserData with each message.
void sendTo(const ReceiverFnc &fnc_r)
Set ReceiverFnc.
static ZConfig & instance()
Singleton ctor.
bool warning(const std::string &msg_r)
function< bool(const ProgressData &)> ReceiverFnc
Most simple version of progress reporting The percentage in most cases.
RpmPostTransCollector(Pathname root_r)
Default ctor.
void discardScripts()
Discard all remembered scripts and/or or dump_posttrans lines.
friend std::ostream & dumpOn(std::ostream &str, const Impl &obj)
int forEachLine(std::istream &str_r, const function< bool(int, std::string)> &consume_r)
Simple lineparser: Call functor consume_r for each line.
String related utilities and Regular expression matching.
std::list< std::pair< std::string, std::string > > ScriptList
<posttrans script basename, pkgname> pairs.
bool toMax()
Set counter value to current max value (unless no range).
std::string receiveLine()
Read one line from the input stream.
std::ostream & dumpOn(std::ostream &str, const RpmPostTransCollector::Impl &obj)
Provide a new empty temporary file and delete it when no longer needed.
void erase(const std::string &key_r)
Remove key from data.
void recallFromDumpfile(const Pathname &dumpfile_r, std::function< void(std::string, std::string, std::string, std::string)> consume_r)
Retrieve "dump_posttrans: install" lines from dumpfile_r and pass n,v,r,a to the consumer_r.
Wrapper providing a librpmDb::db_const_iterator for this RpmDb.
void collectPosttransInfo(const Pathname &rpmPackage_r, const std::vector< std::string > &runposttrans_r)
Extract and remember a packages posttrans script or dump_posttrans lines for later execution...
RW_pointer< Impl > _pimpl
Implementation class.
void collectScriptForPackage(const Pathname &rpmPackage_r)
void setDispose(const Dispose &dispose_r)
Set a new dispose function.
Extract and remember posttrans scripts for later execution.
bool hasPosttransScript(const Pathname &rpmPackage_r)
Test whether a package defines a posttrans script.
bool info(const std::string &msg_r)
Pathname tmpDir()
Lazy create tmpdir on demand.
int addmod(const Pathname &path, mode_t mode)
Add the mode bits to the file given by path.
bool toMin()
Set counter value to current min value.
void executeScripts(rpm::RpmDb &rpm_r)
Execute the remembered scripts.
void collectScriptFromHeader(const rpm::RpmHeader::constPtr &pkg)
std::pair< Pathname, rpm::RpmHeader::constPtr > _headercache
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...
Execute a program and give access to its io An object of this class encapsulates the execution of an ...
bool set(const std::string &key_r, AnyType val_r)
Set the value for key (nonconst version always returns true).
std::optional< Dumpfile > _dumpfile
rpm::RpmHeader::constPtr getHeaderIfPosttrans(const Pathname &rpmPackage_r)
Cache RpmHeader for consecutive hasPosttransScript / collectScriptForPackage calls.
int close() override
Wait for the progamm to complete.
RpmPostTransCollector implementation.
Maintain [min,max] and counter (value) for progress counting.
std::ostream & operator<<(std::ostream &str, const CommitPackageCache &obj)
void collectPosttransInfo(const Pathname &rpmPackage_r, const std::vector< std::string > &runposttrans_r)
Writing the zypp history fileReference counted signleton for writhing the zypp history file...
void executeScripts(rpm::RpmDb &rpm_r)
Execute the remembered scripts and/or or dump_posttrans lines.
bool incr(value_type val_r=1)
Increment counter value (default by 1).
std::vector< std::string > Arguments
std::string numstring(char n, int w=0)
std::optional< ScriptList > _scripts
std::ostream & dumpOn(std::ostream &str, const RpmPostTransCollector &obj)
Regular expression match result.
bool error(const std::string &msg_r)
bool hasPosttransScript(const Pathname &rpmPackage_r)
Dumpfile(Pathname dumpfile_r)
void discardScripts()
Discard all remembered scrips.
~RpmPostTransCollector()
Dtor.
bool _runposttrans
Set to false if rpm lost –runposttrans support during transaction.
void comment(const std::string &comment, bool timestamp=false)
Log a comment (even multiline).
Wrapper class for ::stat/::lstat.
bool regex_match(const std::string &s, smatch &matches, const regex ®ex)
regex ZYPP_STR_REGEX regex ZYPP_STR_REGEX
int runposttrans(const Pathname &filename_r, const std::function< void(const std::string &)> &output_r)
Run collected posttrans and transfiletrigger(postun|in) if rpm --runposttrans is supported.
scoped_ptr< filesystem::TmpDir > _ptrTmpdir
void name(const std::string &name_r)
Set counter name.
bool collectDumpPosttransLines(const std::vector< std::string > &runposttrans_r)
Return whether runposttrans lines were collected.
Pathname _dumpfile
The file holding the collected dump_posttrans: lines.
Easy-to use interface to the ZYPP dependency resolver.
bool headerHasPosttrans(const rpm::RpmHeader::constPtr &pkg_r) const
Return whether RpmHeader has a posttrans.
friend std::ostream & operator<<(std::ostream &str, const Impl &obj)
db_const_iterator dbConstIterator() const
UserDataJobReport _myJobReport
JobReport with ContentType "cmdout/%posttrans".
std::ostream & operator<<(std::ostream &str, const RpmPostTransCollector::Impl &obj)
boost::noncopyable NonCopyable
Ensure derived classes cannot be copied.
void collectPosttransInfo(const std::vector< std::string > &runposttrans_r)