Use cloned version of incomming redis message as template for outgoing message

.gitignore

@@ -5,5 +5,7 @@ _Deparsed_XSubs.pm
 *.pid
 *.log
 data/cache/**
+data/brains/**
+data/lat/**
 data/config.json
 vendor_perl/**

.perlcriticrc

@@ -1,4 +1,19 @@
 #!/usr/bin/env perlcritic
+
+# Задействованные модули критика:
+#
+# Perl::Critic::More
+# Perl::Critic::Pulp
+# Perl::Critic::TooMuchCode
+# Perl::Critic::Lax
+# Perl::Critic::CognitiveComplexity
+# Perl::Critic::Policy::CompileTime
+# Perl::Critic::Policy::ProhibitImplicitImport
+# Perl::Critic::Policy::Dynamic::NoIndirect
+# Perl::Critic::StricterSubs
+# Perl::Critic::Policy::ProhibitImplicitImport
+# Perl::Critic::Policy::CodeLayout::RequireUseUTF8
+
 severity    = 5
 verbose     = 8
 

README

@@ -6,18 +6,18 @@ aleesa-craniac
 
 Механика работы
 -----------------------------------------------------------------------------------------------------------------------
-Бредогенератор подписан на redis-канал craniac. В этот канал пишет другой демоночек - aleesa-misc. Причём, особенность
-такова, что если aleesa-misc не распознала фразу, как команду для другого модуля, то по-умолчанию такая фраза
-оправляется в канал craniac, то есть сюда, в "мозги".
+Бредогенератор подписан на redis-канал craniac. В этот канал пишет другой демоночек - aleesa-misc-go. Причём,
+особенность такова, что если aleesa-misc не распознала фразу, как команду для другого модуля, то по-умолчанию такая
+фраза оправляется в канал craniac, то есть сюда, в "мозги".
 
 У бредогенератора есть 2 типа входящих сообщений - ключевые фразы, на которые у него есть готовые (статические) ответы
 и остальные, для которых ему надо решить нужен ли ответ и по-необходимости сгенерировать его, используя данные в цепях
 Маркова.
 
 Ответ направляется в redis-канал, указанный в поле plugin входящего сообщения, если не предполагается некоей особой
-логики, связанной с easter egg поведением.
+логики, связанной, наприме, с easter egg поведением.
 
-Формат протокола - см. README от aleesa-misc.
+Формат протокола - см. README от aleesa-misc-go.
 
 
 Как это запустить?

cpanfile

@@ -1,11 +1,13 @@
 ## no critic
 requires 'Carp',                 '==1.50';
+requires 'Clone',                '==0.45';
 requires 'Cwd',                  '==3.75';
 requires 'Cwd::utf8',            '==0.011';
 requires 'Data::Dumper',         '==2.183';
 requires 'Digest::SHA',          '==6.02';
 requires 'Encode',               '==3.16';
-requires 'English',              '==1.11';
+# Part of perl
+requires 'English',              '0';
 requires 'File::Basename',       '==2.85';
 requires 'File::Path',           '==2.18';
 requires 'File::Spec',           '==3.75';
@@ -16,7 +18,7 @@ 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.22';
+requires 'Mojolicious',          '==9.24';
 # Part of Mojolicious
 requires 'Mojo::IOLoop',         '0';
 requires 'Mojo::IOLoop::Signal', '==0.003';

data/config_sample.json

@@ -25,6 +25,9 @@
     # maximal amount of message forwardings, to avoid endless loops
     "forwards_max" : 5,
 
+    # Command prefix aka command sign
+    "csign" : "!",
+
 "lat" : {
         "brain" : "data/lat/brain.sqlite",
         "src" : "data/lat.txt"

lib/Craniac.pm

@@ -17,6 +17,7 @@ use open qw (:std :utf8);
 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);
@@ -134,6 +135,10 @@ sub brains (@) {
 my $parse_message = sub {
 	my $self = shift;
 	my $m    = shift;
+
+	my $answer = clone ($m);
+	$answer->{from} = 'craniac';
+
 	my $send_to = $m->{plugin};
 	my $chatid  = $m->{chatid};
 	my $userid  = $m->{userid};
@@ -160,56 +165,57 @@ my $parse_message = sub {
 		}
 
 		unless (defined $m->{misc}->{csign}) {
-			$m->{misc}->{csign} = '!';
+			$m->{misc}->{csign} = $c->{csign};
 		}
 
-		# TODO: не проставлять дефолтный ник!
 		unless (defined $m->{misc}->{bot_nick}) {
-			$m->{misc}->{bot_nick} = 'aleesa';
+			$m->{misc}->{bot_nick} = '';
 		}
 	} else {
 		$m->{misc}->{answer} = 1;
-		$m->{misc}->{csign} = '!';
-		$m->{misc}->{bot_nick} = 'aleesa';
+		$m->{misc}->{csign} = $c->{csign};
+		$m->{misc}->{bot_nick} = '';
 	}
 
-	if (defined $m->{misc}->{bot_nick}) {
+	my $csign = $m->{misc}->{csign};
+
+	if ($m->{misc}->{bot_nick} ne '') {
 		# Если нам сообщили ник бота, попробуем вымарать его из оригинального текста сообщения, в большинстве случаев он
 		# нам не интересн.
 		$phrase =~ s/\s*\,?\s*($m->{misc}->{bot_nick})\s*\,?\s*/ /gui;
 
 		# В ключевых фразах можно обратиться с некоторыми командами к боту по нику, не используя символ команды
