/[A3C]/lib/Strix.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Contents of /lib/Strix.pm

Parent Directory Parent Directory | Revision Log Revision Log


Revision 193 - (show annotations)
Tue Jun 17 21:27:31 2008 UTC (11 years, 1 month ago) by dpavlin
File size: 7787 byte(s)
- implement FIFO pool of dbh connections to strix
- rename sitemap to sites which is more correct
1 package Strix;
2
3 use strict;
4 use warnings;
5
6 use base qw(Jifty::Object Class::Accessor::Fast);
7 __PACKAGE__->mk_accessors( qw(instance uid) );
8
9 use DBI;
10 use Data::Dump qw/dump/;
11 use Carp qw/confess/;
12 use Jifty;
13
14 our $debug = 0;
15
16 =head1 NAME
17
18 Strix
19
20 =head1 METHODS
21
22 =head2 new
23
24 my $strix = Strix->new({ instance => 'os-test0604-zg' });
25
26 =head2 dbh
27
28 my $dbh = Strix->dbh( $strix_instance );
29
30 my $dbh = $strix->dbh;
31
32 =cut
33
34 our $instance_dbh;
35 our @instances_active;
36
37 sub dbh {
38 my $self = shift;
39
40 my $instance = shift || ref($self) && $self->instance || confess "no instance";
41
42 return $instance_dbh->{$instance} if $instance_dbh->{$instance};
43
44 my $config = Jifty->config->app('strix') or die "need strix config";
45 my $database = $config->{database} or die "no strix.database in config";
46
47 Jifty->log->debug("using config ", dump( $database ));
48
49 my $dsn =
50 'DBI:Pg:dbname=' . $instance .
51 ';host=' . $database->{host} .
52 ';port=' . $database->{port};
53
54 Jifty->log->info("Connect to instance $instance with dsn $dsn");
55
56 my $dbh = DBI->connect( $dsn, $database->{user}, $database->{passwd} ) or die "$DBI::errstr\n";
57
58 # force database to send us back UTF-8 no metter what it's encoding
59 $dbh->do("set client_encoding='utf-8'");
60 $dbh->{pg_enable_utf8} = 1;
61
62 $instance_dbh->{$instance} = $dbh;
63 push @instances_active, $instance;
64
65 if ( $#instances_active > 5 ) {
66 my $i = shift @instances_active;
67 warn "## remove connection to instance $instance\n";
68 delete( $instance_dbh->{$i} );
69 }
70
71 warn "## instance_dbh = ",dump( $instance_dbh ) if $debug;
72
73 return $dbh;
74 }
75
76 =head2 category
77
78 my $category = Strix->category( $url );
79
80 =cut
81
82 sub category {
83 my $self = shift;
84
85 my $url = shift || confess "no url";
86
87 # sysinc/profiles.php
88 my $sth = $self->dbh->prepare(qq{
89 SELECT kategorija.*, lang.langid, lang.locale, template.tfilename, template.tflags, site.naziv as sitename, site.admin_mail, site.address, site.root as site_root, getPathFromNav(kategorija.id) as path, site.ordstr as site_ordstr FROM kategorija, template, site, lang WHERE kategorija.url = ? AND kategorija.template_id = template.id AND kategorija.site_id = site.id AND lang.id = kategorija.lang
90 });
91 $sth->execute($url);
92
93 my $category = $sth->fetchrow_hashref() or die "can't fetch category $url";
94 return $category;
95 }
96
97 =head2 layout
98
99 my $layout = $strix->layout( $url );
100
101 =cut
102
103 sub layout {
104 my $self = shift;
105
106 my $url = shift || confess "no url";
107
108 my $dbh = $self->dbh;
109 my $category = $self->category( $url );
110
111 my $sth = $dbh->prepare(qq{
112 SELECT template.tfilename, template.tflags FROM template WHERE id = ?
113 });
114 $sth->execute( $category->{template_id} );
115
116 my $template = $sth->fetchrow_hashref() or die "can't fetch template";
117
118 warn "template = ",dump( $template ) if $debug;
119
120 my $page;
121 warn "### free layout...\n" if $debug;
122
123 # index.php
124 $sth = $dbh->prepare(qq{
125 SELECT layout_id, module_id, pozicija, module_args, name, fname, notitle, class_name
126 FROM pre_layout, modules
127 WHERE id=module_id AND ? = template_id AND redoslijed >= 0
128 ORDER BY redoslijed DESC
129 });
130 $sth->execute( $category->{template_id} );
131
132 sub module_args {
133 my $row = shift;
134 return undef unless $row->{module_args};
135 my $args;
136 foreach my $a ( split(/\&/, $row->{module_args} ) ) {
137 $args->{$1} = $2 if $a =~ m/^(.+)=(.+)$/;
138 }
139 return $args;
140 }
141
142 while (my $row = $sth->fetchrow_hashref() ) {
143 warn dump( $row ) if $debug;
144 push @{ $page->{free} }, { $row->{name} => module_args( $row ) };
145 }
146
147 warn "### pre layout...\n" if $debug;
148
149 $sth = $dbh->prepare(qq{
150 SELECT
151 l.id as layout_id, l.user_id, l.kategorija_id, l.module_id, l.pozicija, l.redoslijed, l.module_args, l.state, l.notitle,
152 m.name, m.fname, m.hidden, m.nocache, m.pos, m.class_name,
153 acl_module.acl_register_id
154 FROM layout as l, modules as m LEFT JOIN acl_module ON (acl_module.modules_id = m.id)
155 WHERE l.user_id=?
156 AND l.kategorija_id=?
157 AND m.id=l.module_id
158 ORDER BY pozicija,redoslijed DESC
159 });
160 $sth->execute( 1, $category->{id} );
161
162 while (my $row = $sth->fetchrow_hashref() ) {
163 warn dump( $row ) if $debug;
164 push @{ $page->{pre}->{ $row->{pos} } }, { $row->{name} => module_args( $row ) };
165 }
166
167 warn "### post layout...\n" if $debug;
168
169 $sth = $dbh->prepare(qq{
170 SELECT layout_id, module_id, pozicija, module_args, name, notitle
171 FROM pre_layout, modules
172 WHERE id=module_id AND ? = template_id AND redoslijed < 0
173 ORDER BY redoslijed DESC
174 });
175 $sth->execute( $category->{template_id} );
176
177 while (my $row = $sth->fetchrow_hashref() ) {
178 warn dump( $row ) if $debug;
179 push @{ $page->{post}->{ $row->{pozicija} } }, { $row->{name} => module_args( $row ) };
180 }
181
182 return $page;
183
184 }
185
186 =head2 sites
187
188 my @sites = $strix->sites;
189
190 =cut
191
192 sub sites {
193 my $self = shift;
194
195 my @sites;
196
197 my $sth = $self->dbh->prepare(
198 "SELECT *, coalesce(( length(ordstr)/3 ) - 1,0) AS depth FROM site ORDER BY ordstr"
199 );
200 $sth->execute;
201
202 while (my $row = $sth->fetchrow_hashref() ) {
203 push @sites, $row;
204 }
205
206 return @sites;
207 }
208
209 =head2 site_navigation
210
211 my $navigation = $strix->site_navigation( $site_id, $uid );
212
213 =cut
214
215 sub site_navigation {
216 my $self = shift;
217
218 my ( $site_id, $uid ) = @_;
219
220 $uid ||= 1; # anonymous
221 # $uid ||= 2; # admin
222
223 my $sth = $self->dbh->prepare(
224 "SELECT kategorija.*, ((length(prikaz)+length(coalesce(ordstr,'')))/3)-1 as depth FROM kategorija JOIN navigacija ON (kategorija.id = kategorija_id), site WHERE site_id = ? AND site.id = site_id AND userCanDoOnObject(?, 1, 'kats', kategorija.id) ORDER BY prikaz");
225 $sth->execute( $site_id, $uid );
226
227 Jifty->log->debug("site $site_id has ", $sth->rows, " categories for uid $uid");
228
229 my $navigation = [];
230
231 my @pos = ( 0 );
232
233 while (my $kat = $sth->fetchrow_hashref() ) {
234 warn "# kat = ",dump( $kat ) if $debug;
235 if ( ! $kat->{depth} ) {
236 Jifty->log->error("depth increased to 1 in ",dump( $kat ));
237 $kat->{depth} = 1;
238 }
239
240 my $node = { type => 'category' };
241 foreach my $c ( qw/naziv url/ ) {
242 $node->{$c} = $kat->{$c};
243 }
244
245 my $depth = $kat->{depth};
246 if ( ! defined $pos[ $depth - 2 ] ) {
247 warn "FIXING CATEGORY: ",dump( $kat );
248 $node->{class} = "error";
249 $depth--;
250 }
251 @pos = splice( @pos, 0, $depth );
252 $pos[ $depth - 1 ]++;
253
254 warn "## category depth = $depth pos = ",dump( @pos ) if $debug;
255
256 my $code = '$navigation';
257 map { $code .= '->[' . ( $_ - 1 ) . ']->{children}' } @pos;
258 $code =~ s/->{children}$//;
259 warn "## category code: $code\n" if $debug;
260 eval $code . '= $node';
261 if ( $@ ) {
262 warn "SKIPPED CATEGORY: $@ ",dump( $kat );
263 next;
264 }
265
266 my $sth_ms = $self->dbh->prepare(
267 "SELECT
268 multistatic.id, multistatic.title, multistatic.kname,
269 multistatic_navigation.kategorija_id, multistatic_navigation.prikaz,
270 (LENGTH(multistatic_navigation.prikaz)/3) AS depth
271 FROM multistatic, multistatic_navigation
272 WHERE multistatic.id = multistatic_navigation.multistatic_id
273 AND multistatic_navigation.prikaz != ''
274 AND multistatic_navigation.kategorija_id = ?
275 AND multistatic.title != ''
276 ORDER BY multistatic_navigation.prikaz");
277 $sth_ms->execute( $kat->{id} );
278
279 if ( my $rows = $sth_ms->rows ) {
280 Jifty->log->debug("$site_id has $rows multistatic pages");
281
282 while (my $ms = $sth_ms->fetchrow_hashref() ) {
283 warn "# ms = ",dump( $ms ) if $debug;
284
285 my $node = {
286 naziv => $ms->{title},
287 url => $kat->{url} . '?ms_nav=' . $ms->{prikaz},
288 type => 'multistatic',
289 };
290
291 my $ms_depth = $ms->{depth} + $depth;
292 my $p = $pos[ $ms_depth - 1 ]++;
293 warn "## multistatic depth = $ms_depth pos = ",dump( @pos ) if $debug;
294
295 my $ms_code = $code . '->{children}->[ ' . $p . '] = $node';
296 warn "## multistatic code: $ms_code\n" if $debug;
297 eval $ms_code;
298 if ( $@ ) {
299 warn "SKIPPED MULTISTATIC: $@ ",dump( $ms );
300 next;
301 }
302 }
303 }
304
305 }
306
307 return $navigation;
308
309 }
310
311 1;

  ViewVC Help
Powered by ViewVC 1.1.26