via:$via} if ($via); $newnote = $self->js_escape($newnote); print qq# workspace.createNote( { 'text':unescape('$newnote') } );\n#; } } else { debug "new workspace: $name\n"; } my $rss_url = $q->url().'/rss/'.uri_escape($name); printf $webnote2,$rss_url,$name,$rss_url; } =head2 workspace_info Get workspace by name (and time) my $ws_info = $wn->workspace_info('Workspace name', 1111679331); If no time is specified, it will return latest version of workspace. =cut sub workspace_info { my $self = shift; my $name = shift || return; my $time = shift; my $sql = qq{ select wsid, wsname, nextNoteNum, time from wn_workspaces where wsname = ? }; my @arg = ( $name ); if ($time) { $sql .= qq{ and time = ? }; push @arg, $time; } else { $sql .= qq{ order by time desc limit 1 }; } my $sth = $self->{'dbh'}->prepare($sql) || die $self->{'dbh'}->errstr(); $sth->execute(@arg) || die $sth->errstr(); my $ws_info = $sth->fetchrow_hashref(); debug "workspace_info($name,$time): ",Dumper($ws_info); return $ws_info; } =head2 store_workspace Save workspace data to database $wn->store_workspace($workspace_hash); C<$workspace_hash> has following structure: 'name' => 'foo', 'nextNoteNum' => '153', 'time' => 1111674868, 'note' => [ { 'noteid' => 'note146', 'content' => 'foobar%0A', 'bgcolor' => '#8facff' 'xposition' => '384', 'yposition' => '411', 'width' => '221', 'height' => '153', 'zindex' => '1', }, # ... ] =cut sub store_workspace { my $self = shift; my $ws = shift || return; return unless ($ws->{'name'} && $ws->{'time'}); $self->{'dbh'}->begin_work; my $sth = $self->{'dbh'}->prepare(qq{ insert into wn_workspaces (wsname, nextNoteNum, time) values (?, ?, ?) }) || die $self->{'dbh'}->errstr(); $sth->execute( map { $ws->{$_} } qw(name nextNoteNum time) ) || die $sth->errstr(); my $ws_info = $self->workspace_info($ws->{'name'}, $ws->{'time'}) || die "can't find newly inserted row!"; my $wsid = $ws_info->{'wsid'} || die "can't find wsid in workspace_info"; my @note_data = qw(noteid content bgcolor xposition yposition height width zindex wsid); $sth = $self->{'dbh'}->prepare( 'insert into wn_notes (' . join(",", @note_data) . ') values (?,?,?,?,?,?,?,?,?)') || die $self->{'dbh'}->errstr(); debug "using db_codepage: ".$self->{'db_codepage'}; my $ok = 1; foreach my $n (@{$ws->{'note'}}) { $n->{'wsid'} ||= $wsid; my $c = $self->js_unescape($n->{'content'}) || ''; # encode content into database codepage $c = encode($self->{db_codepage}, $c); debug "store_workplace(".$ws->{'name'}.") - $wsid ".$n->{'noteid'}." ==> $c"; # save empty notes also $n->{content} = $c; unless ($sth->execute( map { $n->{$_} } @note_data ) ) { $ok = 0; $self->{'dbh'}->rollback; last; } } $self->{'dbh'}->commit if ($ok); return $ok; } =head2 load_workspace Load workspace from database. $workspace_hash = $wn->load_workspace('Workspace name', 1111679331); =cut sub load_workspace { my $self = shift; my ($name, $time) = @_; $time ||= ''; # fix warning my $ws = $self->workspace_info($name, $time) || return; my $sth = $self->{'dbh'}->prepare(qq{ select noteid,content,bgcolor,xposition,yposition,height,width,zindex from wn_notes where wsid = ? order by noteid desc }) || die $self->{'dbh'}->errstr(); $sth->execute($ws->{'wsid'}) || die $sth->errstr(); while (my $n = $sth->fetchrow_hashref()) { # decode content back from database encoding to UTF-8 from_to($n->{content}, $self->{'db_codepage'}, 'UTF-8'); push @{$ws->{'note'}}, $n; } debug "load_workspace($name,$time)",Dumper($ws); return $ws; } =head2 getdates Method to return formatted data for JavaScript call C and C. print $wn->getdates('Workspace name', $offset, $limit); =cut sub getdates { my $self = shift; my ($name,$offset,$limit) = @_; die "no name?" unless ($name); $offset ||= 0; $limit ||= 100; my $sth = $self->{'dbh'}->prepare(qq{ select time from wn_workspaces where wsname=? order by time desc limit $limit offset $offset }) || die $self->{'dbh'}->errstr(); my @times; $sth->execute($name) || die $sth->errstr(); while (my ($t) = $sth->fetchrow_array()) { push @times, $t; } my $ret = join("|",@times); # default to unix time 1, for last update of new notes (never) $ret ||= $self->_fmt_utime(1); debug "getdates($name, $offset, $limit) = $ret"; print "Content-type: text/plain\r\n\r\n$ret"; } =head2 rss Create RSS 2.0 feed for notes print $wn->rss("Workspace name"); =cut sub rss { my $self = shift; my $name = shift || return; $name = uri_unescape($name); my $ws = $self->load_workspace($name); my $q = $self->{'cgi'} || die "no cgi?"; my $url = $q->url()."?name=".uri_escape($name); my $rss = new XML::RSS( version => '2.0', encoding => 'UTF-8', ); $rss->channel( title => $name, link => $url, description => "Webnote notes called $name", ); foreach my $n (@{$ws->{'note'}}) { my $desc = '
' .
$n->{'content'} . '
';
my $title = $1 if ($n->{content} =~ m/^\s*([^\n\r]+)/s);
$rss->add_item(
title => $title || $n->{noteid},
permaLink => $url . '#' . $n->{'noteid'},
description => $desc,
);
}
print "Content-type: text/xml\n\n" . $rss->as_string;
}
=head2 stats
Return RSS 1.0 with some statistic about Webnote workspaces
print $wn->stats;
=cut
sub stats {
my $self = shift;
my $q = $self->{'cgi'} || die "no cgi?";
my $url = $q->url();
my $rss = new XML::RSS(
version => '1.0',
encoding => 'UTF-8',
);
$rss->channel(
title => "Webnote statistics",
link => $url,
description => "Webnote statistics",
);
my $sth = $self->{'dbh'}->prepare(qq{
select
wsname,
count(distinct(wn_notes.time)) as nr_saves,
max(wn_workspaces.time) as last_saved
from wn_workspaces, wn_notes
where wn_workspaces.wsid = wn_notes.wsid
group by wsname
order by last_saved desc
limit 10
}) || die $self->{'dbh'}->errstr();
$sth->execute() || die $sth->errstr();
while (my $row = $sth->fetchrow_hashref()) {
my $dc_date = $self->_fmt_dc_date( $row->{'last_saved'} || time() );
$rss->add_item(
title => $row->{'wsname'},
link => $url . "?name=".uri_escape($row->{'wsname'}),
description => "Saved ". $row->{'nr_saves'} . " times",
dc => {
creator => 'Webnote back-end',
date => $dc_date,
},
);
}
print "Content-type: text/xml\n\n" . $rss->as_string;
}
#
#
=head1 INTERNAL METHODS
You shouldn't need to call this directly.
=head2 _fmt_utime
Return time in ISO format
=cut
sub _fmt_utime {
my $self = shift;
my $t = shift || return;
return strftime('%Y-%m-%d %H:%M:%S', localtime($t));
}
=head2 _fmt_dc_date
Return time in ISO format for dc:date
=cut
sub _fmt_dc_date {
my $self = shift;
my $t = shift || time();
$t = str2time($t) unless ($t =~ m#^\d+$#);
return strftime('%Y-%m-%dT%H:%M:%SZ', gmtime($t));
}
=head2 js_unsescape
Convert string that JavaScript function C