/[cvs]/nfo/perl/libs/Data/Rap/Engine.pm
ViewVC logotype

Diff of /nfo/perl/libs/Data/Rap/Engine.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 1.1 by joko, Tue Feb 18 15:35:25 2003 UTC revision 1.5 by joko, Thu Mar 27 15:03:03 2003 UTC
# Line 2  Line 2 
2  ##  $Id$  ##  $Id$
3  ## ----------------------------------------------------------------------  ## ----------------------------------------------------------------------
4  ##  $Log$  ##  $Log$
5    ##  Revision 1.5  2003/03/27 15:03:03  joko
6    ##  enhanced 'sub run_executable'
7    ##
8    ##  Revision 1.4  2003/02/22 16:51:21  joko
9    ##  + enhanced run_executable
10    ##  modified logging output
11    ##
12    ##  Revision 1.3  2003/02/21 01:46:17  joko
13    ##  renamed core function
14    ##
15    ##  Revision 1.2  2003/02/20 19:46:33  joko
16    ##  renamed and revamped some of modules
17    ##  renamed methods
18    ##  + sub run_executable
19    ##
20  ##  Revision 1.1  2003/02/18 15:35:25  joko  ##  Revision 1.1  2003/02/18 15:35:25  joko
21  ##  + initial commit  ##  + initial commit
22  ##  ##
# Line 15  use warnings; Line 30  use warnings;
30    
31    
32  use Data::Dumper;  use Data::Dumper;
 use Data::Transform::Deep qw( refexpr2perlref );  
 use Iterate;  
