LEFT OUTER JOIN forum_posts fp USING (ftid)
LEFT OUTER JOIN (SELECT * FROM forum_thread_visits WHERE uid = $1) ftv USING (ftid)
WHERE EXISTS (SELECT fbid FROM forum_access WHERE fbid = fb.fbid AND gid IN (SELECT groups($1)))
+ OR ft.ftid IN (SELECT ftid FROM forum_priv_access WHERE uid = $1)
GROUP BY fcid,category,fb.fbid, fb.board
ORDER BY fcid,fb.fbid
});
JOIN forum_posts fp USING (ftid)
JOIN users u ON u.uid = ft.uid
LEFT OUTER JOIN (SELECT * FROM forum_thread_visits WHERE uid = $1) ftv ON ftv.ftid = ft.ftid
- WHERE fbid > 0 AND
- fb.fbid IN (SELECT fbid FROM forum_access WHERE gid IN (SELECT groups($1)))
+ WHERE (fbid > 0 AND
+ fb.fbid IN (SELECT fbid FROM forum_access WHERE gid IN (SELECT groups($1)))
+ ) OR ft.ftid IN (SELECT ftid FROM forum_priv_access WHERE uid = $1)
GROUP BY fcid,category,fbid,board,ft.ftid, ft.subject,ft.sticky,u.username
HAVING count(NULLIF(COALESCE(fp.time > ftv.time,TRUE),FALSE)) >= 1
ORDER BY fcid,fbid,sticky DESC,last_post DESC
JOIN forum_threads ft USING (fbid)
JOIN forum_posts fp USING (ftid)
JOIN users u ON fp.uid = u.uid
- WHERE fb.fbid IN (SELECT fbid FROM forum_access
- WHERE gid IN (SELECT groups($1)))
- AND fp.textsearch @@@ to_tsquery($2)
+ WHERE (fb.fbid IN (SELECT fbid FROM forum_access
+ WHERE gid IN (SELECT groups($1)))
+ OR ft.ftid IN (SELECT ftid FROM forum_priv_access WHERE uid = $1)
+ ) AND fp.textsearch @@@ to_tsquery($2)
ORDER BY rank DESC
});
eval {
$c->forward('findBoard');
$board = $c->stash->{board};
+ if ( !defined $board->{fbid}){
+ $c->detach('/default');
+ }
my $threads = $dbh->prepare(q{SELECT ft.ftid,u.username,ft.subject
,count(NULLIF(COALESCE(fp.time > ftv.time,TRUE),FALSE)) AS unread,count(fp.fpid) AS posts
,date_trunc('seconds',max(fp.time)::timestamp) as last_post
,min(fp.time)::date as posting_date, ft.sticky
FROM forum_threads ft
- JOIN forum_posts fp USING (ftid)
+ JOIN forum_posts fp USING (ftid)
JOIN users u ON u.uid = ft.uid
LEFT OUTER JOIN (SELECT * FROM forum_thread_visits WHERE uid = $2) ftv ON ftv.ftid = ft.ftid
- WHERE ft.fbid = $1
+ WHERE ft.fbid = $1 AND (
+ ft.fbid IN (SELECT fbid FROM forum_access WHERE gid IN (SELECT groups($2)))
+ OR ft.ftid IN (SELECT ftid FROM forum_priv_access WHERE uid = $2)
+ )
GROUP BY ft.ftid, ft.subject,ft.sticky,u.username
ORDER BY sticky DESC,last_post DESC
});
while (my $thread = $threads->fetchrow_hashref){
push @threads,$thread;
}
- $c->stash(threads => \@threads);
- if ($board->{moderate}){
- my $categories = $dbh->prepare(q{SELECT fcid,category FROM forum_categories ORDER BY fcid});
- my $boards = $dbh->prepare(q{SELECT fb.fbid,fb.board, bool_or(fa.post) AS post
- FROM forum_boards fb NATURAL JOIN forum_access fa
- WHERE fb.fcid = $1 AND
- gid IN (SELECT groups($2))
- GROUP BY fb.fbid,fb.board
- ORDER BY fb.fbid
- });
- $categories->execute;
- my @categories;
- while (my $category = $categories->fetchrow_hashref){
- $boards->execute($category->{fcid},$c->stash->{UID});
-
- my @boards;
- while (my $b = $boards->fetchrow_hashref){
- next if (not $b->{post} or $b->{fbid} == $board->{fbid});
- push @boards,$b;
- }
- $category->{boards} = \@boards;
- push @categories,$category if @boards;
- }
- $c->stash(categories => \@categories);
+ if ( !(defined $board->{post}) && @threads == 0){
+ $c->acl_access_denied('test',$c->action,'No access to board')
}
-}
+ $c->stash(threads => \@threads);
+ $c->forward('listModeratorBoards', [$board->{fbid}]) if $board->{moderate};
+
+}
sub thread : Local {
my ( $self, $c, $thread ) = @_;
my $dbh = $c->model;
$c->forward('findThread');
- $thread = $c->stash->{thread};
+ unless ($c->stash->{thread}){
+ $c->stash(template => 'default.tt2');
+ $c->res->status(404);
+ return;
+ }
+ my $query = $dbh->prepare(q{SELECT uid,username FROM users u
+ JOIN forum_priv_access fta USING (uid) WHERE fta.ftid = $1});
+ $query->execute($thread);
+ $c->stash(access => $query->fetchall_arrayref({}) );
+ $c->forward('findPosts');
+ $c->forward('markThreadAsRead') if $c->user_exists;
+ if ($c->stash->{thread}->{moderate}) {
+ $c->forward('findUsers');
+ $c->forward('listModeratorBoards', [$c->stash->{thread}->{fbid}]);
+ }
+}
+
+sub findPosts :Private {
+ my ( $self, $c, $thread ) = @_;
+ my $dbh = $c->model;
my $posts = $dbh->prepare(q{
- SELECT u.username,date_trunc('seconds',fp.time::timestamp) AS time
+ SELECT u.uid,u.username,date_trunc('seconds',fp.time::timestamp) AS time
,fp.message,COALESCE(fp.time > ftv.time,TRUE) AS unread
FROM forum_threads ft
JOIN forum_posts fp USING (ftid)
WHERE ft.ftid = $1
ORDER BY fp.time ASC
});
- $posts->execute($c->stash->{thread}->{ftid},$c->stash->{UID});
+ $posts->execute($thread,$c->stash->{UID});
my @posts;
while (my $post = $posts->fetchrow_hashref){
}
$c->stash(posts => \@posts);
- $c->forward('markThreadAsRead') if $c->user_exists;
}
$c->forward('markThreadAsRead',[$thread->{ftid}]);
}
$dbh->commit;
- $c->res->redirect($c->req->referer);
+ $c->forward('/redirect');
}
sub markThreadAsRead : Private {
sub newThread : Local {
my ( $self, $c, $board ) = @_;
- my $dbh = $c->model;
$c->forward('findBoard');
$board = $c->stash->{board};
unless ($c->stash->{board}->{post}){
$c->acl_access_denied('test',$c->action,'No post access to board.')
}
-
+
+ $c->forward('insertThread');
+ $c->forward('addPost',[$c->stash->{thread}]);
+}
+
+sub insertThread : Private {
+ my ( $self, $c, $board ) = @_;
+ my $dbh = $c->model;
+
my $insert = $dbh->prepare(q{INSERT INTO forum_threads (ftid,fbid,subject,uid)
VALUES(DEFAULT,$1,$2,$3) RETURNING (ftid);
});
-
- $insert->execute($board->{fbid},html_escape($c->req->param('subject')),$c->stash->{UID});
- my $thread = $insert->fetchrow;
+ $insert->execute($board,html_escape($c->req->param('subject')),$c->stash->{UID});
+ $c->stash(thread => $insert->fetchrow);
$insert->finish;
- $c->forward('addPost',[$thread]);
-
}
sub addPost : Local {
$c->res->redirect($c->uri_for('thread',$thread));
}
+sub postthreadaccess : Local {
+ my ( $self, $c, $thread) = @_;
+ my $dbh = $c->model;
+
+ $c->forward('findThread');
+ $dbh->begin_work;
+ unless ($c->stash->{thread}->{moderate}){
+ $c->acl_access_denied('test',$c->action,'No moderator access to board.')
+ }
+ if ($c->req->param('access')){
+ $c->req->parameters->{access} = [$c->req->parameters->{access}]
+ unless ref $c->req->parameters->{access} eq 'ARRAY';
+ my $query = $dbh->prepare(q{DELETE From forum_priv_access
+ WHERE ftid = $1 AND uid = ANY ($2)});
+ $query->execute($thread,$c->req->parameters->{access});
+ $dbh->do(q{INSERT INTO forum_posts (ftid,uid,message)
+ VALUES((SELECT ftid FROM users WHERE uid = $1),$1,$2)
+ }, undef, $c->user->id
+ ,"Removed access on thread $thread for : @{$c->req->parameters->{access}}");
+ }
+ if ($c->req->param('uid')){
+ $c->forward('addaccess');
+ }
+ $dbh->commit;
+ $c->res->redirect($c->uri_for('thread',$thread));
+}
+
+sub removeownthreadaccess : Local {
+ my ( $self, $c, $thread) = @_;
+ my $dbh = $c->model;
+ $dbh->do(q{DELETE FROM forum_priv_access WHERE uid = $1 AND ftid = $2}
+ ,undef,$c->user->id,$thread);
+ $c->res->redirect($c->uri_for('allUnread'));
+}
+
+sub privmsg : Local {
+ my ( $self, $c, $uid ) = @_;
+
+ $uid ||= 0;
+ $c->stash(uid => $uid);
+
+ $c->forward('findUsers');
+}
+
+sub postprivmsg : Local {
+ my ( $self, $c ) = @_;
+ my $dbh = $c->model;
+
+ $dbh->begin_work;
+ $c->forward('insertThread',[-1999]);
+
+ $c->req->parameters->{uid} = [$c->req->parameters->{uid}]
+ unless ref $c->req->parameters->{uid} eq 'ARRAY';
+ push @{$c->req->parameters->{uid}}, $c->user->id;
+ $c->forward('addaccess',[$c->stash->{thread}]);
+
+ $c->forward('addPost',[$c->stash->{thread}]);
+ $dbh->commit;
+}
+
+sub addaccess : Private {
+ my ( $self, $c, $thread) = @_;
+ my $dbh = $c->model;
+
+ $c->req->parameters->{uid} = [$c->req->parameters->{uid}]
+ unless ref $c->req->parameters->{uid} eq 'ARRAY';
+ my $query = $dbh->prepare(q{INSERT INTO forum_priv_access (ftid,uid)
+ (SELECT $1,uid FROM users u WHERE uid = ANY ($2) AND NOT uid
+ IN (SELECT uid FROM forum_priv_access WHERE ftid = $1))});
+ $query->execute($thread,$c->req->parameters->{uid});
+ $dbh->do(q{INSERT INTO forum_posts (ftid,uid,message)
+ VALUES((SELECT ftid FROM users WHERE uid = $1),$1,$2)
+ }, undef, $c->user->id
+ ,"Gave access on thread $thread to : @{$c->req->parameters->{uid}}");
+}
+
+sub findUsers : Private {
+ my ( $self, $c ) = @_;
+ my $dbh = $c->model;
+
+ my $query = $dbh->prepare(q{SELECT uid,username FROM users
+ WHERE uid > 0 AND uid IN (SELECT uid FROM groupmembers)
+ ORDER BY LOWER(username)});
+ $query->execute;
+
+ $c->stash(users => $query->fetchall_arrayref({}) );
+}
+
sub findThread : Private {
my ( $self, $c, $thread ) = @_;
my $dbh = $c->model;
- my $findThread = $dbh->prepare(q{SELECT ft.ftid,ft.subject, bool_or(fa.post) AS post
- , bool_or(fa.moderate) AS moderate,ft.fbid,fb.board,fb.fcid,ft.sticky,fc.category
+ my $findThread = $dbh->prepare(q{SELECT ft.ftid,ft.subject
+ ,COALESCE(bool_or(fa.post),true) AS post, bool_or(fa.moderate) AS moderate
+ ,ft.fbid,fb.board,fb.fcid,ft.sticky,fc.category
FROM forum_boards fb
- NATURAL JOIN forum_access fa
NATURAL JOIN forum_threads ft
NATURAL JOIN forum_categories fc
- WHERE ft.ftid = $1 AND gid IN (SELECT groups($2))
+ LEFT OUTER JOIN (SELECT * FROM forum_access
+ WHERE gid IN (SELECT groups($2))
+ ) fa USING (fbid)
+ WHERE ft.ftid = $1 AND (fa.post IS NOT NULL
+ OR ft.ftid IN (SELECT ftid FROM forum_priv_access WHERE uid = $2))
GROUP BY ft.ftid,ft.subject,ft.fbid,fb.board,fb.fcid,ft.sticky,fc.category
});
$thread = $dbh->selectrow_hashref($findThread,undef,$thread,$c->stash->{UID});
my $dbh = $c->model;
my $boards = $dbh->prepare(q{SELECT fb.fbid,fb.board, bool_or(fa.post) AS post, bool_or(fa.moderate) AS moderate,fb.fcid, fc.category
- FROM forum_boards fb
- NATURAL JOIN forum_access fa
+ FROM forum_boards fb
NATURAL JOIN forum_categories fc
- WHERE fb.fbid = $1 AND
- gid IN (SELECT groups($2))
+ LEFT OUTER JOIN (SELECT * FROM forum_access
+ WHERE fbid = $1 AND gid IN (SELECT groups($2))
+ ) fa USING (fbid)
+ WHERE fb.fbid = $1
GROUP BY fb.fbid,fb.board,fb.fcid,fc.category
});
$board = $dbh->selectrow_hashref($boards,undef,$board,$c->stash->{UID});
$insert->execute($thread,html_escape($c->req->param('message')),$c->stash->{UID});
}
+sub listModeratorBoards : Private {
+ my ( $self, $c, $fbid ) = @_;
+ my $dbh = $c->model;
+
+ my $categories = $dbh->prepare(q{SELECT fcid,category FROM forum_categories ORDER BY fcid});
+ my $boards = $dbh->prepare(q{SELECT fb.fbid,fb.board, bool_or(fa.post) AS post
+ FROM forum_boards fb NATURAL JOIN forum_access fa
+ WHERE fb.fcid = $1
+ AND gid IN (SELECT groups($2))
+ AND moderate
+ GROUP BY fb.fbid,fb.board
+ ORDER BY fb.fbid
+ });
+ $categories->execute;
+ my @categories;
+ while (my $category = $categories->fetchrow_hashref){
+ $boards->execute($category->{fcid},$c->stash->{UID});
+
+ my @boards;
+ while (my $b = $boards->fetchrow_hashref){
+ next if ($b->{fbid} == $fbid);
+ push @boards,$b;
+ }
+ $category->{boards} = \@boards;
+ push @categories,$category if @boards;
+ }
+ $c->stash(categories => \@categories);
+}
+
=head1 AUTHOR
Michael Andreen (harv@ruin.nu)
projects / ndwebbie.git / blobdiff