-		if ($m->{message} =~ /^\s*\Q;m->{misc}->{bot_nick}\E\s*;/ui) {
+		if ($m->{message} =~ /^\s*\Q$m->{misc}->{bot_nick}\E\s*$/ui) {
 			$reply = 'Чего?';
-		} elsif ($m->{message} =~ /^(\Q$m->{misc}->{csign}\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)ping\.?\s*$/i) {
+		} elsif ($m->{message} =~ /^(\Q$csign\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)ping\.?\s*$/i) {
 			$reply = 'Pong.';
-		} elsif ($m->{message} =~ /^(\Q$m->{misc}->{csign}\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)pong\.?\s*$/i) {
+		} elsif ($m->{message} =~ /^(\Q$csign\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)pong\.?\s*$/i) {
 			$reply = 'Wat?';
-		} elsif ($m->{message} =~ /^(\Q$m->{misc}->{csign}\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)пин(г|х)\.?\s*$/ui) {
+		} elsif ($m->{message} =~ /^(\Q$csign\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)пин(г|х)\.?\s*$/ui) {
 			$reply = 'Понг.';
-		} elsif ($m->{message} =~ /^(\Q$m->{misc}->{csign}\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)пон(г|х)\.?\s*$/ui) {
+		} elsif ($m->{message} =~ /^(\Q$csign\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)пон(г|х)\.?\s*$/ui) {
 			$reply = 'Шта?';
-		} elsif ($m->{message} =~ /^(\Q$m->{misc}->{csign}\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)(хэлп|halp)\s*$/ui) {
+		} elsif ($m->{message} =~ /^(\Q$csign\E|\Q$m->{misc}->{bot_nick}\E\s*\,?\s+)(хэлп|halp)\s*$/ui) {
 			$reply = 'HALP!!!11';
 		}
 	} else {
 		# Если нам не сообщили ник бота, то ищем команды, используя символ команды
-		if ($m->{message} =~ /^\Q$m->{misc}->{csign}\Eping\.?\s*$/ui) {
+		if ($m->{message} =~ /^\Q$csign\Eping\.?\s*$/ui) {
 			$reply = 'Pong.';
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\Epong\.?\s*$/i) {
+		} elsif ($m->{message} =~ /^\Q$csign\Epong\.?\s*$/i) {
 			$reply = 'Wat?';
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\Eпин(г|х)\.?\s*$/ui) {
+		} elsif ($m->{message} =~ /^\Q$csign\Eпин(г|х)\.?\s*$/ui) {
 			$reply = 'Понг.';
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\Eпон(г|х)\.?\s*$/ui) {
+		} elsif ($m->{message} =~ /^\Q$csign\Eпон(г|х)\.?\s*$/ui) {
 			$reply = 'Шта?';
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\E(хэлп|halp)\s*$/ui) {
+		} elsif ($m->{message} =~ /^\Q$csign\E(хэлп|halp)\s*$/ui) {
 			$reply = 'HALP!!!11';
 		}
 	}
 
 	# Поищем в тексте входящего сообщения команды общего плана, с символом команды.
 	unless (defined $reply) {
- 		if ($m->{message} =~ /^\Q$m->{misc}->{csign}\E(kde|кде)\s*$/ui) {
+		if ($m->{message} =~ /^\Q$csign\E(kde|кде)\s*$/ui) {
 			my @phrases = (
 				'Нет, я не буду поднимать вам плазму.',
 				'Повторяйте эту мантру по утрам не менее 5 раз: "Плазма не падает." И, возможно, она перестанет у вас падать.',
@@ -218,7 +224,7 @@ my $parse_message = sub {
 			);
 
 			$reply = $phrases[irand ($#phrases + 1)];
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\E(coin|монетка)$/ui) {
+		} elsif ($m->{message} =~ /^\Q$csign\E(coin|монетка)$/ui) {
 			if (rand (101) < 0.016) {
 				$reply = 'ребро';
 			} else {
@@ -236,11 +242,11 @@ my $parse_message = sub {
 					}
 				}
 			}
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\E(roll|dice|кости')$/ui) {
+		} elsif ($m->{message} =~ /^\Q$csign\E(roll|dice|кости)$/ui) {
 			$reply = sprintf 'На первой кости выпало %d, а на второй — %d.', irand (6) + 1, irand (6) + 1;
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\E(ver|version|версия)$/ui) {
+		} elsif ($m->{message} =~ /^\Q$csign\E(ver|version|версия)$/ui) {
 			$reply = 'Версия:  Четыре.Технологическое_превью';
-		} elsif ($m->{message} =~ /^\Q$m->{misc}->{csign}\E(lat|лат)\s*$/ui) {
+		} elsif ($m->{message} =~ /^\Q$csign\E(lat|лат)\s*$/ui) {
 			$reply = Lat ();
 		}
 	}
@@ -249,14 +255,10 @@ my $parse_message = sub {
 	# общения - публичного или приватного.
 	if (defined $reply) {
 		if ($m->{misc}->{answer}) {
+			$answer->{message} = $reply;
+
 			$self->json ($send_to)->notify (
-				$send_to => {
-					from    => 'craniac',
-					userid  => $userid,
-					chatid  => $chatid,
-					plugin  => $m->{plugin},
-					message => $reply,
-				},
+				$send_to => = $answer,
 			);
 		}
 	} else {
@@ -294,14 +296,10 @@ my $parse_message = sub {
 
 			# TODO: дописать запрос в webapp, для easter egg-ов, либо делать это на уровне aleesa-misc
 			if (defined ($reply) && $m->{misc}->{answer}) {
+				$answer->{message} = $reply;
+
 				$self->json ($send_to)->notify (
-					$send_to => {
-						from    => 'craniac',
-						userid  => $userid,
-						chatid  => $chatid,
-						plugin  => $m->{plugin},
-						message => $reply,
-					},
+					$send_to => $answer,
 				);
 
 				return;
@@ -319,14 +317,10 @@ my $parse_message = sub {
 			}
 
 			if (defined ($reply) && $m->{misc}->{answer}) {
+				$answer->{message} = $reply;
+
 				$self->json ($send_to)->notify (
-					$send_to => {
-						from    => 'craniac',
-						userid  => $userid,
-						chatid  => $chatid,
-						plugin  => $m->{plugin},
-						message => $reply,
-					},
+					$send_to => $answer,
 				);
 
 				return;
@@ -362,14 +356,10 @@ my $parse_message = sub {
 						}
 					}
 
+					$answer->{message} = $reply;
+
 					$self->json ($send_to)->notify (
-						$send_to => {
-							from    => 'craniac',
-							userid  => $userid,
-							chatid  => $chatid,
-							plugin  => $m->{plugin},
-							message => $reply,
-						},
+						$send_to => $answer,
 					);
 				}
 			}
@@ -445,10 +435,8 @@ sub RunCraniac () {
 		);
 	}
 
-	Mojo::IOLoop::Signal->on (
-		TERM => $__signal_handler,
-		INT  => $__signal_handler,
-	);
+	Mojo::IOLoop::Signal->on (TERM => $__signal_handler);
+	Mojo::IOLoop::Signal->on (INT  => $__signal_handler);
 
 	do { Mojo::IOLoop->start } until Mojo::IOLoop->is_running;
 	return;