/[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.7 by joko, Fri Mar 28 07:02:56 2003 UTC revision 1.13 by joko, Fri Dec 5 05:02:08 2003 UTC
# Line 2  Line 2 
2  ##  $Id$  ##  $Id$
3  ## ----------------------------------------------------------------------  ## ----------------------------------------------------------------------
4  ##  $Log$  ##  $Log$
5    ##  Revision 1.13  2003/12/05 05:02:08  joko
6    ##  + minor update: disabled some unnecessary loggers or changed to debug-level
7    ##
8    ##  Revision 1.12  2003/06/24 20:59:51  jonen
9    ##  added option 'detach'
10    ##
11    ##  Revision 1.11  2003/06/23 17:54:32  joko
12    ##  prepared execution of in-process perl-code via eval (not activated yet!)
13    ##
14    ##  Revision 1.10  2003/05/13 07:56:12  joko
15    ##  enhanced: *hierarchical* containers for context handling
16    ##  fixes: some pre-flight checks
17    ##  new: propagate "end-tag" event to e.g. close containers
18    ##
19    ##  Revision 1.9  2003/04/04 17:23:11  joko
20    ##  minor update: debugging output
21    ##
22    ##  Revision 1.8  2003/03/29 07:11:54  joko
23    ##  modified: sub run_executable
24    ##  new: sub run_script
25    ##
26  ##  Revision 1.7  2003/03/28 07:02:56  joko  ##  Revision 1.7  2003/03/28 07:02:56  joko
27  ##  modified structure around '$wrapper_program'  ##  modified structure around '$wrapper_program'
28  ##  ##
# Line 41  use Iterate; Line 62  use Iterate;
62    
63  use shortcuts qw( run_cmd );  use shortcuts qw( run_cmd );
64  use Data::Mungle::Code::Ref qw( ref_slot );  use Data::Mungle::Code::Ref qw( ref_slot );
65  use Data::Mungle::Transform::Deep qw( expand );  use Data::Mungle::Transform::Deep qw( expand deep_copy );
66    use File::Temp qw/ tempfile tempdir /;
67    
68    my $DEBUG = 0;
69    
70  sub performTarget {  sub performTarget {
71    my $self = shift;    my $self = shift;
# Line 54  sub perform_target { Line 77  sub perform_target {
77    my $self = shift;    my $self = shift;
78    my $targetname = shift;    my $targetname = shift;
79    
80      # pre-flight checks
81      if (!$targetname) {
82        $self->log("Target name empty. Please try to specify (e.g.) on the command line.", 'critical');
83        return;
84      }
85    
86    my $header = ("- " x 12) . "   " . $targetname . "   " . ("- " x 6);    my $header = ("- " x 12) . "   " . $targetname . "   " . ("- " x 6);
87        
88      # V1
89    #$self->log("- " x 35, 'notice');    #$self->log("- " x 35, 'notice');
90    #$self->log("Performing Target '$targetname'.", 'notice');    #$self->log("Performing Target '$targetname'.", 'notice');
91    
92    $self->log($header, 'notice');    # V2
93      #$self->log($header, 'notice');
94    
95      # V3
96      #$self->log("- " x 20, 'info');
97      $self->log("Performing Target '$targetname'.", 'notice');
98    
99    #exit;    #exit;
100    
# Line 71  sub perform_target { Line 106  sub perform_target {
106            
107    $self->perform_dependencies($target);    $self->perform_dependencies($target);
108    $self->perform_details($target);    $self->perform_details($target);
109      
110      return 1;
111    
112  }  }
113    
# Line 102  sub perform_details { Line 139  sub perform_details {
139    foreach my $entry (@{$target->{content}}) {    foreach my $entry (@{$target->{content}}) {
140      my $command = $entry->{name};      my $command = $entry->{name};
141      my $args = $entry->{attrib};      my $args = $entry->{attrib};
142      $self->perform_command($command, $args);      my $content = $entry->{content};
143        $self->perform_command($command, $args, $content, { warn => 1 } );
144      # check recursiveness      # check recursiveness
145      if ($entry->{content} && ref $entry->{content}) {      # new condition: don't recurse if node is flagged to have inline-args (2003-04-17)
146        my $has_inline_args = ($entry->{attrib}->{_args} && $entry->{attrib}->{_args} eq 'inline');
147        if ($entry->{content} && ref $entry->{content} && !$has_inline_args) {
148        $self->perform_details($entry);        $self->perform_details($entry);
149      }      }
150        # new of 2003-05-08
151        $command ||= '';
152        $self->perform_command($command . '_end', undef, undef, { warn => 0 } );
153    }    }
154  }  }
155    
# Line 118  sub rc { Line 161  sub rc {
161  sub perform_command {  sub perform_command {
162    my $self = shift;    my $self = shift;
163    my $command = shift;    my $command = shift;
164      my $args_list = shift;
165      my $content = shift;
166      my $options = shift;
167    
168    if (!$command) {    if (!$command) {
169      $self->log("Command was empty!", 'debug');      $self->log("Command was empty!", 'debug') if $DEBUG;
170      return;      return;
171    }    }
172    
173    # FIXME: make '__PACKAGE__' go one level deeper properly!    # FIXME: make '__PACKAGE__' go one level deeper properly!
174    $self->log( __PACKAGE__ . "->perform_command: " . $command, 'debug');    $self->log( __PACKAGE__ . "->perform_command: " . $command, 'debug') if $DEBUG;
175        
176    my $args_list = shift;    
177      # 1. make arguments from list of arguments(?)
178    
179    my $args = {};    my $args = {};
180    #print Dumper($args_list);    #print Dumper($args_list);
181    if ($args_list) {    if ($args_list) {
# Line 139  sub perform_command { Line 187  sub perform_command {
187        $args = $args_list;        $args = $args_list;
188      }      }
189    }    }
   $command = '_' . $command;  
