followRequestProvider.cpp

Go to the documentation of this file.

#include "followRequestProvider.h"
 
defineStatic(followRequestProvider::mayDelete, '\0', "delete",
             "accept deletion requests", false);
defineStatic(followRequestProvider::nullDelimiter, '0', "null",
             "use NUL as delimiter", false);
 
 
followRequestProvider::followRequestProvider(decltype(requests) aRequests,
        decltype(delayedRequests) aDelayedRequests,
        decltype(parents) aParents,
        decltype(InputHandler) aInputHandler,
        decltype(OutputHandler) aOutputHandler):
    requestProvider(aRequests, aDelayedRequests, aParents,
                    aInputHandler, aOutputHandler) {
}
 
void followRequestProvider::processSources(const std::vector<std::string>& sources) {
    for (auto& source : sources) {
        if (source == "-") {
            followStream(std::cin);
        } else {
            std::ifstream stream(source);
            followStream(stream);
        }
    }
}
 
 
 
void followRequestProvider::handleMove(const std::string& srcPath,
                                       const std::string& dstPath,
                                       const std::string& fromPath,
                                       const std::string& origPath,
                                       const singleMap& mapEntry,
                                       copyRequest::clock_type::time_point timestamp) {
    enqueueOrAppend(srcPath, copyRequest::fileInWork::slotTypes::move, timestamp,
                    dstPath, fromPath, origPath, mapEntry);
}
 
void followRequestProvider::handleOther(const std::string& srcPath,
                                        const std::string& dstPath,
                                        const singleMap& mapEntry,
                                        copyRequest::clock_type::time_point timestamp,
                                        bool requestForRemoval) {
    if (mayDelete || !requestForRemoval) {
        enqueueOrAppend(srcPath,
                        requestForRemoval ? copyRequest::fileInWork::slotTypes::unlink :
                        copyRequest::fileInWork::slotTypes::copy,
                        timestamp,
                        dstPath, mapEntry, requestForRemoval);
    }
}