Function TestReverseEdge

worker/mutation_unit_test.go:24–59

(t *testing.T)

)

func TestReverseEdge(t *testing.T) {
	dir, err := os.MkdirTemp("", "storetest_")
	x.Check(err)
	defer os.RemoveAll(dir)

	opt := badger.DefaultOptions(dir)
	ps, err := badger.OpenManaged(opt)
	x.Check(err)
	pstore = ps
	// Not using posting list cache
	posting.Init(ps, 0, false)
	Init(ps)
	err = schema.ParseBytes([]byte("revc: [uid] @reverse @count ."), 1)
	require.NoError(t, err)

	ctx := context.Background()
	txn := posting.Oracle().RegisterStartTs(5)
	attr := x.AttrInRootNamespace("revc")

	edge := &pb.DirectedEdge{
		ValueId: 2,
		Attr:    attr,
		Entity:  1,
		Op:      pb.DirectedEdge_DEL,
	}

	x.Check(runMutation(ctx, edge, txn))
	x.Check(runMutation(ctx, edge, txn))

	pl, err := txn.Get(x.DataKey(attr, 1))
	require.NoError(t, err)
	pl.RLock()
	c := pl.GetLength(5)
	pl.RUnlock()
	require.Equal(t, 0, c)
}

func TestReverseEdgeSetDel(t *testing.T) {
	dir, err := os.MkdirTemp("", "storetest_")