190        
191        
192    # determine container    # 2. prepare command
193      
194      # default setting for internal rap commands
195      my $method_prefix_default = '_';
196      # setting from property database
197      my $method_prefix_setting = $self->get_property('core.method_prefix');
198      #print "setting: ", $method_prefix_setting, "\n";
199      my $prefix = $method_prefix_setting;
200      if (not defined $prefix) {
201        $prefix = $method_prefix_default;
202      }
203      $command = $prefix . $command;
204      
205      
206      # 3. determine container
207    my $container; # = $self->getInstance();    my $container; # = $self->getInstance();
208      #$container ||= $self->getInstance();
209    $container ||= $self;    $container ||= $self;
210        
211      # 4. run method
212    if ($container->can($command)) {    if ($container->can($command)) {
213      $container->$command($args);      $container->$command($args, $content);
214    } else {    } else {
215      $self->log("Command '$command' not implemented.", "warning");      my $level = "debug";
216        $level = "warning" if $options->{warn};
217        $self->log("Command '$command' not implemented.", $level) if $DEBUG;
218    }    }
219        
220  }  }
# Line 213  sub set_property { Line 278  sub set_property {
278    
279    $self->log("set-name: $name");    $self->log("set-name: $name");
280    
281      #print Dumper($name, $value, '.');
282    
283    # fill property slot with given value    # fill property slot with given value
284    if ($value) {    # fix (2003-04-17): always do fill if value is *defined*!!!
285      if (defined $value) {
286      ref_slot($self, $name, $value, '.');      ref_slot($self, $name, $value, '.');
287    }    }
288        
# Line 273  sub get_property { Line 341  sub get_property {
341    
342      $name = '__rap.properties.' . $name;      $name = '__rap.properties.' . $name;
343            
344      $self->log("get-name: $name");      $self->log("get-name: $name") if $DEBUG;
345            
346      # get property slot and return value      # get property slot and return value
347      $result = ref_slot($self, $name, undef, '.');      $result = ref_slot($self, $name, undef, '.');
# Line 300  sub run_executable { Line 368  sub run_executable {
368    my $self = shift;    my $self = shift;
369    my $opts = shift;    my $opts = shift;
370    
371      my $meta = deep_copy($opts);
372    
373      delete $opts->{caption};
374      delete $opts->{async};
375      delete $opts->{detach};
376    
377      #print Dumper($meta);
378    
379    if ($opts->{executable}) {    if ($opts->{executable}) {
380    
381      my $program = $opts->{executable};      my $program = $opts->{executable};
# Line 355  sub run_executable { Line 431  sub run_executable {
431        #run_cmd($cmd);        #run_cmd($cmd);
432    
433        # V1.b - enhanced: variable local method        # V1.b - enhanced: variable local method
434        my $evalstr = "run_cmd('$cmd', 'Some task...', { async => 1 });";        $meta->{caption} ||= '';
435          $meta->{async} ||= 0;
436          $meta->{detach} ||= 0;
437          # new of 2003-05-08: USE_PATH!
438          $meta->{USE_PATH} ||= 0;
439          my $evalstr = "run_cmd('$cmd', '$meta->{caption}', { async => $meta->{async}, detach => $meta->{detach}, USE_PATH => $meta->{USE_PATH} });";
440        eval($evalstr);        eval($evalstr);
441        #my $res = do "$cmd";        #my $res = do "$cmd";
442        #print $res, "\n" if $res;        #print $res, "\n" if $res;
# Line 372  sub run_executable { Line 453  sub run_executable {
453  }  }
454    
455    
456    sub run_script {
457    
458      my $self = shift;
459      my $args = shift;
460      my $code = shift;
461    
462      if ($args->{language} eq 'msdos/bat') {
463        
464        #print "code: $code", "\n";
465        
466        # reporting
467        $self->log("Executing some arbitrary unsigned code (probably unsafe). [language=$args->{language}]", 'info');
468        $self->log("\n<code>\n$code\n</code>", 'info');
469        
470        # create temporary intermediate file to execute code
471        my $tmpdir = '/tmp/rap';
472        mkdir $tmpdir;
473        (my $fh, my $filename) = tempfile( DIR => $tmpdir, SUFFIX => '.bat' );
474        print $fh $code, "\n";
475        run_cmd( $filename, '', { async => 1 } );
476        
477        # FIXME: DELETE code inside temp-files as soon as possible!
478        #print $fh '';
479        
480        # TODO: delete FILE completely!
481        # required for this: wait until execution has finished, then unlink....
482        # but: "how to wait until execution is finished"?
483        # i believe the best is to spawn *another* process directly from here,
484        # let's call it 'watcher-agent'.
485        # This one should monitor a certain running process and delete its
486        # executable file after it has finished execution.
487        # Possible extensions could be:
488        #   keep track of all stuff sent to STDOUT or STDERR and
489        #   send that stuff to the task-owner indirectly (not via shell/console)
490        #   (e.g. via email, by posting report to a newsgroup or publishing on a specified web-page: use mod-dav!)
491        
492      } elsif ($args->{language} eq 'bash') {
493        $self->log("FIXME: - - - - - -- - - --  BASH -  - -    -  - -   -    --   - ", 'error');
494    
495      } elsif ($args->{language} eq 'perl') {
496        
497        # reporting
498        #$self->log("Executing some arbitrary unsigned code (probably unsafe). [language=$args->{language}]", 'info');
499        #$self->log("\n<code>\n$code\n</code>", 'info');
500        
501        # do it
502        #eval($code);
503        #$self->log("\n<code>\n$code\n</code>", 'error') if $@;
504        
505      } else {
506        $self->log("FIXME: Script language '$args->{language}' not implemented.", 'error');
507        
508      }
509    
510    }
511    
512  1;  1;
513  __END__  __END__
Legend:
Removed from v.1.7  
changed lines
  Added in v.1.13
MailToCvsAdmin">MailToCvsAdmin
 ViewVC Help
Powered by ViewVC 1.1.26 RSS 2.0 feed