Function TestReplicatorRevocationsFromZero

rest/revocation_test.go:2126–2239

(t *testing.T)

}

func TestReplicatorRevocationsFromZero(t *testing.T) {
	defer db.SuspendSequenceBatching()()

	base.RequireNumTestBuckets(t, 2)

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

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

		resp := rt2.SendAdminRequest("PUT", "/db/_user/user", GetUserPayload(t, "user", "letmein", "", rt2ds, []string{"A", "B"}, nil))
		RequireStatus(t, resp, http.StatusOK)

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

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

		passiveDBURL.User = url.UserPassword("user", "letmein")
		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)

		activeReplCfg := &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,
		}

		ar, err := db.NewActiveReplicator(ctx1, activeReplCfg)
		require.NoError(t, err)

		_ = rt2.PutDoc("docA", `{"channels": ["A"]}`)
		_ = rt2.PutDoc("docA1", `{"channels": ["A"]}`)
		_ = rt2.PutDoc("docA2", `{"channels": ["A"]}`)