Function WriteDirect

db/util_testing.go:731–773

WriteDirect will write a document named doc-{sequence} with a given set of channels. This is used to simulate out of order sequence writes by bypassing typical Sync Gateway CRUD functions.

(t *testing.T, collection *DatabaseCollection, channelArray []string, sequence uint64)

// WriteDirect will write a document named doc-{sequence} with a given set of channels. This is used to simulate out of order sequence writes by bypassing typical Sync Gateway CRUD functions.
func WriteDirect(t *testing.T, collection *DatabaseCollection, channelArray []string, sequence uint64) {
	key := fmt.Sprintf("doc-%v", sequence)

	rev := "1-a"
	chanMap := make(map[string]*channels.ChannelRemoval, 10)
	chanSetMap := base.Set{}

	for _, channel := range channelArray {
		chanMap[channel] = nil
		chanSetMap[channel] = struct{}{}
	}

	revInf := RevInfo{
		ID:       rev,
		Channels: chanSetMap,
	}
	revTree := RevTree{
		rev: &revInf,
	}

	syncData := &SyncData{
		RevAndVersion: channels.RevAndVersion{
			RevTreeID: rev,
		},
		Sequence:  sequence,
		Channels:  chanMap,
		TimeSaved: time.Now(),
		History:   revTree,
	}
	body := fmt.Sprintf(`{"key": "%s"}`, key)
	if base.TestUseXattrs() {

		opts := &sgbucket.MutateInOptions{
			MacroExpansion: macroExpandSpec(base.SyncXattrName),
		}
		ctx := base.TestCtx(t)
		_, err := collection.dataStore.WriteWithXattrs(ctx, key, 0, 0, []byte(body), map[string][]byte{base.SyncXattrName: base.MustJSONMarshal(t, syncData)}, nil, opts)
		require.NoError(t, err)
	} else {
		_, err := collection.dataStore.Add(key, 0, base.MustJSONMarshal(t, Body{base.SyncPropertyName: syncData, "key": key}))
		require.NoError(t, err)
	}
}

// GetIndexPartitionCount returns the number of partitions for a given index. This function queries index nodes directly and would not be suitable for production use, since this port is not generally accessible.
func GetIndexPartitionCount(t testing.TB, bucket *base.GocbV2Bucket, dsName sgbucket.DataStoreName, indexName string) uint32 {