134 lines
3.4 KiB
Perl
134 lines
3.4 KiB
Perl
package RedisLib;
|
|
|
|
use 5.018; ## no critic (ProhibitImplicitImport)
|
|
use strict;
|
|
use warnings;
|
|
use utf8;
|
|
use open qw (:std :utf8);
|
|
|
|
use Data::Dumper qw (Dumper);
|
|
use Log::Any qw ($log);
|
|
use Mojo::Redis ();
|
|
use Mojo::Redis::Connection ();
|
|
|
|
use BotLib::Conf qw (LoadConf);
|
|
use Teapot::Bot::Object::ChatPermissions ();
|
|
|
|
use version; our $VERSION = qw (1.0);
|
|
use Exporter qw (import);
|
|
our @EXPORT_OK = qw (redis_parse_message redis_events_listener);
|
|
|
|
my $c = LoadConf ();
|
|
|
|
sub redis_parse_message {
|
|
my $self = shift;
|
|
my $m = shift;
|
|
my $message;
|
|
|
|
$log->debug ('Incoming redis message: ' . Dumper $m);
|
|
|
|
# Мы "не можем" отправлять сообщения в телеграм, если мы к нему не подключены
|
|
# (конечно, можем, но Teapot-lib предполагает, что объектик с чатом - это его собственность, а городить свой что-то
|
|
# не очень хочется)
|
|
until (defined $main::TGM) {
|
|
sleep 1;
|
|
}
|
|
|
|
if ($m->{misc}->{msg_format}) {
|
|
$message->{parse_mode} = 'Markdown';
|
|
}
|
|
|
|
$message->{chat_id} = eval { 0 + $m->{chatid}; };
|
|
|
|
unless (defined $message->{chat_id}) {
|
|
$log->error ('Incoming redis message is incorrect: chat id must be numeric value!');
|
|
return;
|
|
}
|
|
|
|
if ($message->{chat_id} == 0) {
|
|
$log->error ('Incoming redis message is incorrect: chat id must not be equal 0!');
|
|
return;
|
|
}
|
|
|
|
$message->{text} = "$m->{message}";
|
|
if (defined ($m->{threadid}) && $m->{threadid} ne '') {
|
|
$message->{message_thread_id} = 0 + $m->{threadid};
|
|
}
|
|
|
|
my $can_talk = Teapot::Bot::Object::ChatPermissions->canTalk ($main::TGM, 0 + $m->{chatid});
|
|
|
|
if ($can_talk) {
|
|
# Результат этого действия нас не сильно волнует, т.к. если будет ошибка, то в лог попадёт трейс
|
|
my $r = $main::TGM->sendMessage ($message);
|
|
|
|
if ($r->{error}) {
|
|
$log->error ("An error occured while sending message to chat $m->{chatid}");
|
|
}
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
sub redis_events_listener {
|
|
$log->notice ('[NOTICE] Run redis events listener');
|
|
# If we already connected there is no point to disconnect
|
|
if (defined $main::REDIS) {
|
|
my $connected = eval { Mojo::Redis::Connection->is_connected ($main::REDIS); };
|
|
|
|
if ($connected) {
|
|
$log->notice ('[NOTICE] Redis client already running and connected');
|
|
return;
|
|
} else {
|
|
$log->notice ('[NOTICE] Redis client registered, but looks like it is not connected, try to re-connect');
|
|
$main::REDIS = undef;
|
|
}
|
|
}
|
|
|
|
my $r = Mojo::Redis->new (
|
|
sprintf 'redis://%s:%s/1', $c->{redis_server}, $c->{redis_port},
|
|
);
|
|
|
|
$log->notice ('[NOTICE] New redis client registered, registering callbacks');
|
|
# Don't forget to update global ref to our redis context
|
|
$main::REDIS = $r;
|
|
|
|
$r->on (
|
|
connection => sub {
|
|
my ($redis, $connection) = @_;
|
|
$main::RCONN = $connection;
|
|
|
|
# Log error
|
|
$connection->on (
|
|
error => sub {
|
|
my ($conn, $error) = @_;
|
|
$log->error ("[ERROR] Redis connection error: $error");
|
|
$main::RCONN = undef;
|
|
return;
|
|
},
|
|
);
|
|
|
|
return;
|
|
},
|
|
);
|
|
|
|
# Subscribe to channels
|
|
my $pubsub = $r->pubsub;
|
|
my $sub;
|
|
my $rpm = \&redis_parse_message;
|
|
$log->notice ('[NOTICE] Subscribing to redis channels');
|
|
|
|
foreach my $channel (@{$c->{redis_channels}}) {
|
|
$log->info ("[INFO] Subscribing to $channel");
|
|
|
|
$sub->{$channel} = $pubsub->json ($channel)->listen (
|
|
$channel => sub { $rpm->(@_); },
|
|
);
|
|
}
|
|
|
|
return;
|
|
}
|
|
|
|
1;
|
|
|
|
# vim: set ft=perl noet ai ts=4 sw=4 sts=4:
|