diff options
| author | ildar-khisam <ikhis@ydb.tech> | 2023-02-15 10:16:57 +0300 |
|---|---|---|
| committer | ildar-khisam <ikhis@ydb.tech> | 2023-02-15 10:16:57 +0300 |
| commit | 3a5bd6c0e387a0b040704b7ced45acf59e2c78a0 (patch) | |
| tree | 7e2ba35f25c84e1682f7483bab0b95f57794a583 | |
| parent | b6379c4bd7f5c5daa7a24989d00c8579ebb6caeb (diff) | |
| download | ydb-3a5bd6c0e387a0b040704b7ced45acf59e2c78a0.tar.gz | |
fix update token test
fix update token test
| -rw-r--r-- | ydb/services/persqueue_v1/persqueue_ut.cpp | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/ydb/services/persqueue_v1/persqueue_ut.cpp b/ydb/services/persqueue_v1/persqueue_ut.cpp index cf1d5842b11..3f690074361 100644 --- a/ydb/services/persqueue_v1/persqueue_ut.cpp +++ b/ydb/services/persqueue_v1/persqueue_ut.cpp @@ -759,6 +759,13 @@ Y_UNIT_TEST_SUITE(TPersQueueTest) { Ydb::Topic::StreamReadMessage::FromClient req; Ydb::Topic::StreamReadMessage::FromServer resp; + NACLib::TDiffACL acl; + for (ui32 i = 0; i < 10; ++i) { + acl.AddAccess(NACLib::EAccessType::Allow, NACLib::SelectRow, "test_user_" + ToString(i) + "@" + BUILTIN_ACL_DOMAIN); + } + server.Server->AnnoyingClient->ModifyACL("/Root/PQ", "acc/topic1", acl.SerializeAsString()); + WaitACLModification(); + for (ui32 i = 0; i < 10; ++i) { resp.Clear(); UNIT_ASSERT(readStream->Read(&resp)); @@ -766,7 +773,7 @@ Y_UNIT_TEST_SUITE(TPersQueueTest) { UNIT_ASSERT_C(resp.server_message_case() == Ydb::Topic::StreamReadMessage::FromServer::kReadResponse, resp); // send update token request, await response - const TString token = TString("test_user_" + ToString(i) + "@") + BUILTIN_ACL_DOMAIN;; + const TString token = "test_user_" + ToString(i) + "@" + BUILTIN_ACL_DOMAIN; req.Clear(); resp.Clear(); req.mutable_update_token_request()->set_token(token); |