line |
stmt |
bran |
cond |
sub |
pod |
time |
code |
1
|
|
|
|
|
|
|
package WebService::Cmis::Test::ChangeFeed; |
2
|
1
|
|
|
1
|
|
724
|
use base qw(WebService::Cmis::Test); |
|
1
|
|
|
|
|
2
|
|
|
1
|
|
|
|
|
641
|
|
3
|
|
|
|
|
|
|
|
4
|
|
|
|
|
|
|
use strict; |
5
|
|
|
|
|
|
|
use warnings; |
6
|
|
|
|
|
|
|
|
7
|
|
|
|
|
|
|
use Test::More; |
8
|
|
|
|
|
|
|
|
9
|
|
|
|
|
|
|
sub test_ChangeFeed_paginate : Tests { |
10
|
|
|
|
|
|
|
my $this = shift; |
11
|
|
|
|
|
|
|
|
12
|
|
|
|
|
|
|
my $repo = $this->getRepository; |
13
|
|
|
|
|
|
|
my $canChanges = $repo->getCapabilities()->{'Changes'}; |
14
|
|
|
|
|
|
|
|
15
|
|
|
|
|
|
|
my $msg = $this->isBrokenFeature("paging"); |
16
|
|
|
|
|
|
|
|
17
|
|
|
|
|
|
|
SKIP: { |
18
|
|
|
|
|
|
|
skip "not able to log changes", unless defined $canChanges; |
19
|
|
|
|
|
|
|
skip $msg if $msg; |
20
|
|
|
|
|
|
|
|
21
|
|
|
|
|
|
|
my $changes1 = $repo->getContentChanges(maxItems => 2); |
22
|
|
|
|
|
|
|
my $size = $changes1->getSize; |
23
|
|
|
|
|
|
|
|
24
|
|
|
|
|
|
|
note("size1=$size"); |
25
|
|
|
|
|
|
|
|
26
|
|
|
|
|
|
|
# print STDERR "### changes:\n".$changes1->{xmlDoc}->toString(1)."\n###\n"; |
27
|
|
|
|
|
|
|
|
28
|
|
|
|
|
|
|
my %entries1 = (); |
29
|
|
|
|
|
|
|
my @keys = (); |
30
|
|
|
|
|
|
|
my $index = 0; |
31
|
|
|
|
|
|
|
my $numTestedCycles = 10; |
32
|
|
|
|
|
|
|
while (my $entry = $changes1->getNext) { |
33
|
|
|
|
|
|
|
my $changeId = $entry->getId; |
34
|
|
|
|
|
|
|
ok(defined $changeId); |
35
|
|
|
|
|
|
|
|
36
|
|
|
|
|
|
|
my $id = $entry->getObjectId; |
37
|
|
|
|
|
|
|
ok(defined $id); |
38
|
|
|
|
|
|
|
|
39
|
|
|
|
|
|
|
my $changeType = $entry->getChangeType; |
40
|
|
|
|
|
|
|
like($changeType, qr'^(created|updated|deleted|security)$'); |
41
|
|
|
|
|
|
|
|
42
|
|
|
|
|
|
|
my $changeTime = $entry->getChangeTime; |
43
|
|
|
|
|
|
|
like($changeTime, qr'^\d+'); |
44
|
|
|
|
|
|
|
|
45
|
|
|
|
|
|
|
my $key = "$id-$changeTime"; |
46
|
|
|
|
|
|
|
|
47
|
|
|
|
|
|
|
#print STDERR "$index: key1=$key\n"; |
48
|
|
|
|
|
|
|
push @keys, $key; |
49
|
|
|
|
|
|
|
|
50
|
|
|
|
|
|
|
# this fails on nuxeo for no obvious reason ... bug |
51
|
|
|
|
|
|
|
#ok(!defined $entries1{$key}) || diag("found same key=$key twice in change log"); |
52
|
|
|
|
|
|
|
$entries1{$key} = $entry; |
53
|
|
|
|
|
|
|
$index++; |
54
|
|
|
|
|
|
|
last if $index >= $numTestedCycles; |
55
|
|
|
|
|
|
|
} |
56
|
|
|
|
|
|
|
|
57
|
|
|
|
|
|
|
#print STDERR "index1=" . scalar(keys %entries1) . "\n"; |
58
|
|
|
|
|
|
|
|
59
|
|
|
|
|
|
|
my $changes2 = $repo->getContentChanges(maxItems => 2); |
60
|
|
|
|
|
|
|
my $size2 = $changes2->getSize; |
61
|
|
|
|
|
|
|
note("size2=$size2"); |
62
|
|
|
|
|
|
|
|
63
|
|
|
|
|
|
|
my %entries2 = (); |
64
|
|
|
|
|
|
|
$index = 0; |
65
|
|
|
|
|
|
|
while (my $entry = $changes2->getNext) { |
66
|
|
|
|
|
|
|
my $id = $entry->getObjectId; |
67
|
|
|
|
|
|
|
my $changeTime = $entry->getChangeTime; |
68
|
|
|
|
|
|
|
my $key = "$id-$changeTime"; |
69
|
|
|
|
|
|
|
|
70
|
|
|
|
|
|
|
#print STDERR "$index: key2=$key\n"; |
71
|
|
|
|
|
|
|
|
72
|
|
|
|
|
|
|
ok(defined $entries1{$key}) || diag("didn't find key=$key in first change log"); |
73
|
|
|
|
|
|
|
|
74
|
|
|
|
|
|
|
# this fails on nuxeo for no obvious reason ... bug |
75
|
|
|
|
|
|
|
#ok(!defined $entries2{$key}) || diag("found same key=$key twice in change log"); |
76
|
|
|
|
|
|
|
$entries2{$key} = $entry; |
77
|
|
|
|
|
|
|
$index++; |
78
|
|
|
|
|
|
|
last if $index >= $numTestedCycles; |
79
|
|
|
|
|
|
|
} |
80
|
|
|
|
|
|
|
|
81
|
|
|
|
|
|
|
#print STDERR "index2=".scalar(keys %entries2)."\n"; |
82
|
|
|
|
|
|
|
|
83
|
|
|
|
|
|
|
foreach my $key (@keys) { |
84
|
|
|
|
|
|
|
|
85
|
|
|
|
|
|
|
#print STDERR "key=$key\n"; |
86
|
|
|
|
|
|
|
ok(defined $entries2{$key}) or diag("entry $key in first set not found in second"); |
87
|
|
|
|
|
|
|
} |
88
|
|
|
|
|
|
|
} |
89
|
|
|
|
|
|
|
} |
90
|
|
|
|
|
|
|
|
91
|
|
|
|
|
|
|
1; |
92
|
|
|
|
|
|
|
|