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
|
# Copyright 2014 - present MongoDB, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
use strict;
use warnings;
use Test::More 0.96;
use Test::Deep qw/:v1/;
use JSON::MaybeXS;
use Scalar::Util qw/looks_like_number/;
use MongoDB;
use BSON::Types ':all';
use lib "t/lib";
use MongoDBTest qw/
build_client
skip_unless_mongod
/;
skip_unless_mongod();
use MongoDBTest::Callback;
my $cb = MongoDBTest::Callback->new;
my $conn = build_client( monitoring_callback => $cb->callback );
my $topo = $conn->_topology;
$cb->clear_events;
$topo->scan_all_servers;
my @events_cb = @{$cb->events};
my @heartbeat_started_events;
my @heartbeat_succeeded_events;
for my $event_idx ( 0..$#events_cb ) {
my $event_header = $events_cb[$event_idx]->{'type'} // "";
if ($event_header eq 'server_heartbeat_started_event') {
push @heartbeat_started_events, delete $events_cb[$event_idx];
}
}
for my $event_idx ( 0..$#events_cb ) {
my $event_header = $events_cb[$event_idx]->{'type'} // "";
if ($event_header eq 'server_heartbeat_succeeded_event') {
push @heartbeat_succeeded_events, delete $events_cb[$event_idx];
}
}
for my $i (0 .. $#heartbeat_succeeded_events) {
my $heartbeat_succeed = $heartbeat_succeeded_events[$i];
my $heartbeat_started = $heartbeat_started_events[$i];
ok( looks_like_number( $heartbeat_succeed->{'duration'} ),
"duration looks like a number");
cmp_deeply(
$heartbeat_succeed,
{
connectionId => $heartbeat_started->{'connectionId'},
duration => ignore(),
reply => ignore(),
type => "server_heartbeat_succeeded_event"
},
"heartbeat succeed event appears to match the pattern it should"
);
}
done_testing;
|
