Function TestReadFilterWithConditions

pkg/storage/postgres/postgres_test.go:1071–1168

(t *testing.T)

}

func TestReadFilterWithConditions(t *testing.T) {
	ctx := context.Background()
	testDatastore := storagefixtures.RunDatastoreTestContainer(t, "postgres")

	uri := testDatastore.GetConnectionURI(true)
	cfg := sqlcommon.NewConfig()
	ds, err := New(uri, cfg)
	require.NoError(t, err)
	defer ds.Close()

	var writeItems [][]interface{}
	writeItems = append(writeItems, []interface{}{
		"store",
		"folder",
		"2021-budget",
		"owner",
		"user:anne",
		"user",
		"cond1",
		"",
		ulid.Make().String(),
		sq.Expr("NOW()"),
	})

	writeItems = append(writeItems, []interface{}{
		"store",
		"folder",
		"2022-budget",
		"owner",
		"user:anne",
		"user",
		"",
		"",
		ulid.Make().String(),
		sq.Expr("NOW()"),
	})

	err = executeWriteTuples(ctx, ds.primaryDB, writeItems)
	require.NoError(t, err)

	// Read: if the tuple has condition and the filter has the same condition the tuple should be returned
	tk := tupleUtils.NewTupleKeyWithCondition("folder:2021-budget", "owner", "user:anne", "cond1", nil)
	filter := storage.ReadFilter{Object: "folder:2021-budget", Relation: "owner", User: "user:anne", Conditions: []string{"cond1"}}
	iter, err := ds.Read(ctx, "store", filter, storage.ReadOptions{})
	require.NoError(t, err)
	defer iter.Stop()
	curTuple, err := iter.Next(ctx)
	require.NoError(t, err)
	require.Equal(t, tk.GetUser(), curTuple.GetKey().GetUser())
	require.Equal(t, tk.GetObject(), curTuple.GetKey().GetObject())
	require.Equal(t, tk.GetRelation(), curTuple.GetKey().GetRelation())
	require.Equal(t, tk.GetCondition().String(), curTuple.GetKey().GetCondition().String())
	_, err = iter.Next(ctx)
	require.Error(t, err)

	// Read: if filter has no condition the tuple cannot be returned
	filter = storage.ReadFilter{Object: "folder:2021-budget", Relation: "owner", User: "user:anne", Conditions: []string{""}}
	iter, err = ds.Read(ctx, "store", filter, storage.ReadOptions{})