Function TestGetRemovedDoc

rest/blip_api_crud_test.go:1828–1911

Repro attempt for SG #3281 - Set up a user w/ access to channel A - Write two revision of a document (both in channel A) - Write two more revisions of the document, no longer in channel A - Have the user issue a rev request for rev 3. Expected: - Users gets a removed:true response Actual: - Same

(t *testing.T)

// Actual:
// - Same as Expected (this test is unable to repro SG #3281, but is being left in as a regression test)
func TestGetRemovedDoc(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)

	rt := NewRestTester(t, &RestTesterConfig{SyncFn: channels.DocChannelsSyncFunction})
	defer rt.Close()
	const (
		user1 = "user1"
		user2 = "user2"
	)
	rt.CreateUser(user1, []string{user1})
	rt.CreateUser(user2, []string{user1})
	btSpec := BlipTesterSpec{
		connectingUsername: user1,
		blipProtocols:      []string{db.CBMobileReplicationV2.SubprotocolString()},
	}
	bt := NewBlipTesterFromSpecWithRT(rt, &btSpec)
	defer bt.Close()

	// Workaround data race (https://gist.github.com/tleyden/0ace70b8a38b76a7beee95529610b6cf) that happens because
	// there are multiple goroutines accessing the bt.blipContext.HandlerForProfile map.
	// The workaround uses a separate blipTester, and therefore a separate context.  It uses a different
	// user to avoid an error when the NewBlipTesterFromSpec tries to create the user (eg, user1 already exists error)
	btSpec2 := BlipTesterSpec{
		connectingUsername: user1,
		blipProtocols:      []string{db.CBMobileReplicationV2.SubprotocolString()},
	}
	bt2 := NewBlipTesterFromSpecWithRT(rt, &btSpec2)
	defer bt2.Close()

	// Add rev-1 in channel user1
	sent, _, resp, err := bt.SendRev("foo", "1-abc", []byte(`{"key": "val", "channels": ["user1"]}`), blip.Properties{})
	assert.True(t, sent)
	require.NoError(t, err)                        // no error
	assert.Empty(t, resp.Properties["Error-Code"]) // no error

	// Add rev-2 in channel user1
	history := []string{"1-abc"}
	sent, _, resp, err = bt.SendRevWithHistory("foo", "2-bcd", history, []byte(`{"key": "val", "channels": ["user1"]}`), blip.Properties{"noconflicts": "true"})
	assert.True(t, sent)
	require.NoError(t, err)                        // no error
	assert.Empty(t, resp.Properties["Error-Code"]) // no error

	// wait for rev 2 to arrive to cache cache
	rt.WaitForPendingChanges()

	// Try to get rev 2 via BLIP API and assert that _removed == false
	resultDoc, err := bt.GetDocAtRev("foo", "2-bcd")
	require.NoError(t, err, "Unexpected Error")
	assert.False(t, resultDoc.IsRemoved())

	// Add rev-3, remove from channel user1 and put into channel another_channel
	history = []string{"2-bcd", "1-abc"}
	sent, _, resp, err = bt.SendRevWithHistory("foo", "3-cde", history, []byte(`{"key": "val", "channels": ["another_channel"]}`), blip.Properties{"noconflicts": "true"})
	assert.True(t, sent)
	assert.NoError(t, err)                         // no error
	assert.Empty(t, resp.Properties["Error-Code"]) // no error

	// Add rev-4, keeping it in channel another_channel