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/**

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,22 +165,21 @@ 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} = '';
 	}
 
 	my $csign = $m->{misc}->{csign};
 
-	if (defined $m->{misc}->{bot_nick}) {
+	if ($m->{misc}->{bot_nick} ne '') {
 		# Если нам сообщили ник бота, попробуем вымарать его из оригинального текста сообщения, в большинстве случаев он
 		# нам не интересн.
 		$phrase =~ s/\s*\,?\s*($m->{misc}->{bot_nick})\s*\,?\s*/ /gui;
@@ -251,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  => 0 + $userid,
-					chatid  => 0 + $chatid,
-					plugin  => $m->{plugin},
-					message => $reply,
-				},
+				$send_to => = $answer,
 			);
 		}
 	} else {
@@ -296,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  => 0 + $userid,
-						chatid  => 0 + $chatid,
-						plugin  => $m->{plugin},
-						message => $reply,
-					},
+					$send_to => $answer,
 				);
 
 				return;
@@ -321,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  => 0 + $userid,
-						chatid  => 0 + $chatid,
-						plugin  => $m->{plugin},
-						message => $reply,
-					},
+					$send_to => $answer,
 				);
 
 				return;
@@ -364,14 +356,10 @@ my $parse_message = sub {
 						}
 					}
 
+					$answer->{message} = $reply;
+
 					$self->json ($send_to)->notify (
-						$send_to => {
-							from    => 'craniac',
-							userid  => 0 + $userid,
-							chatid  => 0 + $chatid,
-							plugin  => $m->{plugin},
-							message => $reply,
-						},
+						$send_to => $answer,
 					);
 				}
 			}
@@ -447,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;