@@ -960,18 +960,22 @@ func TestBlipNonDeltaSyncPush(t *testing.T) {
960
960
defer client .Close ()
961
961
962
962
client .ClientDeltas = false
963
- btcRunner .StartPull (client .id )
964
- btcRunner .StartPush (client .id )
965
963
966
964
// create doc1 rev 1-0335a345b6ffed05707ccc4cbc1b67f4
967
965
version := rt .PutDocDirectly (docID , JsonToMap (t , `{"greetings": [{"hello": "world!"}, {"hi": "alice"}]}` ))
968
966
967
+ btcRunner .StartOneshotPull (client .id )
969
968
data := btcRunner .WaitForVersion (client .id , docID , version )
970
969
assert .Equal (t , `{"greetings":[{"hello":"world!"},{"hi":"alice"}]}` , string (data ))
970
+
971
971
// create doc1 rev 2-abcxyz on client
972
972
newRev := btcRunner .AddRev (client .id , docID , & version , []byte (`{"greetings":[{"hello":"world!"},{"hi":"alice"},{"howdy":"bob"}]}` ))
973
- // Check EE is delta, and CE is full-body replication
973
+
974
+ btcRunner .StartPushWithOpts (client .id , BlipTesterPushOptions {Continuous : false , Since : "0" })
975
+
974
976
msg := client .waitForReplicationMessage (collection , 2 )
977
+ // ensure message is type rev
978
+ require .Equal (t , db .MessageRev , msg .Profile ())
975
979
976
980
// Check the request was NOT sent with a deltaSrc property
977
981
assert .Equal (t , "" , msg .Properties [db .RevMessageDeltaSrc ])
0 commit comments