108 lines
2.6 KiB
Perl
108 lines
2.6 KiB
Perl
#!/usr/bin/env perl
|
|
use strict;
|
|
use warnings;
|
|
use POE;
|
|
use POE::Component::IRC;
|
|
use WWW::Telegram::BotAPI;
|
|
require './.secrets.pm';
|
|
|
|
my $IRC_SERVER = '127.0.0.1';
|
|
my $IRC_PORT = 6667;
|
|
my $IRC_NICK = 'Jerry';
|
|
my $IRC_CHANNEL = $Secrets::IRC_CHANNEL;
|
|
my $NICKSERV_PASSWORD = $Secrets::NICKSERV_PASSWORD;
|
|
|
|
my $telegram = WWW::Telegram::BotAPI->new(
|
|
token => $Secrets::TELEGRAM_TOKEN
|
|
);
|
|
|
|
my $myTele = $Secrets::TELEGRAM_USER_ID;
|
|
|
|
# We don't wanna double post the last thing we saw
|
|
my $last_update_id = 0;
|
|
my $irc = POE::Component::IRC->spawn(
|
|
Nick => $IRC_NICK,
|
|
Server => $IRC_SERVER,
|
|
Port => $IRC_PORT,
|
|
Ircname => 'Jerry',
|
|
) or die "Cannot spawn IRC component\n";
|
|
|
|
POE::Session->create(
|
|
package_states => [
|
|
main => [
|
|
qw(
|
|
_start
|
|
irc_001
|
|
irc_public
|
|
irc_msg
|
|
irc_disconnected
|
|
poll_telegram
|
|
)
|
|
],
|
|
],
|
|
);
|
|
|
|
$poe_kernel->run();
|
|
exit 0;
|
|
sub _start {
|
|
my ($kernel) = $_[KERNEL];
|
|
$irc->yield(register => 'all');
|
|
$irc->yield(connect => {});
|
|
# Poll Telegram every 2 seconds
|
|
$kernel->delay(poll_telegram => 2);
|
|
}
|
|
|
|
sub irc_001 {
|
|
# Connected
|
|
$irc->yield(join => $IRC_CHANNEL);
|
|
$irc->yield(privmsg => 'NickServ' => "IDENTIFY $NICKSERV_PASSWORD");
|
|
}
|
|
|
|
sub irc_public {
|
|
my ($who, $where, $what) = @_[ARG0, ARG1, ARG2];
|
|
my $nick = (split /!/, $who)[0];
|
|
my $channel = $where->[0];
|
|
return unless $channel eq $IRC_CHANNEL;
|
|
send_telegram("[$nick] $what");
|
|
}
|
|
|
|
sub irc_msg {
|
|
my ($who, $what) = @_[ARG0, ARG2];
|
|
my $nick = (split /!/, $who)[0];
|
|
send_telegram("[PM from $nick] $what");
|
|
}
|
|
|
|
sub irc_disconnected {
|
|
$irc->yield(connect => {});
|
|
}
|
|
|
|
sub poll_telegram {
|
|
my ($kernel) = $_[KERNEL];
|
|
my $updates = eval { $telegram->getUpdates({ offset => $last_update_id }) };
|
|
if ($@) {
|
|
warn "Telegram poll failed: $@";
|
|
} elsif ($updates && $updates->{ok}) {
|
|
for my $update (@{ $updates->{result} }) {
|
|
$last_update_id = $update->{update_id} + 1;
|
|
next unless $update->{message};
|
|
my $msg = $update->{message};
|
|
# Only allow the specific user
|
|
next unless $msg->{from}{id} == $myTele;
|
|
my $text = $msg->{text} // '';
|
|
next unless $text;
|
|
$irc->yield(privmsg => $IRC_CHANNEL => $text);
|
|
}
|
|
}
|
|
$kernel->delay(poll_telegram => 2);
|
|
}
|
|
|
|
sub send_telegram {
|
|
my ($text) = @_;
|
|
eval {
|
|
$telegram->sendMessage({
|
|
chat_id => $myTele,
|
|
text => $text,
|
|
});
|
|
};
|
|
warn "Failed to send telegram message: $@" if $@;
|
|
}
|