CBG-4862 force BlipTester SendRev to check for errors (#7762)

Author: torcolvin

rest/access_test.go

@@ -806,15 +806,11 @@ func TestChannelAccessChanges(t *testing.T) {
 	assert.Equal(t, "g1", changes.Results[0].ID)
 
 	// Look up sequences for created docs
-	deltaGrantDocSeq, err := rt.SequenceForDoc("delta")
-	assert.NoError(t, err, "Error retrieving document sequence")
-	gammaGrantDocSeq, err := rt.SequenceForDoc("gamma")
-	assert.NoError(t, err, "Error retrieving document sequence")
+	deltaGrantDocSeq := rt.SequenceForDoc("delta")
+	gammaGrantDocSeq := rt.SequenceForDoc("gamma")
 
-	alphaDocSeq, err := rt.SequenceForDoc("a1")
-	assert.NoError(t, err, "Error retrieving document sequence")
-	gammaDocSeq, err := rt.SequenceForDoc("g1")
-	assert.NoError(t, err, "Error retrieving document sequence")
+	alphaDocSeq := rt.SequenceForDoc("a1")
+	gammaDocSeq := rt.SequenceForDoc("g1")
 
 	// Check user access:
 	alice, _ = a.GetUser("alice")
@@ -843,8 +839,7 @@ func TestChannelAccessChanges(t *testing.T) {
 	response = rt.SendRequest(http.MethodPut, "/{{.keyspace}}/alpha", str)
 	RequireStatus(t, response, http.StatusCreated)
 
-	alphaGrantDocSeq, err := rt.SequenceForDoc("alpha")
-	assert.NoError(t, err, "Error retrieving document sequence")
+	alphaGrantDocSeq := rt.SequenceForDoc("alpha")
 
 	// Check user access again:
 	alice, _ = a.GetUser("alice")

rest/adminapitest/admin_api_test.go

@@ -457,8 +457,7 @@ func TestDBOfflineConcurrent(t *testing.T) {
 		wg.Done()
 	}()
 
-	err := rest.WaitWithTimeout(&wg, time.Second*30)
-	assert.NoError(t, err, "Error waiting for waitgroup")
+	rest.WaitWithTimeout(t, &wg, time.Second*30)
 	rest.RequireStatus(t, goroutineresponse1, http.StatusOK)
 	rest.RequireStatus(t, goroutineresponse2, http.StatusOK)
 

rest/api_test.go

@@ -2052,7 +2052,7 @@ func TestWebhookProperties(t *testing.T) {
 		assert.NoError(t, err)
 	}
 
-	require.NoError(t, WaitWithTimeout(&wg, 30*time.Second))
+	WaitWithTimeout(t, &wg, 30*time.Second)
 }
 
 func TestWebhookSpecialProperties(t *testing.T) {

rest/attachment_test.go

@@ -2483,9 +2483,7 @@ func TestProveAttachmentNotFound(t *testing.T) {
 	}
 
 	// Initial set up
-	sent, _, _, err := bt.SendRev("doc1", "1-abc", []byte(`{"key": "val", "_attachments": {"attachment": {"data": "`+attachmentDataEncoded+`"}}}`), blip.Properties{})
-	require.True(t, sent)
-	require.NoError(t, err)
+	bt.SendRev("doc1", "1-abc", []byte(`{"key": "val", "_attachments": {"attachment": {"data": "`+attachmentDataEncoded+`"}}}`), blip.Properties{})
 
 	rt.WaitForPendingChanges()
 
@@ -2495,9 +2493,7 @@ func TestProveAttachmentNotFound(t *testing.T) {
 
 	// Use different attachment name to bypass digest check in ForEachStubAttachment() which skips prove attachment code
 	// Set attachment to V2 so it can be retrieved by RT successfully
-	sent, _, _, err = bt.SendRev("doc1", "2-abc", []byte(`{"key": "val", "_attachments":{"attach":{"digest":"sha1-wzp8ZyykdEuZ9GuqmxQ7XDrY7Co=","length":11,"stub":true,"revpos":1,"ver":2}}}`), blip.Properties{})
-	require.True(t, sent)
-	require.NoError(t, err)
+	bt.SendRev("doc1", "2-abc", []byte(`{"key": "val", "_attachments":{"attach":{"digest":"sha1-wzp8ZyykdEuZ9GuqmxQ7XDrY7Co=","length":11,"stub":true,"revpos":1,"ver":2}}}`), blip.Properties{})
 
 	rt.WaitForPendingChanges()
 	// Check attachment is on the document
@@ -2569,8 +2565,7 @@ func TestPutInvalidAttachment(t *testing.T) {
 				attachmentBody:   test.invalidAttachmentBody,
 				attachmentDigest: digest,
 			}
-			sent, _, resp := bt.SendRevWithAttachment(input)
-			assert.True(t, sent)
+			resp := bt.SendRevWithAttachment(input)
 
 			// Make sure we get the expected response back
 			assert.Equal(t, test.expectedType, resp.Type())

rest/blip_api_attachment_test.go

@@ -472,8 +472,8 @@ func TestPutAttachmentViaBlipGetViaBlip(t *testing.T) {
 		attachmentBody:   attachmentBody,
 		attachmentDigest: digest,
 	}
-	sent, _, _ := bt.SendRevWithAttachment(input)
-	assert.True(t, sent)
+	resp := bt.SendRevWithAttachment(input)
+	require.NotContains(t, resp.Properties, "Error-Code")
 
 	// Get all docs and attachment via subChanges request
 	allDocs := bt.WaitForNumDocsViaChanges(1)