Compare commits
3 Commits
ouput_json
...
v1.4
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
dcb3204c9e | ||
|
|
e6d8e4c1a2 | ||
|
|
ca982571d9 |
7
cpanfile
7
cpanfile
@@ -5,7 +5,6 @@ requires 'Cwd', '==3.75';
|
||||
requires 'Cwd::utf8', '==0.011';
|
||||
requires 'Data::Dumper', '==2.183';
|
||||
requires 'Digest::SHA', '==6.02';
|
||||
requires 'Encode', '==3.16';
|
||||
# Part of perl
|
||||
requires 'English', '0';
|
||||
requires 'File::Basename', '==2.85';
|
||||
@@ -18,15 +17,13 @@ requires 'Log::Any', '==1.710';
|
||||
requires 'Log::Any::Adapter', '==1.710';
|
||||
requires 'Log::Any::For::Std', '==0.05';
|
||||
requires 'Math::Random::Secure', '==0.080001';
|
||||
requires 'Mojolicious', '==9.24';
|
||||
requires 'Mojolicious', '==9.26';
|
||||
# Part of Mojolicious
|
||||
requires 'Mojo::IOLoop', '0';
|
||||
requires 'Mojo::IOLoop::Signal', '==0.003';
|
||||
requires 'Mojo::Redis', '==3.27';
|
||||
requires 'Mojo::Redis', '==3.29';
|
||||
# Part of perl
|
||||
requires 'POSIX', '0';
|
||||
# Buggy, latest version works, as pub-sub, but fails tests
|
||||
requires 'Protocol::Redis::XS', '0';
|
||||
requires 'Text::Fuzzy', '==0.29';
|
||||
# Part of perl
|
||||
requires 'utf8', '0';
|
||||
|
||||
@@ -19,15 +19,12 @@ use English qw ( -no_match_vars );
|
||||
# Модули для работы приложения
|
||||
use Clone qw (clone);
|
||||
use Data::Dumper qw (Dumper);
|
||||
use Digest::SHA qw (sha1_base64);
|
||||
use Encode qw (encode_utf8);
|
||||
use Digest::SHA qw (sha256_hex);
|
||||
use File::Spec ();
|
||||
use Hailo ();
|
||||
use Log::Any qw ($log);
|
||||
use Mojo::IOLoop ();
|
||||
use Mojo::IOLoop::Signal ();
|
||||
# Чтобы "уж точно" использовать hiredis-биндинги, загрузим этот модуль перед Mojo::Redis
|
||||
use Protocol::Redis::XS ();
|
||||
use Mojo::Redis ();
|
||||
use Math::Random::Secure qw (irand);
|
||||
use Text::Fuzzy qw (distance_edits);
|
||||
@@ -40,7 +37,6 @@ use Exporter qw (import);
|
||||
our @EXPORT_OK = qw (RunCraniac);
|
||||
|
||||
sub RandomCommonPhrase ();
|
||||
sub utf2sha1 ($);
|
||||
sub fmatch (@);
|
||||
sub brains (@);
|
||||
sub RunCraniac ();
|
||||
@@ -69,17 +65,6 @@ sub RandomCommonPhrase () {
|
||||
return $myphrase[irand ($#myphrase + 1)];
|
||||
}
|
||||
|
||||
sub utf2sha1 ($) {
|
||||
my $string = shift;
|
||||
|
||||
if ($string eq '') {
|
||||
return sha1_base64 '';
|
||||
}
|
||||
|
||||
my $bytes = encode_utf8 $string;
|
||||
return sha1_base64 $bytes;
|
||||
}
|
||||
|
||||
sub fmatch (@) {
|
||||
my $srcphrase = shift;
|
||||
my $answer = shift;
|
||||
@@ -97,30 +82,27 @@ sub fmatch (@) {
|
||||
|
||||
# Ленивая инициализация мозга. Создаём/открываем мозг только если нам надо "подумать" а не на каждую входящую фразу.
|
||||
sub brains (@) {
|
||||
my $chatid = shift;
|
||||
my $telegram = shift // 0;
|
||||
my $plugin = shift;
|
||||
my $cid = shift;
|
||||
|
||||
unless (defined $hailo->{$chatid}) {
|
||||
my $cid = $chatid;
|
||||
unless (defined $hailo->{$cid}) {
|
||||
my $brainname;
|
||||
|
||||
# Костыль, чтобы не портировать данные из телеграммных мозгов и не заниматься переименованием
|
||||
unless ($telegram) {
|
||||
$cid = utf2sha1 ($chatid);
|
||||
$cid =~ s/\//-/xmsg;
|
||||
$brainname = sprintf '%s/%s.sqlite', $c->{braindir}, $cid;
|
||||
} else {
|
||||
if ($plugin eq 'telegram') {
|
||||
$brainname = sprintf '%s/%s.brain.sqlite', $c->{braindir}, $cid;
|
||||
} else {
|
||||
$brainname = sprintf '%s/%s.sqlite', $c->{braindir}, $cid;
|
||||
}
|
||||
|
||||
$hailo->{$chatid} = eval {
|
||||
$hailo->{$cid} = eval {
|
||||
Hailo->new (
|
||||
brain => $brainname,
|
||||
order => 3,
|
||||
);
|
||||
};
|
||||
|
||||
if (defined $hailo->{$chatid}) {
|
||||
if (defined $hailo->{$cid}) {
|
||||
$log->info (sprintf '[INFO] Lazy init brain: %s', $brainname);
|
||||
} else {
|
||||
$log->error ("[ERROR] $EVAL_ERROR");
|
||||
@@ -358,19 +340,20 @@ my $parse_message = sub {
|
||||
}
|
||||
|
||||
# Попадаем сюда только если входящая фраза не распознана ранее как ключевая.
|
||||
my $cid;
|
||||
|
||||
if ($m->{plugin} eq 'telegram') {
|
||||
$cid = $chatid;
|
||||
} else {
|
||||
$cid = sha256_hex (sprintf '%s/%s', $m->{plugin}, $chatid);
|
||||
}
|
||||
|
||||
if ($m->{misc}->{answer}) {
|
||||
# Пытаемся что-то генерировать, если фраза длиннее 3-х букв.
|
||||
if (length ($m->{message}) > 3) {
|
||||
my $telegram = 0;
|
||||
|
||||
# Костыль для совместимости со старым наименованием "мозгов".
|
||||
if ($m->{plugin} eq 'telegram') {
|
||||
$telegram = 1;
|
||||
}
|
||||
|
||||
# Lazy brain init
|
||||
if (brains ($chatid, $telegram)) {
|
||||
$reply = $hailo->{$chatid}->learn_reply ($m->{message});
|
||||
if (brains ($m->{plugin}, $cid)) {
|
||||
$reply = $hailo->{$cid}->learn_reply ($m->{message});
|
||||
|
||||
# Если из реактора вернулся undef выдаём "общую" фразу из словаря.
|
||||
unless (defined $reply) {
|
||||
@@ -397,14 +380,9 @@ my $parse_message = sub {
|
||||
} else {
|
||||
# Пытаемся что-то запоминать, если фраза длиннее 3-х букв
|
||||
if (length ($m->{message}) > 3) {
|
||||
my $telegram = 0;
|
||||
|
||||
if ($m->{plugin} eq 'telegram') {
|
||||
$telegram = 1;
|
||||
}
|
||||
|
||||
if (brains ($chatid, $telegram)) {
|
||||
$hailo->{$chatid}->learn ($m->{message});
|
||||
# Lazy brain init
|
||||
if (brains ($m->{plugin}, $cid)) {
|
||||
$hailo->{$cid}->learn ($m->{message});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user