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
|
// 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.
var replicator_db = {};
replicator_db.wait_rep_doc = 500; // number of millisecs to wait after saving a Rep Doc
replicator_db.dbA = new CouchDB("test_suite_rep_db_a", {"X-Couch-Full-Commit":"false"});
replicator_db.dbB = new CouchDB("test_suite_rep_db_b", {"X-Couch-Full-Commit":"false"});
replicator_db.repDb = new CouchDB("test_suite_rep_db", {"X-Couch-Full-Commit":"false"});
replicator_db.usersDb = new CouchDB("test_suite_auth", {"X-Couch-Full-Commit":"false"});
replicator_db.docs1 = [
{
_id: "foo1",
value: 11
},
{
_id: "foo2",
value: 22
},
{
_id: "foo3",
value: 33
}
];
replicator_db.waitForRep = function waitForSeq(repDb, repDoc, state, errorState) {
var newRep,
t0 = new Date(),
t1,
ms = 3000;
do {
newRep = repDb.open(repDoc._id);
t1 = new Date();
} while (((t1 - t0) <= ms) && newRep._replication_state !== state && (!errorState || newRep._replication_state !== errorState));
return newRep ? newRep._replication_state : null;
}
replicator_db.waitForSeq = function waitForSeq(sourceDb, targetDb) {
var targetSeq,
sourceSeq = sourceDb.info().update_seq,
t0 = new Date(),
t1,
ms = 3000;
do {
targetSeq = targetDb.info().update_seq;
t1 = new Date();
} while (((t1 - t0) <= ms) && targetSeq < sourceSeq);
}
replicator_db.waitForDocPos = function waitForDocPos(db, docId, pos) {
var doc, curPos, t0, t1,
maxWait = 3000;
doc = db.open(docId);
curPos = Number(doc._rev.split("-", 1));
t0 = t1 = new Date();
while ((curPos < pos) && ((t1 - t0) <= maxWait)) {
doc = db.open(docId);
curPos = Number(doc._rev.split("-", 1));
t1 = new Date();
}
return doc;
}
replicator_db.wait = function wait(ms) {
var t0 = new Date(), t1;
do {
CouchDB.request("GET", "/");
t1 = new Date();
} while ((t1 - t0) <= ms);
}
replicator_db.populate_db = function populate_db(db, docs) {
if (db.name !== replicator_db.usersDb.name) {
db.deleteDb();
db.createDb();
}
for (var i = 0; i < docs.length; i++) {
var d = docs[i];
delete d._rev;
T(db.save(d).ok);
}
}
|
