582 |
|
|
583 |
|
|
584 |
if ($import_dircproxy) { |
if ($import_dircproxy) { |
585 |
|
my ( $from_time, $date_time ) = $dbh->selectrow_array(qq{ |
586 |
|
select date_part('epoch',max(time)),max(time) from log |
587 |
|
}); |
588 |
|
|
589 |
|
warn "IMPORT $date_time [$from_time]\n"; |
590 |
|
|
591 |
open(my $l, $import_dircproxy) || die "can't open $import_dircproxy: $!"; |
open(my $l, $import_dircproxy) || die "can't open $import_dircproxy: $!"; |
592 |
warn "importing $import_dircproxy...\n"; |
warn "importing $import_dircproxy...\n"; |
593 |
my $tz_offset = 1 * 60 * 60; # TZ GMT+2 |
my $tz_offset = 1 * 60 * 60; # TZ GMT+2 |
596 |
if (/^@(\d+)\s(\S+)\s(.+)$/) { |
if (/^@(\d+)\s(\S+)\s(.+)$/) { |
597 |
my ($time, $nick, $msg) = ($1,$2,$3); |
my ($time, $nick, $msg) = ($1,$2,$3); |
598 |
|
|
599 |
|
next if $time <= $from_time; |
600 |
|
|
601 |
my $dt = DateTime->from_epoch( epoch => $time + $tz_offset ); |
my $dt = DateTime->from_epoch( epoch => $time + $tz_offset ); |
602 |
|
|
603 |
my $me = 0; |
my $me = 0; |