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
|
#!perl
use strict;
no warnings;
use Test::More;
use AnyEvent::XMPP::TestClient;
use AnyEvent::XMPP::IM::Message;
use AnyEvent::XMPP::Util qw/prep_bare_jid bare_jid cmp_bare_jid/;
my $cl =
AnyEvent::XMPP::TestClient->new_or_exit (tests => 1, two_accounts => 1, finish_count => 2);
my $C = $cl->client;
my ($src, $dest, $src_full, $dest_full);
my $message_conv = "";
my @seq = (
sub {
my ($srcacc, $destacc, $msg, $msg_from_src) = @_;
if ($msg_from_src) {
my $repl = $msg->make_reply;
$repl->add_body ($msg->any_body () . $msg->to . "\n");
$destacc->send_tracked_message ($repl);
}
},
sub {
my ($srcacc, $destacc, $msg, $msg_from_src) = @_;
if (!$msg_from_src) {
my $repl = $msg->make_reply;
$repl->add_body ($msg->any_body () . $msg->to . "\n");
$srcacc->send_tracked_message ($repl);
}
},
sub {
my ($srcacc, $destacc, $msg, $msg_from_src) = @_;
if ($msg_from_src) {
my $repl = $msg->make_reply;
$repl->add_body ($msg->any_body () . $msg->to . "\nend\n");
$destacc->send_tracked_message ($repl);
}
},
sub {
my ($srcacc, $destacc, $msg, $msg_from_src) = @_;
if (!$msg_from_src) {
$message_conv = $msg->any_body;
$cl->finish;
}
},
);
$C->reg_cb (
two_accounts_ready => sub {
my ($C) = @_;
$src = prep_bare_jid $cl->{jid};
$dest = prep_bare_jid $cl->{jid2};
$src_full = $cl->{jid};
$dest_full = $cl->{jid2};
my $msg = AnyEvent::XMPP::IM::Message->new (
body => "start\n",
to => $dest,
type => 'chat',
);
$cl->{acc}->send_tracked_message ($msg);
$cl->finish;
},
message => sub {
my ($C, $acc, $msg) = @_;
my $sacc = $C->get_account ($src);
my $dacc = $C->get_account ($dest);
if (my $seq = shift @seq) {
$seq->($sacc, $dacc, $msg, cmp_bare_jid ($msg->from, $src));
} else {
$cl->finish;
}
}
);
$cl->wait;
is ($message_conv,
"start\n"
.$dest."\n"
.$src_full."\n"
.$dest_full."\n"
."end\n",
"conversation had expected results"
);
|
