3 use DX::Lib::FS::Observation::PathStatus;
4 use DX::Lib::FS::Observation::EnvDir;
5 use DX::Lib::FS::Action::CreateDirectory;
6 use DX::Lib::FS::Action::CreateFile;
7 use DX::Lib::FS::Action::SetPathMode;
8 use DX::Lib::FS::Observation::FileContent;
9 use DX::Lib::FS::Action::RewriteFile;
15 [ path_status => [ qw(PS) ],
16 [ member_of => 'PS', \'path_status' ] ],
18 [ _path_status_at => [ qw(PS P) ],
19 [ path_status => 'PS' ],
20 [ prop => PS => \'path' => 'P' ] ],
22 [ path_status_at => [ qw(PS P) ],
23 [ _path_status_at => qw(PS P) ],
26 [ path_status_at => [ 'PS', 'P' ],
27 [ observe => [ 'P' ], sub {
28 DX::Lib::FS::Observation::PathStatus->new(
32 [ _path_status_at => qw(PS P) ] ],
34 [ ps_prop => [ 'P', 'Name', 'Value' ],
35 [ path_status_at => qw(PS P) ],
36 [ prop => qw(PS Name Value) ] ],
38 [ ps_info_prop => [ 'P', 'Name', 'Value' ],
39 [ ps_prop => 'P', \'info', 'PSI' ],
40 [ prop => 'PSI', 'Name', 'Value' ] ],
42 [ exists_path => [ qw(P) ],
43 [ ps_prop => 'P' => \'info' => 'PSI' ] ],
45 [ _is_directory => [ qw(P) ],
46 [ ps_info_prop => 'P' => \'is_directory' => \1 ] ],
48 [ is_directory => [ qw(P) ],
49 [ _is_directory => 'P' ] ],
51 [ _is_file => [ qw(P) ],
52 [ ps_info_prop => 'P' => \'is_file' => \1 ] ],
54 [ is_file => [ qw(P) ],
55 [ _is_file => 'P' ] ],
57 [ _mode => [ qw(P M) ],
58 [ ps_info_prop => 'P' => \'mode' => 'M' ] ],
60 [ mode => [ qw(P M) ],
61 [ _mode => qw(P M) ] ],
63 [ is_directory => [ 'Path' ],
64 [ not => [ _is_directory => 'Path' ] ],
65 [ act => [ 'Path' ], sub {
66 DX::Lib::FS::Action::CreateDirectory->new(
70 [ _is_directory => 'Path' ] ],
72 [ is_file => [ 'Path' ],
73 [ not => [ _is_file => 'Path' ] ],
74 [ act => [ 'Path' ], sub {
75 DX::Lib::FS::Action::CreateFile->new(
79 [ _is_file => 'Path' ] ],
81 [ _action_is_creating => [ qw(A) ],
82 [ does => 'A', \'DX::Lib::FS::Action::CreateDirectory' ] ],
84 [ _action_is_creating => [ qw(A) ],
85 [ does => 'A', \'DX::Lib::FS::Action::CreateFile' ] ],
87 [ mode => [ qw(P M) ],
88 [ path_status_at => qw(PS P) ],
89 [ has_action => qw(PS A) ],
90 [ _action_is_creating => 'A' ],
91 [ react => [ qw(PS M) ], sub {
92 $_[0]->but(mode => $_[1]);
96 [ mode => [ qw(P M) ],
97 [ path_status_at => qw(PS P) ],
98 [ not => [ _mode => qw(P M) ] ],
99 [ act => [ qw(PS M) ], sub {
100 DX::Lib::FS::Action::SetPathMode->new(
101 path_status => $_[0], mode => $_[1]
106 [ file_content => [ qw(FC) ],
107 [ member_of => 'FC', \'file_content' ] ],
109 [ _file_content_at => [ qw(FC P) ],
110 [ file_content => 'FC' ],
111 [ prop => 'FC', \'path', 'P' ] ],
113 [ file_content_at => [ qw(FC P) ],
114 [ _file_content_at => qw(FC P) ],
117 [ file_content_at => [ qw(FC P) ],
119 [ observe => [ 'P' ], sub {
120 DX::Lib::FS::Observation::FileContent->new(
124 [ _file_content_at => qw(FC P) ] ],
126 [ fc_prop => [ qw(P Name Value) ],
127 [ file_content_at => qw(FC P) ],
128 [ prop => qw(FC Name Value) ] ],
130 [ file_data => [ qw(P D) ], [ fc_prop => 'P', \'data', 'D' ] ],
132 [ _contains_line => [ qw(P L) ],
134 [ fc_prop => 'P', \'lines', 'Lines' ],
135 [ member_of => qw(L Lines) ] ],
137 [ contains_line => [ qw(P L) ],
138 [ _contains_line => qw(P L) ] ],
140 [ _action_modifying_fc => [ 'A' ],
141 [ does => 'A' => \'DX::Lib::FS::Action::CreateFile' ] ],
143 [ _action_modifying_fc => [ 'A' ],
144 [ does => 'A' => \'DX::Lib::FS::Action::RewriteFile' ] ],
146 [ contains_line => [ qw(P L) ],
147 [ not => [ _contains_line => qw(P L) ] ],
148 [ file_content_at => qw(FC P) ],
149 [ has_action => qw(FC A) ],
150 [ _action_modifying_fc => 'A' ],
151 [ react => [ qw(FC L) ], sub {
152 $_[0]->but_add($_[1])
156 [ contains_line => [ qw(P L) ],
157 [ not => [ _contains_line => qw(P L) ] ],
158 [ file_content_at => qw(FC P) ],
159 [ act => [ qw(FC L) ], sub {
160 DX::Lib::FS::Action::RewriteFile->new(
165 [ not_contains_line => [ qw(P L) ],
166 [ not => [ _contains_line => qw(P L) ] ] ],
168 [ _arrange_removal_of => [ qw(FC L) ],
169 [ has_action => qw(FC A) ],
170 [ does => 'A' => \'DX::Lib::FS::Action::RewriteFile' ],
171 [ react => [ qw(FC L) ], sub { $_[0]->but_remove($_[1]) } ] ],
173 [ _arrange_removal_of => [ qw(FC L) ],
174 [ act => [ qw(FC L) ], sub {
175 DX::Lib::FS::Action::RewriteFile->new(
177 )->but_remove($_[1]);
180 [ not_contains_line => [ qw(P L) ],
181 [ _contains_line => qw(P L) ],
182 [ file_content_at => qw(FC P) ],
183 [ _arrange_removal_of => qw(FC L) ],
186 [ file_in => [ qw(DirPath FileName FilePath) ],
187 [ catfile => qw(DirPath FileName FilePath) ],
188 [ is_directory => 'DirPath' ],
189 [ is_file => 'FilePath' ] ],
191 [ directory_in => [ qw(DirPath DirName SubdirPath) ],
192 [ catfile => qw(DirPath DirName SubdirPath) ],
193 [ is_directory => 'DirPath' ],
194 [ is_directory => 'SubdirPath' ] ],
196 [ env_dir => [ qw(ED) ],
197 [ member_of => 'ED', \'env_dir' ] ],
199 [ _env_dir_at => [ qw(ED P) ],
201 [ prop => ED => \'path' => 'P' ] ],
203 [ env_dir_at => [ qw(ED P) ],
204 [ _env_dir_at => qw(ED P) ],
207 [ env_dir_at => [ 'ED', 'P' ],
208 [ observe => [ 'P' ], sub {
209 DX::Lib::FS::Observation::EnvDir->new(
213 [ _env_dir_at => qw(ED P) ] ],
215 [ home_dir_on => [ qw(A D) ],
216 [ path_on => 'A', \'HOME', 'P' ],
217 [ env_dir_at => ED => 'P' ],
218 [ prop => ED => \'value' => 'H' ],
219 [ path_on => 'A', 'H', 'D' ] ],
223 my ($self, $solver) = @_;
224 $solver->facts->{path_status} = DX::SetOver->new(over => 'path');
225 $solver->facts->{file_content} = DX::SetOver->new(over => 'path');
226 $solver->facts->{env_dir} = DX::SetOver->new(over => 'path');
227 $solver->add_predicate(
228 catdir => [ qw(DirPath DirName SubDirPath) ],
229 [ qw(+ + -) ] => sub {
231 value => File::Spec->catdir($_{DirPath}, $_{DirName})
234 [ qw(- - +) ] => sub {
235 my @split = File::Spec->splitdir($_{SubDirPath});
236 my $last = pop @split;
237 my $rest = File::Spec->catdir(@split);
238 +(DirPath => [ value => $rest ], DirName => [ value => $last ])
241 $solver->add_predicate(
242 catfile => [ qw(DirPath FileName FilePath) ],
243 [ qw(+ + -) ] => sub {
244 my ($vol, $dir) = File::Spec->splitpath($_{DirPath}, 1);
245 my $file_path = File::Spec->catpath($vol, $dir, $_{FileName});
246 +(FilePath => [ value => $file_path ])
248 [ qw(- - +) ] => sub {
249 my ($vol, $dir, $file) = File::Spec->splitpath($_{FilePath});
250 my $dir_path = File::Spec->catpath($vol, $dir);
251 +(DirPath => [ value => $dir_path ], FileName => [ value => $file ])
254 $solver->add_predicate(
255 path_on => [ qw(On Path FullPath) ],
256 [ qw(+ + -) ] => sub {
257 (my $path = $_{Path}) =~ s/^(:!\/)/.\//;
258 if ($_{On} eq '' or $_{On} eq 'localhost') {
259 (FullPath => [ value => $path ])
261 (FullPath => [ value => join(':', $_{On}, $path) ])
264 [ qw(- - +) ] => sub {
265 if (my ($on, $path) = $_{FullPath} =~ /^([^\/]+):(.*)$/) {
266 (On => [ value => $on ], Path => [ value => $path ]);
268 (On => [ value => 'localhost' ], Path => [ value => $_{FullPath} ]);
273 does => [ qw(Thing RoleName) ],
274 [ constrain => [ qw(Thing RoleName) ], sub { $_[0]->DOES($_[1]) } ]
276 $solver->add_rule(@$_) for @RULES;