initial commit
|
1 |
#!/usr/bin/perl |
2 | ||
3 |
use strict; |
|
4 |
use warnings; |
|
5 | ||
6 |
use Net::XMPP; |
|
7 |
use DBI; |
|
8 |
use POSIX qw/ceil strftime/; |
|
9 | ||
10 |
use open ':utf8'; |
|
11 |
use open ':std'; |
|
12 |
use utf8; |
|
13 |
#use Data::Dumper; |
|
14 | ||
15 |
use threads; |
|
16 |
use threads::shared; |
|
17 |
use Thread::Queue; |
|
18 | ||
remplacement de nom de varia...
|
19 |
$ENV{PWD} = "" if not defined $ENV{PWD}; |
initial commit
|
20 |
my $scriptconf = $ENV{PWD} . "/$0"; |
21 |
$scriptconf =~ s/\.pl$//; |
|
22 |
$scriptconf =~ s/$/.conf/; |
|
23 |
if (-r $scriptconf) { |
|
24 |
package cfg; |
|
25 |
unless (my $return = do $scriptconf) { |
|
26 |
warn "couldn't parse $scriptconf: $@" if $@; |
|
27 |
warn "couldn't do $scriptconf: $!" unless defined $return; |
|
28 |
warn "couldn't run $scriptconf" unless $return; |
|
29 |
} |
|
30 |
} |
|
31 |
else { |
|
32 |
print "pas de config\n"; |
|
33 |
exit; |
|
34 |
} |
|
35 | ||
36 |
$SIG{INT}=\&terminate; |
|
37 |
#my $next_sms :shared; # utilisé pour le top du procahin envoi |
|
38 |
my $debugLevel = 0; |
|
39 | ||
remplacement de nom de varia...
|
40 |
my $phone_status : shared = ""; |
initial commit
|
41 | |
42 |
my $from_gtalksms_queue = Thread::Queue->new; |
|
43 |
my $to_gtalksms_queue = Thread::Queue->new; |
|
44 |
my $mail_queue = Thread::Queue->new; |
|
45 | ||
46 |
my $bot = &xmpp_login($cfg::config{xmpp}->{hostName}, |
|
47 |
$cfg::config{xmpp}->{portNumber}, |
|
48 |
$cfg::config{xmpp}->{userName}, |
|
49 |
$cfg::config{xmpp}->{passWord}, |
|
50 |
$cfg::config{xmpp}->{componentName}, |
|
51 |
$cfg::config{xmpp}->{resource}, |
|
52 |
$cfg::config{xmpp}->{tls}, |
|
53 |
1, "", 0, |
|
54 |
$cfg::config{DEBUG}); |
|
55 | ||
56 |
$SIG{INT} = sub { $bot->Disconnect; }; |
|
57 | ||
58 |
my $mail = threads->new(\&ssmtp_send_mail); |
|
59 | ||
60 |
my $from_gtalksms = threads->new(\&from_gtalksms_parse); |
|
61 | ||
62 |
my $to_gtalksms = threads->new(\&xmpp_send_sms); |
|
63 | ||
64 |
sub debug_print { |
|
65 |
print STDERR "sendxmpp: " . (join ' ', @_) . "\n" |
|
66 |
if (@_ && ($cfg::config{DEBUG} ||$cfg::config{VERBOSE})); |
|
67 |
} |
|
68 | ||
69 |
sub log_bot { |
|
70 |
# open(LOGFILE,'>>', 'bot.log'); |
|
71 |
# print LOGFILE sprintf("[%s] %s\n",strftime("%Y-%m-%d %H:%M:%S", localtime), shift); |
|
72 |
print sprintf("[%s] %s\n",strftime("%Y-%m-%d %H:%M:%S", localtime), shift); |
|
73 |
# close LOGFILE; |
|
74 |
} |
|
75 | ||
76 |
sub xmpp_logout($) { |
|
77 |
# HACK |
|
78 |
# messages may not be received if we log out too quickly... |
|
79 |
sleep 1; |
|
80 | ||
81 |
my $cnx = shift; |
|
82 |
$cnx->Disconnect(); |
|
83 |
xmpp_check_result ('Disconnect',0); # well, nothing to check, really |
|
84 |
} |
|
85 | ||
86 |
sub terminate () { |
|
87 |
my $cnx = shift; |
|
88 |
debug_print "caught TERM"; |
|
89 |
xmpp_logout($cnx); |
|
90 |
exit 0; |
|
91 |
} |
|
92 | ||
93 |
sub error_exit { |
|
94 |
my ($err,$cnx) = @_; |
|
95 |
print STDERR "$err\n"; |
|
96 |
xmpp_logout ($cnx) |
|
97 |
if ($cnx); |
|
98 |
exit 1; |
|
99 |
} |
|
100 | ||
101 |
sub xmpp_check_result { |
|
102 |
my ($txt, $res, $cnx)=@_; |
|
103 | ||
104 |
error_exit ("Error '$txt': result undefined") |
|
105 |
unless (defined $res); |
|
106 | ||
107 |
# res may be 0 |
|
108 |
if ($res == 0) { |
|
109 |
debug_print "$txt"; |
|
110 |
# result can be true or 'ok' |
|
111 |
} |
|
112 |
elsif ((@$res == 1 && $$res[0]) || $$res[0] eq 'ok') { |
|
113 |
debug_print "$txt: " . $$res[0]; |
|
114 |
# otherwise, there is some error |
|
115 |
} |
|
116 |
else { |
|
117 |
my $errmsg = $cnx->GetErrorCode() || '?'; |
|
118 |
error_exit ("Error '$txt': " . join (': ',@$res) . "[$errmsg]", $cnx); |
|
119 |
} |
|
120 |
} |
|
121 | ||
122 |
sub xmpp_login ($$$$$$$$$$$) { |
|
123 |
my ($host, $port, $user, $pw, $comp, $res, $tls, $no_tls_verify, $tls_ca_path, $ssl, $debug) = @_; |
|
124 |
my $cnx = new Net::XMPP::Client(debuglevel=>0); |
|
125 |
error_exit "could not create XMPP client object: $!" unless ($cnx); |
|
126 | ||
127 |
my $ssl_verify = 0x01; |
|
128 |
if ($no_tls_verify) { $ssl_verify = 0x00; } |
|
129 |
debug_print "ssl_verify: $ssl_verify"; |
|
130 | ||
131 |
debug_print "tls_ca_path: $tls_ca_path"; |
|
132 | ||
133 |
my @res; |
|
134 |
my $arghash = { |
|
135 |
hostname => $host, |
|
136 |
port => $port, |
|
137 |
tls => $tls, |
|
138 |
ssl_verify => $ssl_verify, |
|
139 |
ssl_ca_path => $tls_ca_path, |
|
140 |
ssl => $ssl, |
|
141 |
connectiontype => 'tcpip', |
|
142 |
componentname => $comp |
|
143 |
}; |
|
144 | ||
145 |
delete $arghash->{port} unless $port; |
|
146 |
if ($arghash->{port}) { |
|
147 |
@res = $cnx->Connect(%$arghash); |
|
148 |
error_exit ("Could not connect to '$host' on port $port: $@") unless @res; |
|
149 |
} else { |
|
150 |
@res = $cnx->Connect(%$arghash); |
|
151 |
error_exit ("Could not connect to server '$host': $@") unless @res; |
|
152 |
} |
|
153 | ||
154 |
xmpp_check_result("Connect",\@res,$cnx); |
|
155 | ||
156 |
if ($comp) { |
|
157 |
my $sid = $cnx->{SESSION}->{id}; |
|
158 |
$cnx->{STREAM}->{SIDS}->{$sid}->{hostname} = $comp |
|
159 |
} |
|
160 | ||
161 |
@res = $cnx->AuthSend(#'hostname' => $host, |
|
162 |
'username' => $user, |
|
163 |
'password' => $pw, |
|
164 |
'resource' => $res); |
|
165 |
xmpp_check_result('AuthSend',\@res,$cnx); |
|
166 | ||
167 |
return $cnx; |
|
168 |
} |
|
169 | ||
170 |
sub sql_request ($) { |
|
171 |
my $request = shift; |
|
172 |
my @result; |
|
173 |
my $dbh = DBI->connect($cfg::config{db}->{driver}, $cfg::config{db}->{user}, $cfg::config{db}->{password}, {'RaiseError' => 1}); |
|
174 |
$dbh->{'mysql_enable_utf8'} = 1; |
|
175 |
$dbh->do(qq{SET NAMES "utf8"}); |
|
176 |
my $sth = $dbh->prepare($request); |
|
177 |
$sth->execute(); |
|
178 |
if (defined($sth->{NUM_OF_FIELDS})) { |
|
179 |
while (my $ref = $sth->fetchrow_hashref()) { |
|
180 |
push @result, $ref; |
|
181 |
} |
|
182 |
} |
|
183 |
$sth->finish(); |
|
184 |
$dbh->disconnect(); |
|
185 |
return @result; |
|
186 |
} |
|
187 | ||
188 |
sub massive_send_sms { |
|
189 |
my $request = shift; |
|
190 |
my @results = sql_request("SELECT * FROM __tables__ WHERE phone = '$request->{phone}' AND table_id = '$request->{table}'"); |
|
191 |
if (scalar(@results) == 1) { |
|
192 |
my @results = sql_request("SELECT * FROM $request->{table}"); |
|
193 |
my $start_msg = "envoi de " . scalar(@results) . " SMS (30 max par demi-heure)"; |
|
194 |
$to_gtalksms_queue->enqueue([$request->{phone}, $start_msg]); |
|
195 |
foreach my $contact (@results) { |
|
196 |
$contact->{phone} =~ s/[\s\.]//g; |
|
197 |
$_ = $request->{body}; |
|
198 |
s/\@prénom/$contact->{firstname}/g; |
|
199 |
if ($contact->{gender} eq 'F') { |
|
200 |
s/\@\(\s*(\w+)\s*,\s*\w+\s*\)/$1/g; |
|
201 |
} |
|
202 |
else { |
|
203 |
s/\@\(\s*\w+\s*,\s*(\w+)\s*\)/$1/g; |
|
204 |
} |
|
205 |
$to_gtalksms_queue->enqueue([$contact->{phone}, $_]) |
|
206 |
} |
|
207 |
$to_gtalksms_queue->enqueue([$request->{phone}, "envoi des SMS terminé !"]); |
|
208 |
} |
|
209 |
else { |
|
210 |
$to_gtalksms_queue->enqueue([$request->{phone}, "pas la bonne base $request->{table} pour $request->{phone}"]); |
|
211 |
} |
|
212 |
} |
|
213 | ||
214 |
sub control_sms_flow { |
|
215 |
my ($body, $max, $interval) = @_; |
|
216 |
my $flow_control="/home/sms/flow.control"; |
|
217 |
# use bytes; # les caractères UTF-8 peuvent être codés sur plus d'un octet |
|
218 |
# my $nbr = ceil(length($$body)/140); # taille d'un SMS 140 octets |
|
219 |
my $nbr = 1; |
|
220 |
# no bytes; |
|
221 |
while (1) { |
|
222 |
my $left = $max; |
|
223 |
my $t = time; |
|
224 |
open (FILE, "<", $flow_control); |
|
225 |
my @lines = <FILE>; |
|
226 |
close FILE; |
|
227 |
open(FILE, ">", $flow_control); |
|
228 |
foreach my $line (@lines) { |
|
229 |
$line =~ /(\d+)/; |
|
230 |
my $ts = $1; |
|
231 |
if ($ts + $interval > $t) { |
|
232 |
$left--; |
|
233 |
print FILE $line; |
|
234 |
} |
|
235 |
} |
|
236 |
close FILE; |
|
237 |
log_bot(" ---> to send: $nbr; left: $left"); |
|
238 |
last if $nbr < $left; |
|
temps d'attente aléatoire en...
|
239 |
sleep 60; |
initial commit
|
240 |
} |
241 |
open (FILE,">>", $flow_control); |
|
242 |
for (my $i = 0; $i < $nbr; $i++) { print FILE time, "\n"; } |
|
243 |
close FILE; |
|
244 |
} |
|
245 | ||
246 |
sub xmpp_send { |
|
247 |
my $msg = shift; |
|
248 |
$bot->MessageSend( |
|
remplacement de nom de varia...
|
249 |
to => $cfg::config{xmpp}->{phoneBuddy}, |
initial commit
|
250 |
from => $cfg::config{xmpp}->{userName} . "@" . $cfg::config{xmpp}->{hostName}, |
251 |
resource => $cfg::config{xmpp}->{resource}, |
|
252 |
type => 'chat', |
|
253 |
body => $$msg |
|
254 |
); |
|
255 |
} |
|
256 | ||
257 |
sub ssmtp_send_mail { |
|
258 |
while (my $request = $mail_queue->dequeue) { |
|
259 |
defined($request->{to}) or $request->{to} = $cfg::config{mail}; |
|
260 |
open(MAIL, "|/usr/lib/sendmail -t"); |
|
261 |
print MAIL "Subject: $request->{subject}\n"; |
|
262 |
print MAIL "To: $request->{to}\n"; |
|
possibilité de répondre par ...
|
263 |
print MAIL "Reply-To: $request->{email}\n" if ($request->{email} ne ''); |
initial commit
|
264 |
print MAIL "$request->{body}\n"; |
265 |
close(MAIL); |
|
266 |
log_bot("mail envoyé à $request->{to}"); |
|
267 |
} |
|
268 |
} |
|
269 | ||
270 |
sub wait_open_time ($$) { |
|
271 |
my ($close_hour, $open_hour) = @_; |
|
272 |
while (strftime('%H', localtime) > $close_hour or strftime('%H', localtime) < $open_hour) { |
|
273 |
sleep 1800; |
|
274 |
} |
|
275 |
} |
|
276 | ||
277 |
sub xmpp_send_sms { |
|
278 |
while (my $ref = $to_gtalksms_queue->dequeue) { |
|
279 |
wait_open_time(21, 8); # pas d'envoi entre 21h et 8h |
|
280 |
# TODO lock($next_sms); |
|
281 |
# TODO $next_sms = $$ref[0]; |
|
temps d'attente aléatoire en...
|
282 |
# control_sms_flow(\$$ref[1], 30, 1800); # pas plus de 30 messages de 140 caractères par demi-heure |
initial commit
|
283 |
xmpp_send(\"sms:$$ref[0]:$$ref[1]"); |
284 |
log_bot("envoi à $$ref[0] : $$ref[1]"); |
|
temps d'attente aléatoire en...
|
285 |
sleep 60 + int(rand(30)); # en attendant la maîtrise de cond_wait et cond_signal: cond_signal() called on unlocked variable at ./bot line 348 |
initial commit
|
286 |
# TODO cond_wait($next_sms); # attend le top |
287 |
} |
|
288 |
} |
|
289 | ||
290 |
sub is_authorized { |
|
sms/action: envoi du mail de...
|
291 |
my ($request) = @_; |
292 |
my @results = sql_request("SELECT * FROM __authorized__ WHERE phone = '$request->{phone}'"); |
|
293 |
if (scalar(@results) == 1) { |
|
294 |
$request->{address} = $results[0]->{address}; |
|
295 |
return 1; |
|
296 |
} |
|
297 |
else { |
|
298 |
return 0; |
|
299 |
} |
|
initial commit
|
300 |
} |
301 | ||
302 |
sub authorized_on_table { |
|
303 |
my %request = @_; |
|
304 |
$request{writeable} = (defined($request{writeable})) ? "AND write_auth = '1'" : ""; |
|
305 |
my @results = sql_request("SELECT * FROM __tables__ WHERE table_id = '$request{table}' AND phone = '$request{id}' $request{writeable}"); |
|
306 |
if (scalar(@results) == 0) { |
|
307 |
my @list = sql_request("SELECT * FROM __tables__ WHERE phone = '$request{id}'"); |
|
308 |
my $list_str = ""; |
|
309 |
foreach (@list) { |
|
310 |
$list_str .= "\n- $_->{table_id}"; |
|
311 |
} |
|
312 |
${$request{error}} = sprintf("%s%s%s%s", |
|
313 |
"désolé, $request{table} n'est pas autorisé pour toi", |
|
314 |
($request{writeable} ne "")? " en écriture" : "", |
|
315 |
"... ou n'existe pas:", |
|
316 |
$list_str); |
|
317 |
} |
|
318 |
return (scalar(@results) == 1); |
|
319 |
} |
|
320 | ||
321 |
sub is_table { |
|
322 |
my %request = @_; |
|
323 |
my @results = sql_request("SHOW TABLES WHERE Tables_in_sms = '$request{table}'"); |
|
324 |
if (scalar(@results) == 0) { |
|
325 |
${$request{error}} = "$request{table} n'existe pas... essaie la commande 'liste' pour voir tes tables"; |
|
326 |
} |
|
327 |
return (scalar(@results) == 1); |
|
328 |
} |
|
329 | ||
330 |
sub copy { |
|
331 |
my $request = shift; |
|
332 |
my $rmsg = ""; |
|
333 |
if (authorized_on_table(table => $request->{origin}, id => $request->{phone}, error => \$rmsg)) { |
|
334 |
if (! is_table(table => $request->{destination}, error => \$rmsg)) { |
|
335 |
sql_request("CREATE TABLE $request->{destination} SELECT * FROM $request->{origin}"); |
|
336 |
sql_request("INSERT INTO __tables__ (phone,table_id,creation_date,update_date,comment,write_auth) values('" |
|
337 |
. $request->{phone} . "','" |
|
338 |
. $request->{destination} . "','" |
|
339 |
. strftime("%Y-%m-%d %H:%M:%S", localtime) . "','" |
|
340 |
. strftime("%Y-%m-%d %H:%M:%S", localtime) . "','" |
|
341 |
. $request->{comment} . "','1')" |
|
342 |
); |
|
343 |
$rmsg = "copie de $request->{origin} vers $request->{destination} faite"; |
|
344 |
} |
|
345 |
else { # on change le message d'erreur fourni par is_table() |
|
346 |
$rmsg = "$request->{destination} existe déjà !"; |
|
347 |
} |
|
348 |
} |
|
349 |
$to_gtalksms_queue->enqueue([$request->{phone}, $rmsg]); |
|
350 |
} |
|
351 | ||
352 |
sub insert { |
|
353 |
my $request = shift; |
|
354 |
my $rmsg = ""; |
|
355 |
if (authorized_on_table(table => $request->{table}, id => $request->{phone}, writeable => 1, error => \$rmsg)) { |
|
356 |
my $contact_number = 0; |
|
357 |
foreach my $contact (split("\n", $request->{body})) { |
|
358 |
my ($firstname, $lastname, $phone, $gender) = split(";", $contact); |
|
359 |
sql_request("INSERT INTO $request->{table} (firstname,lastname,phone,gender) values ($firstname, $lastname, $phone, $gender)"); |
|
360 |
$contact_number++; |
|
361 |
} |
|
362 |
$rmsg = "$contact_number contacts ajoutés dans $request->{table}" |
|
363 |
} |
|
364 |
$to_gtalksms_queue->enqueue([$request->{phone}, $rmsg]); |
|
365 |
} |
|
366 | ||
367 |
sub react_on_message { |
|
368 |
my ($hashref , $request) = @_; |
|
369 |
for my $regex (keys(%$hashref)) { |
|
370 |
if ($request->{body} =~ m/$regex/i) { |
|
371 |
$request->{body} =~ s/$regex//i; |
|
372 |
$hashref->{$regex}(); |
|
373 |
return 1; # true |
|
374 |
} |
|
375 |
} |
|
376 |
return 0; # false |
|
377 |
} |
|
378 | ||
379 |
sub messageCB { |
|
380 |
my ($sid, $msg) = @_; |
|
381 |
$from_gtalksms_queue->enqueue($msg) if $msg->DefinedBody(); |
|
382 |
} |
|
383 | ||
384 |
sub from_gtalksms_parse { |
|
385 |
while (my $msg = $from_gtalksms_queue->dequeue) { |
|
386 |
my %request = (body => $msg->GetBody); |
|
387 |
my %part_from_gtalksms = ( |
|
passage des regex dans le fi...
|
388 |
$cfg::gtalksms{"from"} => sub { # Message de +33612345678 : |
initial commit
|
389 |
$request{phone} = "0" . $1; |
390 |
$request{phone_owner} = ''; |
|
possibilité de répondre par ...
|
391 |
$request{email} = ''; |
initial commit
|
392 |
my @results = sql_request("SELECT * FROM section WHERE phone = '$request{phone}'"); |
393 |
my $number_of_candidates = @results; |
|
394 |
$number_of_candidates == 0 and return; |
|
395 |
$request{phone_owner} .= '('; |
|
396 |
foreach (@results) { |
|
397 |
$request{phone_owner} .= "$_->{firstname} $_->{lastname}"; |
|
398 |
--$number_of_candidates > 0 and $request{phone_owner} .= ' ou '; |
|
possibilité de répondre par ...
|
399 |
$request{email} = $_->{email}; |
initial commit
|
400 |
} |
passage des regex dans le fi...
|
401 |
$request{"phone_owner"} .= ')'; |
initial commit
|
402 |
log_bot("message de $request{phone} $request{phone_owner}"); |
403 |
}, |
|
passage des regex dans le fi...
|
404 |
$cfg::gtalksms{"delivered"} => sub { # SMS "un contenu de SMS" pour 0612345678 délivré. |
initial commit
|
405 |
log_bot("message $1 délivré pour $2"); |
406 |
# TODO cond_signal($next_sms); |
|
407 |
}, |
|
passage des regex dans le fi...
|
408 |
$cfg::gtalksms{forget} => sub { # Le destinataire par défaut est 0612345678: inutile |
initial commit
|
409 |
return; |
410 |
}, |
|
411 |
); |
|
signal d'envoi immédiat du m...
|
412 | |
413 |
my %sms_action = ( |
|
414 |
"create flag" => sub { |
|
415 |
my ($flag) = @_; |
|
416 |
my $gid = getgrnam("sms-action"); |
|
417 |
mkdir $cfg::sms_action{flagdir}; |
|
418 |
chmod 0770, $cfg::sms_action{flagdir}; |
|
419 |
chown $>, $gid, $cfg::sms_action{flagdir}; |
|
420 | ||
421 |
open(FLAG, ">" . $cfg::sms_action{flagdir} . "/" . $cfg::sms_action{flag}); |
|
422 |
chmod 0660, $cfg::sms_action{flagdir} . "/" . $cfg::sms_action{flag}; |
|
423 |
chown $>, $gid, $cfg::sms_action{flagdir} . "/" . $cfg::sms_action{flag}; |
|
424 | ||
425 |
print FLAG $$flag if defined $flag; |
|
426 |
close FLAG; |
|
427 |
}, |
|
428 |
"start action" => sub { |
|
429 |
# 0 = false |
|
430 |
return ! system("sudo /bin/systemctl start action.service"); |
|
431 |
}, |
|
432 |
"get locker" => sub { |
|
433 |
open FLAG, $cfg::sms_action{flagdir} . "/" . $cfg::sms_action{flag}; |
|
434 |
my $locker = ''; |
|
435 |
my $intro_ = ''; |
|
436 |
while (<FLAG>) { |
|
437 |
if (/^firstname:(.+)$/) { |
|
438 |
$locker = " par " . $1; |
|
439 |
} |
|
440 |
if (/^intro:(.+)$/) { |
|
441 |
$intro_ = " de test ($1)"; |
|
442 |
} |
|
443 |
} |
|
444 |
close FLAG; |
|
445 |
return "l'envoi " . $intro_ . " est déjà prévu" . $locker . ", abandon"; |
|
446 |
}, |
|
447 |
); |
|
448 | ||
initial commit
|
449 |
my %part_from_user = ( |
passage des regex dans le fi...
|
450 |
$cfg::user{"stop"} => sub { |
initial commit
|
451 |
log_bot("arrêt demandé par $request{phone} $request{phone_owner}"); |
452 |
$bot->Disconnect(); |
|
453 |
}, |
|
passage des regex dans le fi...
|
454 |
$cfg::user{"message de groupe"} => sub { |
initial commit
|
455 |
$request{table} = lc $1; |
456 |
&massive_send_sms(\%request); |
|
457 |
}, |
|
passage des regex dans le fi...
|
458 |
$cfg::user{"message pour un destinataire"} => sub { |
initial commit
|
459 |
$to_gtalksms_queue->enqueue([$1, $2]); |
460 |
}, |
|
passage des regex dans le fi...
|
461 |
$cfg::user{"copie d'une base"} => sub { |
initial commit
|
462 |
$request{origin} = lc $1; |
463 |
$request{destination} = lc $2; |
|
464 |
$request{comment} = $3 =~ s/^\s*//r; |
|
465 |
©(\%request); |
|
466 |
}, |
|
passage des regex dans le fi...
|
467 |
$cfg::user{"ajout d'une entrée dans un base"} => sub { |
initial commit
|
468 |
$request{table} = lc $1; |
469 |
&insert(\%request); |
|
470 |
}, |
|
passage des regex dans le fi...
|
471 |
$cfg::user{"ping"} => sub { |
initial commit
|
472 |
log_bot("envoi d'un pong à $request{phone} $request{phone_owner}"); |
remplacement de nom de varia...
|
473 |
$to_gtalksms_queue->enqueue([$request{phone}, "pong ($phone_status)"]); |
initial commit
|
474 |
}, |
passage des regex dans le fi...
|
475 |
$cfg::user{"test intro pour action"} => sub { |
sms/action: envoi du mail de...
|
476 |
my $intro = $1; |
signal d'envoi immédiat du m...
|
477 |
if (! -r $cfg::sms_action{flag_prefix} . $intro . $cfg::sms_action{flag_suffix}) { |
sms/action: envoi du mail de...
|
478 |
$to_gtalksms_queue->enqueue([$request{phone}, "l'intro $intro n'existe pas, abandon"]); |
479 |
return; |
|
480 |
} |
|
séparation de la configurati...
|
481 |
if (-r $cfg::sms_action{flagdir} . "/" . $cfg::sms_action{flag}) { |
signal d'envoi immédiat du m...
|
482 |
$to_gtalksms_queue->enqueue([$request{phone}, $sms_action{"get locker"}()]); |
sms/action: envoi du mail de...
|
483 |
} |
484 |
else { |
|
485 |
log_bot("demande envoi du mail des actions avec intro $intro depuis $request{phone} $request{phone_owner} à $request{address}"); |
|
signal d'envoi immédiat du m...
|
486 |
my $flag_content = "to:" . $request{address} . "\nintro:" . $intro . "\nfirstname:" . $request{phone} . " " . $request{phone_owner}; |
487 |
$sms_action{"create flag"}(\$flag_content); |
|
488 |
if ($sms_action{"start action"}()) { |
|
489 |
$to_gtalksms_queue->enqueue([$request{phone}, "le mail de test des actions avec intro $intro envoyé à $request{address}"]); |
|
490 |
} |
|
491 |
else { |
|
492 |
$to_gtalksms_queue->enqueue([$request{phone}, "problème: le mail de test des actions avec intro $intro pour $request{address}, n'est probablement pas parti"]); |
|
493 |
} |
|
sms/action: envoi du mail de...
|
494 |
} |
495 |
}, |
|
passage des regex dans le fi...
|
496 |
$cfg::user{"envoi normal pour action"} => sub { |
séparation de la configurati...
|
497 |
if (-r $cfg::sms_action{flagdir} . "/" . $cfg::sms_action{flag}) { |
signal d'envoi immédiat du m...
|
498 |
$to_gtalksms_queue->enqueue([$request{phone}, $sms_action{"get locker"}()]); |
sms/action: envoi du mail de...
|
499 |
} |
500 |
else { |
|
501 |
log_bot("demande envoi du mail des actions depuis $request{phone} $request{phone_owner}"); |
|
signal d'envoi immédiat du m...
|
502 |
$sms_action{"create flag"}(); |
503 |
if ($sms_action{"start action"}()) { |
|
504 |
$to_gtalksms_queue->enqueue([$request{phone}, "le mail des actions est parti"]); |
|
505 |
} |
|
506 |
else { |
|
507 |
$to_gtalksms_queue->enqueue([$request{phone}, "problème: le mail des actions n'est probablement pas parti"]); |
|
508 |
} |
|
sms/action: envoi du mail de...
|
509 |
} |
510 |
}, |
|
initial commit
|
511 |
); |
512 | ||
513 |
if (react_on_message(\%part_from_gtalksms, \%request)) { |
|
sms/action: envoi du mail de...
|
514 |
if (defined $request{phone} and !(is_authorized(\%request) and react_on_message(\%part_from_user, \%request))) { |
initial commit
|
515 |
$request{subject} = "SMS recu de $request{phone} $request{phone_owner}"; |
516 |
$mail_queue->enqueue(\%request); |
|
517 |
} |
|
518 |
} |
|
519 |
else { |
|
520 |
log_bot("message de type inconnu: $request{body}") unless $request{body} eq ""; |
|
521 |
} |
|
522 | ||
523 |
undef %request; |
|
524 |
} |
|
525 |
} |
|
526 | ||
527 |
$from_gtalksms->detach; # gère la file des événements produits par GTalkSMS |
|
528 |
$to_gtalksms->detach; # gère la file des envois de SMS par GTalkSMS |
|
529 |
$mail->detach; # gère la file des mails |
|
530 |
$bot->SetMessageCallBacks(chat => \&messageCB); |
|
531 | ||
532 |
#print "Logged in to $hostName:$portNumber...\n"; |
|
533 |
$bot->PresenceSend(); |
|
534 |
my $roster = $bot->Roster; |
|
remplacement de nom de varia...
|
535 |
$roster->add($cfg::config{xmpp}->{phoneBuddy}); |
initial commit
|
536 | |
537 |
while(defined($bot->Process())) { |
|
538 |
$bot->RosterGet(); |
|
remplacement de nom de varia...
|
539 |
my $status = $roster->query($cfg::config{xmpp}->{phoneBuddy},'resources'); |
540 |
$phone_status = $status->{GTalkSMS}->{status} =~ s/^GTalkSMS - //r if $status; |
|
initial commit
|
541 |
} |