policyRunRequestProvider.cpp

Go to the documentation of this file.

#include "policyRunRequestProvider.h"
#include "throwcall.h"
#include "escapism.h"
#include "timer.h"
#include <errMsgQueue.h>
 
defineStatic(policyRunRequestProvider::factory, "policyRun");
defineStatic(policyRunRequestProvider::escaperOption, *escapism::newEscaperOption("policyRunEscapeSchema",
             "schema used for escaping file names in policy run file"));
 
static void quietStatPrinter(std::ostream& aLogStream) {
    if (printStatAnyway) {
        copyRequest::base::printStats(aLogStream);
    }
}
void policyRunRequestProvider::processSource(const std::string& source) {
    static auto escaper = escapism::newEscaper(escaperOption);
    std::ifstream srcList(source);
    std::string line;
    while (std::getline(srcList, line)) {
        auto separatorStart = line.find(" -- ");
        if (separatorStart == std::string::npos) {
            continue;
        }
        auto pathStart = separatorStart + 4; // length of " -- "
        std::string src;
        escaper->deEscape(line.substr(pathStart), src);
        auto sourceStat = InputHandler->getStat(src, false); // never follow links
        if (!sourceStat) {
            if (ignoreMissing) {
                if (! quiet) {
                    errMsg::emit(errMsg::level::warning, errMsg::location(),
                                 src, "stat", "not found");
                }
                continue;
            }
            throw std::runtime_error("can't stat " + src);
        }
        if (sourceStat->isDir()) { // directories are created on the fly, ignore here
            continue;
        }
        std::string dst;
        auto mapEntry =  getDstPath(src, dst);
        timerInst(emplace);
        requestSet.emplace(new copyRequest::base(InputHandler, src, dst, sourceStat,
                           mapEntry,
                           false, copyRequest::clock_type::now()));
    }
    copyRequest::base::setStatPrinter(quietStatPrinter);
}