Commit 78008493427a069cce680c9494eb59be4b23024c
more relaxed block tests
Dominic Tarr committed on 10/3/2016, 4:01:36 AMParent: 6a7d492d58470cc1653ff2879a1f385f03008e11
Files changed
| test/block.js | changed |
| test/block3.js | changed |
| test/block.js | ||
|---|---|---|
| @@ -55,15 +55,17 @@ | ||
| 55 | 55 … | |
| 56 | 56 … | //get the next messages that are replicated to alice and bob, |
| 57 | 57 … | //and check that these are the correct follow messages. |
| 58 | 58 … | var bobCancel = bob.post(function (op) { |
| 59 … | + console.log('BOB_POST', op) | |
| 59 | 60 … | //should be the alice's follow(bob) message. |
| 60 | 61 … | t.equal(op.value.author, alice.id) |
| 61 | 62 … | t.equal(op.value.content.contact, bob.id) |
| 62 | 63 … | next() |
| 63 | 64 … | }) |
| 64 | 65 … | |
| 65 | 66 … | var aliceCancel = alice.post(function (op) { |
| 67 … | + console.log('ALICE_POST', op) | |
| 66 | 68 … | //should be the bob's follow(alice) message. |
| 67 | 69 … | t.equal(op.value.author, bob.id) |
| 68 | 70 … | t.equal(op.value.content.contact, alice.id) |
| 69 | 71 … | next() |
| @@ -100,17 +102,45 @@ | ||
| 100 | 102 … | |
| 101 | 103 … | //since bob is blocked, he should not be able to connect |
| 102 | 104 … | bob.connect(alice.getAddress(), function (err, rpc) { |
| 103 | 105 … | t.ok(err, 'bob is blocked, should fail to connect to alice') |
| 106 … | + | |
| 107 … | + | |
| 108 … | + carol.post(function (msg) { | |
| 109 … | + console.log('CAROL RECV', msg, alice.id) | |
| 110 … | + if(msg.author === alice.id) { | |
| 111 … | + if(msg.sequence == 2) | |
| 112 … | + t.end() | |
| 113 … | + } | |
| 114 … | + }) | |
| 115 … | + | |
| 104 | 116 … | //but carol, should, because she is not blocked. |
| 105 | - carol.connect(alice.getAddress(), function (err) { | |
| 106 | - t.notOk(err) | |
| 117 … | + carol.connect(alice.getAddress(), function (err, rpc) { | |
| 118 … | + if(err) throw err | |
| 119 … | + console.log('CAROL CONNECTED TO ALICE', carol.id, alice.id) | |
| 120 … | +// pull( | |
| 121 … | +// alice.createHistoryStream({id: alice.id, seq: 0}), | |
| 122 … | +// pull.collect(console.log) | |
| 123 … | +// ) | |
| 124 … | + | |
| 125 … | + rpc.on('closed', function () { | |
| 126 … | + pull( | |
| 127 … | + carol.createHistoryStream({id: alice.id, seq: 0, live: false}), | |
| 128 … | + pull.collect(function (err, ary) { | |
| 129 … | + if(err) throw err | |
| 130 … | + | |
| 131 … | + t.ok(ary.length, 'carol replicated data from alice') | |
| 132 … | + console.log(alice.id, carol.id, err, ary) | |
| 133 … | + t.end() | |
| 134 … | + }) | |
| 135 … | + ) | |
| 136 … | + }) | |
| 107 | 137 … | }) |
| 108 | - carol.once('replicate:finish', function (vclock) { | |
| 109 | - t.equal(vclock[alice.id], 2) | |
| 110 | - //in next test, bob connects to carol... | |
| 111 | - t.end() | |
| 112 | - }) | |
| 138 … | +// carol.once('replicate:finish', function (vclock) { | |
| 139 … | +// t.equal(vclock[alice.id], 2) | |
| 140 … | +// //in next test, bob connects to carol... | |
| 141 … | +// t.end() | |
| 142 … | +// }) | |
| 113 | 143 … | }) |
| 114 | 144 … | }) |
| 115 | 145 … | ) |
| 116 | 146 … | }) |
| @@ -142,4 +172,12 @@ | ||
| 142 | 172 … | tape('cleanup!', function (t) { |
| 143 | 173 … | alice.close(true); bob.close(true); carol.close(true) |
| 144 | 174 … | t.end() |
| 145 | 175 … | }) |
| 176 … | + | |
| 177 … | + | |
| 178 … | + | |
| 179 … | + | |
| 180 … | + | |
| 181 … | + | |
| 182 … | + | |
| 183 … | + | |
| test/block3.js | ||
|---|---|---|
| @@ -60,17 +60,17 @@ | ||
| 60 | 60 … | if(err) throw err |
| 61 | 61 … | }) |
| 62 | 62 … | |
| 63 | 63 … | bob.on('replicate:finish', function (vclock) { |
| 64 | - t.equal(vclock[alice.id], 1) | |
| 65 | - console.log('OKAY') | |
| 64 … | + //I don't care which messages bob doesn't have of alice's | |
| 65 … | + t.ok(vclock[alice.id] < 2, 'bob has alices first message') | |
| 66 | 66 … | alice.close();bob.close();carol.close() |
| 67 | 67 … | t.end() |
| 68 | 68 … | }) |
| 69 | 69 … | |
| 70 | 70 … | var once = false |
| 71 | 71 … | var bobCancel = bob.post(function (op) { |
| 72 | - console.log('BOB RECV', op) | |
| 72 … | + console.log('BOB RECV', op, bob.id) | |
| 73 | 73 … | if(once) throw new Error('should only be called once') |
| 74 | 74 … | once = true |
| 75 | 75 … | //should be the alice's follow(bob) message. |
| 76 | 76 … | |
| @@ -80,4 +80,8 @@ | ||
| 80 | 80 … | (function (err) { if(err) throw err }) |
| 81 | 81 … | }) |
| 82 | 82 … | }) |
| 83 | 83 … | }) |
| 84 … | + | |
| 85 … | + | |
| 86 … | + | |
| 87 … | + | |
Built with git-ssb-web