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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
use strict;
use warnings;
use Net::SIP;
use Test::More tests => 6;
################################################################
# test delivery of packets through stateless proxy
# works by defining domain2leg to specify leg for domain(s).
# the 'deliver' method of the legs are redefined so that no
# actual delivery gets done but that delivery only gets simulated.
# TODO:
# - check with requests which have route header
# - check with responses (routing based on via header)
# - check that route and via header gets stripped and contact
# header rewritten
# - check strict routes vs. loose routers (manipulate URI
# and route header to simulate behavior)
# - more tests for Net::SIP::Dispatcher::resolve_uri (not
# only related to stateless proxy)
################################################################
my %leg_setup = ( addr => '127.0.0.1', port => 0 );
my $leg_default = myLeg->new(
outgoing_proxy => '10.0.3.4:28',
%leg_setup ) || die;
my $leg_example_com = myLeg->new(
outgoing_proxy => '10.0.3.9:28',
%leg_setup ) || die;
my $leg_example_org = myLeg->new(
outgoing_proxy => '10.0.3.12:28',
%leg_setup ) || die;
my $loop = Net::SIP::Dispatcher::Eventloop->new;
my $disp = Net::SIP::Dispatcher->new(
[
$leg_default,
$leg_example_com,
$leg_example_org
],
$loop,
domain2proxy => {
'example.com' => $leg_example_com->{outgoing_proxy},
'example.org' => $leg_example_org->{outgoing_proxy},
'*.example.org' => $leg_example_org->{outgoing_proxy},
'*' => $leg_default->{outgoing_proxy},
},
) || die;
our $delivered_via;
my $proxy = Net::SIP::StatelessProxy->new(
dispatcher => $disp
);
$disp->set_receiver( $proxy );
# -------------------------------------------------------------------------
# fw( address, incoming_leg, expected_outgoing_leg )
# -------------------------------------------------------------------------
fw( 'sip:me@example.com', $leg_default, $leg_example_com );
fw( 'sip:me@example.com', $leg_example_org, $leg_example_com );
fw( 'sip:me@somewhere.example.com', $leg_example_org, $leg_default );
fw( 'sip:me@example.org', $leg_example_com, $leg_example_org );
fw( 'sip:me@somewhere.example.org', $leg_example_com, $leg_example_org );
fw( 'sip:me@whatever', $leg_example_com, $leg_default );
# DONE
# -------------------------------------------------------------------------
sub fw {
my ($to,$incoming_leg,$expected_outgoing_leg) = @_;
$delivered_via = undef;
my $request = Net::SIP::Request->new( 'INVITE', $to, {
to => $to,
cseq => '1 INVITE',
'call-id' => sprintf( "%8x\@somewhere.com", rand(2**16 )),
from => 'me@somewhere.com',
});
$disp->receive( $request,$incoming_leg,'127.0.0.1:282' );
$loop->loop(1,\$delivered_via );
ok( $delivered_via == $expected_outgoing_leg, 'expected leg' );
}
# -------------------------------------------------------------------------
package myLeg;
use base 'Net::SIP::Leg';
use Net::SIP::Debug;
use Net::SIP::Util 'invoke_callback';
use fields qw( outgoing_proxy );
sub new {
my ($class,%args) = @_;
my $p = delete $args{outgoing_proxy};
my $self = $class->SUPER::new(%args);
$self->{outgoing_proxy} = $p;
return $self;
}
sub can_deliver_to {
my $self = shift;
my ($proto,$addr,$port) = do {
if ( @_>1 ) {
my %args = @_;
@args{ qw/proto addr port/ }
} else {
$_[0] =~m{^(?:(udp|tcp):)?([^:]+)(?::(\d+))$}
}
};
return 1 if ! $addr || ! $port;
return 1 if "$addr:$port" eq $self->{outgoing_proxy};
return 0;
}
sub deliver {
my ($self,$packet,$addr,$callback) = @_;
$::delivered_via = $self;
DEBUG( "deliver through $self" );
invoke_callback( $callback,0 );
}
|
