File Coverage

blib/lib/Kwiki/UserMessage.pm

Criterion	Covered	Total	%
statement	1	3	33.3
branch			n/a
condition			n/a
subroutine	1	1	100.0
pod			n/a
total	2	4	50.0

package Kwiki::UserMessage;
use Kwiki::Plugin qw(-Base -XXX);
use mixin 'Kwiki::Installer';
our $VERSION = '0.02';

const class_id    => 'user_message';
const class_title => 'Kwiki User Message';
const cgi_class   => 'Kwiki::UserMessage::CGI';

const css_file => 'user_message.css';
const javascript_file => 'user_message.js';

field cdbi => -init => '$self->hub->cdbi';

field 'display_msg';

sub register {
    my $registry = shift;
    $registry->add(action  => 'user_message');
    $registry->add(toolbar => 'user_message',
		   template => 'user_message_toolbar.html');
}

sub dbinit {
    my $dbpath = io->catfile($self->plugin_directory,"data.sqlt");
    my $db = $self->hub->cdbi;
    $db->base('Kwiki::UserMessage::CDBI');
    $db->connection("dbi:SQLite:".$dbpath->name);
    $db->dbinit unless $dbpath->exists;
}

sub user_message {
    $self->dbinit;
    my $mode = $self->cgi->run_mode || 'list';
    $self->$mode if $self->can($mode);
    $self->render_screen;
}

sub list {}
sub compose {}

sub delete {
    my $id = shift || $self->cgi->id;
    $self->delete_message($id) if $id;

    my $obj = $self->cdbi->retrieve($id);
    $obj->delete if $obj;
}

sub post {
    my $caller_sub = (caller(1))[3];
    if($caller_sub eq 'Kwiki::UserMessage::user_message') {
	if($self->post($self->users->current->name,
		       $self->cgi->to,
		       $self->cgi->subject,
		       $self->cgi->body)) {
	    $self->display_msg("Message Delivered");
	} else {
	    $self->display_msg("Delivery Error");
	}
    } else {
	my ($sender,$receiver,$subject,$body) = @_;
	my $vars = {
		    id => $self->cdbi->maximum_value_of("id")||0 + 1,
		    sender => $sender,
		    receiver => $receiver,
		    subject => $subject,
		    body => $body,
		    ts => scalar(localtime)
		   };
	$self->cdbi->create($vars);
    }
}

sub message_list {
    my $user = shift || $self->users->current->name;
    my $it = $self->cdbi->search( receiver => $user );
    my @obj = $self->retrieve_obj_list($it);
    return \@obj;
}

sub load_message {
    my $id = shift;
    $self->retrieve_obj($self->cdbi->retrieve($id), $self->cdbi->columns());
}

sub retrieve_obj_list {
    my $it = shift || return;
    my $entity = shift || $self->cdbi;
    my @objs;
    my @columns = $entity->columns();
    while(my $obj = $it->next) {
	push @objs, $self->retrieve_obj($obj,@columns);
    }
    return @objs;
}

sub retrieve_obj {
    my ($obj,@columns) = @_;
    return unless ref($obj);
    my $var;
    for(@columns) {
	$var->{$_} = $self->utf8_decode($obj->$_);
    }
    $var->{time} = $var->{ts};
    return $var;
}

package Kwiki::UserMessage::CGI;
use base 'Kwiki::CGI';

cgi 'run_mode';
cgi 'id';
cgi 'to';
cgi 'body';
cgi 'subject';

package Kwiki::UserMessage;

__DATA__