1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
#!/usr/bin/perl -T
use lib '.'; use lib 't';
use SATest; sa_t_init("spamd_protocol_10");
use Test::More;
plan skip_all => "Spamd tests disabled" if $SKIP_SPAMD_TESTS;
plan tests => 10;
use File::Path;
use IO::Socket;
# ---------------------------------------------------------------------------
%patterns = (
qr/^SPAMD\/1.1 0 EX_OK/m, 'response-11',
'Spam: True ;', 'spamheader', # we use a regexp later for the rest
'GTUBE', 'gtube',
);
start_spamd("-L");
my $data = "";
open (GTUBE, "data/spam/gtube.eml") || die $!;
foreach (<GTUBE>) {
s/\r?\n?$/\n/;
print "GTUBE: $_";
$data .= $_;
}
close (GTUBE);
my $out;
for ($p = 0; $p <= 1; $p++) {
$out = run_symbols ($data, $p);
ok (defined ($out));
if ($out =~ /Spam: True \; ([\d\.]+) \/ 5\.0/) {
# the exact count could be just over or under 1000. compute!
ok ($1 >= 980 && $1 < 1020);
}
patterns_run_cb ($out);
ok_all_patterns();
clear_pattern_counters();
}
stop_spamd();
exit;
sub run_symbols {
my($data, $proto10) = @_;
my $use_inet4 =
!$have_inet6 ||
($have_inet4 && $spamdhost =~ /^\d+\.\d+\.\d+\.\d+\z/);
my %args = ( PeerAddr => $spamdhost,
PeerPort => $spamdport,
Proto => "tcp",
Type => SOCK_STREAM
);
$socket = $use_inet4 ? IO::Socket::INET->new(%args)
: IO::Socket::INET6->new(%args);
unless ($socket) {
warn("FAILED - Couldn't Connect to SpamCheck Host\n");
return undef;
}
if ($proto10) {
sockwrite ("SYMBOLS SPAMC/1.0\r\n");
}
else {
sockwrite ("SYMBOLS SPAMC/1.2\r\n");
sockwrite ("Content-Length: " . length($data) . "\r\n");
sockwrite ("\r\n");
}
sockwrite ($data);
shutdown($socket, 1);
$data = "";
while (<$socket>) {
s/\r?\n?$/\n/;
print "READ: $_";
$data .= $_;
}
$socket = undef;
return $data;
}
sub sockwrite {
my $data = shift;
print $socket $data;
$data =~ s/^/WRITE: /mg;
print $data;
}
|
