our
@ISA
=
qw(Exporter)
;
our
@EXPORT
= ();
our
@EXPORT_OK
=
qw(&local_tz &base64_decode &base64_encode &base32_encode
&untaint_var &untaint_file_path &exit_status_str
&proc_status_ok &am_running_on_windows &reverse_ip_address
&decode_dns_question_entry &touch_file &secure_tmpfile
&secure_tmpdir &uri_list_canonicalize &get_my_locales
&parse_rfc822_date &idn_to_ascii &is_valid_utf_8
&get_user_groups &compile_regexp &qr_to_string
&is_fqdn_valid &parse_header_addresses &force_die
&domain_to_search_list &get_part_details)
;
our
$AM_TAINTED
;
use
Errno
qw(ENOENT EACCES EEXIST)
;
use
POSIX
qw(:sys_wait_h WIFEXITED WIFSIGNALED WIFSTOPPED WEXITSTATUS
WTERMSIG WSTOPSIG)
;
use
constant
RUNNING_ON_WINDOWS
=> ($^O =~ /^(?:mswin|dos|os2)/i);
BEGIN {
if
(RUNNING_ON_WINDOWS) {
no
warnings
'redefine'
;
*WIFEXITED
=
sub
{ not
$_
[0] & 127 };
*WEXITSTATUS
=
sub
{
$_
[0] >> 8 };
*WIFSIGNALED
=
sub
{ (
$_
[0] & 127) && ((
$_
[0] & 127) != 127) };
*WTERMSIG
=
sub
{
$_
[0] & 127 };
}
}
our
$ALT_FULLSTOP_UTF8_RE
;
BEGIN {
no
bytes;
my
$dot_chars
=
"\x{2024}\x{3002}\x{FF0E}\x{FF61}\x{FE52}"
;
my
$dot_bytes
=
join
(
'|'
,
split
(//,
$dot_chars
)); utf8::encode(
$dot_bytes
);
$ALT_FULLSTOP_UTF8_RE
=
qr/$dot_bytes/
s;
}
our
(
$have_libidn
,
$have_libidn2
);
BEGIN {
my
$sa_libidn
= (
$ENV
{
'SA_LIBIDN'
}||
''
) =~ /(\d+)/ ? $1 : 0;
if
(!
$sa_libidn
||
$sa_libidn
eq
'2'
) {
eval
{
require
Net::LibIDN2; } and
do
{
$have_libidn2
= 1; };
}
if
(!
$have_libidn2
&& (!
$sa_libidn
||
$sa_libidn
eq
'1'
)) {
eval
{
require
Net::LibIDN; } and
do
{
$have_libidn
= 1; };
}
}
$have_libidn
||
$have_libidn2
or info(
"util: module Net::LibIDN or Net::LibIDN2 not available, "
.
"internationalized domain names with U-labels will not be recognized!"
);
{
my
$displayed_path
= 0;
sub
find_executable_in_env_path {
my
(
$filename
) =
@_
;
clean_path_in_taint_mode();
if
( !
$displayed_path
++ ) {
dbg(
"util: current PATH is: "
.
join
(
$Config
{
'path_sep'
},File::Spec->path()));
}
my
@pathext
= (
''
);
if
(RUNNING_ON_WINDOWS) {
if
(
$ENV
{PATHEXT} ) {
push
@pathext
,
split
(
$Config
{
'path_sep'
},
$ENV
{PATHEXT});
}
else
{
push
@pathext
,
qw{.exe .com .bat}
;
}
}
foreach
my
$path
(File::Spec->path()) {
my
$base
= File::Spec->catfile (
$path
,
$filename
);
for
my
$ext
(
@pathext
) {
my
$fname
=
$base
.
$ext
;
if
( -f
$fname
) {
if
(-x
$fname
) {
dbg(
"util: executable for $filename was found at $fname"
);
return
$fname
;
}
else
{
dbg(
"util: $filename was found at $fname, but isn't executable"
);
}
}
}
}
return
;
}
}
{
my
$cleaned_taint_path
= 0;
sub
clean_path_in_taint_mode {
return
if
(
$cleaned_taint_path
++);
return
unless
am_running_in_taint_mode();
dbg(
"util: taint mode: deleting unsafe environment variables, resetting PATH"
);
if
(RUNNING_ON_WINDOWS) {
if
(
$ENV
{
'PATHEXT'
} ) {
$ENV
{
'PATHEXT'
} =
join
(
$Config
{
'path_sep'
},
grep
(
$_
,
map
( {
$_
=~ m/^(\.[a-zA-Z]{1,10})$/; $1; }
split
(
$Config
{
'path_sep'
},
$ENV
{
'PATHEXT'
}))));
}
}
else
{
delete
@ENV
{
qw(IFS CDPATH ENV BASH_ENV)
};
}
my
@path
;
my
@stat
;
foreach
my
$dir
(File::Spec->path()) {
next
unless
$dir
;
local
($1);
$dir
= untaint_var($1)
if
$dir
=~ /^(.+)$/;
$dir
= File::Spec->canonpath(
$dir
);
if
(!File::Spec->file_name_is_absolute(
$dir
)) {
dbg(
"util: PATH included '$dir', which is not absolute, dropping"
);
next
;
}
elsif
(!(
@stat
=
stat
(
$dir
))) {
dbg(
"util: PATH included '$dir', which is unusable, dropping: $!"
);
next
;
}
elsif
(!-d _) {
dbg(
"util: PATH included '$dir', which isn't a directory, dropping"
);
next
;
}
elsif
(!RUNNING_ON_WINDOWS && ((
$stat
[2]&2) != 0)) {
dbg(
"util: PATH included '$dir', which is world writable, dropping"
);
next
;
}
dbg(
"util: PATH included '$dir', keeping"
);
push
(
@path
,
$dir
);
}
$ENV
{
'PATH'
} =
join
(
$Config
{
'path_sep'
},
@path
);
dbg(
"util: final PATH set to: "
.
$ENV
{
'PATH'
});
}
}
sub
am_running_in_taint_mode {
return
$AM_TAINTED
if
defined
$AM_TAINTED
;
if
($] >= 5.008) {
$AM_TAINTED
=
eval
q(no warnings q(syntax)
; ${^TAINT});
}
else
{
my
$blank
;
for
my
$d
((File::Spec->curdir, File::Spec->rootdir, File::Spec->tmpdir)) {
opendir
(TAINT,
$d
) ||
next
;
$blank
=
readdir
(TAINT);
closedir
(TAINT) or
die
"error closing directory $d: $!"
;
last
;
}
if
(!(
defined
$blank
&&
$blank
)) {
$blank
=
join
(
''
,
values
%ENV
, $0,
@ARGV
);
}
$blank
=
substr
(
$blank
, 0, 0);
$AM_TAINTED
= not
eval
{
eval
"1 || $blank"
|| 1 };
}
dbg(
"util: running in taint mode? %s"
,
$AM_TAINTED
?
"yes"
:
"no"
);
return
$AM_TAINTED
;
}
sub
am_running_on_windows {
return
RUNNING_ON_WINDOWS;
}
sub
untaint_file_path {
my
(
$path
) =
@_
;
return
unless
defined
(
$path
);
return
''
if
(
$path
eq
''
);
local
($1);
my
$chars
=
'-_A-Za-z0-9.#%=+,/:()\\@\\xA0-\\xFF\\\\'
;
my
$re
=
qr{^\s*([$chars][${chars}
~ ]*)\z};
if
(
$path
=~
$re
) {
$path
= $1;
return
untaint_var(
$path
);
}
else
{
warn
"util: refusing to untaint suspicious path: \"$path\"\n"
;
return
$path
;
}
}
sub
untaint_hostname {
my
(
$host
) =
@_
;
return
unless
defined
(
$host
);
return
''
if
(
$host
eq
''
);
if
(
length
(
$host
) <= 255 &&
$host
=~ /^[a-z\d](?:[a-z\d-]{0,61}[a-z\d])?(?:\.[a-z\d](?:[a-z\d-]{0,61}[a-z\d])?)*$/i) {
return
untaint_var(
$host
);
}
else
{
warn
"util: cannot untaint hostname: \"$host\"\n"
;
return
$host
;
}
}
sub
untaint_var {
if
(!
ref
$_
[0]) {
no
re
'taint'
;
return
undef
if
!
defined
$_
[0];
local
($1);
$_
[0] =~ /^(.*)\z/s;
return
$1;
}
else
{
my
$r
=
ref
$_
[0];
if
(
$r
eq
'ARRAY'
) {
my
$arg
=
$_
[0];
$_
= untaint_var(
$_
)
for
@{
$arg
};
return
@{
$arg
}
if
wantarray
;
}
elsif
(
$r
eq
'HASH'
) {
my
$arg
=
$_
[0];
if
(
$arg
== \
%ENV
) {
while
(
my
(
$k
,
$v
) =
each
%{
$arg
}) {
if
(!
defined
$v
) {
delete
${
$arg
}{
$k
};
next
}
${
$arg
}{untaint_var(
$k
)} = untaint_var(
$v
);
}
}
else
{
if
($] < 5.020) {
while
(
my
(
$k
,
$v
) =
each
%{
$arg
}) {
${
$arg
}{untaint_var(
$k
)} = untaint_var(
$v
);
}
}
}
return
%{
$arg
}
if
wantarray
;
}
elsif
(
$r
eq
'SCALAR'
||
$r
eq
'REF'
) {
my
$arg
=
$_
[0];
${
$arg
} = untaint_var(${
$arg
});
}
else
{
warn
"util: can't untaint a $r !\n"
;
}
}
return
$_
[0];
}
sub
taint_var {
my
(
$v
) =
@_
;
return
$v
unless
defined
$v
;
my
$t
=
eval
{
local
$/;
open
my
$fh
,
'<'
, \
""
; <
$fh
>; };
$t
=
''
unless
defined
$t
;
return
$v
.
$t
.
substr
($^X, 0, 0);
}
sub
is_fqdn_valid {
my
(
$host
,
$is_ascii
) =
@_
;
return
if
!
defined
$host
;
if
(
$is_ascii
) {
utf8::encode(
$host
)
if
utf8::is_utf8(
$host
);
$host
=
lc
$host
;
}
else
{
$host
= idn_to_ascii(
$host
);
}
$host
=~ s/\.+\z//;
return
if
length
(
$host
) > 253;
my
@labels
=
split
(/\./,
$host
);
my
$cnt
=
scalar
@labels
;
return
unless
$cnt
> 1;
foreach
my
$label
(
@labels
) {
return
if
length
(
$label
) < 1;
return
if
length
(
$label
) > 63;
return
if
$label
!~ /^[a-z0-9_](?:[a-z0-9_-]*[a-z0-9_])?$/;
if
(
$cnt
== 2 ||
$cnt
== 1) {
return
if
index
(
$label
,
'_'
) != -1;
}
$cnt
--;
}
return
1;
}
sub
is_valid_utf_8 {
return
undef
if
!
defined
$_
[0];
$_
[0] =~ /^ (?: [\x00-\x7F] |
[\xC2-\xDF] [\x80-\xBF] |
\xE0 [\xA0-\xBF] [\x80-\xBF] |
[\xE1-\xEC] [\x80-\xBF]{2} |
\xED [\x80-\x9F] [\x80-\xBF] |
[\xEE-\xEF] [\x80-\xBF]{2} |
\xF0 [\x90-\xBF] [\x80-\xBF]{2} |
[\xF1-\xF3] [\x80-\xBF]{3} |
\xF4 [\x80-\x8F] [\x80-\xBF]{2} )* \z/xs ? 1 : 0;
}
sub
idn_to_ascii {
no
bytes;
return
undef
if
!
defined
$_
[0];
my
$s
=
"$_[0]"
;
utf8::encode(
$s
)
if
utf8::is_utf8(
$s
);
if
(
$s
!~
tr
/a-zA-Z0-9_.:[]-//c || !(
$have_libidn
||
$have_libidn2
)) {
return
lc
$s
;
}
my
$t
= tainted(
$s
);
if
(
$t
) {
$s
= untaint_var(
$s
);
}
my
$charset
;
if
(is_valid_utf_8(
$s
)) {
if
(
$s
=~ s/
$ALT_FULLSTOP_UTF8_RE
/./gs) {
dbg(
"util: idn_to_ascii: alternative dots normalized: '%s' -> '%s'"
,
$_
[0],
$s
);
}
$charset
=
'UTF-8'
;
}
elsif
(
$s
!~
tr
/a-zA-Z0-9\xc0-\xd6\xd8-\xde\xe0-\xf6\xf8-\xfe_.-//c) {
$charset
=
'ISO-8859-1'
;
}
if
(
$charset
) {
if
(
$have_libidn
) {
my
$sa
= Net::LibIDN::idn_to_ascii(
$s
,
$charset
);
if
(!
defined
$sa
) {
info(
"util: idn_to_ascii: conversion to ACE failed: '%s' (charset %s)"
,
$s
,
$charset
);
}
else
{
dbg(
"util: idn_to_ascii: converted to ACE: '%s' -> '%s' (charset %s)"
,
$s
,
$sa
,
$charset
)
if
$s
ne
$sa
;
$s
=
$sa
;
}
}
elsif
(
$have_libidn2
) {
my
$si
=
$s
;
if
(
$charset
eq
'ISO-8859-1'
) {
Encode::from_to(
$si
,
'ISO-8859-1'
,
'UTF-8'
);
}
utf8::decode(
$si
)
unless
utf8::is_utf8(
$si
);
my
$rc
= 0;
my
$sa
= Net::LibIDN2::idn2_to_ascii_8(
$si
,
&Net::LibIDN2::IDN2_NFC_INPUT
+
&Net::LibIDN2::IDN2_NONTRANSITIONAL
,
$rc
);
if
(!
defined
$sa
) {
info(
"util: idn_to_ascii: conversion to ACE failed, %s: '%s' (charset %s) (LibIDN2)"
,
Net::LibIDN2::idn2_strerror(
$rc
),
$s
,
$charset
);
}
else
{
dbg(
"util: idn_to_ascii: converted to ACE: '%s' -> '%s' (charset %s) (LibIDN2)"
,
$s
,
$sa
,
$charset
)
if
$s
ne
$sa
;
$s
=
$sa
;
}
}
}
else
{
my
(
$package
,
$filename
,
$line
) =
caller
;
info(
"util: idn_to_ascii: valid charset not detected: '%s', called from %s line %d"
,
$s
,
$package
,
$line
);
$s
=
lc
$s
;
}
return
$t
? taint_var(
$s
) :
$s
;
}
sub
exit_status_str {
my
(
$stat
,
$errno
) =
@_
;
my
$str
;
if
(!
defined
(
$stat
)) {
$str
=
'(no status)'
;
}
elsif
(WIFEXITED(
$stat
)) {
$str
=
sprintf
(
"exit %d"
, WEXITSTATUS(
$stat
));
}
elsif
(WIFSTOPPED(
$stat
)) {
$str
=
sprintf
(
"stopped, signal %d"
, WSTOPSIG(
$stat
));
}
else
{
my
$sig
= WTERMSIG(
$stat
);
$str
=
sprintf
(
"%s, signal %d (%04x)"
,
$sig
== 1 ?
'HANGUP'
:
$sig
== 2 ?
'interrupted'
:
$sig
== 6 ?
'ABORTED'
:
$sig
== 9 ?
'KILLED'
:
$sig
== 15 ?
'TERMINATED'
:
'DIED'
,
$sig
,
$stat
);
}
if
(
defined
$errno
) {
$str
.=
', '
.
$errno
if
(0+
$errno
) != 0 || (
$errno
ne
''
&&
$errno
ne
'0'
);
}
return
$str
;
}
sub
proc_status_ok {
my
(
$exit_status
,
$errno
,
@success
) =
@_
;
my
$ok
= 0;
if
((!
defined
$errno
||
$errno
== 0) && WIFEXITED(
$exit_status
)) {
my
$j
= WEXITSTATUS(
$exit_status
);
if
(!
@success
) {
$ok
=
$j
==0 }
elsif
(
grep
{
$_
==
$j
}
@success
) {
$ok
= 1 }
}
return
$ok
;
}
my
%TZ
= (
'UT'
=>
'+0000'
,
'UTC'
=>
'+0000'
,
'NDT'
=>
'-0230'
,
'AST'
=>
'-0400'
,
'ADT'
=>
'-0300'
,
'NST'
=>
'-0330'
,
'EST'
=>
'-0500'
,
'EDT'
=>
'-0400'
,
'CST'
=>
'-0600'
,
'CDT'
=>
'-0500'
,
'MST'
=>
'-0700'
,
'MDT'
=>
'-0600'
,
'PST'
=>
'-0800'
,
'PDT'
=>
'-0700'
,
'HST'
=>
'-1000'
,
'AKST'
=>
'-0900'
,
'AKDT'
=>
'-0800'
,
'HADT'
=>
'-0900'
,
'HAST'
=>
'-1000'
,
'GMT'
=>
'+0000'
,
'BST'
=>
'+0100'
,
'IST'
=>
'+0100'
,
'WET'
=>
'+0000'
,
'WEST'
=>
'+0100'
,
'CET'
=>
'+0100'
,
'CEST'
=>
'+0200'
,
'EET'
=>
'+0200'
,
'EEST'
=>
'+0300'
,
'MSK'
=>
'+0300'
,
'MSD'
=>
'+0400'
,
'MET'
=>
'+0100'
,
'MEZ'
=>
'+0100'
,
'MEST'
=>
'+0200'
,
'MESZ'
=>
'+0200'
,
'BRST'
=>
'-0200'
,
'BRT'
=>
'-0300'
,
'AEST'
=>
'+1000'
,
'AEDT'
=>
'+1100'
,
'ACST'
=>
'+0930'
,
'ACDT'
=>
'+1030'
,
'AWST'
=>
'+0800'
,
'NZST'
=>
'+1200'
,
'NZDT'
=>
'+1300'
,
'JST'
=>
'+0900'
,
'KST'
=>
'+0900'
,
'HKT'
=>
'+0800'
,
'SGT'
=>
'+0800'
,
'PHT'
=>
'+0800'
,
'IDT'
=>
'+0300'
,
);
my
%MONTH
= (
jan
=> 1,
feb
=> 2,
mar
=> 3,
apr
=> 4,
may
=> 5,
jun
=> 6,
jul
=> 7,
aug
=> 8,
sep
=> 9,
oct
=> 10,
nov
=> 11,
dec
=> 12);
my
$LOCALTZ
;
sub
local_tz {
return
$LOCALTZ
if
defined
(
$LOCALTZ
);
my
$time
=
time
;
my
@g
=
gmtime
(
$time
);
my
@t
=
localtime
(
$time
);
my
$z
=
$t
[1]-
$g
[1]+(
$t
[2]-
$g
[2])*60+(
$t
[7]-
$g
[7])*1440+(
$t
[5]-
$g
[5])*525600;
$LOCALTZ
=
sprintf
(
"%+.2d%.2d"
,
$z
/60,
$z
%60);
return
$LOCALTZ
;
}
sub
parse_rfc822_date {
my
(
$date
) =
@_
;
local
(
$_
);
local
($1,$2,$3,$4);
my
(
$yyyy
,
$mmm
,
$dd
,
$hh
,
$mm
,
$ss
,
$mon
,
$tzoff
);
$_
=
" $date "
; s/, */ /gs; s/\s+/ /gs;
if
(s/ (\d+) (Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec) (\d{4}) / /i) {
$dd
= $1;
$mon
=
lc
($2);
$yyyy
= $3;
}
elsif
(s/ (Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec) +(\d+) \d+:\d+:\d+ (\d{4}) / /i) {
$dd
= $2;
$mon
=
lc
($1);
$yyyy
= $3;
}
elsif
(s/ (\d+) (Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec) (\d{2,3}) / /i) {
$dd
= $1;
$mon
=
lc
($2);
$yyyy
= $3;
}
else
{
dbg(
"util: time cannot be parsed: $date"
);
return
;
}
if
(
defined
$yyyy
) {
if
(
length
(
$yyyy
) == 2 &&
$yyyy
< 50) {
$yyyy
+= 2000;
}
elsif
(
length
(
$yyyy
) != 4) {
$yyyy
+= 1900;
}
}
if
(s/ (\d?\d):(\d\d)(:(\d\d))? / /) {
$hh
= $1;
$mm
= $2;
$ss
= $4 || 0;
}
if
(s/ ([-+]\d{4}) / /) {
$tzoff
= $1;
}
elsif
(s/\b([A-Z]{2,4}(?:-DST)?)\b/ / &&
exists
$TZ
{$1}) {
$tzoff
=
$TZ
{$1};
}
$tzoff
||=
'-0000'
;
if
(
exists
$MONTH
{
$mon
}) {
$mmm
=
$MONTH
{
$mon
};
}
$hh
||= 0;
$mm
||= 0;
$ss
||= 0;
$dd
||= 0;
$mmm
||= 0;
$yyyy
||= 0;
if
(
$ss
> 59) {
dbg(
"util: second after supported range, forcing second to 59: $date"
);
$ss
= 59;
}
if
(
$mm
> 59) {
dbg(
"util: minute after supported range, forcing minute to 59: $date"
);
$mm
= 59;
}
if
(
$hh
> 23) {
dbg(
"util: hour after supported range, forcing hour to 23: $date"
);
$hh
= 23;
}
my
$max_dd
= 31;
if
(
$mmm
== 4 ||
$mmm
== 6 ||
$mmm
== 9 ||
$mmm
== 11) {
$max_dd
= 30;
}
elsif
(
$mmm
== 2) {
$max_dd
= (!(
$yyyy
% 4) && ((
$yyyy
% 100) || !(
$yyyy
% 400))) ? 29 : 28;
}
if
(
$dd
>
$max_dd
) {
dbg(
"util: day is too high, incrementing date to next valid date: $date"
);
$dd
= 1;
$mmm
++;
if
(
$mmm
> 12) {
$mmm
= 1;
$yyyy
++;
}
}
if
(
$yyyy
> 2037) {
dbg(
"util: year after supported range, forcing year to 2037: $date"
);
$yyyy
= 2037;
}
elsif
(
$yyyy
< 1970) {
dbg(
"util: year before supported range, forcing year to 1970: $date"
);
$yyyy
= 1970;
}
my
$time
;
eval
{
$time
= timegm(
$ss
,
$mm
,
$hh
,
$dd
,
$mmm
-1,
$yyyy
);
1;
} or
do
{
my
$eval_stat
= $@ ne
''
? $@ :
"errno=$!"
;
chomp
$eval_stat
;
dbg(
"util: time cannot be parsed: $date, $yyyy-$mmm-$dd $hh:$mm:$ss, $eval_stat"
);
return
;
};
if
(
$tzoff
=~ /([-+])(\d\d)(\d\d)$/)
{
$tzoff
= (($2 * 60) + $3) * 60;
if
($1 eq
'-'
) {
$time
+=
$tzoff
;
}
elsif
(
$time
<
$tzoff
) {
$time
= 0;
}
else
{
$time
-=
$tzoff
;
}
}
return
$time
;
}
sub
time_to_rfc822_date {
my
(
$time
) =
@_
;
my
@days
=
qw/Sun Mon Tue Wed Thu Fri Sat/
;
my
@months
=
qw/Jan Feb Mar Apr May Jun Jul Aug Sep Oct Nov Dec/
;
my
@localtime
=
localtime
(
$time
||
time
);
$localtime
[5]+=1900;
sprintf
(
"%s, %02d %s %4d %02d:%02d:%02d %s"
,
$days
[
$localtime
[6]],
$localtime
[3],
$months
[
$localtime
[4]],
@localtime
[5,2,1,0], local_tz());
}
sub
wrap {
my
$string
=
shift
||
''
;
my
$prefix
=
shift
||
''
;
my
$first
=
shift
||
''
;
my
$length
=
shift
|| 77;
my
$overflow
=
shift
|| 0;
my
$break
=
shift
||
qr/\s/
;
my
$sep
=
"\n"
;
my
@arr
=
split
(/(
$break
)/,
$string
);
splice
@arr
, 0, 0,
$first
if
$first
;
my
$pos
= 0;
my
$pos_mod
= 0;
while
(
$#arr
>
$pos
) {
my
$len
=
length
(
$arr
[
$pos
]);
$len
+= (
$arr
[
$pos
] =~
tr
/\t//) * 7;
if
(
$pos_mod
!= 0 &&
$overflow
== 0) {
$len
+=
length
(
$arr
[
$pos
+1]);
$len
+= (
$arr
[
$pos
+1] =~
tr
/\t//) * 7;
}
if
(
$len
<=
$length
) {
$arr
[
$pos
] .=
splice
@arr
,
$pos
+1, 1;
$pos_mod
= 1;
}
else
{
$arr
[
$pos
] =~ s/\s+$//;
$pos
++;
$pos_mod
= 0;
splice
@arr
,
$pos
, 0,
$prefix
;
}
}
return
join
(
$sep
,
@arr
);
}
sub
base64_decode {
local
$_
=
shift
;
my
$decoded_length
=
shift
;
s/\s+//g;
if
(HAS_MIME_BASE64 && (
length
(
$_
) % 4 == 0) &&
m|^(?:[A-Za-z0-9+/=]{2,}={0,2})$|s)
{
local
$1;
s/(=+)(?!=*$)/
'A'
x
length
($1)/ge;
if
(
defined
$decoded_length
) {
$_
=
substr
$_
, 0, 4 * (
int
(
$decoded_length
/3) + 1);
my
$decoded
= MIME::Base64::decode_base64(
$_
);
return
substr
$decoded
, 0,
$decoded_length
;
}
return
MIME::Base64::decode_base64(
$_
);
}
tr
{A-Za-z0-9+/=}{}cd;
s/=+$//;
tr
{A-Za-z0-9+/=}{ -_};
s/.$//
if
(
length
(
$_
) % 4 == 1);
my
$length
;
my
$out
=
''
;
while
(
$_
) {
$length
= (
length
>= 84) ? 84 :
length
;
$out
.=
unpack
(
"u"
,
chr
(32 +
$length
* 3/4) .
substr
(
$_
, 0,
$length
,
''
));
last
if
(
defined
$decoded_length
&&
length
$out
>=
$decoded_length
);
}
if
(
defined
$decoded_length
) {
return
substr
$out
, 0,
$decoded_length
;
}
return
$out
;
}
sub
qp_decode {
my
$str
=
$_
[0];
$str
=~ s/[ \t]+(?=\r?\n)//gs;
$str
=~ s/=\r?\n//gs;
local
$1;
$str
=~ s/=([0-9a-fA-F]{2})/
chr
(
hex
($1))/ge;
return
$str
;
}
sub
base64_encode {
local
$_
=
shift
;
if
(HAS_MIME_BASE64) {
return
MIME::Base64::encode_base64(
$_
,
''
);
}
$_
=
pack
(
"u57"
,
$_
);
s/^.//mg;
tr
| -_`|A-Za-z0-9+/A|;
s/(A+)$/
'='
x
length
$1/e;
return
$_
;
}
our
%base32_bitchr
= (
'00000'
=>
'A'
,
'00001'
=>
'B'
,
'00010'
=>
'C'
,
'00011'
=>
'D'
,
'00100'
=>
'E'
,
'00101'
=>
'F'
,
'00110'
=>
'G'
,
'00111'
=>
'H'
,
'01000'
=>
'I'
,
'01001'
=>
'J'
,
'01010'
=>
'K'
,
'01011'
=>
'L'
,
'01100'
=>
'M'
,
'01101'
=>
'N'
,
'01110'
=>
'O'
,
'01111'
=>
'P'
,
'10000'
=>
'Q'
,
'10001'
=>
'R'
,
'10010'
=>
'S'
,
'10011'
=>
'T'
,
'10100'
=>
'U'
,
'10101'
=>
'V'
,
'10110'
=>
'W'
,
'10111'
=>
'X'
,
'11000'
=>
'Y'
,
'11001'
=>
'Z'
,
'11010'
=>
'2'
,
'11011'
=>
'3'
,
'11100'
=>
'4'
,
'11101'
=>
'5'
,
'11110'
=>
'6'
,
'11111'
=>
'7'
);
sub
base32_encode {
my
(
$str
) =
@_
;
return
if
!
defined
$str
;
utf8::encode(
$str
)
if
utf8::is_utf8(
$str
);
my
$bits
=
unpack
(
"B*"
,
$str
).
"0000"
;
my
$output
;
local
($1);
$output
.=
$base32_bitchr
{$1}
while
(
$bits
=~ /(.{5})/g);
return
$output
;
}
sub
portable_getpwuid {
if
(
defined
&Mail::SpamAssassin::Util::_getpwuid_wrapper
) {
return
Mail::SpamAssassin::Util::_getpwuid_wrapper(
@_
);
}
my
$sts
;
if
(!RUNNING_ON_WINDOWS) {
$sts
=
eval
' sub _getpwuid_wrapper { getpwuid($_[0]); }; 1 '
;
}
else
{
dbg(
"util: defining getpwuid() wrapper using 'unknown' as username"
);
$sts
=
eval
' sub _getpwuid_wrapper { _fake_getpwuid($_[0]); }; 1 '
;
}
if
(!
$sts
) {
my
$eval_stat
= $@ ne
''
? $@ :
"errno=$!"
;
chomp
$eval_stat
;
warn
"util: failed to define getpwuid() wrapper: $eval_stat\n"
;
}
else
{
return
Mail::SpamAssassin::Util::_getpwuid_wrapper(
@_
);
}
}
sub
_fake_getpwuid {
return
(
'unknown'
,
'x'
,
$_
[0],
0,
''
,
''
,
''
,
'/'
,
''
,
''
,
);
}
sub
common_application_data_directory {
return
Win32::GetFolderPath(Win32::CSIDL_COMMON_APPDATA())
if
(RUNNING_ON_WINDOWS);
}
sub
extract_ipv4_addr_from_string {
my
(
$str
) =
@_
;
return
unless
defined
(
$str
);
if
(
$str
=~ /\b(
(?:1\d\d|2[0-4]\d|25[0-5]|[1-9]\d|\d)\.
(?:1\d\d|2[0-4]\d|25[0-5]|[1-9]\d|\d)\.
(?:1\d\d|2[0-4]\d|25[0-5]|[1-9]\d|\d)\.
(?:1\d\d|2[0-4]\d|25[0-5]|[1-9]\d|\d)
)\b/ix)
{
if
(
defined
$1) {
return
$1; }
}
return
;
}
{
my
(
$hostname
,
$fq_hostname
);
sub
hostname {
return
$hostname
if
defined
(
$hostname
);
clean_path_in_taint_mode();
$hostname
= Sys::Hostname::hostname();
$hostname
=~ s/[()]//gs;
return
$hostname
;
}
sub
fq_hostname {
return
$fq_hostname
if
defined
(
$fq_hostname
);
$fq_hostname
= hostname();
if
(
index
(
$fq_hostname
,
'.'
) == -1) {
my
@names
=
grep
(/^\Q${fq_hostname}.\E/o,
map
{
split
} (
gethostbyname
(
$fq_hostname
))[0 .. 1]
);
$fq_hostname
=
$names
[0]
if
(
@names
);
$fq_hostname
=~ s/[()]//gs;
}
return
$fq_hostname
;
}
}
sub
ips_match_in_16_mask {
my
(
$ipset1
,
$ipset2
) =
@_
;
my
(
$b1
,
$b2
);
foreach
my
$ip1
(@{
$ipset1
}) {
foreach
my
$ip2
(@{
$ipset2
}) {
next
unless
defined
$ip1
;
next
unless
defined
$ip2
;
next
unless
(
$ip1
=~ /^(\d+\.\d+\.)/);
$b1
= $1;
next
unless
(
$ip2
=~ /^(\d+\.\d+\.)/);
$b2
= $1;
if
(
$b1
eq
$b2
) {
return
1; }
}
}
return
0;
}
sub
ips_match_in_24_mask {
my
(
$ipset1
,
$ipset2
) =
@_
;
my
(
$b1
,
$b2
);
foreach
my
$ip1
(@{
$ipset1
}) {
foreach
my
$ip2
(@{
$ipset2
}) {
next
unless
defined
$ip1
;
next
unless
defined
$ip2
;
next
unless
(
$ip1
=~ /^(\d+\.\d+\.\d+\.)/);
$b1
= $1;
next
unless
(
$ip2
=~ /^(\d+\.\d+\.\d+\.)/);
$b2
= $1;
if
(
$b1
eq
$b2
) {
return
1; }
}
}
return
0;
}
sub
reverse_ip_address {
my
(
$ip
) =
@_
;
my
$revip
;
local
($1,$2,$3,$4);
if
(
$ip
=~ /^(\d{1,3})\.(\d{1,3})\.(\d{1,3})\.(\d{1,3})\z/) {
$revip
=
"$4.$3.$2.$1"
;
}
elsif
(
index
(
$ip
,
':'
) == -1 ||
$ip
!~ /^[0-9a-fA-F:.]{2,}\z/) {
}
elsif
(!HAS_NETADDR_IP || !NetAddr::IP->can(
'full6'
)) {
info(
"util: sufficiently new NetAddr::IP not found, IPv6 not supported"
);
}
else
{
my
$ip_obj
= NetAddr::IP->new6(
$ip
);
if
(
defined
$ip_obj
) {
$revip
=
lc
$ip_obj
->network->full6;
$revip
=~ s/://g;
$revip
=
join
(
'.'
,
reverse
split
(//,
$revip
));
}
}
return
$revip
;
}
sub
my_inet_aton {
unpack
(
"N"
,
pack
(
"C4"
,
split
(/\./,
$_
[0]))) }
sub
decode_dns_question_entry {
my
$q
=
$_
[0];
my
$qname
=
$q
->qname;
utf8::encode(
$qname
)
if
utf8::is_utf8(
$qname
);
local
$1;
$qname
=~ s{ \\ ( [0-9]{3} | (?![0-9]{3}) . ) }
{
length
($1)==3 && $1 <= 255 ?
chr
($1) : $1 }xgse;
return
(
$q
->qclass,
$q
->qtype,
$qname
);
}
sub
parse_content_type {
my
$missing
;
my
$ct
=
$_
[-1] ||
do
{
$missing
= 1;
'text/plain; charset=us-ascii'
};
my
(
$boundary
) =
$ct
=~ m!\bboundary\s*=\s*(
"[^"
]+|[^\s";]+(?=[\s;]|$))!i;
$boundary
=~
tr
/"//d
if
defined
$boundary
;
my
(
$charset
) =
$ct
=~ /\bcharset\s*=\s*[
"']?(.*?)["
']?(?:;|$)/i;
my
(
$name
) =
$ct
=~ /\b(?:file)?name\s*=\s*[
"']?(.*?)["
']?(?:;|$)/i;
if
(!
$name
&&
$ct
=~ /\b(?:file)?name\*0\s*=/i) {
my
@name
;
$name
[$1] = $2
while
(
$ct
=~ /\b(?:file)?name\*(\d+)\s*=\s*[
"']?(.*?)["
']?(?:;|$)/ig);
$name
=
join
""
,
grep
defined
,
@name
;
}
$ct
=~ s/^\s+//;
$ct
=~ s/;.*$//s;
$ct
=~ s@^([^/]+(?:/[^/\s]*)?).*$@$1
@s
;
$ct
=
lc
$ct
;
$missing
= 1
if
!
$ct
;
if
(!
$ct
||
(
$ct
=~ /^text\b/ &&
$ct
!~ /^text\/(?:x-vcard|calendar|html)$/))
{
$ct
=
"text/plain"
;
}
$ct
=~
tr
/\000-\040\177-\377\042\050\051\054\072-\077\100\133-\135//d;
return
wantarray
? (
$ct
,
$boundary
,
$charset
,
$name
,
$missing
) :
$ct
;
}
sub
url_encode {
my
(
$url
) =
@_
;
my
(
@characters
) =
split
(/(\%[0-9a-fA-F]{2})/,
$url
);
my
(
@unencoded
);
my
(
@encoded
);
foreach
(
@characters
) {
if
(/\%[0-9a-fA-F]{2}/) {
unless
(/(20|7f|[0189a-fA-F][0-9a-fA-F])/i) {
s/\%([2-7][0-9a-fA-F])/
sprintf
"%c"
,
hex
($1)/e;
push
(
@unencoded
,
$_
);
}
}
else
{
s/([\000-\040\177-\377\042\045\074\076])
/
push
(
@encoded
, $1) &&
sprintf
"%%%02x"
,
unpack
(
"C"
,$1)/egx;
}
}
if
(
wantarray
) {
return
(
join
(
""
,
@characters
),
join
(
""
,
@unencoded
),
join
(
""
,
@encoded
));
}
else
{
return
join
(
""
,
@characters
);
}
}
sub
first_available_module {
my
(
@packages
) =
@_
;
foreach
my
$mod
(
@packages
) {
next
if
$mod
!~ /^[\w:]+$/;
if
(
eval
'require '
.
$mod
.
'; 1;'
) {
return
$mod
;
}
}
undef
;
}
sub
touch_file {
my
(
$file
,
$args
) =
@_
;
$file
= untaint_file_path(
$file
);
$args
||= {};
return
unless
defined
$file
&&
$file
ne
''
;
if
(
$args
->{create_exclusive}) {
if
(
sysopen
(
my
$fh
,
$file
, O_CREAT|O_EXCL)) {
close
$fh
;
return
1;
}
return
1
if
$! == EEXIST;
dbg(
"util: exclusive touch_file failed: $file: $!"
);
return
0;
}
if
(!
utime
(
undef
,
undef
,
$file
)) {
dbg(
"util: touch_file failed: $file: $!"
);
return
0;
}
return
1;
}
sub
pseudo_random_string {
my
$len
=
shift
|| 6;
my
$str
=
''
;
$str
.= (0..9,
'A'
..
'Z'
,
'a'
..
'z'
)[
rand
62]
for
(1 ..
$len
);
return
$str
;
}
sub
secure_tmpfile {
my
$tmpenv
= am_running_on_windows() ?
'TMP'
:
'TMPDIR'
;
my
$tmpdir
= untaint_file_path(
$ENV
{
$tmpenv
} || File::Spec->tmpdir());
defined
$tmpdir
&&
$tmpdir
ne
''
or
die
"util: cannot find a temporary directory, set TMP or TMPDIR in environment"
;
opendir
(
my
$dh
,
$tmpdir
) or
die
"Could not open directory $tmpdir: $!"
;
closedir
$dh
or
die
"Error closing directory $tmpdir: $!"
;
my
(
$reportfile
,
$tmpfh
);
for
(
my
$retries
= 20;
$retries
> 0;
$retries
--) {
my
$suffix
= pseudo_random_string(6);
$reportfile
= File::Spec->catfile(
$tmpdir
,
".spamassassin${$}${suffix}tmp"
);
if
(
sysopen
(
$tmpfh
,
$reportfile
, O_RDWR|O_CREAT|O_EXCL, 0600)) {
binmode
$tmpfh
or
die
"cannot set $reportfile to binmode: $!"
;
last
;
}
my
$errno
= $!;
if
(
$tmpfh
) {
if
(!
close
$tmpfh
) {
info(
"error closing $reportfile: $!"
);
undef
$tmpfh
;
}
}
next
if
$errno
== EEXIST;
die
"util: failed to create a temporary file '$reportfile': $errno"
;
}
if
(!
$tmpfh
) {
warn
"util: secure_tmpfile failed to create a temporary file, giving up"
;
return
;
}
dbg(
"util: secure_tmpfile created a temporary file %s"
,
$reportfile
);
return
(
$reportfile
,
$tmpfh
);
}
sub
secure_tmpdir {
my
$tmpdir
= untaint_file_path(File::Spec->tmpdir());
if
(!
$tmpdir
) {
warn
"util: cannot find a temporary directory, set TMP or TMPDIR in environment"
;
return
;
}
my
(
$reportpath
,
$tmppath
);
my
$umask
=
umask
077;
for
(
my
$retries
= 20;
$retries
> 0;
$retries
--) {
my
$suffix
=
join
(
''
, (0..9,
'A'
..
'Z'
,
'a'
..
'z'
)[
rand
62,
rand
62,
rand
62,
rand
62,
rand
62,
rand
62]);
$reportpath
= File::Spec->catfile(
$tmpdir
,
".spamassassin${$}${suffix}tmp"
);
if
(
mkdir
$reportpath
, 0700) {
$tmppath
=
$reportpath
;
last
;
}
if
($!{EEXIST}) {
next
;
}
warn
"util: secure_tmpdir failed to create file '$reportpath': $!\n"
;
}
umask
$umask
;
warn
"util: secure_tmpdir failed to create a directory, giving up"
if
(!
$tmppath
);
return
$tmppath
;
}
*uri_list_canonify
= \
&uri_list_canonicalize
;
sub
uri_list_canonicalize {
my
$redirector_patterns
=
shift
;
my
@uris
;
my
$rb
;
if
(
ref
(
$_
[0]) eq
'ARRAY'
) {
@uris
= @{
$_
[0]};
$rb
=
$_
[1];
}
else
{
@uris
=
@_
;
}
my
@nuris
;
for
my
$uri
(
@uris
) {
$uri
=~ s/\n//g;
$uri
=~ s/^\s+//;
$uri
=~ s/\s+$//;
$uri
=~ s/\r//g;
next
if
length
(
$uri
) <= 1 ||
$uri
=~ m{^(?:[
my
$nuri
=
$uri
;
if
(
$nuri
=~ /^mailto:/i ||
$nuri
=~ /^[^:]*\@/) {
if
(
$nuri
=~ /^([^\@]+\@[^?]+)\?/) {
push
@nuris
, $1;
}
if
(
$nuri
=~ /^([^\@]+\@[^?&]+)\&/) {
push
@nuris
, $1
}
if
(
index
(
$nuri
,
'%20'
) >= 0 &&
$nuri
=~ /^(?:mailto:)?(?:\%20)*([^\@]+\@[^?&%]+)/) {
push
@nuris
,
"mailto:$1"
;
}
if
(
$nuri
=~ /^[^?&]*<([^\@>]+\@[^>]+)>/) {
push
@nuris
,
"mailto:$1"
;
}
next
;
}
$nuri
=~
tr
{\\}{/};
$nuri
=~ s{^(https?:)/{0,2}}{$1//}i;
if
(
$nuri
=~ /%[0-9a-fA-F]{2}/) {
$nuri
= Mail::SpamAssassin::Util::url_encode(
$nuri
);
}
if
(
$nuri
!~ /^[-_a-z0-9]+:/i) {
if
(
$nuri
=~ /^ftp\./) {
}
else
{
}
}
$nuri
=~ s{^(https?://[^/?
$nuri
=~ s/\&\
$nuri
=~ s/\&\
$nuri
=~ s/\&\
if
(
$nuri
ne
$uri
) {
push
(
@nuris
,
$nuri
);
}
if
(
$nuri
=~ m{^(https?://)([^\@/?
my
(
$proto
,
$host
,
$rest
) = ($1,$3,$4);
my
$auth
=
defined
$2 ? $2 :
''
;
my
$port
=
defined
$5 ? $5 :
''
;
my
$rest_noport
;
if
(
$port
eq
''
) {
$port
=
$proto
eq
'http://'
? 80 : 443;
}
else
{
$rest_noport
=
$rest
;
if
(
$rest_noport
=~ s/^:80\b//) {
push
(
@nuris
,
join
(
''
,
$proto
,
$host
,
$rest_noport
));
}
}
elsif
(
$rest_noport
=~ s/^:443\b//) {
push
(
@nuris
,
join
(
''
,
$proto
,
$host
,
$rest_noport
));
}
}
my
$nhost
= idn_to_ascii(
$host
);
if
(
$nhost
ne
lc
(
$host
)) {
push
(
@nuris
,
join
(
''
,
$proto
,
$nhost
,
$rest
));
push
(
@nuris
,
join
(
''
,
$proto
,
$nhost
,
$rest_noport
))
if
$rest_noport
;
$host
=
$nhost
;
}
if
(
$host
=~
tr
/\x00-\x20//d) {
push
(
@nuris
,
join
(
''
,
$proto
,
$host
,
$rest
));
}
my
$found_redirector_match
;
foreach
my
$re
(@{
$redirector_patterns
}) {
if
(
"$proto$host$rest"
=~
$re
) {
next
unless
defined
$1 &&
index
($1,
'.'
) != -1;
dbg(
"uri: parsed uri pattern: $re"
);
dbg(
"uri: parsed uri found: $1 in redirector: $proto$host$rest"
);
push
(
@uris
, $1);
$found_redirector_match
= 1;
last
;
}
}
if
(!
$found_redirector_match
) {
if
(
$rest
=~ m{(https?:/{0,2}[^&
push
(
@uris
, $1);
dbg(
"uri: parsed uri found: $1 in hard-coded redirector"
);
}
}
if
(
$host
=~ s/^[^\@]+\@//gs) {
push
(
@nuris
,
join
(
''
,
$proto
,
$host
,
$rest
));
}
if
(
$host
=~ s/[^0-9A-Za-z]+$//) {
push
(
@nuris
,
join
(
''
,
$proto
,
$host
,
$rest
));
}
if
(
$host
=~ /^
((?:0x[0-9a-f]+|\d+)\.)
((?:0x[0-9a-f]+|\d+)\.)
((?:0x[0-9a-f]+|\d+)\.)
(0x[0-9a-f]+|\d+)
$/ix)
{
my
@chunk
= ($1,$2,$3,$4);
foreach
my
$octet
(
@chunk
) {
$octet
=~ s/^0x([0-9a-f]+)/
sprintf
"%d"
,
hex
($1)/gei;
$octet
=~ s/^0+([1-3][0-7]{0,2}|[4-7][0-7]?)\b/
sprintf
"%d"
,
oct
($1)/ge;
$octet
=~ s/^0+//;
}
push
(
@nuris
,
join
(
''
,
$proto
,
@chunk
,
$rest
));
}
elsif
(
$host
=~ /^0x[0-9a-f]+$/i) {
$host
=~ s/^0x[0-9a-f]*?([0-9a-f]{1,8})$/
sprintf
"%d"
,
hex
($1)/gei;
push
(
@nuris
,
join
(
''
,
$proto
, decode_ulong_to_ip(
$host
),
$rest
));
}
elsif
(
$host
=~ /^[0-9]+$/) {
push
(
@nuris
,
join
(
''
,
$proto
, decode_ulong_to_ip(
$host
),
$rest
));
}
elsif
(
$proto
eq
'http://'
&&
$auth
eq
''
&&
$nhost
ne
'localhost'
&&
$port
eq
'80'
&&
$nhost
=~ /^(?:www\.)?([^.]+)$/) {
unless
(
defined
$rb
&&
$rb
->is_domain_valid(
$nhost
)) {
push
(
@nuris
,
join
(
''
,
$proto
,
'www.'
, $1,
'.com'
,
$rest
));
}
}
}
}
my
%uris
=
map
{
$_
=> 1 }
@uris
,
@nuris
;
return
keys
%uris
;
}
sub
decode_ulong_to_ip {
return
join
(
"."
,
unpack
(
"CCCC"
,
pack
(
"H*"
,
sprintf
"%08lx"
,
$_
[0])));
}
sub
first_date {
my
(
@strings
) =
@_
;
foreach
my
$string
(
@strings
) {
my
$time
= parse_rfc822_date(
$string
);
return
$time
if
defined
(
$time
) &&
$time
;
}
return
;
}
sub
receive_date {
my
(
$header
) =
@_
;
$header
||=
''
;
$header
=~ s/\n[ \t]+/ /gs;
my
@rcvd
= (
$header
=~ /^Received:(.*)/img);
my
@local
;
my
$time
;
if
(
@rcvd
) {
if
(
$rcvd
[0] =~ /qmail \d+ invoked by uid \d+/ ||
$rcvd
[0] =~ /\bfrom (?:localhost\s|(?:\S+ ){1,2}\S*\b127\.0\.0\.1\b)/)
{
push
@local
, (
shift
@rcvd
);
}
if
(
@rcvd
&& (
$rcvd
[0] =~ m/\bby localhost
with
\w+ \(fetchmail-[\d.]+/)) {
push
@local
, (
shift
@rcvd
);
}
elsif
(
@local
) {
unshift
@rcvd
, (
shift
@local
);
}
}
if
(
@rcvd
) {
$time
= first_date(
shift
@rcvd
);
return
$time
if
defined
(
$time
);
}
if
(
@local
) {
$time
= first_date(
@local
);
return
$time
if
defined
(
$time
);
}
if
(
$header
=~ /^(?:From|X-From-Line:)\s+(.+)$/im) {
my
$string
= $1;
$string
.=
" "
.local_tz()
unless
$string
=~ /(?:[-+]\d{4}|\b[A-Z]{2,4}\b)/;
$time
= first_date(
$string
);
return
$time
if
defined
(
$time
);
}
if
(
@rcvd
) {
$time
= first_date(
@rcvd
);
return
$time
if
defined
(
$time
);
}
if
(
$header
=~ /^Resent-Date:\s*(.+)$/im) {
$time
= first_date($1);
return
$time
if
defined
(
$time
);
}
if
(
$header
=~ /^Date:\s*(.+)$/im) {
$time
= first_date($1);
return
$time
if
defined
(
$time
);
}
return
time
;
}
sub
get_user_groups {
my
$suid
=
shift
;
dbg(
"util: get_user_groups: uid is $suid\n"
);
my
(
$user
,
$gid
) = (
getpwuid
(
$suid
))[0,3];
my
$rgids
=
"$gid "
;
while
(
my
(
$name
,
$gid
,
$members
) = (
getgrent
())[0,2,3]) {
if
(
grep
{
$_
eq
$user
}
split
(/ /,
$members
)) {
$rgids
.=
"$gid "
;
dbg(
"util: get_user_groups: added $gid ($name) to group list which is now: $rgids\n"
);
}
}
endgrent
;
chop
$rgids
;
return
(
$rgids
);
}
sub
setuid_to_euid {
return
if
(RUNNING_ON_WINDOWS);
my
$touid
= $>;
my
$gids
= get_user_groups(
$touid
);
my
(
$pgid
,
$supgs
) =
split
(
' '
,
$gids
,2);
defined
$supgs
or
$supgs
=
$pgid
;
my
$prgid
= 0 + $(;
if
( (
$prgid
== 0) or not (
grep
{
$_
==
$prgid
}
split
(/ /, ${(}))) {
$> = 0;
if
($> != 0) {
warn
(
"util: seteuid to 0 failed: $!"
); }
dbg(
"util: changing real primary gid from $( to $pgid and supplemental groups to $supgs to match effective uid $touid"
);
$! = 0; POSIX::setgid(
$pgid
);
if
($!) {
warn
(
"util: POSIX::setgid $pgid failed: $!\n"
); }
$! = 0; $( =
$pgid
;
if
($!) {
warn
(
"util: failed to set gid $pgid: $!\n"
); }
$! = 0; $) =
"$pgid $supgs"
;
if
($!) {
if
(
grep
{
$_
eq
'0'
}
split
(/ /, ${)})) {
die
(
"util: failed to set effective gid $pgid $supgs: $!\n"
);
}
else
{
warn
(
"util: failed to set effective gid $pgid $supgs: $!\n"
);
}
}
}
if
($< !=
$touid
) {
dbg(
"util: changing real uid from $< to match effective uid $touid"
);
POSIX::setuid(
$touid
);
$< =
$touid
; $> =
$touid
;
if
($< !=
$touid
) {
die
"util: setuid $< to $touid failed!"
;
}
}
}
sub
helper_app_pipe_open {
my
@cmdline
;
my
$startquote
= 0;
my
$ntok
;
foreach
my
$tok
(
@_
) {
if
(
defined
$tok
&& (
$tok
=~ /^\"/) && (
$tok
!~ /\"$/)) {
$startquote
= 1;
}
if
(
$startquote
) {
$ntok
.=
" "
if
(
$tok
!~ /^\"/);
$ntok
=~ s/\"//
if
defined
$ntok
;
$ntok
.=
$tok
;
}
if
(
$startquote
&&
defined
$tok
&& (
$tok
=~ /\"$/)) {
$startquote
= 0;
$ntok
=~ s/\"//
if
defined
$ntok
;
push
(
@cmdline
,
$ntok
);
undef
$ntok
;
}
elsif
(not
$startquote
) {
push
(
@cmdline
,
$tok
);
}
}
if
(RUNNING_ON_WINDOWS) {
return
helper_app_pipe_open_windows (
@cmdline
);
}
else
{
return
helper_app_pipe_open_unix (
@cmdline
);
}
}
sub
helper_app_pipe_open_windows {
my
(
$fh
,
$stdinfile
,
$duperr2out
,
@cmdline
) =
@_
;
$cmdline
[0] =
'"'
.
$cmdline
[0].
'"'
if
(
$cmdline
[0] !~ /^\".*\"$/);
my
$cmd
=
join
(
' '
,
@cmdline
);
if
(
$stdinfile
) {
$cmd
.=
qq/ < "$stdinfile"/
; }
if
(
$duperr2out
) {
if
(
$duperr2out
=~ /^>/) {
$cmd
.=
" 2$duperr2out"
;
}
else
{
$cmd
.=
" 2>&1"
;
}
}
return
open
(
$fh
,
$cmd
.
'|'
);
}
sub
force_die {
my
(
$statrc
,
$msg
) =
@_
;
if
(
$msg
) {
eval
{
warn
$msg
};
eval
{ dbg(
"util: force_die: $msg"
) };
}
if
(am_running_on_windows()) {
exit
(
$statrc
);
}
else
{
POSIX::_exit(
$statrc
);
kill
(
'KILL'
,$$)
if
(
$statrc
);
}
}
sub
helper_app_pipe_open_unix {
my
(
$fh
,
$stdinfile
,
$duperr2out
,
@cmdline
) =
@_
;
my
$pid
;
eval
{
$pid
=
open
(
$fh
,
'-|'
); 1;
} or
do
{
my
$eval_stat
= $@ ne
''
? $@ :
"errno=$!"
;
chomp
$eval_stat
;
die
"util: cannot fork: $eval_stat"
;
};
if
(!
defined
$pid
) {
die
"util: cannot open a pipe to a forked process: $!"
;
}
if
(
$pid
!= 0) {
return
$pid
;
}
eval
{
setuid_to_euid();
dbg(
"util: setuid: ruid=$< euid=$> rgid=$( egid=$)"
);
if
(!
$stdinfile
) {
$stdinfile
=
"/dev/null"
;
}
my
$f
=
fileno
(STDIN);
close
STDIN or
die
"error closing STDIN: $!"
;
if
(
$f
!= 0) {
POSIX::
close
(0);
}
open
(STDIN,
"<$stdinfile"
) or
die
"cannot open $stdinfile: $!"
;
if
(
fileno
(STDIN) != 0) {
die
"oops: fileno(STDIN) ["
.
fileno
(STDIN).
"] != 0"
;
}
STDOUT->autoflush(1);
if
(
$duperr2out
) {
my
$f
=
fileno
(STDERR);
close
STDERR or
die
"error closing STDERR: $!"
;
if
(
$f
!= 2) {
POSIX::
close
(2);
}
my
$errout
;
if
(
$duperr2out
=~ /^>/) {
$errout
=
$duperr2out
;
}
else
{
$errout
=
">&STDOUT"
;
}
open
(STDERR,
$errout
) or
die
"dup $errout failed: $!"
;
STDERR->autoflush(1);
if
(
fileno
(STDERR) != 2) {
die
"oops: fileno(STDERR) ["
.
fileno
(STDERR).
"] != 2"
;
}
}
exec
@cmdline
;
die
"exec failed: $!"
;
};
my
$eval_stat
= $@ ne
''
? $@ :
"errno=$!"
;
chomp
$eval_stat
;
force_die(6,
sprintf
(
'util: failed to spawn a process "%s": %s'
,
join
(
", "
,
@cmdline
),
$eval_stat
));
die
;
}
sub
trap_sigalrm_fully {
my
(
$handler
) =
@_
;
if
($] < 5.008 || am_running_on_windows()) {
$SIG
{ALRM} =
$handler
;
}
else
{
POSIX::sigaction POSIX::SIGALRM(), POSIX::SigAction->new(
$handler
);
}
}
my
$qr_sa
;
if
($] >= 5.016) {
eval
'$qr_sa = sub { return qr/$_[0]/aa; }'
;
}
else
{
eval
'$qr_sa = sub { return qr/$_[0]/; }'
;
}
sub
compile_regexp {
my
(
$re
,
$strip_delimiters
,
$ignore_always_matching
) =
@_
;
local
($1);
if
(
ref
(
$re
) ne
''
) {
return
(
undef
,
'ref passed: '
.
ref
(
$re
));
}
$strip_delimiters
= 1
if
!
defined
$strip_delimiters
;
my
$origre
=
$re
;
my
$delim_end
=
''
;
if
(
$strip_delimiters
>= 1) {
if
(
$re
=~ s{^/}{}) {
$delim_end
=
'/'
;
}
elsif
(
$re
=~ s/^(?:m|
qr)([\{\(\<\[])
//) {
(
$delim_end
= $1) =~
tr
/\{\(\<\[/\}\)\>\]/;
}
elsif
(
$re
=~ s/^(?:m|
qr)(\W)
//) {
$delim_end
= $1;
if
(
$delim_end
eq
'\\'
) {
return
(
undef
,
'backslash delimiter not allowed'
);
}
}
elsif
(
$strip_delimiters
!= 2) {
return
(
undef
,
'missing regexp delimiters'
);
}
}
my
$mods
;
if
(
$delim_end
) {
if
(
$re
=~ s/\Q${delim_end}\E([a-df-z]*)\z//) {
$mods
= $1;
}
else
{
return
(
undef
,
'invalid end delimiter/mods'
);
}
}
if
(
index
(
$re
,
'?{'
) >= 0 &&
$re
=~ /\(\?\??\{/) {
return
(
undef
,
'eval (?{}) found'
);
}
if
(
$delim_end
&&
$delim_end
!~
tr
/\}\)\]//) {
my
$dbs_stripped
=
$re
;
$dbs_stripped
=~ s/\\\\//g
if
index
(
$dbs_stripped
,
'\\\\'
) >= 0;
if
(
$dbs_stripped
=~ /(?<!\\)\Q${delim_end}\E/) {
return
(
undef
,
"unquoted delimiter '$delim_end' found"
);
}
}
if
(
$ignore_always_matching
) {
if
(
my
$err
= is_always_matching_regexp(
$re
)) {
return
(
undef
,
"always matching regexp: $err"
);
}
}
if
(
$mods
) {
$re
=
'(?'
.
$mods
.
')'
.
$re
;
}
my
$compiled_re
;
$re
= untaint_var(
$re
);
my
$ok
=
eval
{
local
$SIG
{__WARN__} =
sub
{
if
(
$_
[0] !~ /deprecated/i) {
die
"$_[0]\n"
;
}
};
$compiled_re
=
$qr_sa
->(
$re
);
1;
};
if
(
$ok
&&
ref
(
$compiled_re
) eq
'Regexp'
) {
return
(
$compiled_re
,
''
);
}
else
{
my
$err
= $@ ne
''
? $@ :
"errno=$!"
;
chomp
$err
;
$err
=~ s/ at .*? line \d.*$//;
return
(
undef
,
$err
);
}
}
sub
is_always_matching_regexp {
my
(
$re
) =
@_
;
if
(
$re
eq
''
) {
return
"empty"
;
}
elsif
(
$re
=~ /(?<!\\)\|\|/) {
return
"contains '||'"
;
}
elsif
(
$re
=~ /^\||\|(?<!\\\|)$/) {
return
"starts or ends with '|'"
;
}
return
""
;
}
sub
qr_to_string {
my
(
$re
) =
@_
;
return
undef
unless
ref
(
$re
) eq
'Regexp'
;
$re
=
""
.
$re
;
local
($1);
my
$mods
;
if
(
$re
=~ s/^\(\?\^([a-z]*)://) {
$mods
= $1;
$re
=~ s/\)\s*\z//;
}
elsif
(
$re
=~ s/^\(\?([a-z]*)-[a-z]*://) {
$mods
= $1;
$re
=~ s/\)\s*\z//;
}
return
(
$mods
?
"(?$mods)$re"
:
$re
);
}
sub
regexp_remove_delimiters {
my
(
$re
) =
@_
;
warn
(
"deprecated Util regexp_remove_delimiters() called\n"
);
my
$delim
;
if
(!
defined
$re
||
$re
eq
''
) {
return
undef
;
}
elsif
(
$re
=~ s/^m?\{//) {
$delim
=
'}'
;
}
elsif
(
$re
=~ s/^m?\[//) {
$delim
=
']'
;
}
elsif
(
$re
=~ s/^m?\(//) {
$delim
=
')'
;
}
elsif
(
$re
=~ s/^m?<//) {
$delim
=
'>'
;
}
elsif
(
$re
=~ s/^m?(\W)//) {
$delim
= $1;
}
else
{
return
undef
;
}
if
(
$re
!~ s/\Q${delim}\E([imsx]*)$//) {
return
undef
;
}
my
$mods
= $1;
if
(
$mods
) {
$re
=
"(?"
.
$mods
.
")"
.
$re
;
}
return
$re
;
}
sub
make_qr {
my
(
$re
) =
@_
;
warn
(
"deprecated Util make_qr() called\n"
);
$re
= regexp_remove_delimiters(
$re
);
return
undef
if
!
defined
$re
||
$re
eq
''
;
my
$compiled_re
;
if
(
eval
{
$compiled_re
=
qr/$re/
; 1; } &&
ref
(
$compiled_re
) eq
'Regexp'
) {
return
$compiled_re
;
}
else
{
return
undef
;
}
}
sub
get_my_locales {
my
(
$ok_locales
) =
@_
;
my
@locales
=
split
(/\s+/,
$ok_locales
);
my
$lang
=
$ENV
{
'LC_ALL'
};
$lang
||=
$ENV
{
'LANGUAGE'
};
$lang
||=
$ENV
{
'LC_MESSAGES'
};
$lang
||=
$ENV
{
'LANG'
};
push
(
@locales
,
$lang
)
if
defined
(
$lang
);
return
@locales
;
}
sub
avoid_db_file_locking_bug {
my
(
$path
) =
@_
;
my
$db_tmpfile
= untaint_file_path(File::Spec->catfile(dirname(
$path
),
'__db.'
.basename(
$path
)));
foreach
my
$tfile
(
$db_tmpfile
,
glob
(
"$db_tmpfile.*"
)) {
my
$file
= untaint_file_path(
$tfile
);
my
$stat_errn
=
stat
(
$file
) ? 0 : 0+$!;
next
if
$stat_errn
== ENOENT;
dbg(
"util: Berkeley DB bug work-around: cleaning tmp file $file"
);
unlink
(
$file
) or
warn
"cannot remove Berkeley DB tmp file $file: $!\n"
;
}
}
sub
fisher_yates_shuffle {
my
(
$deck
) =
@_
;
for
(
my
$i
= $
my
$j
=
int
rand
(
$i
+1);
@$deck
[
$i
,
$j
] =
@$deck
[
$j
,
$i
];
}
}
sub
domain_to_search_list {
my
(
$domain
) =
@_
;
$domain
=~ s/^\.+//;
$domain
=~ s/\.+\z//;
return
[]
unless
$domain
;
return
[
$domain
]
if
index
(
$domain
,
'['
) == 0;
$domain
=
lc
$domain
;
my
@search_keys
= (
$domain
);
my
$pos
= 0;
while
((
$pos
=
index
(
$domain
,
'.'
,
$pos
+1)) != -1) {
push
@search_keys
,
substr
(
$domain
,
$pos
+1);
}
if
(
@search_keys
> 20) {
@search_keys
=
@search_keys
[
$#search_keys
-19 ..
$#search_keys
];
}
return
\
@search_keys
;
}
sub
get_tag_value_for_score {
my
(
$score
,
$rscore
,
$is_spam
) =
@_
;
$score
=
sprintf
(
"%2.1f"
,
$score
);
$rscore
=
sprintf
(
"%2.1f"
,
$rscore
);
return
$score
if
$is_spam
or
$score
<
$rscore
;
return
$rscore
- 0.1;
}
our
$header_address_parser
;
our
$email_address_xs
;
our
$email_address_xs_fix_address
;
BEGIN {
$header_address_parser
= untaint_var(
$ENV
{
'SA_HEADER_ADDRESS_PARSER'
});
if
((!
defined
$header_address_parser
||
$header_address_parser
eq
'2'
) &&
eval
'use Email::Address::XS; 1;'
) {
$email_address_xs
= 1;
if
(version->parse(Email::Address::XS->VERSION) < version->parse(1.02)) {
$email_address_xs_fix_address
= 1;
}
}
}
our
$header_address_mailre
=
qr/
# user
(?:
# quoted localpart
" (?:|(?:[^"\\]++|\\.)*+) " |
# or un-quoted localpart
[^\@\s\<\>\(\)\[\]\,\:\;]+
)
# domain
\@ (?: [^\"\s\<\>\(\)\[\]\,\:\;]+ | \[ [\d:.]+ \] )
/
ix;
our
$header_address_re
=
qr/^
\s*
(?:
# optional phrase, quoted or non-quoted
(?:
( (?: " (?:|(?:[^"\\]++|\\.)*+) " | [^",;<]++ )+ )
\s*
)?
# and enclosed email (or empty)
# ... allow whitespace in localpart
< \s* ( [^>\@]* \S+ | \s* ) \s* >
# some output duplicate enclosures..
(?: \s* < \s* (?: (?: " (?:|(?:[^"\\]++|\\.)*+) " )? \S+ | \s* ) \s* > )*
|
# or standalone email or phrase
(?:
( $header_address_mailre ) |
( (?: " (?:|(?:[^"\\]++|\\.)*+) " | [^",;<]++ )+ )
)
)
# possible comment after (no nested support here)
(?: \s* \( ( (?:|(?:[^()\\]++|\\.)*+) ) \) )?
# Followed by comma (semi-colon sometimes) or finish
\s* (?: [,;] | \z )
/
ix;
sub
parse_header_addresses {
my
(
$str
) =
@_
;
return
if
!
defined
$str
||
$str
!~ /\S/;
my
@results
;
if
(!
$header_address_parser
||
$header_address_parser
eq
'1'
) {
@results
= _parse_header_addresses(
$str
);
}
if
(
$email_address_xs
) {
if
(!
$header_address_parser
||
$header_address_parser
eq
'2'
) {
my
$maybe_nested
=
scalar
(
$str
=~ /\(/) >= 2;
if
(!
@results
||
$maybe_nested
||
@results
<
scalar
(
$str
=~
tr
/,//)+1) {
my
@results_xs
= _parse_header_addresses_xs(
$str
);
if
(
@results_xs
>
@results
||
$maybe_nested
) {
return
@results_xs
;
}
}
}
}
return
@results
;
}
sub
get_part_details {
my
(
$pms
,
$part
,
$prefer_contentdisposition
) =
@_
;
my
$ctt
=
$part
->get_header(
'content-type'
);
return
undef
unless
defined
$ctt
;
my
$cte
=
lc
(
$part
->get_header(
'content-transfer-encoding'
) ||
''
);
return
undef
unless
(
$cte
=~ /^(?:base64|quoted\-printable)$/);
$ctt
= _decode_part_header(
$part
,
$ctt
||
''
);
my
$name
=
''
;
my
$cttname
=
''
;
my
$ctdname
=
''
;
if
(
$ctt
=~ m/name\s*=\s*[
"']?([^"
';]*)/is) {
$cttname
= $1;
$cttname
=~ s/\s+$//;
}
my
$ctd
=
$part
->get_header(
'content-disposition'
);
$ctd
= _decode_part_header(
$part
,
$ctd
||
''
);
if
(
$ctd
=~ m/filename\s*=\s*[
"']?([^"
';]*)/is) {
$ctdname
= $1;
$ctdname
=~ s/\s+$//;
}
if
(
lc
$ctdname
eq
lc
$cttname
) {
$name
=
$ctdname
;
}
elsif
(
$ctdname
eq
''
) {
$name
=
$cttname
;
}
elsif
(
$cttname
eq
''
) {
$name
=
$ctdname
;
}
else
{
if
((
defined
$ctdname
) and
$prefer_contentdisposition
) {
$name
=
$ctdname
;
}
else
{
$name
=
$cttname
;
}
}
return
$ctt
,
$ctd
,
$cte
,
$name
;
}
sub
_decode_part_header {
my
(
$part
,
$header_field_body
) =
@_
;
return
''
unless
defined
$header_field_body
&&
$header_field_body
ne
''
;
$header_field_body
=~ s/\n[ \t]+/\n /g;
$header_field_body
=~ s/\015?\012//gs;
local
($1,$2,$3);
1
while
$header_field_body
=~
s{ ( = \? [A-Za-z0-9_-]+ \? [bqBQ] \? [^?]* \? = ) \s+
( = \? [A-Za-z0-9_-]+ \? [bqBQ] \? [^?]* \? = ) }
{$1$2}xsg;
$header_field_body
=~
s{ (?: = \? ([A-Za-z0-9_-]+) \? ([bqBQ]) \? ([^?]*) \? = ) }
{
$part
->__decode_header($1,
uc
($2), $3) }xsge;
return
$header_field_body
;
}
sub
_valid_parsed_address {
return
0
if
!
defined
$_
[0];
return
0
if
index
(
$_
[0],
'""@'
) == 0;
return
0
if
scalar
(
$_
[0] =~
tr
/"//) == 1;
return
1;
}
sub
_parse_header_addresses {
local
$_
=
shift
;
local
($1, $2, $3, $4, $5);
s/\s+\z//s;
s/\\\\//g;
s/^[^"()<>]+:\s*(.*?)\s*(?:;.*)?/$1/gs;
return
unless
/\S/;
my
@results
;
while
(s/
$header_address_re
//igs) {
my
$phrase
=
defined
$1 ? $1 :
defined
$4 ? $4 :
undef
;
my
$address
=
defined
$2 ? $2 :
defined
$3 ? $3 :
undef
;
my
$comment
=
defined
$5 ? $5 :
undef
;
my
(
$user
,
$host
,
$invalid
);
if
(
defined
$2) {
$address
=~ s/\((?:|(?:[^()\\]++|\\.)*+)\)//gs;
if
(
$address
!~ /^
$header_address_mailre
$/) {
$address
=
undef
;
}
}
if
(!_valid_parsed_address(
$address
)) {
$address
=
undef
;
}
if
(
defined
$phrase
) {
my
$newphrase
;
while
(
$phrase
=~ /(?:
"(|(?:[^"
\\]++|\\.)*+)
"|([^"
]++))/igs) {
my
$qs
= $1;
my
$nqs
= $2;
if
(
defined
$qs
) {
$qs
=~ s/\\(?!\\)//g;
$qs
=~ s/\\\\/\\/g;
$newphrase
.=
$qs
;
}
else
{
$nqs
=~ s/\((?:|(?:[^()\\]++|\\.)*+)\)//gs;
$newphrase
.=
$nqs
;
}
}
$phrase
=
$newphrase
;
if
(!
defined
$address
&&
$phrase
=~ /^
$header_address_mailre
$/i &&
_valid_parsed_address(
$phrase
) &&
$phrase
=~ /^[^\@]*\@([^\@]*)/ &&
is_fqdn_valid(idn_to_ascii($1), 1)) {
$address
=
$phrase
;
$phrase
=
undef
;
}
else
{
if
(
defined
$address
&&
$phrase
eq
$address
) {
$phrase
=
undef
;
}
elsif
(
$phrase
eq
''
) {
$phrase
=
undef
;
}
}
}
if
(!
defined
$phrase
&&
defined
$comment
) {
$phrase
=
$comment
;
}
if
(
defined
$address
) {
$address
=~ s/^(([^\@]*)\@([^\@]*)).*/$1/;
(
$user
,
$host
) = ($2, $3);
}
$invalid
= !
defined
$host
|| !is_fqdn_valid(idn_to_ascii(
$host
), 1);
push
@results
, {
'phrase'
=>
$phrase
,
'user'
=>
$user
,
'host'
=>
$host
,
'address'
=>
$address
,
'comment'
=>
$comment
,
'invalid'
=>
$invalid
};
}
if
(
index
(
$_
,
'@'
) != -1) {
while
(/<(
$header_address_mailre
)>/igs) {
my
$address
= $1;
next
if
!_valid_parsed_address(
$address
);
$address
=~ s/^(([^\@]*)\@([^\@]*)).*/$1/;
my
(
$user
,
$host
) = ($2, $3);
my
$invalid
= !is_fqdn_valid(idn_to_ascii(
$host
), 1);
push
@results
, {
'phrase'
=>
undef
,
'user'
=>
$user
,
'host'
=>
$host
,
'address'
=>
$address
,
'comment'
=>
undef
,
'invalid'
=>
$invalid
};
}
}
return
if
!
@results
;
return
@results
;
}
sub
_parse_header_addresses_xs {
my
(
$str
) =
@_
;
$str
=~ s/\\\\//g;
my
@results
;
my
@addrs
= Email::Address::XS->parse(
$str
);
local
($1, $2);
foreach
my
$addr
(
@addrs
) {
my
$name
=
$addr
->name;
my
$address
=
$addr
->address;
my
$user
=
$addr
->user;
my
$host
=
$addr
->host;
my
$phrase
=
$addr
->phrase;
my
$comment
=
$addr
->comment;
my
$invalid
;
if
(!
defined
$address
&& !
defined
$user
&&
!
defined
$comment
&&
defined
$phrase
&&
_valid_parsed_address(
$phrase
) &&
$phrase
=~ /^([^\s\@]+)\@([^\s\@]+)$/ &&
is_fqdn_valid(idn_to_ascii($2), 1))
{
$user
= $1;
$host
= $2;
$address
=
$phrase
;
$name
=
$user
;
$invalid
= 0;
$phrase
=
undef
;
}
else
{
$invalid
= !
$addr
->is_valid;
}
if
(
$email_address_xs_fix_address
) {
if
(
defined
$user
&&
defined
$host
) {
if
(
index
(
$user
,
' '
) != -1 &&
index
(
$user
,
'"'
) == -1) {
$user
=
'"'
.
$user
.
'"'
;
}
$address
=
$user
.
'@'
.
$host
;
}
}
if
(!
defined
$phrase
&&
defined
$comment
) {
$phrase
=
$comment
;
}
if
(!
defined
$phrase
&& !
defined
$address
) {
$phrase
=
$str
;
}
push
@results
, {
'phrase'
=>
$phrase
,
'user'
=>
$user
,
'host'
=>
$host
,
'address'
=>
$address
,
'comment'
=>
$comment
,
'invalid'
=>
$invalid
};
}
return
@results
;
}
1;