blob: c32a3c571fee66c59611a629ad80c6c3e9d2a85c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
#include "change_tracker.h"
#include <boost/optional.hpp>
#include <boost/filesystem/fstream.hpp>
namespace {
// constants for increasing pair access readability
constexpr unsigned int EMPLACE_SUCCESS = 1;
constexpr unsigned int FILE_PATH = 0;
constexpr unsigned int FILE_CONTENT = 1;
boost::process::context getDefaultContext() {
boost::process::context context;
context.environment = boost::process::self::get_environment();
context.stdout_behavior = boost::process::capture_stream();
context.stdin_behavior = boost::process::capture_stream();
return context;
}
// Build `diff` command to be used to display the tracked changes in a
// human readable fashion.
//
// As the original file contents are read by this library and forwarded
// to `diff` via its standard input the command has to be structured as
// follows:
//
// diff -u --label $file_path - $file_path
//
std::string getDiffCommand(
const std::string& diff_cmd, const std::string& full_path) {
return diff_cmd + " --label " + full_path + " - " + full_path;
}
}
namespace tracking {
ChangeTracker::ChangeTracker(utility::Logger* logger, const std::string& diff_cmd):
diff_cmd_(diff_cmd),
logger_(logger),
children_() { }
ChangeTracker::ChangeTracker(utility::Logger* logger):
ChangeTracker(logger, "diff -u") { }
ChangeTracker::~ChangeTracker() {
for ( auto&& tracked : this->children_ ) {
const auto& tracked_path = std::get<FILE_PATH>(tracked);
if ( boost::filesystem::exists(tracked_path) ) {
boost::process::child diffProcess{
boost::process::launch_shell(
getDiffCommand(this->diff_cmd_, tracked_path),
getDefaultContext()
)
};
diffProcess.get_stdin() << std::get<FILE_CONTENT>(tracked)->rdbuf();
diffProcess.get_stdin().close();
this->logger_->forward(diffProcess.get_stdout());
diffProcess.wait();
}
}
}
bool ChangeTracker::is_tracked(const std::string& file_path) const {
return this->children_.find(
boost::filesystem::canonical(file_path).string()
) != this->children_.end();
}
// Begins tracking changes to a file reachable by a given path
//
// _Tracking_ consists of adding the full file path to the `children_`
// map and reading the full pre-change file contents into the mapped
// `std::stringstream` instance.
//
// This seems to be the most workable of various tested approaches
// to providing `diff` with proper input in all circumstances. Leaving
// the intermediate preservation of the original file content to
// `diff` sadly failed randomly as it is _too intelligent_ in actually
// reading the file from permanent storage. e.g. it opens all relevant
// file descriptors at launch and only reads the first block of the
// file contents until more is required. This leads to problems when
// the tracked file is modified after `diff` has been spawned.
//
bool ChangeTracker::track(const std::string& file_path) {
const std::string full_file_path{
boost::filesystem::canonical(file_path).string()
};
std::unique_lock<std::mutex> guard(this->write_mutex_);
auto result = this->children_.emplace(
full_file_path,
std::make_unique<std::stringstream>()
);
guard.unlock();
if ( std::get<EMPLACE_SUCCESS>(result) ) {
boost::filesystem::ifstream file(
std::get<FILE_PATH>(*result.first)
);
if ( file.is_open() ) {
*std::get<FILE_CONTENT>(*result.first) << file.rdbuf();
std::get<FILE_CONTENT>(*result.first)->sync();
}
return true;
} else {
return false;
}
}
}
|
