diff options
Diffstat (limited to 'test/javascript/tests/replicator_db_identical_continuous.js')
| -rw-r--r-- | test/javascript/tests/replicator_db_identical_continuous.js | 139 |
1 files changed, 0 insertions, 139 deletions
diff --git a/test/javascript/tests/replicator_db_identical_continuous.js b/test/javascript/tests/replicator_db_identical_continuous.js deleted file mode 100644 index 37495ecbd..000000000 --- a/test/javascript/tests/replicator_db_identical_continuous.js +++ /dev/null @@ -1,139 +0,0 @@ -// 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. - -couchTests.skip = true; -couchTests.replicator_db_identical_continuous = function(debug) { - if (debug) debugger; - - var populate_db = replicator_db.populate_db; - var docs1 = replicator_db.docs1; - var dbA = replicator_db.dbA; - var dbB = replicator_db.dbB; - var repDb = replicator_db.repDb; - var wait = replicator_db.wait; - var waitForRep = replicator_db.waitForRep; - var waitForSeq = replicator_db.waitForSeq; - var wait_rep_doc = replicator_db.wait_rep_doc; - - // test the case where multiple replication docs (different IDs) - // describe in fact the same continuous replication (source, target, etc) - function identical_continuous_rep_docs() { - populate_db(dbA, docs1); - populate_db(dbB, []); - - var repDoc1 = { - _id: "foo_dup_cont_rep_doc_1", - source: "http://" + CouchDB.host + "/" + dbA.name, - target: dbB.name, - continuous: true - }; - var repDoc2 = { - _id: "foo_dup_cont_rep_doc_2", - source: "http://" + CouchDB.host + "/" + dbA.name, - target: dbB.name, - continuous: true - }; - - T(repDb.save(repDoc1).ok); - T(repDb.save(repDoc2).ok); - - waitForSeq(dbA, dbB); - for (var i = 0; i < docs1.length; i++) { - var doc = docs1[i]; - var copy = dbB.open(doc._id); - T(copy !== null); - T(copy.value === doc.value); - } - - // Rather than a timeout we're just waiting to hear the - // fourth change to the database. Changes 1 and 2 were - // us storing repDoc1 and repDoc2. Changes 3 and 4 are - // the replicator manager updating each document. This - // just waits until the fourth change before continuing. - repDb.changes({"feed":"longpoll", "since":3}); - - repDoc1 = repDb.open("foo_dup_cont_rep_doc_1"); - T(repDoc1 !== null); - T(repDoc1._replication_state === "triggered"); - T(typeof repDoc1._replication_state_time === "string"); - T(typeof repDoc1._replication_id === "string"); - - repDoc2 = repDb.open("foo_dup_cont_rep_doc_2"); - T(repDoc2 !== null); - T(typeof repDoc2._replication_state === "undefined"); - T(typeof repDoc2._replication_state_time === "undefined"); - T(repDoc2._replication_id === repDoc1._replication_id); - - var newDoc = { - _id: "foo666", - value: 999 - }; - T(dbA.save(newDoc).ok); - - waitForSeq(dbA, dbB); - var copy = dbB.open("foo666"); - T(copy !== null); - T(copy.value === 999); - - // deleting second replication doc, doesn't affect the 1st one and - // neither it stops the replication - T(repDb.deleteDoc(repDoc2).ok); - repDoc1 = repDb.open("foo_dup_cont_rep_doc_1"); - T(repDoc1 !== null); - T(repDoc1._replication_state === "triggered"); - T(typeof repDoc1._replication_state_time === "string"); - - var newDoc2 = { - _id: "foo5000", - value: 5000 - }; - T(dbA.save(newDoc2).ok); - - waitForSeq(dbA, dbB); - var copy = dbB.open("foo5000"); - T(copy !== null); - T(copy.value === 5000); - - // deleting the 1st replication document stops the replication - T(repDb.deleteDoc(repDoc1).ok); - var newDoc3 = { - _id: "foo1983", - value: 1983 - }; - T(dbA.save(newDoc3).ok); - - wait(wait_rep_doc); //how to remove wait? - var copy = dbB.open("foo1983"); - T(copy === null); - } - - var server_config = [ - { - section: "couch_httpd_auth", - key: "iterations", - value: "1" - }, - { - section: "replicator", - key: "db", - value: repDb.name - } - ]; - - repDb.deleteDb(); - run_on_modified_server(server_config, identical_continuous_rep_docs); - - // cleanup - repDb.deleteDb(); - dbA.deleteDb(); - dbB.deleteDb(); -}
\ No newline at end of file |