1 |
## ---------------------------------------------------------------------- |
2 |
## $Id: Process.pm,v 1.3 2003/06/06 03:14:16 joko Exp $ |
3 |
## ---------------------------------------------------------------------- |
4 |
## $Log: Process.pm,v $ |
5 |
## Revision 1.3 2003/06/06 03:14:16 joko |
6 |
## enhanced database connection bootstrapping: |
7 |
## - boot default ones |
8 |
## - boot-on-demand |
9 |
## - protection for multiple redundant connections |
10 |
## |
11 |
## Revision 1.2 2003/03/27 15:43:05 joko |
12 |
## minor fix: new comment/remark |
13 |
## |
14 |
## Revision 1.1 2003/02/20 18:41:48 joko |
15 |
## + initial commit |
16 |
## |
17 |
## ---------------------------------------------------------------------- |
18 |
|
19 |
|
20 |
=pod |
21 |
|
22 |
This could also be called App::Component, App::Bean or whatever. |
23 |
Since it conducts various things of the OEF framework, |
24 |
it should probably be better renamed to OEF::App::Xyz, hmmm!? |
25 |
OEF::App::Bean? OEF::App::Bimbo? Yakka and Bimbo... |
26 |
|
27 |
=cut |
28 |
|
29 |
|
30 |
package App::Process; |
31 |
|
32 |
use strict; |
33 |
use warnings; |
34 |
|
35 |
use base qw( |
36 |
DesignPattern::Object |
37 |
DesignPattern::Logger |
38 |
); |
39 |
|
40 |
use Data::Dumper; |
41 |
|
42 |
use shortcuts qw( now ); |
43 |
|
44 |
|
45 |
# --------------------------------------------------- main ------------ |
46 |
DesignPattern::Object->log_basic("Package " . __PACKAGE__ . " loaded."); |
47 |
|
48 |
|
49 |
sub constructor { |
50 |
my $self = shift; |
51 |
|
52 |
$self->log( __PACKAGE__ . "->constructor", 'info'); |
53 |
#$self->log( "INIT", 'info'); |
54 |
|
55 |
# trace |
56 |
#print Dumper($self); |
57 |
#exit; |
58 |
|
59 |
# just boot database called "oefcore" |
60 |
# TODO: REVIEW: just boot if not booted yet..... |
61 |
# FIXME: this is hardcoded! |
62 |
#$self->{boot} = BizWorks::Boot->new( use_databases => [qw( oefcore )] ); |
63 |
#$self->{app}->{use_databases} =|| [qw( oefcore )]; |
64 |
$self->_bootDatabases(); |
65 |
|
66 |
# if no "guid" is given .... |
67 |
if (!$self->{guid}) { |
68 |
|
69 |
# ... create fresh task-object, ... |
70 |
$self->{TASK} = Task->new( |
71 |
stamp => now(), |
72 |
#context => , |
73 |
); |
74 |
$self->{app}->{storage}->{oefcore}->insert($self->{TASK}); |
75 |
|
76 |
=pod |
77 |
# ... create fresh report-object, ... |
78 |
$self->{REPORT} = Report->new( |
79 |
stamp => now(), |
80 |
#context => , |
81 |
); |
82 |
$self->{app}->{storage}->{oefcore}->insert($self->{REPORT}); |
83 |
|
84 |
# ... link them together |
85 |
=cut |
86 |
|
87 |
# ... and (finally) assign the Task's GUID to an object attribute here |
88 |
$self->{guid} = $self->{TASK}->{guid}; |
89 |
|
90 |
} else { |
91 |
|
92 |
# load context from (resumed) task |
93 |
# FIXME: move this to OEF::Component::Task::Persistable |
94 |
my $task = $self->{app}->{storage}->{oefcore}->getObjectByGuid($self->{guid}, { classname => 'Task' }); |
95 |
$self->{_context_raw} = $task->{context}; |
96 |
|
97 |
} |
98 |
|
99 |
|
100 |
} |
101 |
|
102 |
|
103 |
sub _check { |
104 |
my $self = shift; |
105 |
if (!$self->getGuid()) { |
106 |
return 1; |
107 |
} |
108 |
} |
109 |
|
110 |
sub perform { |
111 |
my $self = shift; |
112 |
|
113 |
return if ($self->skip("task has no guid", $self->_check())); |
114 |
|
115 |
#print Dumper($self); |
116 |
#exit; |
117 |
|
118 |
$self->log("task " . $self->getGuid() . " starting."); |
119 |
$self->{TASK}->{begin} = now(); |
120 |
$self->run() if $self->can('run'); |
121 |
#$self->_run(); |
122 |
$self->{TASK}->{end} = now(); |
123 |
$self->log("task " . $self->getGuid() . " finished."); |
124 |
} |
125 |
|
126 |
sub getGuid { |
127 |
my $self = shift; |
128 |
return $self->{guid}; |
129 |
} |
130 |
|
131 |
sub _bootDatabases { |
132 |
my $self = shift; |
133 |
|
134 |
# re-enabled as of 2003-05-16: Now accepts db-keys via method-args again! |
135 |
my $dbkeys = shift; |
136 |
|
137 |
#my $dbkeys; |
138 |
my $dbcfg; |
139 |
|
140 |
# A - Build list of db-keys to boot |
141 |
|
142 |
# FIXME: CACHE THIS! JUST BOOT STORAGES INTO CONTAINER IF NOT ALREADY DONE! |
143 |
# WATCH OUT FOR GLOBAL USED RESOURCES! |
144 |
if (not ref $self->{DSC} eq 'Data::Storage::Container') { |
145 |
$self->{DSC} = DesignPattern::Object->fromPackage('Data::Storage::Container'); |
146 |
} |
147 |
|
148 |
# Check if database keys were specified explicitely |
149 |
# as default inside the application container ... |
150 |
# new of 2003-05-16: Just do this if no dbkeys have been passed in via args. |
151 |
$dbkeys ||= $self->_get_dbkeys_app_defaults(); |
152 |
|
153 |
# ... if yes, just boot specified databases... |
154 |
if ($dbkeys) { |
155 |
|
156 |
$self->log("Using database(s): " . join(', ', @{$dbkeys}), 'info'); |
157 |
foreach (@$dbkeys) { |
158 |
$dbcfg->{$_} = $self->{app}->{config}->{databases}->{$_}; |
159 |
} |
160 |
|
161 |
# ... otherwise boot all databases. |
162 |
} else { |
163 |
$self->log("Using all databases.", 'info'); |
164 |
$dbcfg = $self->{app}->{config}->{databases}; |
165 |
} |
166 |
|
167 |
|
168 |
# B - Propagate stuff to application -config and -resource slots etc. |
169 |
# TODO: refactor: abstract this out |
170 |
|
171 |
# B.1 - Initialize config |
172 |
foreach (keys %$dbcfg) { |
173 |
$self->{DSC}->addConfig($_, $dbcfg->{$_}); |
174 |
} |
175 |
|
176 |
# B.2 - Initialize resources |
177 |
$self->{DSC}->initLocators(); |
178 |
$self->{DSC}->initStorages(); |
179 |
|
180 |
# B.3 - Establish symbols inside the application container |
181 |
# as references to the storage handle instances inside the |
182 |
# storage container singleton. |
183 |
# In other words: spread the refs |
184 |
# FIXME: This should be cleared up somehow! ;-) |
185 |
foreach (keys %{$self->{DSC}->{storage}}) { |
186 |
$self->{app}->{storage}->{$_} = $self->{DSC}->{storage}->{$_}; |
187 |
} |
188 |
|
189 |
} |
190 |
|
191 |
sub _get_dbkeys_app_defaults { |
192 |
my $self = shift; |
193 |
my $dbkeys; |
194 |
if (my $dbkey_raw = $self->{app}->{use_databases}) { |
195 |
if (ref $dbkey_raw eq 'ARRAY') { |
196 |
$dbkeys = $dbkey_raw; |
197 |
} else { |
198 |
#$self->{app}->{instance}->_bootDatabases(); |
199 |
my @dbkeys = split(/,\s|,/, $dbkey_raw); |
200 |
#$self->_bootDatabases(\@dbkeys); |
201 |
$dbkeys = \@dbkeys; |
202 |
} |
203 |
} |
204 |
return $dbkeys; |
205 |
} |
206 |
|
207 |
sub _shutdownDatabases { |
208 |
my $self = shift; |
209 |
foreach my $dbkey (keys %{$self->{app}->{storage}}) { |
210 |
#print "SHUTDOWN $dbkey", "\n"; |
211 |
#print Dumper($self->{app}->{storage}->{$dbkey}); |
212 |
my $handle = $self->{app}->{storage}->{$dbkey}; |
213 |
#print ref $handle, "\n"; |
214 |
#next if not $handle or not ref $handle or ref($handle) =~ m/(ARRAY|HASH)/; |
215 |
next if not $handle or not ref $handle or ref($handle) !~ m/(Data::Storage|DBI)/; |
216 |
$handle->disconnect(); |
217 |
} |
218 |
} |
219 |
|
220 |
#=pod |
221 |
sub DESTROY { |
222 |
my $self = shift; |
223 |
$self->_shutdownDatabases(); |
224 |
} |
225 |
#=cut |
226 |
|
227 |
|
228 |
sub activate_resources { |
229 |
my $self = shift; |
230 |
my $args = shift; |
231 |
$self->_bootDatabases($args); |
232 |
} |
233 |
|
234 |
sub resource_is_active { |
235 |
my $self = shift; |
236 |
my $key = shift; |
237 |
# FIXME: Enhance this! |
238 |
#print "key: $key", "\n"; |
239 |
#print Dumper($self->{DSC}->{storage}); |
240 |
return 1 if exists $self->{DSC}->{storage}->{$key}; |
241 |
} |
242 |
|
243 |
1; |
244 |
__END__ |