55 |
|
|
56 |
my $DSN = 'DBI:Pg:dbname=' . $NICK; |
my $DSN = 'DBI:Pg:dbname=' . $NICK; |
57 |
|
|
|
# log output encoding |
|
|
my $ENCODING = 'ISO-8859-2'; |
|
58 |
my $TIMESTAMP = '%Y-%m-%d %H:%M:%S'; |
my $TIMESTAMP = '%Y-%m-%d %H:%M:%S'; |
59 |
|
|
60 |
my $sleep_on_error = 5; |
my $sleep_on_error = 5; |
75 |
use POE qw(Component::IRC Wheel::FollowTail Component::Server::HTTP); |
use POE qw(Component::IRC Wheel::FollowTail Component::Server::HTTP); |
76 |
use HTTP::Status; |
use HTTP::Status; |
77 |
use DBI; |
use DBI; |
|
use Encode qw/from_to is_utf8/; |
|
78 |
use Regexp::Common qw /URI/; |
use Regexp::Common qw /URI/; |
79 |
use CGI::Simple; |
use CGI::Simple; |
80 |
use HTML::TagCloud; |
use HTML::TagCloud; |
108 |
open(STDOUT, '>', $log_path) || warn "can't redirect log to $log_path: $!"; |
open(STDOUT, '>', $log_path) || warn "can't redirect log to $log_path: $!"; |
109 |
|
|
110 |
sub _log { |
sub _log { |
111 |
my $out = strftime($TIMESTAMP,localtime()) . ' ' . join(" ",@_) . $/; |
print strftime($TIMESTAMP,localtime()) . ' ' . join(" ",@_) . $/; |
|
from_to( $out, 'UTF-8', $ENCODING ); |
|
|
print $out; |
|
112 |
} |
} |
113 |
|
|
114 |
# LOG following |
# LOG following |
172 |
}; |
}; |
173 |
|
|
174 |
my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr; |
my $dbh = DBI->connect($DSN,"","", { RaiseError => 1, AutoCommit => 1 }) || die $DBI::errstr; |
175 |
|
$dbh->do( qq{ set client_encoding = 'UTF-8' } ); |
176 |
|
|
177 |
my $sql_schema = { |
my $sql_schema = { |
178 |
log => qq{ |
log => qq{ |
529 |
return unless ($arg->{id} && $arg->{message}); |
return unless ($arg->{id} && $arg->{message}); |
530 |
|
|
531 |
my $m = $arg->{message}; |
my $m = $arg->{message}; |
|
from_to('UTF-8', 'iso-8859-2', $m) if (is_utf8($m)); |
|
532 |
|
|
533 |
my @tags; |
my @tags; |
534 |
|
|
676 |
# $msg .= prefix( ' id ' , $entry->id ); |
# $msg .= prefix( ' id ' , $entry->id ); |
677 |
|
|
678 |
if ( $args->{kernel} && $send_rss_msgs ) { |
if ( $args->{kernel} && $send_rss_msgs ) { |
|
warn "# sending to $CHANNEL\n"; |
|
679 |
$send_rss_msgs--; |
$send_rss_msgs--; |
680 |
|
_log('RSS', $msg); |
681 |
|
$sth_insert_log->execute( $CHANNEL, 1, $NICK, $msg, undef ); |
682 |
$args->{kernel}->post( $IRC_ALIAS => notice => $CHANNEL, $msg ); |
$args->{kernel}->post( $IRC_ALIAS => notice => $CHANNEL, $msg ); |
683 |
$updates++; |
$updates++; |
|
#$sth_insert_log->execute( $CHANNEL, 1, $NICK, $msg, undef ); |
|
|
_log('RSS', $msg); |
|
684 |
} |
} |
685 |
} |
} |
686 |
|
|