OEF/YAA/Jobs.pm

## -------------------------------------------------------------------------
##  $Id: Jobs.pm,v 1.2 2003/03/28 03:07:41 joko Exp $
## -------------------------------------------------------------------------
##  $Log: Jobs.pm,v $
##  Revision 1.2  2003/03/28 03:07:41  joko
##  minor fix: 'run_cmd' required here
##
##  Revision 1.1  2003/03/27 15:39:55  joko
##  initial commit, jobs -core and -api
##
## -------------------------------------------------------------------------


package OEF::YAA::Jobs;

use strict;
use warnings;

use base qw( DesignPattern::Object );
use base qw( OEF::API::Abstract );


#use Data::Dumper;
#use Data::Mungle::Transform::Deep qw( merge_to expand );
use shortcuts qw( run_cmd );

# get logger instance
my $logger = Log::Dispatch::Config->instance;


#my $bizWorks = $main::bizWorks;
my $bizProcess = $main::bizProcess;
#my $process = $main::bizProcess;

#print Dumper($bizProcess);
#push @{$process->{app}->{use_databases}}, 'control';
#my $boot = $main::boot;
#$boot->_bootDatabases();

#our ($logger, $bizWorks, $bizProcess, $process, $boot);

  # ==============================
  # api-method-declarations
  # ==============================
  # remote method declaration

  sub _api_init {
    my $self = shift;
    #return;
    my $procs = [
      {
        name => "getTaskList",
        version => "0.03",
        hidden => 0,
        code => \&getTaskList,
        signature => [
          'struct string',             # w/o session
          'struct string struct',    # session initialized (a struct containing a key 'RPCSESSID' will get propagated!)
        ],
        help => "",
        protected => 1,
      },
      {
        name => "getTaskInfo",
        version => "0.02",
        hidden => 0,
        code => \&getTaskInfo,
        signature => [ 'struct string' ],
        help => "",
        protected => 1,
      },
      {
        name => "runTask",
        version => "0.02",
        hidden => 0,
        code => \&runTask,
        signature => [ 'string string' ],
        help => "",
        protected => 1,
      },
    ];
    $self->register($procs);
  }  


  # ==============================
  # methods


  sub getTaskList {
    my $srv = shift;
    my $crit_key = shift;
    $crit_key ||= '';

    $logger->info( __PACKAGE__ . "->getTaskList( crit_key $crit_key )" );

    #print Dumper($bizProcess);

    my $file = $bizProcess->{app}->{storage}->{control}->{locator}->{files}->{jobs};

    # build xpath query database
      my $xpq_db = {
        'all-jobs-unfiltered' => '*/*',
      };
      my $crit_db = {
        'all-jobs' => '/*',
        'to-backend' => '@source="backend" and (@action="import" or @action="load")',
        'to-frontend' => '@target="frontend"',
      };
      $crit_db->{'about-import'} = "not ($crit_db->{'to-backend'} or $crit_db->{'to-frontend'})";

    # select xpath query by criteria
      my $xpq = '';
      if ($crit_key) {
        if ($xpq_db->{$crit_key}) {
          $xpq = $xpq_db->{$crit_key};
        } else {
          my $crit = $crit_db->{$crit_key};
          if ($crit) {
            $xpq = "*/target[*/*[$crit]]";
          }
        }
    }

    # issue the query
      my $mdbe = DesignPattern::Object->fromPackage('Data::Storage::Handler::XML', filename => $file );
      $mdbe->sendQuery($xpq);
      $mdbe->circumflex('result');  
      my $tasks = $mdbe->toSimpleTree();

    #print Dumper($tasks);

    return $tasks;
  }


  sub _getTaskByName {
    #my $self = shift;
    my $name = shift;

    #print "getTaskByName!!!!!", "\n";

    $logger->info( __PACKAGE__ . "->getTaskByName( name $name )" );

    my $file = $bizProcess->{app}->{storage}->{control}->{locator}->{files}->{jobs};

    # issue the query
      my $xpq = "*/target[\@name=\"$name\"]";
      my $mdbe = DesignPattern::Object->fromPackage('Data::Storage::Handler::XML', filename => $file );
      $mdbe->sendQuery($xpq);
      my $task = $mdbe->toSimpleTree();
    return $task;

  }

  sub getTaskInfo {
    my $self = shift;
    my $crit = shift;
    $crit ||= '';

    $logger->info( __PACKAGE__ . "->getTaskInfo( crit $crit )" );

    my $task = _getTaskByName($crit);
    #print Dumper($tasks);
    return $task;

    my $jobname = $task->{name};
    
    my $status = {
      metadata => { 
        description => $task->{description},
      },
      jobstatus => {
        running => $self->{_pcontrol}->{$jobname}->{running},
        locked => $self->{_pcontrol}->{$jobname}->{locked},
      },
    };

    return $status;
  }


  sub runTask {
    my $self = shift;
    my $crit = shift;
    $crit ||= '';

    $logger->info( __PACKAGE__ . "->runTask( crit $crit )" );

    #print "getTask - 1", "\n";
    my $task = _getTaskByName($crit);
    #print "getTask - 1.1", "\n";

    #print Dumper($task);

    # build command
      my $jobname = $task->{name};
      my $command = "rap.pl $jobname";
    
    # run
      # FIXME: what about asynchronous job execution?
      $self->{_pcontrol}->{$jobname}->{locked} = 1;
      $self->{_pcontrol}->{$jobname}->{running} = 1;

        run_cmd($command);

=pod
        #system($command);
        my $base = $bizProcess->{app}->{config}->{paths}->{base};
        $command = "$base/bin/$command";
        print "command: $command", "\n";
        my $in; my $out; my $err;
        #run $command, "", \$out, \$err or print "Could not execute $command.", "\n";
        #my $result = run $command, '>&' or print "Could not execute $command.", "\n";
        my $result = run $command, '2>&1' or print "Could not execute $command.", "\n";
        #print Dumper($in, $out, $err);
        print "result: $result", "\n";
=cut

      $self->{_pcontrol}->{$jobname}->{locked} = 0;
      $self->{_pcontrol}->{$jobname}->{running} = 0;

    return 1;
  }