33  use Hash::Merge qw( merge );  use Hash::Merge qw( merge );
34    use Iterate;
35    
36    use shortcuts qw( run_cmd );
37    use Data::Code::Ref qw( ref_slot );
38    use Data::Transform::Deep qw( expand );
39    
40    
41  sub performTarget {  sub performTarget {
42    my $self = shift;    my $self = shift;
43    my $targetname = shift;    my $targetname = shift;
44    my $target = $self->getTargetMetadata($targetname);    $self->perform_target($targetname);
45    }
46    
47    sub perform_target {
48      my $self = shift;
49      my $targetname = shift;
50    
51      my $header = ("- " x 12) . "   " . $targetname . "   " . ("- " x 6);
52      
53      #$self->log("- " x 35, 'notice');
54      #$self->log("Performing Target '$targetname'.", 'notice');
55    
56      $self->log($header, 'notice');
57    
58      #exit;
59    
60      my $target = $self->getTargetDetails($targetname);
61    
62    # trace    # trace
63      #print Dumper($target);      #print Dumper($target);
64      #exit;      #exit;
65            
66      $self->perform_dependencies($target);
67      $self->perform_details($target);
68    
69    }
70    
71    sub perform_dependencies {
72      my $self = shift;
73      my $target = shift;
74    # resolve dependencies (just run prior)    # resolve dependencies (just run prior)
75    if (my $targetname_dep = $target->{attrib}->{depends}) {    if (my $targetname_dep = $target->{attrib}->{depends}) {
76      $self->performTarget($targetname_dep);      my @targets = split(/,\s|,/, $targetname_dep);
77        #print Dumper(@targets);
78        #$self->perform($targetname_dep);
79        #delete $target->{attrib}->{depends};
80        foreach (@targets) {
81          if (!$self->{__rap}->{dependencies}->{resolved}->{$_}++) {
82            $self->perform_target($_);
83          }
84        }
85      delete $target->{attrib}->{depends};      delete $target->{attrib}->{depends};
86    }    }
87    }
88    
89    sub perform_details {
90      my $self = shift;
91      my $target = shift;
92      
93      #print Dumper($target);
94      #exit;
95      
96    foreach my $entry (@{$target->{content}}) {    foreach my $entry (@{$target->{content}}) {
97      my $command = $entry->{name};      my $command = $entry->{name};
98      my $args = $entry->{attrib};      my $args = $entry->{attrib};
99      $self->run_command($command, $args);      $self->perform_command($command, $args);
100        # check recursiveness
101        if ($entry->{content} && ref $entry->{content}) {
102          $self->perform_details($entry);
103        }
104    }    }
105  }  }
106    
107  sub rc {  sub rc {
108    my $self = shift;    my $self = shift;
109    return $self->run_command(@_);    return $self->perform_command(@_);
110  }  }
111    
112  sub run_command {  sub perform_command {
113    my $self = shift;    my $self = shift;
114    my $command = shift;    my $command = shift;
115      
116    if (!$command) {    if (!$command) {
117      $self->log("Command was empty!", 'warning');      $self->log("Command was empty!", 'debug');
118      return;      return;
119    }    }
120    
121      # FIXME: make '__PACKAGE__' go one level deeper properly!
122      $self->log( __PACKAGE__ . "->perform_command: " . $command, 'debug');
123        
124    my $args_list = shift;    my $args_list = shift;
125    my $args = {};    my $args = {};
# Line 69  sub run_command { Line 134  sub run_command {
134      }      }
135    }    }
136    $command = '_' . $command;    $command = '_' . $command;
137    if ($self->can($command)) {    
138      $self->$command($args);    
139      # determine container
140      my $container; # = $self->getInstance();
141      $container ||= $self;
142      
143      if ($container->can($command)) {
144        $container->$command($args);
145    } else {    } else {
146      $self->log("Command \"$command\" not implemented.", "warning");      $self->log("Command '$command' not implemented.", "warning");
147    }    }
148      
149  }  }
150    
 sub set_property {  
   my $self = shift;  
   my $args = shift;  
151    
152    my $name;  sub merge_properties {
153    my $value;    my $self = shift;
154        my $name = shift;
155    if (ref $args) {    my $data = shift;
     $self->interpolate($args) ;  
     $name = $args->{name};  
     $value = $args->{value};  
156    
157    } else {    $self->log("merge-name: $name");
158      $name = $args;    #print "name: $name", "\n";
159      $value = shift;    #print Dumper($data);
160    }    #exit;
161    
162    # check if slot (or childs of it) is/are already occupied    # check if slot (or childs of it) is/are already occupied
163    if (my $oldvalue = refexpr2perlref($self, $name, undef, '.')) {    #if (my $data_old = ref_slot($self, $name, undef, '.')) {
164      if (my $data_old = $self->get_property($name)) {
165        #print "old:", "\n";
166        #print Dumper($data_old);
167        
168      # FIXME: review - any options for 'merge' here?      # FIXME: review - any options for 'merge' here?
169      $value = merge($oldvalue, $value);      my $data_new = merge($data_old, $data);
170        #print "DATA NEE! - MERGE!", "\n";
171        #print Dumper($data_new);
172        #exit;
173        #merge_to($self, $data_new);
174        $self->set_property( { name => $name, value => $data_new } );
175        
176      } else {
177    
178    =pod    
179        # make up a dummy hash matching the structure of the destination one
180          my $dummy = {};
181          ref_slot($dummy, $name, $data, '.');
182          print Dumper($dummy);
183        
184        # mix into destination
185          mixin($self, $dummy, { init => 1 });
186    =cut
187    
188          ref_slot($self, $name, $data, '.');
189    
190    }    }
191      
192      
193      #print Dumper($self);
194      #exit;
195      #$self->
196    
197    }
198    
199    sub set_property {
200      my $self = shift;
201      my $args = shift;
202    
203      $self->interpolate($args) ;
204      my $name = $args->{name};
205      my $value = $args->{value};
206      $name = '__rap.properties.' . $name;
207    
208      $self->log("set-name: $name");
209    
210    # fill property slot with given value    # fill property slot with given value
211    if ($value) {    if ($value) {
212      refexpr2perlref($self, $name, $value, '.');      ref_slot($self, $name, $value, '.');
213    }    }
214        
215      #print Dumper($self);
216      
217    # FIXME!!!    # FIXME!!!
218    return if ! ref $args;    #return if ! ref $args;
219    
220    # fill property slot with (probably bigger) data structure from property-/configuration-style - file    # fill property slot with (probably bigger) data structure from property-/configuration-style - file
221    if (my $file = $args->{file}) {    if (my $file = $args->{file}) {
# Line 123  sub set_property { Line 233  sub set_property {
233      }      }
234    
235    } elsif (my $command = $args->{command}) {    } elsif (my $command = $args->{command}) {
236      $self->run_command($command, $args);      $self->perform_command($command, $args);
237        
238    }    }
239    
# Line 137  sub get_property { Line 247  sub get_property {
247    #$self->interpolate($args);    #$self->interpolate($args);
248    
249    #my $name = $args->{name};    #my $name = $args->{name};
250      my $result;
251    
252      if (!$name) {
253        $self->log( __PACKAGE__ . ": no name!", 'critical');
254        
255      } elsif ($name eq '/') {
256        $result = expand($self);
257    
258      } elsif ($name eq '.') {
259        if (my $instance = $self->getInstance()) {
260          $result = expand($instance);
261        } else {
262          $result = ref_slot($self, '__rap.properties', undef, '.');
263          
264        }
265    
266      } else {
267    
268    # get property slot and return value      $name = '__rap.properties.' . $name;
269    return refexpr2perlref($self, $name, undef, '.');      
270        $self->log("get-name: $name");
271        
272        # get property slot and return value
273        $result = ref_slot($self, $name, undef, '.');
274        
275        # FIXME: Is this okay? It's provided for now in order not
276        # to deliver an 'undef' to the regex below inside 'interpolate'.
277        # revamp this, maybe!
278        #$result ||= '';    # NO!!!
279      }
280        
281      return $result;
282  }  }
283    
284  sub interpolate {  sub interpolate {
# Line 152  sub interpolate { Line 290  sub interpolate {
290    }    }
291  }  }
292    
293    sub run_executable {
294      my $self = shift;
295      my $opts = shift;
296    
297      if ($opts->{executable}) {
298    
299        my $program = $opts->{executable};
300        delete $opts->{executable};
301    
302        # determine execution method
303        my $method = 'run_cmd';
304        my $wrapper_program = '';
305        
306        # check if program is a namespace-string (contains '::') - use 'do' in this case!
307        if ($program =~ /::/) {
308        #if ($program =~ s/::/\\/g) {
309          #$program = '.\\' . $program;
310          #$method = 'require';
311          #do "$program";
312          #return;
313          #$method = 'rap.';
314          
315          $wrapper_program = 'rap.pl';
316          
317        }
318    
319        # prepare arguments
320        my @buf;
321        foreach (keys %$opts) {
322          my $value = $opts->{$_};
323          if (m/^_/) {
324            if ($_ eq '_switches') {
325              my @switches = split(/,\s|,/, $value);
326              foreach my $switch (@switches) {
327                push @buf, '--' . $switch;
328              }
329            }
330            next;
331          }
332          
333          if ($value =~ /\s/) {
334            $value = "\"$value\"";
335          }
336          push @buf, "--$_=$value";
337        }
338    
339        # build {program} & {arguments}  
340        my $cmd = join(' ', $wrapper_program, $program) . ' ' . join(' ', @buf);
341        
342        # trace
343          #print "command: $cmd", "\n";
344        
345        # start process
346          # V1: via shortcut
347          #$ENV{PERL5LIB} = join(' ', @INC);
348          
349          # FIXME!!! what about the other slots of @INC?
350          $ENV{PERL5LIB} = $INC[0];
351          
352          #print Dumper(%ENV);
353          
354          print "command: '$cmd'", "\n";
355    
356          # V1 - basic
357          #run_cmd($cmd);
358    
359          # V1.b - enhanced: variable local method
360          my $evalstr = "$method('$cmd');";
361          eval($evalstr);
362          #my $res = do "$cmd";
363          #print $res, "\n" if $res;
364    
365          #$self->log("run_executable: $evalstr", 'info');
366          $self->raiseException("run_executable: $evalstr\n$@") if $@;
367    
368          # V2: via IPC::Run
369          # ....  (TODO)
370        
371        
372      }
373      
374    }
375    
376    
377  1;  1;
378  __END__  __END__
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.5
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed