Function TestReplicatorRevocationsNoRev

rest/revocation_test.go:1569–1639

(t *testing.T)

}

func TestReplicatorRevocationsNoRev(t *testing.T) {
	base.RequireNumTestBuckets(t, 2)

	sgrRunner := NewSGRTestRunner(t)
	sgrRunner.Run(func(t *testing.T) {
		// Passive
		revocationTester, rt2 := InitScenario(t, nil)
		defer rt2.Close()

		// Active
		rt1 := NewRestTester(t,
			&RestTesterConfig{
				CustomTestBucket: base.GetTestBucket(t),
				SyncFn:           channels.DocChannelsSyncFunction,
			})
		defer rt1.Close()
		ctx1 := rt1.Context()

		revocationTester.addRole("user", "foo")
		revocationTester.addRoleChannel("foo", "chanA")

		const doc1ID = "doc1"
		doc1Version := rt2.PutDoc(doc1ID, `{"channels": "chanA"}`)
		rt2.WaitForPendingChanges()

		srv := httptest.NewServer(rt2.TestPublicHandler())
		defer srv.Close()

		passiveDBURL, err := url.Parse(srv.URL + "/db")
		require.NoError(t, err)

		passiveDBURL.User = url.UserPassword("user", RestTesterDefaultUserPassword)
		id := SafeDocumentName(t, t.Name())
		sgwStats, err := base.SyncGatewayStats.NewDBStats(id, false, false, false, nil, nil)
		require.NoError(t, err)
		dbstats, err := sgwStats.DBReplicatorStats(id)
		require.NoError(t, err)

		ar, err := db.NewActiveReplicator(ctx1, &db.ActiveReplicatorConfig{
			ID:          id,
			Direction:   db.ActiveReplicatorTypePull,
			RemoteDBURL: passiveDBURL,
			ActiveDB: &db.Database{
				DatabaseContext: rt1.GetDatabase(),
			},
			Continuous:             false,
			PurgeOnRemoval:         true,
			ReplicationStatsMap:    dbstats,
			CollectionsEnabled:     base.TestsUseNamedCollections(),
			SupportedBLIPProtocols: sgrRunner.SupportedSubprotocols,
		})
		require.NoError(t, err)

		require.NoError(t, ar.Start(ctx1))
		rt1.WaitForReplicationStatus(ar.ID, db.ReplicationStateStopped)

		resp := rt1.SendAdminRequest("GET", "/{{.keyspace}}/doc1", "")
		RequireStatus(t, resp, http.StatusOK)