1;
__END__
1	joko	1.1	## -------------------------------------------------------------------------
2	joko	1.3	## $Id: Jobs.pm,v 1.2 2003/03/28 03:07:41 joko Exp $
3	joko	1.1	## -------------------------------------------------------------------------
4	joko	1.2	## $Log: Jobs.pm,v $
5	joko	1.3	## Revision 1.2 2003/03/28 03:07:41 joko
6			## minor fix: 'run_cmd' required here
7			##
8	joko	1.2	## Revision 1.1 2003/03/27 15:39:55 joko
9			## initial commit, jobs -core and -api
10			##
11	joko	1.1	## -------------------------------------------------------------------------
12
13
14			package OEF::YAA::Jobs;
15
16			use strict;
17			use warnings;
18
19			use base qw( DesignPattern::Object );
20			use base qw( OEF::API::Abstract );
21
22
23			#use Data::Dumper;
24			#use Data::Mungle::Transform::Deep qw( merge_to expand );
25	joko	1.2	use shortcuts qw( run_cmd );
26	joko	1.1
27			# get logger instance
28			my $logger = Log::Dispatch::Config->instance;
29
30
31			#my $bizWorks = $main::bizWorks;
32			my $bizProcess = $main::bizProcess;
33			#my $process = $main::bizProcess;
34
35			#print Dumper($bizProcess);
36			#push @{$process->{app}->{use_databases}}, 'control';
37			#my $boot = $main::boot;
38			#$boot->_bootDatabases();
39
40			#our ($logger, $bizWorks, $bizProcess, $process, $boot);
41
42			# ==============================
43			# api-method-declarations
44			# ==============================
45			# remote method declaration
46
47			sub _api_init {
48			my $self = shift;
49			#return;
50			my $procs = [
51			{
52			name => "getTaskList",
53	joko	1.3	version => "0.03",
54	joko	1.1	hidden => 0,
55			code => \&getTaskList,
56	joko	1.3	signature => [
57			'struct string', # w/o session
58			'struct string struct', # session initialized (a struct containing a key 'RPCSESSID' will get propagated!)
59			],
60	joko	1.1	help => "",
61	joko	1.3	protected => 1,
62	joko	1.1	},
63			{
64			name => "getTaskInfo",
65			version => "0.02",
66			hidden => 0,
67			code => \&getTaskInfo,
68			signature => [ 'struct string' ],
69			help => "",
70	joko	1.3	protected => 1,
71	joko	1.1	},
72			{
73			name => "runTask",
74			version => "0.02",
75			hidden => 0,
76			code => \&runTask,
77			signature => [ 'string string' ],
78			help => "",
79	joko	1.3	protected => 1,
80	joko	1.1	},
81			];
82			$self->register($procs);
83			}
84
85
86			# ==============================
87			# methods
88
89
90			sub getTaskList {
91			my $srv = shift;
92			my $crit_key = shift;
93			$crit_key \|\|= '';
94
95			$logger->info( __PACKAGE__ . "->getTaskList( crit_key $crit_key )" );
96
97			#print Dumper($bizProcess);
98
99			my $file = $bizProcess->{app}->{storage}->{control}->{locator}->{files}->{jobs};
100
101			# build xpath query database
102			my $xpq_db = {
103			'all-jobs-unfiltered' => '/',
104			};
105			my $crit_db = {
106			'all-jobs' => '/*',
107			'to-backend' => '@source="backend" and (@action="import" or @action="load")',
108			'to-frontend' => '@target="frontend"',
109			};
110			$crit_db->{'about-import'} = "not ($crit_db->{'to-backend'} or $crit_db->{'to-frontend'})";
111
112			# select xpath query by criteria
113			my $xpq = '';
114			if ($crit_key) {
115			if ($xpq_db->{$crit_key}) {
116			$xpq = $xpq_db->{$crit_key};
117			} else {
118			my $crit = $crit_db->{$crit_key};
119			if ($crit) {
120			$xpq = "/target[/*[$crit]]";
121			}
122			}
123			}
124
125			# issue the query
126			my $mdbe = DesignPattern::Object->fromPackage('Data::Storage::Handler::XML', filename => $file );
127			$mdbe->sendQuery($xpq);
128			$mdbe->circumflex('result');
129			my $tasks = $mdbe->toSimpleTree();
130
131			#print Dumper($tasks);
132
133			return $tasks;
134			}
135
136
137			sub _getTaskByName {
138			#my $self = shift;
139			my $name = shift;
140
141			#print "getTaskByName!!!!!", "\n";
142
143			$logger->info( __PACKAGE__ . "->getTaskByName( name $name )" );
144
145			my $file = $bizProcess->{app}->{storage}->{control}->{locator}->{files}->{jobs};
146
147			# issue the query
148			my $xpq = "*/target[\@name=\"$name\"]";
149			my $mdbe = DesignPattern::Object->fromPackage('Data::Storage::Handler::XML', filename => $file );
150			$mdbe->sendQuery($xpq);
151			my $task = $mdbe->toSimpleTree();
152			return $task;
153
154			}
155
156			sub getTaskInfo {
157			my $self = shift;
158			my $crit = shift;
159			$crit \|\|= '';
160
161			$logger->info( __PACKAGE__ . "->getTaskInfo( crit $crit )" );
162
163			my $task = _getTaskByName($crit);
164			#print Dumper($tasks);
165			return $task;
166
167			my $jobname = $task->{name};
168
169			my $status = {
170			metadata => {
171			description => $task->{description},
172			},
173			jobstatus => {
174			running => $self->{_pcontrol}->{$jobname}->{running},
175			locked => $self->{_pcontrol}->{$jobname}->{locked},
176			},
177			};
178
179			return $status;
180			}
181
182
183			sub runTask {
184			my $self = shift;
185			my $crit = shift;
186			$crit \|\|= '';
187
188			$logger->info( __PACKAGE__ . "->runTask( crit $crit )" );
189
190			#print "getTask - 1", "\n";
191			my $task = _getTaskByName($crit);
192			#print "getTask - 1.1", "\n";
193
194			#print Dumper($task);
195
196			# build command
197			my $jobname = $task->{name};
198			my $command = "rap.pl $jobname";
199
200			# run
201			# FIXME: what about asynchronous job execution?
202			$self->{_pcontrol}->{$jobname}->{locked} = 1;
203			$self->{_pcontrol}->{$jobname}->{running} = 1;
204
205			run_cmd($command);
206
207			=pod
208			#system($command);
209			my $base = $bizProcess->{app}->{config}->{paths}->{base};
210			$command = "$base/bin/$command";
211			print "command: $command", "\n";
212			my $in; my $out; my $err;
213			#run $command, "", \$out, \$err or print "Could not execute $command.", "\n";
214			#my $result = run $command, '>&' or print "Could not execute $command.", "\n";
215			my $result = run $command, '2>&1' or print "Could not execute $command.", "\n";
216			#print Dumper($in, $out, $err);
217			print "result: $result", "\n";
218			=cut
219
220			$self->{_pcontrol}->{$jobname}->{locked} = 0;
221			$self->{_pcontrol}->{$jobname}->{running} = 0;
222
223			return 1;
224			}
225
226
227
228
229			1;
230			__END__
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26