metrics have been added

93 files changed, 7711 insertions, 0 deletions

diff --git a/library/cpp/http/cookies/cookies.cpp b/library/cpp/http/cookies/cookies.cpp
new file mode 100644
index 0000000000..12b66c7f9d
--- /dev/null
+++ b/library/cpp/http/cookies/cookies.cpp
@@ -0,0 +1,33 @@
+#include "cookies.h"
+
+#include <library/cpp/string_utils/scan/scan.h>
+#include <util/string/strip.h>
+#include <util/string/builder.h>
+
+namespace {
+    struct TCookiesScanner {
+        THttpCookies* C;
+
+        inline void operator()(const TStringBuf& key, const TStringBuf& val) {
+            C->Add(StripString(key), StripString(val));
+        }
+    };
+}
+
+void THttpCookies::Scan(const TStringBuf& s) {
+    Clear();
+    TCookiesScanner scan = {this};
+    ScanKeyValue<true, ';', '='>(s, scan);
+}
+
+/*** https://datatracker.ietf.org/doc/html/rfc6265#section-5.4 ***/
+TString THttpCookies::ToString() const {
+    TStringBuilder result;
+    for (const auto& [key, value] : *this) {
+        if (!result.empty()) {
+            result << "; ";
+        }
+        result << key << "=" << value;
+    }
+    return result;
+}
diff --git a/library/cpp/http/cookies/cookies.h b/library/cpp/http/cookies/cookies.h
new file mode 100644
index 0000000000..d7a0030c8b
--- /dev/null
+++ b/library/cpp/http/cookies/cookies.h
@@ -0,0 +1,17 @@
+#pragma once
+
+#include "lctable.h"
+
+class THttpCookies: public TLowerCaseTable<TStringBuf> {
+public:
+    inline THttpCookies(const TStringBuf& cookieString) {
+        Scan(cookieString);
+    }
+
+    inline THttpCookies() noexcept {
+    }
+
+    void Scan(const TStringBuf& cookieString);
+
+    TString ToString() const;
+};
diff --git a/library/cpp/http/cookies/lctable.h b/library/cpp/http/cookies/lctable.h
new file mode 100644
index 0000000000..09c88eafb8
--- /dev/null
+++ b/library/cpp/http/cookies/lctable.h
@@ -0,0 +1,86 @@
+#pragma once
+
+#include <library/cpp/digest/lower_case/lchash.h>
+
+#include <util/generic/hash_multi_map.h>
+#include <util/generic/strbuf.h>
+#include <util/generic/algorithm.h>
+#include <util/generic/singleton.h>
+
+struct TStrBufHash {
+    inline size_t operator()(const TStringBuf& s) const noexcept {
+        return FnvCaseLess<size_t>(s);
+    }
+};
+
+struct TStrBufEqualToCaseLess {
+    inline bool operator()(const TStringBuf& c1, const TStringBuf& c2) const noexcept {
+        typedef TLowerCaseIterator<const TStringBuf::TChar> TIter;
+
+        return (c1.size() == c2.size()) && std::equal(TIter(c1.begin()), TIter(c1.end()), TIter(c2.begin()));
+    }
+};
+
+template <class T>
+class TLowerCaseTable: private THashMultiMap<TStringBuf, T, TStrBufHash, TStrBufEqualToCaseLess> {
+    typedef THashMultiMap<TStringBuf, T, TStrBufHash, TStrBufEqualToCaseLess> TBase;
+
+public:
+    typedef typename TBase::const_iterator const_iterator;
+    typedef std::pair<const_iterator, const_iterator> TConstIteratorPair;
+
+    using TBase::TBase;
+    using TBase::begin;
+    using TBase::end;
+
+    inline TConstIteratorPair EqualRange(const TStringBuf& name) const {
+        return TBase::equal_range(name);
+    }
+
+    inline const T& Get(const TStringBuf& name, size_t numOfValue = 0) const {
+        TConstIteratorPair range = EqualRange(name);
+
+        if (range.first == TBase::end())
+            return Default<T>();
+
+        if (numOfValue == 0)
+            return range.first->second;
+
+        const_iterator next = range.first;
+        for (size_t c = 0; c < numOfValue; ++c) {
+            ++next;
+            if (next == range.second)
+                return Default<T>();
+        }
+
+        return next->second;
+    }
+
+    inline bool Has(const TStringBuf& name) const {
+        return TBase::find(name) != TBase::end();
+    }
+
+    size_t NumOfValues(const TStringBuf& name) const {
+        return TBase::count(name);
+    }
+
+    inline size_t Size() const noexcept {
+        return TBase::size();
+    }
+
+    inline bool Empty() const noexcept {
+        return TBase::empty();
+    }
+
+    inline void Add(const TStringBuf& key, const T& val) {
+        TBase::insert(typename TBase::value_type(key, val));
+    }
+
+    inline void Clear() noexcept {
+        TBase::clear();
+    }
+
+    inline size_t Erase(const TStringBuf& key) {
+        return TBase::erase(key);
+    }
+};
diff --git a/library/cpp/http/cookies/ya.make b/library/cpp/http/cookies/ya.make
new file mode 100644
index 0000000000..70c1e8f250
--- /dev/null
+++ b/library/cpp/http/cookies/ya.make
@@ -0,0 +1,14 @@
+LIBRARY()
+
+SRCS(
+    cookies.cpp
+)
+
+PEERDIR(
+    library/cpp/digest/lower_case
+    library/cpp/string_utils/scan
+)
+
+END()
+
+RECURSE_FOR_TESTS(ut)
diff --git a/library/cpp/string_utils/secret_string/secret_string.cpp b/library/cpp/string_utils/secret_string/secret_string.cpp
new file mode 100644
index 0000000000..3b68d3cd27
--- /dev/null
+++ b/library/cpp/string_utils/secret_string/secret_string.cpp
@@ -0,0 +1,68 @@
+#include "secret_string.h"
+
+#include <util/system/madvise.h>
+
+namespace NSecretString {
+    TSecretString::TSecretString(TStringBuf value) {
+        Init(value);
+    }
+
+    TSecretString::~TSecretString() {
+        try {
+            Clear();
+        } catch (...) {
+        }
+    }
+
+    TSecretString& TSecretString::operator=(const TSecretString& o) {
+        if (&o == this) {
+            return *this;
+        }
+
+        Init(o.Value_);
+
+        return *this;
+    }
+
+    /**
+     * It is not honest "move". Actually it is copy-assignment with cleaning of other instance.
+     * This way allowes to avoid side effects of string optimizations:
+     *   Copy-On-Write or Short-String-Optimization
+     */
+    TSecretString& TSecretString::operator=(TSecretString&& o) {
+        if (&o == this) {
+            return *this;
+        }
+
+        Init(o.Value_);
+        o.Clear();
+
+        return *this;
+    }
+
+    TSecretString& TSecretString::operator=(const TStringBuf o) {
+        Init(o);
+
+        return *this;
+    }
+
+    void TSecretString::Init(TStringBuf value) {
+        Clear();
+        if (value.empty()) {
+            return;
+        }
+
+        Value_ = value;
+        MadviseExcludeFromCoreDump(Value_);
+    }
+
+    void TSecretString::Clear() {
+        if (Value_.empty()) {
+            return;
+        }
+
+        SecureZero((void*)Value_.data(), Value_.size());
+        MadviseIncludeIntoCoreDump(Value_);
+        Value_.clear();
+    }
+}
diff --git a/library/cpp/string_utils/secret_string/secret_string.h b/library/cpp/string_utils/secret_string/secret_string.h
new file mode 100644
index 0000000000..fdb9f6a85c
--- /dev/null
+++ b/library/cpp/string_utils/secret_string/secret_string.h
@@ -0,0 +1,74 @@
+#pragma once
+
+#include <library/cpp/string_utils/ztstrbuf/ztstrbuf.h>
+
+#include <util/generic/string.h>
+
+namespace NSecretString {
+    /**
+     * TSecretString allowes to store some long lived secrets in "secure" storage in memory.
+     * Common usage:
+     *  1) read secret value from disk/env/etc
+     *  2) put it into TSecretString
+     *  3) destory secret copy from 1)
+     *
+     * Useful scenerios for TSecretString:
+     *   - in memory only tasks: using key to create crypto signature;
+     *   - rare network cases: db password on connection or OAuth token in background tasks.
+     *     These cases disclosure the secret
+     *       because of sending it over network with some I/O frameworks.
+     *     Usually such frameworks copy input params to provide network protocol: gRPC, for example.
+     *
+     * Supported features:
+     *  1. Exclude secret from core dump.
+     *     madvise(MADV_DONTDUMP) in ctor excludes full memory page from core dump.
+     *     madvise(MADV_DODUMP) in dtor reverts previous action.
+     *  2. Zero memory before free.
+     *
+     * Code dump looks like this:
+(gdb) print s
+$1 = (const TSecretString &) @0x7fff23c4c560: {
+  Value_ = {<TStringBase<TBasicString<char, std::__y1::char_traits<char> >, char, std::__y1::char_traits<char> >> = {
+      static npos = <optimized out>}, Data_ = 0x107c001d8 <error: Cannot access memory at address 0x107c001d8>}}
+     */
+
+    class TSecretString {
+    public:
+        TSecretString() = default;
+        TSecretString(TStringBuf value);
+        ~TSecretString();
+
+        TSecretString(const TSecretString& o)
+            : TSecretString(o.Value())
+        {
+        }
+
+        TSecretString(TSecretString&& o)
+            : TSecretString(o.Value())
+        {
+            o.Clear();
+        }
+
+        TSecretString& operator=(const TSecretString& o);
+        TSecretString& operator=(TSecretString&& o);
+
+        TSecretString& operator=(const TStringBuf o);
+
+        operator TZtStringBuf() const {
+            return Value();
+        }
+
+        // Provides zero terminated string
+        TZtStringBuf Value() const {
+            return TZtStringBuf(Value_);
+        }
+
+    private:
+        // TStringBuf breaks Copy-On-Write to provide correct copy-ctor and copy-assignment
+        void Init(TStringBuf value);
+        void Clear();
+
+    private:
+        TString Value_;
+    };
+}
diff --git a/library/cpp/string_utils/secret_string/ya.make b/library/cpp/string_utils/secret_string/ya.make
new file mode 100644
index 0000000000..c1d43f7a1d
--- /dev/null
+++ b/library/cpp/string_utils/secret_string/ya.make
@@ -0,0 +1,13 @@
+LIBRARY()
+
+SRCS(
+    secret_string.cpp
+)
+
+PEERDIR(
+    library/cpp/string_utils/ztstrbuf
+)
+
+END()
+
+RECURSE_FOR_TESTS(ut)
diff --git a/library/cpp/string_utils/tskv_format/builder.cpp b/library/cpp/string_utils/tskv_format/builder.cpp
new file mode 100644
index 0000000000..ede9074022
--- /dev/null
+++ b/library/cpp/string_utils/tskv_format/builder.cpp
@@ -0,0 +1 @@
+#include "builder.h"
diff --git a/library/cpp/string_utils/tskv_format/builder.h b/library/cpp/string_utils/tskv_format/builder.h
new file mode 100644
index 0000000000..40689ddc85
--- /dev/null
+++ b/library/cpp/string_utils/tskv_format/builder.h
@@ -0,0 +1,67 @@
+#pragma once
+
+#include "escape.h"
+
+#include <util/stream/str.h>
+
+namespace NTskvFormat {
+    class TLogBuilder {
+    private:
+        TStringStream Out;
+
+    public:
+        TLogBuilder() = default;
+
+        TLogBuilder(TStringBuf logType, ui32 unixtime) {
+            Begin(logType, unixtime);
+        }
+
+        TLogBuilder(TStringBuf logType) {
+            Begin(logType);
+        }
+
+        TLogBuilder& Add(TStringBuf fieldName, TStringBuf fieldValue) {
+            if (!Out.Empty()) {
+                Out << '\t';
+            }
+            Escape(fieldName, Out.Str());
+            Out << '=';
+            Escape(fieldValue, Out.Str());
+
+            return *this;
+        }
+
+        TLogBuilder& AddUnescaped(TStringBuf fieldName, TStringBuf fieldValue) {
+            if (!Out.Empty()) {
+                Out << '\t';
+            }
+            Out << fieldName << '=' << fieldValue;
+            return *this;
+        }
+
+        TLogBuilder& Begin(TStringBuf logType, ui32 unixtime) {
+            Out << "tskv\ttskv_format=" << logType << "\tunixtime=" << unixtime;
+            return *this;
+        }
+
+        TLogBuilder& Begin(TStringBuf logType) {
+            Out << "tskv\ttskv_format=" << logType;
+            return *this;
+        }
+
+        TLogBuilder& End() {
+            Out << '\n';
+            return *this;
+        }
+
+        TLogBuilder& Clear() {
+            Out.Clear();
+            return *this;
+        }
+
+        TString& Str() {
+            return Out.Str();
+        }
+    };
+
+}
diff --git a/library/cpp/string_utils/tskv_format/escape.cpp b/library/cpp/string_utils/tskv_format/escape.cpp
new file mode 100644
index 0000000000..3dc78bec8c
--- /dev/null
+++ b/library/cpp/string_utils/tskv_format/escape.cpp
@@ -0,0 +1,112 @@
+#include <util/generic/yexception.h>
+#include "escape.h"
+
+namespace NTskvFormat {
+    namespace {
+        const TStringBuf ESCAPE_CHARS("\t\n\r\\\0=\"", 7);
+
+        TString& EscapeImpl(const char* src, size_t len, TString& dst) {
+            TStringBuf srcStr(src, len);
+            size_t noEscapeStart = 0;
+
+            while (noEscapeStart < len) {
+                size_t noEscapeEnd = srcStr.find_first_of(ESCAPE_CHARS, noEscapeStart);
+
+                if (noEscapeEnd == TStringBuf::npos) {
+                    dst.append(src + noEscapeStart, len - noEscapeStart);
+                    break;
+                }
+
+                dst.append(src + noEscapeStart, noEscapeEnd - noEscapeStart);
+
+                switch (src[noEscapeEnd]) {
+                    case '\t':
+                        dst.append(TStringBuf("\\t"));
+                        break;
+                    case '\n':
+                        dst.append(TStringBuf("\\n"));
+                        break;
+                    case '\r':
+                        dst.append(TStringBuf("\\r"));
+                        break;
+                    case '\0':
+                        dst.append(TStringBuf("\\0"));
+                        break;
+                    case '\\':
+                        dst.append(TStringBuf("\\\\"));
+                        break;
+                    case '=':
+                        dst.append(TStringBuf("\\="));
+                        break;
+                    case '"':
+                        dst.append(TStringBuf("\\\""));
+                        break;
+                }
+
+                noEscapeStart = noEscapeEnd + 1;
+            }
+
+            return dst;
+        }
+
+        TString& UnescapeImpl(const char* src, const size_t len, TString& dst) {
+            TStringBuf srcStr(src, len);
+            size_t noEscapeStart = 0;
+
+            while (noEscapeStart < len) {
+                size_t noEscapeEnd = srcStr.find('\\', noEscapeStart);
+
+                if (noEscapeEnd == TStringBuf::npos) {
+                    dst.append(src + noEscapeStart, len - noEscapeStart);
+                    break;
+                }
+
+                dst.append(src + noEscapeStart, noEscapeEnd - noEscapeStart);
+
+                if (noEscapeEnd + 1 >= len) {
+                    throw yexception() << "expected (t|n|r|0|\\|=|\"|) after \\. Got end of line.";
+                }
+
+                switch (src[noEscapeEnd + 1]) {
+                    case 't':
+                        dst.append('\t');
+                        break;
+                    case 'n':
+                        dst.append('\n');
+                        break;
+                    case 'r':
+                        dst.append('\r');
+                        break;
+                    case '0':
+                        dst.append('\0');
+                        break;
+                    case '\\':
+                        dst.append('\\');
+                        break;
+                    case '=':
+                        dst.append('=');
+                        break;
+                    case '"':
+                        dst.append('"');
+                        break;
+                    default:
+                        throw yexception() << "unexpected symbol '" << src[noEscapeEnd + 1] << "' after \\";
+                }
+
+                noEscapeStart = noEscapeEnd + 2;
+            }
+
+            return dst;
+        }
+
+    }
+
+    TString& Escape(const TStringBuf& src, TString& dst) {
+        return EscapeImpl(src.data(), src.size(), dst);
+    }
+
+    TString& Unescape(const TStringBuf& src, TString& dst) {
+        return UnescapeImpl(src.data(), src.size(), dst);
+    }
+
+}
diff --git a/library/cpp/string_utils/tskv_format/escape.h b/library/cpp/string_utils/tskv_format/escape.h
new file mode 100644
index 0000000000..2e3dd02c98
--- /dev/null
+++ b/library/cpp/string_utils/tskv_format/escape.h
@@ -0,0 +1,10 @@
+#pragma once
+
+#include <util/generic/strbuf.h>
+#include <util/generic/string.h>
+
+namespace NTskvFormat {
+    TString& Escape(const TStringBuf& src, TString& dst);
+    TString& Unescape(const TStringBuf& src, TString& dst);
+
+}
diff --git a/library/cpp/string_utils/tskv_format/tskv_map.cpp b/library/cpp/string_utils/tskv_format/tskv_map.cpp
new file mode 100644
index 0000000000..99e5f19731
--- /dev/null
+++ b/library/cpp/string_utils/tskv_format/tskv_map.cpp
@@ -0,0 +1,60 @@
+#include "tskv_map.h"
+
+namespace {
+    void Split(const TStringBuf& kv, TStringBuf& key, TStringBuf& value, bool& keyHasEscapes) {
+        size_t delimiter = 0;
+        keyHasEscapes = false;
+        for (delimiter = 0; delimiter < kv.size() && kv[delimiter] != '='; ++delimiter) {
+            if (kv[delimiter] == '\\') {
+                ++delimiter;
+                keyHasEscapes = true;
+            }
+        }
+
+        if (delimiter < kv.size()) {
+            key = kv.Head(delimiter);
+            value = kv.Tail(delimiter + 1);
+        } else {
+            throw yexception() << "Incorrect tskv format";
+        }
+    }
+
+    TStringBuf DeserializeTokenToBuffer(const TStringBuf& token, TString& buffer) {
+        size_t tokenStart = buffer.size();
+        NTskvFormat::Unescape(token, buffer);
+        return TStringBuf(buffer).Tail(tokenStart);
+    }
+
+    void DeserializeTokenToString(const TStringBuf& token, TString& result, bool unescape) {
+        if (unescape) {
+            result.clear();
+            NTskvFormat::Unescape(token, result);
+        } else {
+            result = token;
+        }
+
+    }
+}
+
+void NTskvFormat::NDetail::DeserializeKvToStringBufs(const TStringBuf& kv, TStringBuf& key, TStringBuf& value, TString& buffer, bool unescape) {
+    bool keyHasEscapes = false;
+    Split(kv, key, value, keyHasEscapes);
+    if (unescape) {
+        if (keyHasEscapes) {
+            key = DeserializeTokenToBuffer(key, buffer);
+        }
+        if (value.Contains('\\')) {
+            value = DeserializeTokenToBuffer(value, buffer);
+        }
+    }
+}
+
+void NTskvFormat::NDetail::DeserializeKvToStrings(const TStringBuf& kv, TString& key, TString& value, bool unescape) {
+    TStringBuf keyBuf, valueBuf;
+    bool keyHasEscapes = false;
+    Split(kv, keyBuf, valueBuf, keyHasEscapes);
+
+    Y_UNUSED(keyHasEscapes);
+    DeserializeTokenToString(keyBuf, key, unescape);
+    DeserializeTokenToString(valueBuf, value, unescape);
+}
diff --git a/library/cpp/string_utils/tskv_format/tskv_map.h b/library/cpp/string_utils/tskv_format/tskv_map.h
new file mode 100644
index 0000000000..4f4978fcf5
--- /dev/null
+++ b/library/cpp/string_utils/tskv_format/tskv_map.h
@@ -0,0 +1,62 @@
+#pragma once
+
+#include "escape.h"
+#include <util/string/cast.h>
+#include <util/string/split.h>
+
+namespace NTskvFormat {
+    namespace NDetail {
+        void DeserializeKvToStringBufs(const TStringBuf& kv, TStringBuf& key, TStringBuf& value, TString& buffer, bool unescape);
+        void DeserializeKvToStrings(const TStringBuf& kv, TString& key, TString& value, bool unescape);
+    }
+
+    template <typename T>
+    TString& SerializeMap(const T& data, TString& result) {
+        result.clear();
+        for (const auto& kv : data) {
+            if (result.size() > 0) {
+                result.push_back('\t');
+            }
+            Escape(ToString(kv.first), result);
+            result.push_back('=');
+            Escape(ToString(kv.second), result);
+        }
+        return result;
+    }
+
+    /**
+     * Deserializing to TStringBuf is faster, just remember that `data'
+     * must not be invalidated while `result' is still in use.
+     */
+    template <typename T>
+    void DeserializeMap(const TStringBuf& data, T& result, TString& buffer, bool unescape = true) {
+        result.clear();
+        buffer.clear();
+        buffer.reserve(data.size());
+        TStringBuf key, value;
+
+        StringSplitter(data.begin(), data.end()).Split('\t').Consume([&](const TStringBuf kv){
+            NDetail::DeserializeKvToStringBufs(kv, key, value, buffer, unescape);
+            result[key] = value;
+        });
+
+        Y_ASSERT(buffer.size() <= data.size());
+    }
+
+    template <typename T>
+    void DeserializeMap(const TStringBuf& data, T& result, bool unescape = true) {
+        if constexpr(std::is_same<typename T::key_type, TStringBuf>::value ||
+            std::is_same<typename T::mapped_type, TStringBuf>::value)
+        {
+            DeserializeMap(data, result, result.DeserializeBuffer, unescape); // we can't unescape values w/o buffer
+            return;
+        }
+        result.clear();
+        TString key, value;
+
+        StringSplitter(data.begin(), data.end()).Split('\t').Consume([&](const TStringBuf kv){
+            NDetail::DeserializeKvToStrings(kv, key, value, unescape);
+            result[key] = value;
+        });
+    }
+}
diff --git a/library/cpp/string_utils/tskv_format/ya.make b/library/cpp/string_utils/tskv_format/ya.make
new file mode 100644
index 0000000000..1283d748b3
--- /dev/null
+++ b/library/cpp/string_utils/tskv_format/ya.make
@@ -0,0 +1,9 @@
+LIBRARY()
+
+SRCS(
+    builder.cpp
+    escape.cpp
+    tskv_map.cpp
+)
+
+END()
diff --git a/library/cpp/tvmauth/checked_service_ticket.h b/library/cpp/tvmauth/checked_service_ticket.h
new file mode 100644
index 0000000000..71dc48b7cb
--- /dev/null
+++ b/library/cpp/tvmauth/checked_service_ticket.h
@@ -0,0 +1,76 @@
+#pragma once
+
+#include "ticket_status.h"
+#include "type.h"
+#include "utils.h"
+
+#include <util/generic/ptr.h>
+
+namespace NTvmAuth::NInternal {
+    class TCanningKnife;
+}
+
+namespace NTvmAuth {
+    class TCheckedServiceTicket {
+    public:
+        class TImpl;
+
+        TCheckedServiceTicket(THolder<TImpl> impl);
+        TCheckedServiceTicket(TCheckedServiceTicket&& o);
+        ~TCheckedServiceTicket();
+
+        TCheckedServiceTicket& operator=(TCheckedServiceTicket&&);
+
+        /*!
+         * @return True value if ticket parsed and checked successfully
+         */
+        explicit operator bool() const;
+
+        /*!
+         * @return TTvmId of request destination
+         */
+        TTvmId GetDst() const;
+
+        /*!
+         * You should check src with your ACL
+         * @return TvmId of request source
+         */
+        TTvmId GetSrc() const;
+
+        /*!
+         * @return Ticket check status
+         */
+        ETicketStatus GetStatus() const;
+
+        /*!
+         * DebugInfo is human readable data for debug purposes
+         * @return Serialized ticket
+         */
+        TString DebugInfo() const;
+
+        /*!
+         * IssuerUID is UID of developer who is debuging something,
+         * so he(she) issued ServiceTicket with his(her) ssh-sign:
+         * it is grant_type=sshkey in tvm-api.
+         * https://wiki.yandex-team.ru/passport/tvm2/debug/#sxoditvapizakrytoeserviceticketami
+         * @return uid
+         */
+        TMaybe<TUid> GetIssuerUid() const;
+
+    public: // for python binding
+        TCheckedServiceTicket() = default;
+
+    private:
+        THolder<TImpl> Impl_;
+        friend class NInternal::TCanningKnife;
+    };
+
+    namespace NBlackboxTvmId {
+        const TStringBuf Prod = "222";
+        const TStringBuf Test = "224";
+        const TStringBuf ProdYateam = "223";
+        const TStringBuf TestYateam = "225";
+        const TStringBuf Stress = "226";
+        const TStringBuf Mimino = "239";
+    }
+}
diff --git a/library/cpp/tvmauth/checked_user_ticket.h b/library/cpp/tvmauth/checked_user_ticket.h
new file mode 100644
index 0000000000..32256de6a7
--- /dev/null
+++ b/library/cpp/tvmauth/checked_user_ticket.h
@@ -0,0 +1,111 @@
+#pragma once
+
+#include "ticket_status.h"
+#include "type.h"
+#include "utils.h"
+
+#include <util/generic/ptr.h>
+
+#include <optional>
+
+namespace NTvmAuth::NInternal {
+    class TCanningKnife;
+}
+
+namespace NTvmAuth {
+    /*!
+     * BlackboxEnv describes environment of Passport:
+     * https://wiki.yandex-team.ru/passport/tvm2/user-ticket/#0-opredeljaemsjasokruzhenijami
+     */
+    enum class EBlackboxEnv: ui8 {
+        Prod,
+        Test,
+        ProdYateam,
+        TestYateam,
+        Stress
+    };
+
+    /*!
+     * UserTicket contains only valid users.
+     * Details: https://wiki.yandex-team.ru/passport/tvm2/user-ticket/#chtoestvusertickete
+     */
+    class TCheckedUserTicket {
+    public:
+        class TImpl;
+
+        TCheckedUserTicket(THolder<TImpl> impl);
+        TCheckedUserTicket(TCheckedUserTicket&&);
+        ~TCheckedUserTicket();
+
+        TCheckedUserTicket& operator=(TCheckedUserTicket&&);
+
+        /*!
+         * @return True value if ticket parsed and checked successfully
+         */
+        explicit operator bool() const;
+
+        /*!
+         * Never empty
+         * @return UIDs of users listed in ticket
+         */
+        const TUids& GetUids() const;
+
+        /*!
+         * Maybe 0
+         * @return Default user in ticket
+         */
+        TUid GetDefaultUid() const;
+
+        /*!
+         * Never empty
+         * @return UIDs of users listed in ticket with user extended fields
+         */
+        TUidsExtFieldsMap GetUidsExtFields() const;
+
+        /*!
+         * Empty if there is no default uid in ticket
+         * @return Default user in ticket with extended fields
+         */
+        std::optional<TUserExtFields> GetDefaultUidExtFields() const;
+
+        /*!
+         * Scopes inherited from credential - never empty
+         * @return Newly constructed vector of scopes
+         */
+        const TScopes& GetScopes() const;
+
+        /*!
+         * Check if scope presented in ticket
+         */
+        bool HasScope(TStringBuf scopeName) const;
+
+        /*!
+         * @return Ticket check status
+         */
+        ETicketStatus GetStatus() const;
+
+        /*!
+         * DebugInfo is human readable data for debug purposes
+         * @return Serialized ticket
+         */
+        TString DebugInfo() const;
+
+        /*!
+         * Env of user
+         */
+        EBlackboxEnv GetEnv() const;
+
+        /*!
+         * @return login_id of user
+         * empty if ticket does not contain login_id
+         */
+        const TString& GetLoginId() const;
+
+    public: // for python binding
+        TCheckedUserTicket() = default;
+
+    private:
+        THolder<TImpl> Impl_;
+        friend class NInternal::TCanningKnife;
+    };
+}
diff --git a/library/cpp/tvmauth/client/README.md b/library/cpp/tvmauth/client/README.md
new file mode 100644
index 0000000000..cda6a22d3c
--- /dev/null
+++ b/library/cpp/tvmauth/client/README.md
@@ -0,0 +1,84 @@
+Overview
+===
+This library provides ability to operate with TVM. Library is fast enough to get or check tickets for every request without burning CPU.
+
+[Home page of project](https://wiki.yandex-team.ru/passport/tvm2/)
+You can find some examples in [here](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/examples).
+
+You can ask questions: [PASSPORTDUTY](https://st.yandex-team.ru/createTicket?queue=PASSPORTDUTY&_form=77618)
+
+TvmClient
+===
+Don't forget to collect logs from client.
+___
+`TvmClient` allowes:
+1. `GetServiceTicketFor()` - to fetch ServiceTicket for outgoing request
+2. `CheckServiceTicket()` - to check ServiceTicket from incoming request
+3. `CheckUserTicket()` - to check UserTicket from incoming request
+4. `GetRoles()` - to get roles from IDM
+
+All methods are thread-safe.
+
+You should check status of `CheckedServiceTicket` or `CheckedUserTicket` for equality 'Ok'. You can get ticket fields (src/uids/scopes) only for correct ticket. Otherwise exception will be thrown.
+___
+You should check status of client with `GetStatus()`:
+* `OK` - nothing to do here
+* `Warning` - **you should trigger your monitoring alert**
+
+      Normal operation of TvmClient is still possible but there are problems with refreshing cache, so it is expiring.
+      Is tvm-api.yandex.net accessible?
+      Have you changed your TVM-secret or your backend (dst) deleted its TVM-client?
+
+* `Error` - **you should trigger your monitoring alert and close this instance for user-traffic**
+
+      TvmClient's cache is already invalid (expired) or soon will be: you can't check valid ServiceTicket or be authenticated by your backends (dsts)
+
+___
+Constructor creates system thread for refreshing cache - so do not fork your proccess after creating `TTvmClient` instance. Constructor leads to network I/O. Other methods always use memory.
+
+Exceptions maybe thrown from constructor:
+* `TRetriableException` - maybe some network trouble: you can try to create client one more time.
+* `TNonRetriableException` - settings are bad: fix them.
+___
+You can choose way for fetching data for your service operation:
+* http://localhost:{port}/tvm - recomended way
+* https://tvm-api.yandex.net
+
+TvmTool
+------------
+`TTvmClient` uses local http-interface to get state. This interface can be provided with tvmtool (local daemon) or Qloud/YP (local http api in container).
+See more: https://wiki.yandex-team.ru/passport/tvm2/tvm-daemon/.
+
+`TTvmClient` fetches configuration from tvmtool, so you need only to tell client how to connect to it and tell which alias of tvm id should be used for this `TvmClient` instance.
+
+TvmApi
+------------
+First of all: please use `DiskCacheDir` - it provides reliability for your service and for tvm-api.
+Please check restrictions of this field.
+
+Roles
+===
+[Example](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/examples/create_with_tvmapi/create.cpp?rev=r8888584#L84)
+
+You need to configure roles fetching
+------------
+1. Enable disk cache: [DiskCacheDir](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/misc/api/settings.h?rev=r9001419#L54)
+
+2. Enable ServiceTicket fetching:
+     [SelfTvmId](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/misc/api/settings.h?rev=r9001419#L57) + [Secret](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/misc/api/settings.h?rev=r9001419#L60)
+3. Enable roles fetching from tirole:
+    [FetchRolesForIdmSystemSlug](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/misc/api/settings.h?rev=r9001419#L78)
+
+You need to use roles for request check
+------------
+1. Check ServiceTicket and/or UserTicket - as usual:
+     [CheckServiceTicket()](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/facade.h?rev=r7890770#L91)/[CheckUserTicket()](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/facade.h?rev=r7890770#L99)
+
+2. Get actual roles from `TvmClient`: [GetRoles()](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/facade.h?rev=r7890770#L105)
+
+3. Use roles
+     - case#1: [get](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/misc/roles/roles.h?rev=r7890770#L37-46) role list for service or user and check for the exact role you need.
+     - case#2: use [shortcuts](https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/misc/roles/roles.h?rev=r7890770#L50) - they are wrappers for case#1
+
+4. If consumer (service or user) has required role, you can perform request.
+     If consumer doesn't have required role, you should show error message with useful message.
diff --git a/library/cpp/tvmauth/client/client_status.cpp b/library/cpp/tvmauth/client/client_status.cpp
new file mode 100644
index 0000000000..eca35ba22b
--- /dev/null
+++ b/library/cpp/tvmauth/client/client_status.cpp
@@ -0,0 +1,6 @@
+#include "client_status.h"
+
+template <>
+void Out<NTvmAuth::TClientStatus>(IOutputStream& out, const NTvmAuth::TClientStatus& s) {
+    out << s.GetCode() << ": " << s.GetLastError();
+}
diff --git a/library/cpp/tvmauth/client/client_status.h b/library/cpp/tvmauth/client/client_status.h
new file mode 100644
index 0000000000..831a66e299
--- /dev/null
+++ b/library/cpp/tvmauth/client/client_status.h
@@ -0,0 +1,84 @@
+#pragma once
+
+#include <util/generic/string.h>
+#include <util/string/builder.h>
+
+namespace NTvmAuth {
+    class TClientStatus {
+    public:
+        enum ECode {
+            Ok,
+            Warning,
+            Error,
+            IncompleteTicketsSet,
+            NotInitialized,
+        };
+
+        TClientStatus(ECode state, TString&& lastError)
+            : Code_(state)
+            , LastError_(std::move(lastError))
+        {
+        }
+
+        TClientStatus() = default;
+        TClientStatus(const TClientStatus&) = default;
+        TClientStatus(TClientStatus&&) = default;
+
+        TClientStatus& operator=(const TClientStatus&) = default;
+        TClientStatus& operator=(TClientStatus&&) = default;
+
+        ECode GetCode() const {
+            return Code_;
+        }
+
+        const TString& GetLastError() const {
+            return LastError_;
+        }
+
+        TString CreateJugglerMessage() const {
+            return TStringBuilder() << GetJugglerCode() << ";TvmClient: " << LastError_ << "\n";
+        }
+
+    private:
+        int32_t GetJugglerCode() const {
+            switch (Code_) {
+                case ECode::Ok:
+                    return 0; // OK juggler check state
+                case ECode::Warning:
+                case ECode::IncompleteTicketsSet:
+                case ECode::NotInitialized:
+                    return 1; // WARN juggler check state
+                case ECode::Error:
+                    return 2; // CRIT juggler check state
+            }
+            return 2; // This should not happen, so set check state as CRIT.
+        }
+
+        ECode Code_ = Ok;
+        TString LastError_;
+    };
+
+    static inline bool operator==(const TClientStatus& l, const TClientStatus& r) noexcept {
+        return l.GetCode() == r.GetCode() && l.GetLastError() == r.GetLastError();
+    }
+
+    static inline bool operator==(const TClientStatus& l, const TClientStatus::ECode r) noexcept {
+        return l.GetCode() == r;
+    }
+
+    static inline bool operator==(const TClientStatus::ECode l, const TClientStatus& r) noexcept {
+        return r.GetCode() == l;
+    }
+
+    static inline bool operator!=(const TClientStatus& l, const TClientStatus& r) noexcept {
+        return !(l == r);
+    }
+
+    static inline bool operator!=(const TClientStatus& l, const TClientStatus::ECode r) noexcept {
+        return !(l == r);
+    }
+
+    static inline bool operator!=(const TClientStatus::ECode l, const TClientStatus& r) noexcept {
+        return !(l == r);
+    }
+}
diff --git a/library/cpp/tvmauth/client/exception.h b/library/cpp/tvmauth/client/exception.h
new file mode 100644
index 0000000000..43de506f4e
--- /dev/null
+++ b/library/cpp/tvmauth/client/exception.h
@@ -0,0 +1,29 @@
+#pragma once
+
+#include <library/cpp/tvmauth/exception.h>
+
+namespace NTvmAuth {
+    class TClientException: public TTvmException {
+    };
+
+    class TInternalException: public TTvmException {
+    };
+
+    class TRetriableException: public TClientException {
+    };
+    class TNonRetriableException: public TClientException {
+    };
+
+    class TNotInitializedException: public TClientException {
+    };
+
+    class TIllegalUsage: public TNonRetriableException {
+    };
+
+    class TBrokenTvmClientSettings: public TIllegalUsage {
+    };
+    class TMissingServiceTicket: public TNonRetriableException {
+    };
+    class TPermissionDenied: public TNonRetriableException {
+    };
+}
diff --git a/library/cpp/tvmauth/client/facade.cpp b/library/cpp/tvmauth/client/facade.cpp
new file mode 100644
index 0000000000..2647c276fc
--- /dev/null
+++ b/library/cpp/tvmauth/client/facade.cpp
@@ -0,0 +1,88 @@
+#include "facade.h"
+
+#include "misc/api/threaded_updater.h"
+#include "misc/tool/threaded_updater.h"
+
+namespace NTvmAuth {
+    TTvmClient::TTvmClient(const NTvmTool::TClientSettings& settings, TLoggerPtr logger)
+        : Updater_(NTvmTool::TThreadedUpdater::Create(settings, std::move(logger)))
+    {
+        ServiceTicketCheckFlags_.NeedDstCheck = settings.ShouldCheckDst;
+    }
+
+    TTvmClient::TTvmClient(const NTvmApi::TClientSettings& settings, TLoggerPtr logger)
+        : Updater_(NTvmApi::TThreadedUpdater::Create(settings, std::move(logger)))
+    {
+        ServiceTicketCheckFlags_.NeedDstCheck = settings.ShouldCheckDst;
+    }
+
+    TTvmClient::TTvmClient(
+        TAsyncUpdaterPtr updater,
+        const TServiceContext::TCheckFlags& serviceTicketCheckFlags)
+        : Updater_(std::move(updater))
+        , ServiceTicketCheckFlags_(serviceTicketCheckFlags)
+    {
+        try {
+            if (Updater_->GetRoles()) {
+            }
+        } catch (const TIllegalUsage&) {
+            // it is a test probably
+        } catch (const TNotInitializedException&) {
+            // it is a test probably
+        }
+    }
+
+    TTvmClient::TTvmClient(TTvmClient&& o) = default;
+    TTvmClient::~TTvmClient() = default;
+    TTvmClient& TTvmClient::operator=(TTvmClient&& o) = default;
+
+    TClientStatus TTvmClient::GetStatus() const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetStatus();
+    }
+
+    TInstant TTvmClient::GetUpdateTimeOfPublicKeys() const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetUpdateTimeOfPublicKeys();
+    }
+
+    TInstant TTvmClient::GetUpdateTimeOfServiceTickets() const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetUpdateTimeOfServiceTickets();
+    }
+
+    TInstant TTvmClient::GetInvalidationTimeOfPublicKeys() const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetInvalidationTimeOfPublicKeys();
+    }
+
+    TInstant TTvmClient::GetInvalidationTimeOfServiceTickets() const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetInvalidationTimeOfServiceTickets();
+    }
+
+    TString TTvmClient::GetServiceTicketFor(const TClientSettings::TAlias& dst) const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetServiceTicketFor(dst);
+    }
+
+    TString TTvmClient::GetServiceTicketFor(const TTvmId dst) const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetServiceTicketFor(dst);
+    }
+
+    TCheckedServiceTicket TTvmClient::CheckServiceTicket(TStringBuf ticket) const {
+        Y_ENSURE(Updater_);
+        return Updater_->CheckServiceTicket(ticket, ServiceTicketCheckFlags_);
+    }
+
+    TCheckedUserTicket TTvmClient::CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overridenEnv) const {
+        Y_ENSURE(Updater_);
+        return Updater_->CheckUserTicket(ticket, overridenEnv);
+    }
+
+    NRoles::TRolesPtr TTvmClient::GetRoles() const {
+        Y_ENSURE(Updater_);
+        return Updater_->GetRoles();
+    }
+}
diff --git a/library/cpp/tvmauth/client/facade.h b/library/cpp/tvmauth/client/facade.h
new file mode 100644
index 0000000000..8e8b635a2a
--- /dev/null
+++ b/library/cpp/tvmauth/client/facade.h
@@ -0,0 +1,118 @@
+#pragma once
+
+#include "misc/async_updater.h"
+#include "misc/api/settings.h"
+#include "misc/tool/settings.h"
+
+#include <library/cpp/tvmauth/checked_service_ticket.h>
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+
+namespace NTvmAuth::NInternal {
+    class TClientCaningKnife;
+}
+
+namespace NTvmAuth {
+    class TDefaultUidChecker;
+    class TServiceTicketGetter;
+    class TServiceTicketChecker;
+    class TSrcChecker;
+    class TUserTicketChecker;
+
+    /*!
+     * Long lived thread-safe object for interacting with TVM.
+     * In 99% cases TvmClient shoud be created at service startup and live for the whole process lifetime.
+     */
+    class TTvmClient {
+    public:
+        /*!
+         * Uses local http-interface to get state: http://localhost/tvm/.
+         * This interface can be provided with tvmtool (local daemon) or Qloud/YP (local http api in container).
+         * See more: https://wiki.yandex-team.ru/passport/tvm2/tvm-daemon/.
+         *
+         * Starts thread for updating of in-memory cache in background
+         * @param settings
+         * @param logger is usefull for monitoring and debuging
+         */
+        TTvmClient(const NTvmTool::TClientSettings& settings, TLoggerPtr logger);
+
+        /*!
+         * Uses general way to get state: https://tvm-api.yandex.net.
+         * It is not recomended for Qloud/YP.
+         *
+         * Starts thread for updating of in-memory cache in background
+         * Reads cache from disk if specified
+         * @param settings
+         * @param logger is usefull for monitoring and debuging
+         */
+        TTvmClient(const NTvmApi::TClientSettings& settings, TLoggerPtr logger);
+
+        /*!
+         * Feel free to use custom updating logic in tests
+         */
+        TTvmClient(
+            TAsyncUpdaterPtr updater,
+            const TServiceContext::TCheckFlags& serviceTicketCheckFlags = {});
+
+        TTvmClient(TTvmClient&&);
+        ~TTvmClient();
+        TTvmClient& operator=(TTvmClient&&);
+
+        /*!
+         * You should trigger your monitoring if status is not Ok.
+         * It will be unable to operate if status is Error.
+         * Description: https://a.yandex-team.ru/arc/trunk/arcadia/library/cpp/tvmauth/client/README.md#high-level-interface
+         * @return Current status of client.
+         */
+        TClientStatus GetStatus() const;
+
+        /*!
+         * Some tools for monitoring
+         */
+
+        TInstant GetUpdateTimeOfPublicKeys() const;
+        TInstant GetUpdateTimeOfServiceTickets() const;
+        TInstant GetInvalidationTimeOfPublicKeys() const;
+        TInstant GetInvalidationTimeOfServiceTickets() const;
+
+        /*!
+         * Requires fetchinig options (from TClientSettings or Qloud/YP/tvmtool settings)
+         * Can throw exception if cache is invalid or wrong config
+         *
+         * Alias is local label for TvmID
+         *  which can be used to avoid this number in every checking case in code.
+         * @param dst
+         */
+        TString GetServiceTicketFor(const TClientSettings::TAlias& dst) const;
+        TString GetServiceTicketFor(const TTvmId dst) const;
+
+        /*!
+         * For TTvmApi::TClientSettings: checking must be enabled in TClientSettings
+         * Can throw exception if checking was not enabled in settings
+         *
+         * ServiceTicket contains src: you should check it by yourself with ACL
+         * @param ticket
+         */
+        TCheckedServiceTicket CheckServiceTicket(TStringBuf ticket) const;
+
+        /*!
+         * Requires blackbox enviroment (from TClientSettings or Qloud/YP/tvmtool settings)
+         * Can throw exception if checking was not enabled in settings
+         * @param ticket
+         * @param overrideEnv allowes you to override env from settings
+         */
+        TCheckedUserTicket CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overrideEnv = {}) const;
+
+        /*!
+         * Requires idm system slug (from TClientSettings or Qloud/YP/tvmtool settings)
+         * Can throw exception if slug was not specified in settings
+         */
+        NRoles::TRolesPtr GetRoles() const;
+
+    private:
+        TAsyncUpdaterPtr Updater_;
+
+        TServiceContext::TCheckFlags ServiceTicketCheckFlags_;
+
+        friend class NInternal::TClientCaningKnife;
+    };
+}
diff --git a/library/cpp/tvmauth/client/logger.cpp b/library/cpp/tvmauth/client/logger.cpp
new file mode 100644
index 0000000000..bd63773cdf
--- /dev/null
+++ b/library/cpp/tvmauth/client/logger.cpp
@@ -0,0 +1,12 @@
+#include "logger.h"
+
+#include <util/datetime/base.h>
+#include <util/generic/string.h>
+
+namespace NTvmAuth {
+    void TCerrLogger::Log(int lvl, const TString& msg) {
+        if (lvl > Level_)
+            return;
+        Cerr << TInstant::Now().ToStringLocal() << " lvl=" << lvl << " msg: " << msg << "\n";
+    }
+}
diff --git a/library/cpp/tvmauth/client/logger.h b/library/cpp/tvmauth/client/logger.h
new file mode 100644
index 0000000000..6f3718a2aa
--- /dev/null
+++ b/library/cpp/tvmauth/client/logger.h
@@ -0,0 +1,59 @@
+#pragma once
+
+#include <util/generic/ptr.h>
+
+namespace NTvmAuth {
+    class ILogger: public TAtomicRefCount<ILogger> {
+    public:
+        virtual ~ILogger() = default;
+
+        void Debug(const TString& msg) {
+            Log(7, msg);
+        }
+
+        void Info(const TString& msg) {
+            Log(6, msg);
+        }
+
+        void Warning(const TString& msg) {
+            Log(4, msg);
+        }
+
+        void Error(const TString& msg) {
+            Log(3, msg);
+        }
+
+    protected:
+        /*!
+         * Log event
+         * @param lvl is syslog level: 0(Emergency) ... 7(Debug)
+         * @param msg
+         */
+        virtual void Log(int lvl, const TString& msg) = 0;
+    };
+
+    class TCerrLogger: public ILogger {
+    public:
+        TCerrLogger(int level)
+            : Level_(level)
+        {
+        }
+
+        void Log(int lvl, const TString& msg) override;
+
+    private:
+        const int Level_;
+    };
+
+    using TLoggerPtr = TIntrusivePtr<ILogger>;
+
+    class TDevNullLogger: public ILogger {
+    public:
+        static TLoggerPtr IAmBrave() {
+            return MakeIntrusive<TDevNullLogger>();
+        }
+
+        void Log(int, const TString&) override {
+        }
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/api/dynamic_dst/tvm_client.cpp b/library/cpp/tvmauth/client/misc/api/dynamic_dst/tvm_client.cpp
new file mode 100644
index 0000000000..cd6ec45406
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/dynamic_dst/tvm_client.cpp
@@ -0,0 +1,166 @@
+#include "tvm_client.h"
+
+#include <util/string/builder.h>
+
+namespace NTvmAuth::NDynamicClient {
+    TIntrusivePtr<TTvmClient> TTvmClient::Create(const NTvmApi::TClientSettings& settings, TLoggerPtr logger) {
+        Y_ENSURE_EX(logger, TNonRetriableException() << "Logger is required");
+        THolder<TTvmClient> p(new TTvmClient(settings, std::move(logger)));
+        p->Init();
+        p->StartWorker();
+        return p.Release();
+    }
+
+    NThreading::TFuture<TAddResponse> TTvmClient::Add(TDsts&& dsts) {
+        if (dsts.empty()) {
+            LogDebug("Adding dst: got empty task");
+            return NThreading::MakeFuture<TAddResponse>(TAddResponse{});
+        }
+
+        NThreading::TPromise<TAddResponse> promise = NThreading::NewPromise<TAddResponse>();
+
+        TServiceTickets::TMapIdStr requestedTicketsFromStartUpCache = GetRequestedTicketsFromStartUpCache(dsts);
+
+        if (requestedTicketsFromStartUpCache.size() == dsts.size() &&
+            !IsInvalid(TServiceTickets::GetInvalidationTime(requestedTicketsFromStartUpCache), TInstant::Now())) {
+            std::unique_lock lock(*ServiceTicketBatchUpdateMutex_);
+
+            TPairTicketsErrors newCache;
+            TServiceTicketsPtr cache = GetCachedServiceTickets();
+
+            NTvmApi::TDstSetPtr oldDsts = GetDsts();
+            std::shared_ptr<TDsts> newDsts = std::make_shared<TDsts>(oldDsts->begin(), oldDsts->end());
+
+            for (const auto& ticket : cache->TicketsById) {
+                newCache.Tickets.insert(ticket);
+            }
+            for (const auto& error : cache->ErrorsById) {
+                newCache.Errors.insert(error);
+            }
+            for (const auto& ticket : requestedTicketsFromStartUpCache) {
+                newCache.Tickets.insert(ticket);
+                newDsts->insert(ticket.first);
+            }
+
+            UpdateServiceTicketsCache(std::move(newCache), GetStartUpCacheBornDate());
+            SetDsts(std::move(newDsts));
+
+            lock.unlock();
+
+            TAddResponse response;
+
+            for (const auto& dst : dsts) {
+                response.emplace(dst, TDstResponse{EDstStatus::Success, TString()});
+                LogDebug(TStringBuilder() << "Got ticket from disk cache"
+                                          << ": dst=" << dst.Id << " got ticket");
+            }
+
+            promise.SetValue(std::move(response));
+            return promise.GetFuture();
+        }
+
+        const size_t size = dsts.size();
+        const ui64 id = ++TaskIds_;
+
+        TaskQueue_.Enqueue(TTask{id, promise, std::move(dsts)});
+
+        LogDebug(TStringBuilder() << "Adding dst: got task #" << id << " with " << size << " dsts");
+        return promise.GetFuture();
+    }
+
+    std::optional<TString> TTvmClient::GetOptionalServiceTicketFor(const TTvmId dst) {
+        TServiceTicketsPtr tickets = GetCachedServiceTickets();
+
+        Y_ENSURE_EX(tickets,
+                    TBrokenTvmClientSettings()
+                        << "Need to enable fetching of service tickets in settings");
+
+        auto it = tickets->TicketsById.find(dst);
+        if (it != tickets->TicketsById.end()) {
+            return it->second;
+        }
+
+        it = tickets->ErrorsById.find(dst);
+        if (it != tickets->ErrorsById.end()) {
+            ythrow TMissingServiceTicket()
+                << "Failed to get ticket for '" << dst << "': "
+                << it->second;
+        }
+
+        return {};
+    }
+
+    TTvmClient::TTvmClient(const NTvmApi::TClientSettings& settings, TLoggerPtr logger)
+        : TBase(settings, logger)
+    {
+    }
+
+    TTvmClient::~TTvmClient() {
+        TBase::StopWorker();
+    }
+
+    void TTvmClient::Worker() {
+        TBase::Worker();
+        ProcessTasks();
+    }
+
+    void TTvmClient::ProcessTasks() {
+        TaskQueue_.DequeueAll(&Tasks_);
+        if (Tasks_.empty()) {
+            return;
+        }
+
+        TDsts required;
+        for (const TTask& task : Tasks_) {
+            for (const auto& dst : task.Dsts) {
+                required.insert(dst);
+            }
+        }
+
+        TServiceTicketsPtr cache = UpdateMissingServiceTickets(required);
+        for (TTask& task : Tasks_) {
+            try {
+                SetResponseForTask(task, *cache);
+            } catch (const std::exception& e) {
+                LogError(TStringBuilder()
+                         << "Adding dst: task #" << task.Id << ": exception: " << e.what());
+            } catch (...) {
+                LogError(TStringBuilder()
+                         << "Adding dst: task #" << task.Id << ": exception: " << CurrentExceptionMessage());
+            }
+        }
+
+        Tasks_.clear();
+    }
+
+    static const TString UNKNOWN = "Unknown reason";
+    void TTvmClient::SetResponseForTask(TTvmClient::TTask& task, const TServiceTickets& cache) {
+        if (task.Promise.HasValue()) {
+            LogWarning(TStringBuilder() << "Adding dst: task #" << task.Id << " already has value");
+            return;
+        }
+
+        TAddResponse response;
+
+        for (const auto& dst : task.Dsts) {
+            if (cache.TicketsById.contains(dst.Id)) {
+                response.emplace(dst, TDstResponse{EDstStatus::Success, TString()});
+
+                LogDebug(TStringBuilder() << "Adding dst: task #" << task.Id
+                                          << ": dst=" << dst.Id << " got ticket");
+                continue;
+            }
+
+            auto it = cache.ErrorsById.find(dst.Id);
+            const TString& error = it == cache.ErrorsById.end() ? UNKNOWN : it->second;
+            response.emplace(dst, TDstResponse{EDstStatus::Fail, error});
+
+            LogWarning(TStringBuilder() << "Adding dst: task #" << task.Id
+                                        << ": dst=" << dst.Id
+                                        << " failed to get ticket: " << error);
+        }
+
+        LogDebug(TStringBuilder() << "Adding dst: task #" << task.Id << ": set value");
+        task.Promise.SetValue(std::move(response));
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/api/dynamic_dst/tvm_client.h b/library/cpp/tvmauth/client/misc/api/dynamic_dst/tvm_client.h
new file mode 100644
index 0000000000..67eeb2618a
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/dynamic_dst/tvm_client.h
@@ -0,0 +1,60 @@
+#pragma once
+
+#include <library/cpp/tvmauth/client/misc/api/threaded_updater.h>
+
+#include <library/cpp/threading/future/future.h>
+
+#include <util/generic/map.h>
+#include <util/thread/lfqueue.h>
+
+#include <optional>
+
+namespace NTvmAuth::NDynamicClient {
+    enum class EDstStatus {
+        Success,
+        Fail,
+    };
+
+    struct TDstResponse {
+        EDstStatus Status = EDstStatus::Fail;
+        TString Error;
+
+        bool operator==(const TDstResponse& o) const {
+            return Status == o.Status && Error == o.Error;
+        }
+    };
+
+    using TDsts = NTvmApi::TDstSet;
+    using TAddResponse = TMap<NTvmApi::TClientSettings::TDst, TDstResponse>;
+
+    class TTvmClient: public NTvmApi::TThreadedUpdater {
+    public:
+        static TIntrusivePtr<TTvmClient> Create(const NTvmApi::TClientSettings& settings, TLoggerPtr logger);
+        virtual ~TTvmClient();
+
+        NThreading::TFuture<TAddResponse> Add(TDsts&& dsts);
+        std::optional<TString> GetOptionalServiceTicketFor(const TTvmId dst);
+
+    protected: // for tests
+        struct TTask {
+            ui64 Id = 0;
+            NThreading::TPromise<TAddResponse> Promise;
+            TDsts Dsts;
+        };
+
+        using TBase = NTvmApi::TThreadedUpdater;
+
+    protected: // for tests
+        TTvmClient(const NTvmApi::TClientSettings& settings, TLoggerPtr logger);
+
+        void Worker() override;
+        void ProcessTasks();
+
+        void SetResponseForTask(TTask& task, const TServiceTickets& cache);
+
+    private:
+        std::atomic<ui64> TaskIds_ = {0};
+        TLockFreeQueue<TTask> TaskQueue_;
+        TVector<TTask> Tasks_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/api/dynamic_dst/ya.make b/library/cpp/tvmauth/client/misc/api/dynamic_dst/ya.make
new file mode 100644
index 0000000000..27908b39fe
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/dynamic_dst/ya.make
@@ -0,0 +1,18 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/threading/future
+    library/cpp/tvmauth/client
+)
+
+SRCS(
+    tvm_client.cpp
+)
+
+GENERATE_ENUM_SERIALIZATION(tvm_client.h)
+
+END()
+
+RECURSE_FOR_TESTS(
+    ut
+)
diff --git a/library/cpp/tvmauth/client/misc/api/retry_settings.h b/library/cpp/tvmauth/client/misc/api/retry_settings.h
new file mode 100644
index 0000000000..607b230811
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/retry_settings.h
@@ -0,0 +1,33 @@
+#pragma once
+
+#include <library/cpp/tvmauth/client/misc/exponential_backoff.h>
+
+namespace NTvmAuth::NTvmApi {
+    struct TRetrySettings {
+        TExponentialBackoff::TSettings BackoffSettings = {
+            TDuration::Seconds(0),
+            TDuration::Minutes(1),
+            2,
+            0.5,
+        };
+        TDuration MaxRandomSleepDefault = TDuration::Seconds(5);
+        TDuration MaxRandomSleepWhenOk = TDuration::Minutes(1);
+        ui32 RetriesOnStart = 3;
+        ui32 RetriesInBackground = 2;
+        TDuration WorkerAwakingPeriod = TDuration::Seconds(10);
+        ui32 DstsLimit = 300;
+        TDuration RolesUpdatePeriod = TDuration::Minutes(10);
+        TDuration RolesWarnPeriod = TDuration::Minutes(20);
+
+        bool operator==(const TRetrySettings& o) const {
+            return BackoffSettings == o.BackoffSettings &&
+                   MaxRandomSleepDefault == o.MaxRandomSleepDefault &&
+                   MaxRandomSleepWhenOk == o.MaxRandomSleepWhenOk &&
+                   RetriesOnStart == o.RetriesOnStart &&
+                   WorkerAwakingPeriod == o.WorkerAwakingPeriod &&
+                   DstsLimit == o.DstsLimit &&
+                   RolesUpdatePeriod == o.RolesUpdatePeriod &&
+                   RolesWarnPeriod == o.RolesWarnPeriod;
+        }
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/api/roles_fetcher.cpp b/library/cpp/tvmauth/client/misc/api/roles_fetcher.cpp
new file mode 100644
index 0000000000..8f4b359e8c
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/roles_fetcher.cpp
@@ -0,0 +1,164 @@
+#include "roles_fetcher.h"
+
+#include <library/cpp/tvmauth/client/misc/disk_cache.h>
+#include <library/cpp/tvmauth/client/misc/roles/decoder.h>
+#include <library/cpp/tvmauth/client/misc/roles/parser.h>
+
+#include <library/cpp/http/misc/httpcodes.h>
+#include <library/cpp/string_utils/quote/quote.h>
+
+#include <util/string/builder.h>
+#include <util/string/join.h>
+
+namespace NTvmAuth::NTvmApi {
+    static TString CreatePath(const TString& dir, const TString& file) {
+        return dir.EndsWith("/")
+                   ? dir + file
+                   : dir + "/" + file;
+    }
+
+    TRolesFetcher::TRolesFetcher(const TRolesFetcherSettings& settings, TLoggerPtr logger)
+        : Settings_(settings)
+        , Logger_(logger)
+        , CacheFilePath_(CreatePath(Settings_.CacheDir, "roles"))
+    {
+        Client_ = std::make_unique<TKeepAliveHttpClient>(
+            Settings_.TiroleHost,
+            Settings_.TirolePort,
+            Settings_.Timeout,
+            Settings_.Timeout);
+    }
+
+    TInstant TRolesFetcher::ReadFromDisk() {
+        TDiskReader dr(CacheFilePath_, Logger_.Get());
+        if (!dr.Read()) {
+            return {};
+        }
+
+        std::pair<TString, TString> data = ParseDiskFormat(dr.Data());
+        if (data.second != Settings_.IdmSystemSlug) {
+            Logger_->Warning(
+                TStringBuilder() << "Roles in disk cache are for another slug (" << data.second
+                                 << "). Self=" << Settings_.IdmSystemSlug);
+            return {};
+        }
+
+        CurrentRoles_.Set(NRoles::TParser::Parse(std::make_shared<TString>(std::move(data.first))));
+        Logger_->Debug(
+            TStringBuilder() << "Succeed to read roles with revision "
+                             << CurrentRoles_.Get()->GetMeta().Revision
+                             << " from " << CacheFilePath_);
+
+        return dr.Time();
+    }
+
+    bool TRolesFetcher::AreRolesOk() const {
+        return bool(GetCurrentRoles());
+    }
+
+    bool TRolesFetcher::IsTimeToUpdate(const TRetrySettings& settings, TDuration sinceUpdate) {
+        return settings.RolesUpdatePeriod < sinceUpdate;
+    }
+
+    bool TRolesFetcher::ShouldWarn(const TRetrySettings& settings, TDuration sinceUpdate) {
+        return settings.RolesWarnPeriod < sinceUpdate;
+    }
+
+    NUtils::TFetchResult TRolesFetcher::FetchActualRoles(const TString& serviceTicket) {
+        TStringStream out;
+        THttpHeaders outHeaders;
+
+        TRequest req = CreateTiroleRequest(serviceTicket);
+        TKeepAliveHttpClient::THttpCode code = Client_->DoGet(
+            req.Url,
+            &out,
+            req.Headers,
+            &outHeaders);
+
+        const THttpInputHeader* reqId = outHeaders.FindHeader("X-Request-Id");
+
+        Logger_->Debug(
+            TStringBuilder() << "Succeed to perform request for roles to " << Settings_.TiroleHost
+                             << " (request_id=" << (reqId ? reqId->Value() : "")
+                             << "). code=" << code);
+
+        return {code, std::move(outHeaders), "/v1/get_actual_roles", out.Str(), {}};
+    }
+
+    void TRolesFetcher::Update(NUtils::TFetchResult&& fetchResult, TInstant now) {
+        if (fetchResult.Code == HTTP_NOT_MODIFIED) {
+            Y_ENSURE(CurrentRoles_.Get(),
+                     "tirole did not return any roles because current roles are actual,"
+                     " but there are no roles in memory - this should never happen");
+            return;
+        }
+
+        Y_ENSURE(fetchResult.Code == HTTP_OK,
+                 "Unexpected code from tirole: " << fetchResult.Code << ". " << fetchResult.Response);
+
+        const THttpInputHeader* codec = fetchResult.Headers.FindHeader("X-Tirole-Compression");
+        const TStringBuf codecBuf = codec ? codec->Value() : "";
+
+        NRoles::TRawPtr blob;
+        try {
+            blob = std::make_shared<TString>(NRoles::TDecoder::Decode(
+                codecBuf,
+                std::move(fetchResult.Response)));
+        } catch (const std::exception& e) {
+            throw yexception() << "Failed to decode blob with codec '" << codecBuf
+                               << "': " << e.what();
+        }
+
+        CurrentRoles_.Set(NRoles::TParser::Parse(blob));
+
+        Logger_->Debug(
+            TStringBuilder() << "Succeed to update roles with revision "
+                             << CurrentRoles_.Get()->GetMeta().Revision);
+
+        TDiskWriter dw(CacheFilePath_, Logger_.Get());
+        dw.Write(PrepareDiskFormat(*blob, Settings_.IdmSystemSlug), now);
+    }
+
+    NTvmAuth::NRoles::TRolesPtr TRolesFetcher::GetCurrentRoles() const {
+        return CurrentRoles_.Get();
+    }
+
+    void TRolesFetcher::ResetConnection() {
+        Client_->ResetConnection();
+    }
+
+    static const char DELIMETER = '\t';
+
+    std::pair<TString, TString> TRolesFetcher::ParseDiskFormat(TStringBuf filebody) {
+        TStringBuf slug = filebody.RNextTok(DELIMETER);
+        return {TString(filebody), CGIUnescapeRet(slug)};
+    }
+
+    TString TRolesFetcher::PrepareDiskFormat(TStringBuf roles, TStringBuf slug) {
+        TStringStream res;
+        res.Reserve(roles.size() + 1 + slug.size());
+        res << roles << DELIMETER << CGIEscapeRet(slug);
+        return res.Str();
+    }
+
+    TRolesFetcher::TRequest TRolesFetcher::CreateTiroleRequest(const TString& serviceTicket) const {
+        TRolesFetcher::TRequest res;
+
+        TStringStream url;
+        url.Reserve(512);
+        url << "/v1/get_actual_roles?";
+        url << "system_slug=" << CGIEscapeRet(Settings_.IdmSystemSlug) << "&";
+        Settings_.ProcInfo.AddToRequest(url);
+        res.Url = std::move(url.Str());
+
+        res.Headers.reserve(2);
+        res.Headers.emplace(XYaServiceTicket_, serviceTicket);
+
+        NRoles::TRolesPtr roles = CurrentRoles_.Get();
+        if (roles) {
+            res.Headers.emplace(IfNoneMatch_, Join("", "\"", roles->GetMeta().Revision, "\""));
+        }
+
+        return res;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/api/roles_fetcher.h b/library/cpp/tvmauth/client/misc/api/roles_fetcher.h
new file mode 100644
index 0000000000..63691223b5
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/roles_fetcher.h
@@ -0,0 +1,63 @@
+#pragma once
+
+#include "retry_settings.h"
+
+#include <library/cpp/tvmauth/client/misc/fetch_result.h>
+#include <library/cpp/tvmauth/client/misc/proc_info.h>
+#include <library/cpp/tvmauth/client/misc/utils.h>
+#include <library/cpp/tvmauth/client/misc/roles/roles.h>
+
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <library/cpp/http/simple/http_client.h>
+
+namespace NTvmAuth::NTvmApi {
+    struct TRolesFetcherSettings {
+        TString TiroleHost;
+        ui16 TirolePort = 0;
+        TString CacheDir;
+        NUtils::TProcInfo ProcInfo;
+        TTvmId SelfTvmId = 0;
+        TString IdmSystemSlug;
+        TDuration Timeout = TDuration::Seconds(30);
+    };
+
+    class TRolesFetcher {
+    public:
+        TRolesFetcher(const TRolesFetcherSettings& settings, TLoggerPtr logger);
+
+        TInstant ReadFromDisk();
+
+        bool AreRolesOk() const;
+        static bool IsTimeToUpdate(const TRetrySettings& settings, TDuration sinceUpdate);
+        static bool ShouldWarn(const TRetrySettings& settings, TDuration sinceUpdate);
+
+        NUtils::TFetchResult FetchActualRoles(const TString& serviceTicket);
+        void Update(NUtils::TFetchResult&& fetchResult, TInstant now = TInstant::Now());
+
+        NTvmAuth::NRoles::TRolesPtr GetCurrentRoles() const;
+
+        void ResetConnection();
+
+    public:
+        static std::pair<TString, TString> ParseDiskFormat(TStringBuf filebody);
+        static TString PrepareDiskFormat(TStringBuf roles, TStringBuf slug);
+
+        struct TRequest {
+            TString Url;
+            TKeepAliveHttpClient::THeaders Headers;
+        };
+        TRequest CreateTiroleRequest(const TString& serviceTicket) const;
+
+    private:
+        const TRolesFetcherSettings Settings_;
+        const TLoggerPtr Logger_;
+        const TString CacheFilePath_;
+        const TString XYaServiceTicket_ = "X-Ya-Service-Ticket";
+        const TString IfNoneMatch_ = "If-None-Match";
+
+        NUtils::TProtectedValue<NTvmAuth::NRoles::TRolesPtr> CurrentRoles_;
+
+        std::unique_ptr<TKeepAliveHttpClient> Client_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/api/settings.cpp b/library/cpp/tvmauth/client/misc/api/settings.cpp
new file mode 100644
index 0000000000..082f089f75
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/settings.cpp
@@ -0,0 +1,89 @@
+#include "settings.h"
+
+#include <util/datetime/base.h>
+#include <util/stream/file.h>
+#include <util/system/fs.h>
+
+#include <set>
+
+namespace NTvmAuth::NTvmApi {
+    void TClientSettings::CheckPermissions(const TString& dir) {
+        const TString name = dir + "/check.tmp";
+
+        try {
+            NFs::EnsureExists(dir);
+
+            TFile file(name, CreateAlways | RdWr);
+
+            NFs::Remove(name);
+        } catch (const std::exception& e) {
+            NFs::Remove(name);
+            ythrow TPermissionDenied() << "Permission denied to disk cache directory: " << e.what();
+        }
+    }
+
+    void TClientSettings::CheckValid() const {
+        if (DiskCacheDir) {
+            CheckPermissions(DiskCacheDir);
+        }
+
+        if (TStringBuf(Secret)) {
+            Y_ENSURE_EX(NeedServiceTicketsFetching(),
+                        TBrokenTvmClientSettings() << "Secret is present but destinations list is empty. It makes no sense");
+        }
+        if (NeedServiceTicketsFetching()) {
+            Y_ENSURE_EX(SelfTvmId != 0,
+                        TBrokenTvmClientSettings() << "SelfTvmId cannot be 0 if fetching of Service Tickets required");
+            Y_ENSURE_EX((TStringBuf)Secret,
+                        TBrokenTvmClientSettings() << "Secret is required for fetching of Service Tickets");
+        }
+
+        if (CheckServiceTickets) {
+            Y_ENSURE_EX(SelfTvmId != 0 || !ShouldCheckDst,
+                        TBrokenTvmClientSettings() << "SelfTvmId cannot be 0 if checking of dst in Service Tickets required");
+        }
+
+        if (FetchRolesForIdmSystemSlug) {
+            Y_ENSURE_EX(DiskCacheDir,
+                        TBrokenTvmClientSettings() << "Disk cache must be enabled to use roles: "
+                                                      "they can be heavy");
+        }
+
+        bool needSmth = NeedServiceTicketsFetching() ||
+                        CheckServiceTickets ||
+                        CheckUserTicketsWithBbEnv;
+        Y_ENSURE_EX(needSmth, TBrokenTvmClientSettings() << "Invalid settings: nothing to do");
+
+        // Useless now: keep it here to avoid forgetting check from TDst. TODO: PASSP-35377
+        for (const auto& dst : FetchServiceTicketsForDsts) {
+            Y_ENSURE_EX(dst.Id != 0, TBrokenTvmClientSettings() << "TvmId cannot be 0");
+        }
+        // TODO: check only FetchServiceTicketsForDsts_
+        // Python binding checks settings before normalization
+        for (const auto& [alias, dst] : FetchServiceTicketsForDstsWithAliases) {
+            Y_ENSURE_EX(dst.Id != 0, TBrokenTvmClientSettings() << "TvmId cannot be 0");
+        }
+        Y_ENSURE_EX(TiroleTvmId != 0, TBrokenTvmClientSettings() << "TiroleTvmId cannot be 0");
+    }
+
+    TClientSettings TClientSettings::CloneNormalized() const {
+        TClientSettings res = *this;
+
+        std::set<TTvmId> allDsts;
+        for (const auto& tvmid : res.FetchServiceTicketsForDsts) {
+            allDsts.insert(tvmid.Id);
+        }
+        for (const auto& [alias, tvmid] : res.FetchServiceTicketsForDstsWithAliases) {
+            allDsts.insert(tvmid.Id);
+        }
+        if (FetchRolesForIdmSystemSlug) {
+            allDsts.insert(res.TiroleTvmId);
+        }
+
+        res.FetchServiceTicketsForDsts = {allDsts.begin(), allDsts.end()};
+
+        res.CheckValid();
+
+        return res;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/api/settings.h b/library/cpp/tvmauth/client/misc/api/settings.h
new file mode 100644
index 0000000000..ce5890cb87
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/settings.h
@@ -0,0 +1,239 @@
+#pragma once
+
+#include <library/cpp/tvmauth/client/misc/settings.h>
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+#include <library/cpp/tvmauth/type.h>
+
+#include <library/cpp/string_utils/secret_string/secret_string.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/hash.h>
+#include <util/generic/maybe.h>
+
+namespace NTvmAuth::NTvmApi {
+    /**
+     * Settings for TVM client. Uses https://tvm-api.yandex.net to get state.
+     * At least one of them is required:
+     *     FetchServiceTicketsForDsts_/FetchServiceTicketsForDstsWithAliases_
+     *     CheckServiceTickets_
+     *     CheckUserTicketsWithBbEnv_
+     */
+    class TClientSettings: public NTvmAuth::TClientSettings {
+    public:
+        class TDst;
+
+        /**
+         * Alias is an internal name for destinations within your code.
+         *  You can associate a name with an tvm_id once in your code and use the name as an alias for
+         *  tvm_id to each calling point. Useful for several environments: prod/test/etc.
+         * @example:
+         *      // init
+         *      static const TString MY_BACKEND = "my backend";
+         *      TDstMap map = {{MY_BACKEND, TDst(config.get("my_back_tvm_id"))}};
+         *      ...
+         *      // per request
+         *      TString t = tvmClient.GetServiceTicket(MY_BACKEND);
+         */
+        using TDstMap = THashMap<TAlias, TDst>;
+        using TDstVector = TVector<TDst>;
+
+    public:
+        /*!
+         * NOTE: Please use this option: it provides the best reliability
+         * NOTE: Client requires read/write permissions
+         * WARNING: The same directory can be used only:
+         *            - for TVM clients with the same settings
+         *          OR
+         *            - for new client replacing previous - with another config.
+         *          System user must be the same for processes with these clients inside.
+         *          Implementation doesn't provide other scenarios.
+         */
+        TString DiskCacheDir;
+
+        // Required for Service Ticket fetching or checking
+        TTvmId SelfTvmId = 0;
+
+        // Options for Service Tickets fetching
+        NSecretString::TSecretString Secret;
+        /*!
+         * Client will process both attrs:
+         *   FetchServiceTicketsForDsts_, FetchServiceTicketsForDstsWithAliases_
+         * WARNING: It is not way to provide authorization for incoming ServiceTickets!
+         *          It is way only to send your ServiceTickets to your backend!
+         */
+        TDstVector FetchServiceTicketsForDsts;
+        TDstMap FetchServiceTicketsForDstsWithAliases;
+        bool IsIncompleteTicketsSetAnError = true;
+
+        // Options for Service Tickets checking
+        bool CheckServiceTickets = false;
+
+        // Options for User Tickets checking
+        TMaybe<EBlackboxEnv> CheckUserTicketsWithBbEnv;
+
+        // Options for roles fetching
+        TString FetchRolesForIdmSystemSlug;
+        /*!
+         * By default client checks src from ServiceTicket or default uid from UserTicket -
+         *   to prevent you from forgetting to check it yourself.
+         * It does binary checks only:
+         *   ticket gets status NoRoles, if there is no role for src or default uid.
+         * You need to check roles on your own if you have a non-binary role system or
+         *     you have disabled ShouldCheckSrc/ShouldCheckDefaultUid
+         *
+         * You may need to disable this check in the following cases:
+         *   - You use GetRoles() to provide verbose message (with revision).
+         *     Double check may be inconsistent:
+         *       binary check inside client uses revision of roles X - i.e. src 100500 has no role,
+         *       exact check in your code uses revision of roles Y -  i.e. src 100500 has some roles.
+         */
+        bool ShouldCheckSrc = true;
+        bool ShouldCheckDefaultUid = true;
+        /*!
+         * By default client checks dst from ServiceTicket. If this check is switched off
+         *   incorrect dst does not result in error of checked ticket status
+         * DANGEROUS: This case you must check dst manualy using @link TCheckedServiceTicket::GetDst()
+         */
+        bool ShouldCheckDst = true;
+
+        // In case of unsuccessful initialization at startup the client will be initialized in the background
+        bool EnableLazyInitialization = false;
+
+        // Options for tests
+        TString TvmHost = "https://tvm-api.yandex.net";
+        ui16 TvmPort = 443;
+        TString TiroleHost = "https://tirole-api.yandex.net";
+        TDuration TvmSocketTimeout = TDuration::Seconds(5);
+        TDuration TvmConnectTimeout = TDuration::Seconds(30);
+        ui16 TirolePort = 443;
+        TTvmId TiroleTvmId = TIROLE_TVMID;
+
+        // for debug purposes
+        TString LibVersionPrefix;
+
+        void CheckValid() const;
+        TClientSettings CloneNormalized() const;
+
+        static inline const TTvmId TIROLE_TVMID = 2028120;
+        static inline const TTvmId TIROLE_TVMID_TEST = 2026536;
+
+        // DEPRECATED API
+        // TODO: get rid of it: PASSP-35377
+    public:
+        // Deprecated: set attributes directly
+        void SetSelfTvmId(TTvmId selfTvmId) {
+            SelfTvmId = selfTvmId;
+        }
+
+        // Deprecated: set attributes directly
+        void EnableServiceTicketChecking() {
+            CheckServiceTickets = true;
+        }
+
+        // Deprecated: set attributes directly
+        void EnableUserTicketChecking(EBlackboxEnv env) {
+            CheckUserTicketsWithBbEnv = env;
+        }
+
+        // Deprecated: set attributes directly
+        void SetTvmHostPort(const TString& host, ui16 port) {
+            TvmHost = host;
+            TvmPort = port;
+        }
+
+        // Deprecated: set attributes directly
+        void SetTiroleHostPort(const TString& host, ui16 port) {
+            TiroleHost = host;
+            TirolePort = port;
+        }
+
+        // Deprecated: set attributes directly
+        void EnableRolesFetching(const TString& systemSlug, TTvmId tiroleTvmId = TIROLE_TVMID) {
+            TiroleTvmId = tiroleTvmId;
+            FetchRolesForIdmSystemSlug = systemSlug;
+        }
+
+        // Deprecated: set attributes directly
+        void DoNotCheckSrcByDefault() {
+            ShouldCheckSrc = false;
+        }
+
+        // Deprecated: set attributes directly
+        void DoNotCheckDefaultUidByDefault() {
+            ShouldCheckDefaultUid = false;
+        }
+
+        // Deprecated: set attributes directly
+        void SetDiskCacheDir(const TString& dir) {
+            DiskCacheDir = dir;
+        }
+
+        // Deprecated: set attributes directly
+        void EnableServiceTicketsFetchOptions(const TStringBuf selfSecret,
+                                              TDstMap&& dsts,
+                                              const bool considerIncompleteTicketsSetAsError = true) {
+            IsIncompleteTicketsSetAnError = considerIncompleteTicketsSetAsError;
+            Secret = selfSecret;
+
+            FetchServiceTicketsForDsts = TDstVector{};
+            FetchServiceTicketsForDsts.reserve(dsts.size());
+            for (const auto& pair : dsts) {
+                FetchServiceTicketsForDsts.push_back(pair.second);
+            }
+
+            FetchServiceTicketsForDstsWithAliases = std::move(dsts);
+        }
+
+        // Deprecated: set attributes directly
+        void EnableServiceTicketsFetchOptions(const TStringBuf selfSecret,
+                                              TDstVector&& dsts,
+                                              const bool considerIncompleteTicketsSetAsError = true) {
+            IsIncompleteTicketsSetAnError = considerIncompleteTicketsSetAsError;
+            Secret = selfSecret;
+            FetchServiceTicketsForDsts = std::move(dsts);
+        }
+
+    public:
+        bool IsServiceTicketFetchingRequired() const {
+            return bool(Secret.Value());
+        }
+
+        bool NeedServiceTicketsFetching() const {
+            return !FetchServiceTicketsForDsts.empty() ||
+                   !FetchServiceTicketsForDstsWithAliases.empty() ||
+                   FetchRolesForIdmSystemSlug;
+        }
+
+        // TODO: get rid of TDst: PASSP-35377
+        class TDst {
+        public:
+            TDst(TTvmId id)
+                : Id(id)
+            {
+                Y_ENSURE_EX(id != 0, TBrokenTvmClientSettings() << "TvmId cannot be 0");
+            }
+
+            TTvmId Id;
+
+            bool operator==(const TDst& o) const {
+                return Id == o.Id;
+            }
+
+            bool operator<(const TDst& o) const {
+                return Id < o.Id;
+            }
+
+        public: // for python binding
+            TDst()
+                : Id(0)
+            {
+            }
+        };
+
+    public:
+        static void CheckPermissions(const TString& dir);
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/api/threaded_updater.cpp b/library/cpp/tvmauth/client/misc/api/threaded_updater.cpp
new file mode 100644
index 0000000000..51df498ead
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/threaded_updater.cpp
@@ -0,0 +1,1128 @@
+#include "threaded_updater.h"
+
+#include <library/cpp/tvmauth/client/misc/checker.h>
+#include <library/cpp/tvmauth/client/misc/default_uid_checker.h>
+#include <library/cpp/tvmauth/client/misc/disk_cache.h>
+#include <library/cpp/tvmauth/client/misc/getter.h>
+#include <library/cpp/tvmauth/client/misc/src_checker.h>
+#include <library/cpp/tvmauth/client/misc/utils.h>
+#include <library/cpp/tvmauth/client/misc/retry_settings/v1/settings.pb.h>
+
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <library/cpp/json/json_reader.h>
+
+#include <util/stream/str.h>
+#include <util/string/builder.h>
+#include <util/string/cast.h>
+#include <util/system/thread.h>
+
+namespace NTvmAuth::NTvmApi {
+    static TString CreatePublicKeysUrl(const TClientSettings& settings,
+                                       const NUtils::TProcInfo& procInfo) {
+        TStringStream s;
+        s << "/2/keys";
+        s << "?";
+        procInfo.AddToRequest(s);
+
+        s << "&get_retry_settings=yes";
+
+        if (settings.SelfTvmId != 0) {
+            s << "&src=" << settings.SelfTvmId;
+        }
+
+        if (settings.CheckUserTicketsWithBbEnv) {
+            s << "&env=" << static_cast<int>(*settings.CheckUserTicketsWithBbEnv);
+        }
+
+        return s.Str();
+    }
+
+    TAsyncUpdaterPtr TThreadedUpdater::Create(const TClientSettings& settings, TLoggerPtr logger) {
+        Y_ENSURE_EX(logger, TNonRetriableException() << "Logger is required");
+        THolder<TThreadedUpdater> p(new TThreadedUpdater(settings, std::move(logger)));
+        try {
+            p->Init();
+        } catch (const TRetriableException& e) {
+            if (!settings.EnableLazyInitialization) {
+                throw e;
+            }
+        }
+
+        p->StartWorker();
+        return p.Release();
+    }
+
+    TThreadedUpdater::~TThreadedUpdater() {
+        ExpBackoff_.SetEnabled(false);
+        ExpBackoff_.Interrupt();
+        StopWorker(); // Required here to avoid using of deleted members
+    }
+
+    TClientStatus TThreadedUpdater::GetStatus() const {
+        const TClientStatus::ECode state = GetState();
+        return TClientStatus(state, GetLastError(state == TClientStatus::Ok || state == TClientStatus::IncompleteTicketsSet));
+    }
+
+    TString TThreadedUpdater::GetServiceTicketFor(const TClientSettings::TAlias& dst) const {
+        Y_ENSURE_EX(Settings_.NeedServiceTicketsFetching(), TBrokenTvmClientSettings()
+                                                                << "Need to enable ServiceTickets fetching");
+
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        auto c = GetCachedServiceTickets();
+        return TServiceTicketGetter::GetTicket(dst, c);
+    }
+
+    TString TThreadedUpdater::GetServiceTicketFor(const TTvmId dst) const {
+        Y_ENSURE_EX(Settings_.NeedServiceTicketsFetching(), TBrokenTvmClientSettings()
+                                                                << "Need to enable ServiceTickets fetching");
+
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        auto c = GetCachedServiceTickets();
+        return TServiceTicketGetter::GetTicket(dst, c);
+    }
+
+    TCheckedServiceTicket TThreadedUpdater::CheckServiceTicket(TStringBuf ticket, const TServiceContext::TCheckFlags& flags) const {
+        Y_ENSURE_EX(Settings_.CheckServiceTickets, TBrokenTvmClientSettings()
+                                                       << "Need to TClientSettings::EnableServiceTicketChecking()");
+
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        TServiceContextPtr c = GetCachedServiceContext();
+        TCheckedServiceTicket res = TServiceTicketChecker::Check(ticket, c, flags);
+        if (Settings_.ShouldCheckSrc && Settings_.FetchRolesForIdmSystemSlug && res) {
+            NRoles::TRolesPtr roles = GetRoles();
+            return TSrcChecker::Check(std::move(res), roles);
+        }
+        return res;
+    }
+
+    TCheckedUserTicket TThreadedUpdater::CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overridenEnv) const {
+        Y_ENSURE_EX(Settings_.CheckUserTicketsWithBbEnv, TBrokenTvmClientSettings()
+                                                             << "Need to use TClientSettings::EnableUserTicketChecking()");
+
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        auto c = GetCachedUserContext(overridenEnv);
+        TCheckedUserTicket res = TUserTicketChecker::Check(ticket, c);
+        if (Settings_.ShouldCheckDefaultUid && Settings_.FetchRolesForIdmSystemSlug && res && res.GetEnv() == EBlackboxEnv::ProdYateam) {
+            NRoles::TRolesPtr roles = GetRoles();
+            return TDefaultUidChecker::Check(std::move(res), roles);
+        }
+        return res;
+    }
+
+    NRoles::TRolesPtr TThreadedUpdater::GetRoles() const {
+        Y_ENSURE_EX(RolesFetcher_,
+                    TBrokenTvmClientSettings() << "Roles were not configured in settings");
+
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        return RolesFetcher_->GetCurrentRoles();
+    }
+
+    TClientStatus::ECode TThreadedUpdater::GetState() const {
+        const TInstant now = TInstant::Now();
+
+        if (!IsInited()) {
+            return TClientStatus::NotInitialized;
+        }
+
+        if (Settings_.IsServiceTicketFetchingRequired()) {
+            if (AreServiceTicketsInvalid(now)) {
+                return TClientStatus::Error;
+            }
+            auto tickets = GetCachedServiceTickets();
+            if (!tickets) {
+                return TClientStatus::Error;
+            }
+            if (tickets->TicketsById.size() < GetDsts()->size()) {
+                if (Settings_.IsIncompleteTicketsSetAnError) {
+                    return TClientStatus::Error;
+                } else {
+                    return TClientStatus::IncompleteTicketsSet;
+                }
+            }
+        }
+        if ((Settings_.CheckServiceTickets || Settings_.CheckUserTicketsWithBbEnv) && ArePublicKeysInvalid(now)) {
+            return TClientStatus::Error;
+        }
+
+        const TDuration sincePublicKeysUpdate = now - GetUpdateTimeOfPublicKeys();
+        const TDuration sinceServiceTicketsUpdate = now - GetUpdateTimeOfServiceTickets();
+        const TDuration sinceRolesUpdate = now - GetUpdateTimeOfRoles();
+
+        if (Settings_.IsServiceTicketFetchingRequired() && sinceServiceTicketsUpdate > ServiceTicketsDurations_.Expiring) {
+            return TClientStatus::Warning;
+        }
+        if ((Settings_.CheckServiceTickets || Settings_.CheckUserTicketsWithBbEnv) &&
+            sincePublicKeysUpdate > PublicKeysDurations_.Expiring)
+        {
+            return TClientStatus::Warning;
+        }
+        if (RolesFetcher_ && TRolesFetcher::ShouldWarn(RetrySettings_, sinceRolesUpdate)) {
+            return TClientStatus::Warning;
+        }
+
+        return TClientStatus::Ok;
+    }
+
+    TThreadedUpdater::TThreadedUpdater(const TClientSettings& settings, TLoggerPtr logger)
+        : TThreadedUpdaterBase(
+              TRetrySettings{}.WorkerAwakingPeriod,
+              std::move(logger),
+              settings.TvmHost,
+              settings.TvmPort,
+              settings.TvmSocketTimeout,
+              settings.TvmConnectTimeout)
+        , ExpBackoff_(RetrySettings_.BackoffSettings)
+        , ServiceTicketBatchUpdateMutex_(std::make_unique<std::mutex>())
+        , Settings_(settings.CloneNormalized())
+        , ProcInfo_(NUtils::TProcInfo::Create(Settings_.LibVersionPrefix))
+        , PublicKeysUrl_(CreatePublicKeysUrl(Settings_, ProcInfo_))
+        , DstAliases_(MakeAliasMap(Settings_))
+        , Headers_({{"Content-Type", "application/x-www-form-urlencoded"}})
+        , Random_(TInstant::Now().MicroSeconds())
+    {
+        if (Settings_.IsServiceTicketFetchingRequired()) {
+            SigningContext_ = TServiceContext::SigningFactory(Settings_.Secret);
+        }
+
+        if (Settings_.IsServiceTicketFetchingRequired()) {
+            Destinations_ = std::make_shared<const TDstSet>(Settings_.FetchServiceTicketsForDsts.begin(), Settings_.FetchServiceTicketsForDsts.end());
+        }
+
+        PublicKeysDurations_.RefreshPeriod = TDuration::Days(1);
+        ServiceTicketsDurations_.RefreshPeriod = TDuration::Hours(1);
+
+        if (Settings_.CheckUserTicketsWithBbEnv) {
+            SetBbEnv(*Settings_.CheckUserTicketsWithBbEnv);
+        }
+
+        if (Settings_.FetchRolesForIdmSystemSlug) {
+            RolesFetcher_ = std::make_unique<TRolesFetcher>(
+                TRolesFetcherSettings{
+                    Settings_.TiroleHost,
+                    Settings_.TirolePort,
+                    Settings_.DiskCacheDir,
+                    ProcInfo_,
+                    Settings_.SelfTvmId,
+                    Settings_.FetchRolesForIdmSystemSlug,
+                },
+                Logger_);
+        }
+
+        if (Settings_.DiskCacheDir) {
+            TString path = Settings_.DiskCacheDir;
+            if (path.back() != '/') {
+                path.push_back('/');
+            }
+
+            if (Settings_.IsServiceTicketFetchingRequired()) {
+                ServiceTicketsFilepath_ = path;
+                ServiceTicketsFilepath_.append("service_tickets");
+            }
+
+            if (Settings_.CheckServiceTickets || Settings_.CheckUserTicketsWithBbEnv) {
+                PublicKeysFilepath_ = path;
+                PublicKeysFilepath_.append("public_keys");
+            }
+
+            RetrySettingsFilepath_ = path + "retry_settings";
+        } else {
+            LogInfo("Disk cache disabled. Please set disk cache directory in settings for best reliability");
+        }
+    }
+
+    void TThreadedUpdater::Init() {
+        ReadStateFromDisk();
+        ClearErrors();
+        ExpBackoff_.SetEnabled(false);
+
+        // First of all try to get tickets: there are a lot of reasons to fail this request.
+        // As far as disk cache usually disabled, client will not fetch keys before fail on every ctor call.
+        UpdateServiceTickets();
+        if (!AreServicesTicketsOk()) {
+            ThrowLastError();
+        }
+
+        UpdatePublicKeys();
+        if (!IsServiceContextOk() || !IsUserContextOk()) {
+            ThrowLastError();
+        }
+
+        UpdateRoles();
+        if (RolesFetcher_ && !RolesFetcher_->AreRolesOk()) {
+            ThrowLastError();
+        }
+
+        SetInited(true);
+        ExpBackoff_.SetEnabled(true);
+    }
+
+    void TThreadedUpdater::UpdateServiceTickets() {
+        if (!Settings_.IsServiceTicketFetchingRequired()) {
+            return;
+        }
+
+        TInstant stut = GetUpdateTimeOfServiceTickets();
+        try {
+            if (IsTimeToUpdateServiceTickets(stut)) {
+                UpdateAllServiceTickets();
+                NeedFetchMissingServiceTickets_ = false;
+            } else if (NeedFetchMissingServiceTickets_) {
+                TDstSetPtr dsts = GetDsts();
+                if (GetCachedServiceTickets()->TicketsById.size() < dsts->size()) {
+                    UpdateMissingServiceTickets(*dsts);
+                    NeedFetchMissingServiceTickets_ = false;
+                }
+            }
+            if (AreServicesTicketsOk()) {
+                ClearError(EScope::ServiceTickets);
+            }
+        } catch (const std::exception& e) {
+            ProcessError(EType::Retriable, EScope::ServiceTickets, e.what());
+            LogWarning(TStringBuilder() << "Failed to update service tickets: " << e.what());
+            if (TInstant::Now() - stut > ServiceTicketsDurations_.Expiring) {
+                LogError("Service tickets have not been refreshed for too long period");
+            }
+        }
+    }
+
+    void TThreadedUpdater::UpdateAllServiceTickets() {
+        TDstSetPtr dsts = GetDsts();
+        THttpResult st = GetServiceTicketsFromHttp(*dsts, RetrySettings_.DstsLimit);
+
+        std::unique_lock lock(*ServiceTicketBatchUpdateMutex_);
+
+        auto oldCache = GetCachedServiceTickets();
+        if (oldCache) {
+            if (dsts->size() < GetDsts()->size()) {
+                for (const auto& pair : oldCache->TicketsById) {
+                    st.TicketsWithErrors.Tickets.insert(pair);
+                }
+            }
+
+            for (const auto& pair : oldCache->ErrorsById) {
+                st.TicketsWithErrors.Errors.insert(pair);
+            }
+        }
+
+        UpdateServiceTicketsCache(std::move(st.TicketsWithErrors), TInstant::Now());
+
+        lock.unlock();
+
+        if (ServiceTicketsFilepath_) {
+            DiskCacheServiceTickets_ = CreateJsonArray(st.Responses);
+            TDiskWriter w(ServiceTicketsFilepath_, Logger_.Get());
+            w.Write(PrepareTicketsForDisk(DiskCacheServiceTickets_, Settings_.SelfTvmId));
+        }
+    }
+
+    TServiceTicketsPtr TThreadedUpdater::UpdateMissingServiceTickets(const TDstSet& required) {
+        TServiceTicketsPtr cache = GetCachedServiceTickets();
+        TClientSettings::TDstVector missingDsts = FindMissingDsts(cache, required);
+
+        if (missingDsts.empty()) {
+            return cache;
+        }
+
+        THttpResult st = GetServiceTicketsFromHttp(missingDsts, RetrySettings_.DstsLimit);
+
+        std::unique_lock lock(*ServiceTicketBatchUpdateMutex_);
+
+        cache = GetCachedServiceTickets();
+        size_t gotTickets = st.TicketsWithErrors.Tickets.size();
+
+        TDstSetPtr oldDsts = GetDsts();
+        std::shared_ptr<TDstSet> newDsts = std::make_shared<TDstSet>(oldDsts->begin(), oldDsts->end());
+
+        for (const auto& pair : cache->TicketsById) {
+            st.TicketsWithErrors.Tickets.insert(pair);
+        }
+        for (const auto& pair : cache->ErrorsById) {
+            st.TicketsWithErrors.Errors.insert(pair);
+        }
+        for (const auto& pair : st.TicketsWithErrors.Tickets) {
+            st.TicketsWithErrors.Errors.erase(pair.first);
+            newDsts->insert(pair.first);
+        }
+
+        TServiceTicketsPtr c = UpdateServiceTicketsCachePartly(
+            std::move(st.TicketsWithErrors),
+            gotTickets);
+
+        SetDsts(std::move(newDsts));
+
+        lock.unlock();
+
+        if (!c) {
+            LogWarning("UpdateMissingServiceTickets: new cache is NULL. BUG?");
+            c = cache;
+        }
+
+        if (!ServiceTicketsFilepath_) {
+            return c;
+        }
+
+        DiskCacheServiceTickets_ = AppendToJsonArray(DiskCacheServiceTickets_, st.Responses);
+
+        TDiskWriter w(ServiceTicketsFilepath_, Logger_.Get());
+        w.Write(PrepareTicketsForDisk(DiskCacheServiceTickets_, Settings_.SelfTvmId));
+
+        return c;
+    }
+
+    void TThreadedUpdater::UpdatePublicKeys() {
+        if (!Settings_.CheckServiceTickets && !Settings_.CheckUserTicketsWithBbEnv) {
+            return;
+        }
+
+        TInstant pkut = GetUpdateTimeOfPublicKeys();
+        if (!IsTimeToUpdatePublicKeys(pkut)) {
+            return;
+        }
+
+        try {
+            TString publicKeys = GetPublicKeysFromHttp();
+
+            UpdatePublicKeysCache(publicKeys, TInstant::Now());
+            if (PublicKeysFilepath_) {
+                TDiskWriter w(PublicKeysFilepath_, Logger_.Get());
+                w.Write(publicKeys);
+            }
+            if (IsServiceContextOk() && IsUserContextOk()) {
+                ClearError(EScope::PublicKeys);
+            }
+        } catch (const std::exception& e) {
+            ProcessError(EType::Retriable, EScope::PublicKeys, e.what());
+            LogWarning(TStringBuilder() << "Failed to update public keys: " << e.what());
+            if (TInstant::Now() - pkut > PublicKeysDurations_.Expiring) {
+                LogError("Public keys have not been refreshed for too long period");
+            }
+        }
+    }
+
+    void TThreadedUpdater::UpdateRoles() {
+        if (!RolesFetcher_) {
+            return;
+        }
+
+        TInstant rut = GetUpdateTimeOfRoles();
+        if (!TRolesFetcher::IsTimeToUpdate(RetrySettings_, TInstant::Now() - rut)) {
+            return;
+        }
+
+        struct TCloser {
+            TRolesFetcher* Fetcher;
+            ~TCloser() {
+                Fetcher->ResetConnection();
+            }
+        } closer{RolesFetcher_.get()};
+
+        try {
+            TServiceTicketsPtr st = GetCachedServiceTickets();
+            Y_ENSURE(st, "No one service ticket in memory: how it possible?");
+            auto it = st->TicketsById.find(Settings_.TiroleTvmId);
+            Y_ENSURE(it != st->TicketsById.end(),
+                     "Missing tvmid for tirole in cache: " << Settings_.TiroleTvmId);
+
+            RolesFetcher_->Update(
+                FetchWithRetries(
+                    [&]() { return RolesFetcher_->FetchActualRoles(it->second); },
+                    EScope::Roles));
+            SetUpdateTimeOfRoles(TInstant::Now());
+
+            if (RolesFetcher_->AreRolesOk()) {
+                ClearError(EScope::Roles);
+            }
+        } catch (const std::exception& e) {
+            ProcessError(EType::Retriable, EScope::Roles, e.what());
+            LogWarning(TStringBuilder() << "Failed to update roles: " << e.what());
+            if (TRolesFetcher::ShouldWarn(RetrySettings_, TInstant::Now() - rut)) {
+                LogError("Roles have not been refreshed for too long period");
+            }
+        }
+    }
+
+    TServiceTicketsPtr TThreadedUpdater::UpdateServiceTicketsCachePartly(
+        TAsyncUpdaterBase::TPairTicketsErrors&& tickets,
+        size_t got) {
+        size_t count = tickets.Tickets.size();
+        TServiceTicketsPtr c = MakeIntrusiveConst<TServiceTickets>(std::move(tickets.Tickets),
+                                                                   std::move(tickets.Errors),
+                                                                   DstAliases_);
+        SetServiceTickets(c);
+        LogInfo(TStringBuilder()
+                << "Cache was partly updated with " << got
+                << " service ticket(s). total: " << count);
+
+        return c;
+    }
+
+    void TThreadedUpdater::UpdateServiceTicketsCache(TPairTicketsErrors&& tickets, TInstant time) {
+        size_t count = tickets.Tickets.size();
+        SetServiceTickets(MakeIntrusiveConst<TServiceTickets>(std::move(tickets.Tickets),
+                                                              std::move(tickets.Errors),
+                                                              DstAliases_));
+
+        SetUpdateTimeOfServiceTickets(time);
+
+        if (count > 0) {
+            LogInfo(TStringBuilder() << "Cache was updated with " << count << " service ticket(s): " << time);
+        }
+    }
+
+    void TThreadedUpdater::UpdatePublicKeysCache(const TString& publicKeys, TInstant time) {
+        if (publicKeys.empty()) {
+            return;
+        }
+
+        if (Settings_.CheckServiceTickets) {
+            SetServiceContext(MakeIntrusiveConst<TServiceContext>(
+                TServiceContext::CheckingFactory(Settings_.SelfTvmId,
+                                                 publicKeys)));
+        }
+
+        if (Settings_.CheckUserTicketsWithBbEnv) {
+            SetUserContext(publicKeys);
+        }
+
+        SetUpdateTimeOfPublicKeys(time);
+
+        LogInfo(TStringBuilder() << "Cache was updated with public keys: " << time);
+    }
+
+    void TThreadedUpdater::ReadStateFromDisk() {
+        try {
+            TServiceTicketsFromDisk st;
+            std::tie(st, StartUpCache_) = ReadServiceTicketsFromDisk();
+            UpdateServiceTicketsCache(std::move(st.TicketsWithErrors), st.BornDate);
+            DiskCacheServiceTickets_ = st.FileBody;
+        } catch (const std::exception& e) {
+            LogWarning(TStringBuilder() << "Failed to read service tickets from disk: " << e.what());
+        }
+
+        try {
+            std::pair<TString, TInstant> pk = ReadPublicKeysFromDisk();
+            UpdatePublicKeysCache(pk.first, pk.second);
+        } catch (const std::exception& e) {
+            LogWarning(TStringBuilder() << "Failed to read public keys from disk: " << e.what());
+        }
+
+        try {
+            TString rs = ReadRetrySettingsFromDisk();
+            UpdateRetrySettings(rs);
+        } catch (const std::exception& e) {
+            LogWarning(TStringBuilder() << "Failed to read retry settings from disk: " << e.what());
+        }
+
+        try {
+            if (RolesFetcher_) {
+                SetUpdateTimeOfRoles(RolesFetcher_->ReadFromDisk());
+            }
+        } catch (const std::exception& e) {
+            LogWarning(TStringBuilder() << "Failed to read roles from disk: " << e.what());
+        }
+    }
+
+    std::pair<TThreadedUpdater::TServiceTicketsFromDisk, TThreadedUpdater::TServiceTicketsFromDisk> TThreadedUpdater::ReadServiceTicketsFromDisk() const {
+        if (!ServiceTicketsFilepath_) {
+            return {};
+        }
+
+        TDiskReader r(ServiceTicketsFilepath_, Logger_.Get());
+        if (!r.Read()) {
+            return {};
+        }
+
+        std::pair<TStringBuf, TTvmId> data = ParseTicketsFromDisk(r.Data());
+        if (data.second != Settings_.SelfTvmId) {
+            TStringStream s;
+            s << "Disk cache is for another tvmId (" << data.second << "). ";
+            s << "Self=" << Settings_.SelfTvmId;
+            LogWarning(s.Str());
+            return {};
+        }
+
+        TThreadedUpdater::TServiceTicketsFromDisk resDst{
+            .BornDate = r.Time(),
+            .FileBody = TString(data.first),
+        };
+
+        TThreadedUpdater::TServiceTicketsFromDisk resAll{
+            .BornDate = r.Time(),
+            .FileBody = TString(data.first),
+        };
+
+        TDstSetPtr dsts = GetDsts();
+        ParseTicketsFromResponse(data.first, *dsts, resDst.TicketsWithErrors);
+
+        if (IsInvalid(TServiceTickets::GetInvalidationTime(resDst.TicketsWithErrors.Tickets), TInstant::Now())) {
+            LogWarning("Disk cache (service tickets) is too old");
+            return {};
+        }
+
+        try {
+            ParseTicketsFromDiskCache(data.first, resAll.TicketsWithErrors);
+        } catch (std::exception& e) {
+            LogWarning(TStringBuilder() << "Failed to parse all service tickets from disk cache: " << e.what());
+            LogInfo(TStringBuilder() << "Got " << resDst.TicketsWithErrors.Tickets.size() << " service ticket(s) from disk");
+            return {std::move(resDst), {}};
+        }
+
+        if (resAll.TicketsWithErrors.Tickets.empty()) {
+            LogInfo(TStringBuilder() << "Got " << resDst.TicketsWithErrors.Tickets.size() << " service ticket(s) from disk");
+            return {std::move(resDst), std::move(resAll)};
+        }
+
+        if (IsInvalid(TServiceTickets::GetInvalidationTime(resAll.TicketsWithErrors.Tickets), TInstant::Now())) {
+            LogWarning("Disk cache (service tickets) is too old");
+            LogInfo(TStringBuilder() << "Got " << resDst.TicketsWithErrors.Tickets.size() << " service ticket(s) from disk");
+            return {std::move(resDst), {}};
+        }
+
+        LogInfo(TStringBuilder() << "Got " << resAll.TicketsWithErrors.Tickets.size() << " service ticket(s) from disk");
+        return {std::move(resDst), std::move(resAll)};
+    }
+
+    std::pair<TString, TInstant> TThreadedUpdater::ReadPublicKeysFromDisk() const {
+        if (!PublicKeysFilepath_) {
+            return {};
+        }
+
+        TDiskReader r(PublicKeysFilepath_, Logger_.Get());
+        if (!r.Read()) {
+            return {};
+        }
+
+        if (TInstant::Now() - r.Time() > PublicKeysDurations_.Invalid) {
+            LogWarning("Disk cache (public keys) is too old");
+            return {};
+        }
+
+        return {r.Data(), r.Time()};
+    }
+
+    TString TThreadedUpdater::ReadRetrySettingsFromDisk() const {
+        if (!RetrySettingsFilepath_) {
+            return {};
+        }
+
+        TDiskReader r(RetrySettingsFilepath_, Logger_.Get());
+        if (!r.Read()) {
+            return {};
+        }
+
+        return r.Data();
+    }
+
+    template <class Dsts>
+    TThreadedUpdater::THttpResult TThreadedUpdater::GetServiceTicketsFromHttp(const Dsts& dsts, const size_t dstLimit) const {
+        Y_ENSURE(SigningContext_, "Internal error");
+
+        TClientSettings::TDstVector part;
+        part.reserve(dstLimit);
+        THttpResult res;
+        res.TicketsWithErrors.Tickets.reserve(dsts.size());
+        res.Responses.reserve(dsts.size() / dstLimit + 1);
+
+        for (auto it = dsts.begin(); it != dsts.end();) {
+            part.clear();
+            for (size_t count = 0; it != dsts.end() && count < dstLimit; ++count, ++it) {
+                part.push_back(*it);
+            }
+
+            TString response =
+                FetchWithRetries(
+                    [this, &part]() {
+                        // create request here to keep 'ts' actual
+                        return FetchServiceTicketsFromHttp(PrepareRequestForServiceTickets(
+                            Settings_.SelfTvmId,
+                            *SigningContext_,
+                            part,
+                            ProcInfo_));
+                    },
+                    EScope::ServiceTickets)
+                    .Response;
+            ParseTicketsFromResponse(response, part, res.TicketsWithErrors);
+            LogDebug(TStringBuilder()
+                     << "Response with service tickets for " << part.size()
+                     << " destination(s) was successfully fetched from " << TvmUrl_);
+
+            res.Responses.push_back(response);
+        }
+
+        LogDebug(TStringBuilder()
+                 << "Got responses with service tickets with " << res.Responses.size() << " pages for "
+                 << dsts.size() << " destination(s)");
+        for (const auto& p : res.TicketsWithErrors.Errors) {
+            LogError(TStringBuilder()
+                     << "Failed to get service ticket for dst=" << p.first << ": " << p.second);
+        }
+
+        return res;
+    }
+
+    TString TThreadedUpdater::GetPublicKeysFromHttp() const {
+        TString publicKeys =
+            FetchWithRetries(
+                [this]() { return FetchPublicKeysFromHttp(); },
+                EScope::PublicKeys)
+                .Response;
+
+        LogDebug("Public keys were successfully fetched from " + TvmUrl_);
+
+        return publicKeys;
+    }
+
+    TServiceTickets::TMapIdStr TThreadedUpdater::GetRequestedTicketsFromStartUpCache(const TDstSet& dsts) const {
+        TServiceTickets::TMapIdStr res;
+        for (const TClientSettings::TDst& dst : dsts) {
+            auto it = StartUpCache_.TicketsWithErrors.Tickets.find(dst.Id);
+            if (it != StartUpCache_.TicketsWithErrors.Tickets.end()) {
+                res[dst.Id] = it->second;
+            }
+        }
+        return res;
+    }
+
+    TInstant TThreadedUpdater::GetStartUpCacheBornDate() const {
+        return StartUpCache_.BornDate;
+    }
+
+    NUtils::TFetchResult TThreadedUpdater::FetchServiceTicketsFromHttp(const TString& body) const {
+        TStringStream s;
+
+        THttpHeaders outHeaders;
+        TKeepAliveHttpClient::THttpCode code = GetClient().DoPost("/2/ticket", body, &s, Headers_, &outHeaders);
+
+        const THttpInputHeader* settings = outHeaders.FindHeader("X-Ya-Retry-Settings");
+
+        return {code, {}, "/2/ticket", s.Str(), settings ? settings->Value() : ""};
+    }
+
+    NUtils::TFetchResult TThreadedUpdater::FetchPublicKeysFromHttp() const {
+        TStringStream s;
+
+        THttpHeaders outHeaders;
+        TKeepAliveHttpClient::THttpCode code = GetClient().DoGet(PublicKeysUrl_, &s, {}, &outHeaders);
+
+        const THttpInputHeader* settings = outHeaders.FindHeader("X-Ya-Retry-Settings");
+
+        return {code, {}, "/2/keys", s.Str(), settings ? settings->Value() : ""};
+    }
+
+    bool TThreadedUpdater::UpdateRetrySettings(const TString& header) const {
+        if (header.empty()) {
+            // Probably it is some kind of test?
+            return false;
+        }
+
+        try {
+            TString raw = NUtils::Base64url2bin(header);
+            Y_ENSURE(raw, "Invalid base64url in settings");
+
+            retry_settings::v1::Settings proto;
+            Y_ENSURE(proto.ParseFromString(raw), "Invalid proto");
+
+            // This ugly hack helps to process these settings in any case
+            TThreadedUpdater& this_ = *const_cast<TThreadedUpdater*>(this);
+            TRetrySettings& res = this_.RetrySettings_;
+
+            TStringStream diff;
+            auto update = [&diff](auto& l, const auto& r, TStringBuf desc) {
+                if (l != r) {
+                    diff << desc << ":" << l << "->" << r << ";";
+                    l = r;
+                }
+            };
+
+            if (proto.has_exponential_backoff_min_sec()) {
+                update(res.BackoffSettings.Min,
+                       TDuration::Seconds(proto.exponential_backoff_min_sec()),
+                       "exponential_backoff_min");
+            }
+            if (proto.has_exponential_backoff_max_sec()) {
+                update(res.BackoffSettings.Max,
+                       TDuration::Seconds(proto.exponential_backoff_max_sec()),
+                       "exponential_backoff_max");
+            }
+            if (proto.has_exponential_backoff_factor()) {
+                update(res.BackoffSettings.Factor,
+                       proto.exponential_backoff_factor(),
+                       "exponential_backoff_factor");
+            }
+            if (proto.has_exponential_backoff_jitter()) {
+                update(res.BackoffSettings.Jitter,
+                       proto.exponential_backoff_jitter(),
+                       "exponential_backoff_jitter");
+            }
+            this_.ExpBackoff_.UpdateSettings(res.BackoffSettings);
+
+            if (proto.has_max_random_sleep_default()) {
+                update(res.MaxRandomSleepDefault,
+                       TDuration::MilliSeconds(proto.max_random_sleep_default()),
+                       "max_random_sleep_default");
+            }
+            if (proto.has_max_random_sleep_when_ok()) {
+                update(res.MaxRandomSleepWhenOk,
+                       TDuration::MilliSeconds(proto.max_random_sleep_when_ok()),
+                       "max_random_sleep_when_ok");
+            }
+            if (proto.has_retries_on_start()) {
+                Y_ENSURE(proto.retries_on_start(), "retries_on_start==0");
+                update(res.RetriesOnStart,
+                       proto.retries_on_start(),
+                       "retries_on_start");
+            }
+            if (proto.has_retries_in_background()) {
+                Y_ENSURE(proto.retries_in_background(), "retries_in_background==0");
+                update(res.RetriesInBackground,
+                       proto.retries_in_background(),
+                       "retries_in_background");
+            }
+            if (proto.has_worker_awaking_period_sec()) {
+                update(res.WorkerAwakingPeriod,
+                       TDuration::Seconds(proto.worker_awaking_period_sec()),
+                       "worker_awaking_period");
+                this_.WorkerAwakingPeriod_ = res.WorkerAwakingPeriod;
+            }
+            if (proto.has_dsts_limit()) {
+                Y_ENSURE(proto.dsts_limit(), "dsts_limit==0");
+                update(res.DstsLimit,
+                       proto.dsts_limit(),
+                       "dsts_limit");
+            }
+
+            if (proto.has_roles_update_period_sec()) {
+                Y_ENSURE(proto.roles_update_period_sec(), "roles_update_period==0");
+                update(res.RolesUpdatePeriod,
+                       TDuration::Seconds(proto.roles_update_period_sec()),
+                       "roles_update_period_sec");
+            }
+            if (proto.has_roles_warn_period_sec()) {
+                Y_ENSURE(proto.roles_warn_period_sec(), "roles_warn_period_sec==0");
+                update(res.RolesWarnPeriod,
+                       TDuration::Seconds(proto.roles_warn_period_sec()),
+                       "roles_warn_period_sec");
+            }
+
+            if (diff.empty()) {
+                return false;
+            }
+
+            LogDebug("Retry settings were updated: " + diff.Str());
+            return true;
+        } catch (const std::exception& e) {
+            LogWarning(TStringBuilder()
+                       << "Failed to update retry settings from server, header '"
+                       << header << "': "
+                       << e.what());
+        }
+
+        return false;
+    }
+
+    template <typename Func>
+    NUtils::TFetchResult TThreadedUpdater::FetchWithRetries(Func func, EScope scope) const {
+        const ui32 tries = IsInited() ? RetrySettings_.RetriesInBackground
+                                      : RetrySettings_.RetriesOnStart;
+
+        for (size_t idx = 1;; ++idx) {
+            RandomSleep();
+
+            try {
+                NUtils::TFetchResult result = func();
+
+                if (UpdateRetrySettings(result.RetrySettings) && RetrySettingsFilepath_) {
+                    TDiskWriter w(RetrySettingsFilepath_, Logger_.Get());
+                    w.Write(result.RetrySettings);
+                }
+
+                if (400 <= result.Code && result.Code <= 499) {
+                    throw TNonRetriableException() << ProcessHttpError(scope, result.Path, result.Code, result.Response);
+                }
+                if (result.Code < 200 || result.Code >= 399) {
+                    throw yexception() << ProcessHttpError(scope, result.Path, result.Code, result.Response);
+                }
+
+                ExpBackoff_.Decrease();
+                return result;
+            } catch (const TNonRetriableException& e) {
+                LogWarning(TStringBuilder() << "Failed to get " << scope << ": " << e.what());
+                ExpBackoff_.Increase();
+                throw;
+            } catch (const std::exception& e) {
+                LogWarning(TStringBuilder() << "Failed to get " << scope << ": " << e.what());
+                ExpBackoff_.Increase();
+                if (idx >= tries) {
+                    throw;
+                }
+            }
+        }
+
+        throw yexception() << "unreachable";
+    }
+
+    void TThreadedUpdater::RandomSleep() const {
+        const TDuration maxSleep = TClientStatus::ECode::Ok == GetState()
+                                       ? RetrySettings_.MaxRandomSleepWhenOk
+                                       : RetrySettings_.MaxRandomSleepDefault;
+
+        if (maxSleep) {
+            ui32 toSleep = Random_.GenRand() % maxSleep.MilliSeconds();
+            ExpBackoff_.Sleep(TDuration::MilliSeconds(toSleep));
+        }
+    }
+
+    TString TThreadedUpdater::PrepareRequestForServiceTickets(TTvmId src,
+                                                              const TServiceContext& ctx,
+                                                              const TClientSettings::TDstVector& dsts,
+                                                              const NUtils::TProcInfo& procInfo,
+                                                              time_t now) {
+        TStringStream s;
+
+        const TString ts = IntToString<10>(now);
+        TStringStream dst;
+        dst.Reserve(10 * dsts.size());
+        for (const TClientSettings::TDst& d : dsts) {
+            if (dst.Str()) {
+                dst << ',';
+            }
+            dst << d.Id;
+        }
+
+        s << "grant_type=client_credentials";
+        s << "&src=" << src;
+        s << "&dst=" << dst.Str();
+        s << "&ts=" << ts;
+        s << "&sign=" << ctx.SignCgiParamsForTvm(ts, dst.Str());
+        s << "&get_retry_settings=yes";
+
+        s << "&";
+        procInfo.AddToRequest(s);
+
+        return s.Str();
+    }
+
+    template <class Dsts>
+    void TThreadedUpdater::ParseTicketsFromResponse(TStringBuf resp,
+                                                    const Dsts& dsts,
+                                                    TPairTicketsErrors& out) const {
+        NJson::TJsonValue doc;
+        Y_ENSURE(NJson::ReadJsonTree(resp, &doc), "Invalid json from tvm-api: " << resp);
+        const NJson::TJsonValue* currentResp = doc.IsMap() ? &doc : nullptr;
+        auto find = [&currentResp, &doc](TTvmId id, NJson::TJsonValue& obj) -> bool {
+            const TString idStr = IntToString<10>(id);
+            if (currentResp && currentResp->GetValue(idStr, &obj)) {
+                return true;
+            }
+
+            for (const NJson::TJsonValue& val : doc.GetArray()) {
+                currentResp = &val;
+                if (currentResp->GetValue(idStr, &obj)) {
+                    return true;
+                }
+            }
+
+            return false;
+        };
+
+        for (const TClientSettings::TDst& d : dsts) {
+            NJson::TJsonValue obj;
+            NJson::TJsonValue val;
+
+            if (!find(d.Id, obj) || !obj.GetValue("ticket", &val)) {
+                TString err;
+                if (obj.GetValue("error", &val)) {
+                    err = val.GetString();
+                } else {
+                    err = "Missing tvm_id in response, should never happend: " + IntToString<10>(d.Id);
+                }
+
+                TStringStream s;
+                s << "Failed to get ServiceTicket for " << d.Id << ": " << err;
+                ProcessError(EType::NonRetriable, EScope::ServiceTickets, s.Str());
+
+                out.Errors.insert({d.Id, std::move(err)});
+                continue;
+            }
+
+            out.Tickets.insert({d.Id, val.GetString()});
+        }
+    }
+
+    void TThreadedUpdater::ParseTicketsFromDiskCache(TStringBuf cache,
+                                                     TPairTicketsErrors& out) const {
+        NJson::TJsonValue doc;
+        Y_ENSURE(NJson::ReadJsonTree(cache, &doc), "Invalid json from disk: " << cache);
+
+        for (const NJson::TJsonValue& cacheItem : doc.GetArray()) {
+            for (const auto& [idStr, resp] : cacheItem.GetMap()) {
+                NJson::TJsonValue val;
+                TTvmId id;
+                if (!TryIntFromString<10, TTvmId, TString>(idStr, id)) {
+                    LogWarning(TStringBuilder() << "tvm_id in cache is not integer: " << idStr);
+                    continue;
+                }
+
+                if (resp.GetValue("ticket", &val)) {
+                    out.Tickets[id] = val.GetString();
+                } else if (resp.GetValue("error", &val)) {
+                    out.Errors[id] = val.GetString();
+                } else {
+                    out.Errors[id] = "tvm_id found, but response has no error or ticket, should never happend: " + idStr;
+                }
+            }
+        }
+    }
+
+    static const char DELIMETER = '\t';
+    TString TThreadedUpdater::PrepareTicketsForDisk(TStringBuf tvmResponse, TTvmId selfId) {
+        TStringStream s;
+        s << tvmResponse << DELIMETER << selfId;
+        return s.Str();
+    }
+
+    std::pair<TStringBuf, TTvmId> TThreadedUpdater::ParseTicketsFromDisk(TStringBuf data) {
+        TStringBuf tvmId = data.RNextTok(DELIMETER);
+        return {data, IntFromString<TTvmId, 10>(tvmId)};
+    }
+
+    TDstSetPtr TThreadedUpdater::GetDsts() const {
+        return Destinations_.Get();
+    }
+
+    void TThreadedUpdater::SetDsts(TDstSetPtr dsts) {
+        Destinations_.Set(std::move(dsts));
+    }
+
+    bool TThreadedUpdater::IsTimeToUpdateServiceTickets(TInstant lastUpdate) const {
+        return TInstant::Now() - lastUpdate > ServiceTicketsDurations_.RefreshPeriod;
+    }
+
+    bool TThreadedUpdater::IsTimeToUpdatePublicKeys(TInstant lastUpdate) const {
+        return TInstant::Now() - lastUpdate > PublicKeysDurations_.RefreshPeriod;
+    }
+
+    bool TThreadedUpdater::AreServicesTicketsOk() const {
+        if (!Settings_.IsServiceTicketFetchingRequired()) {
+            return true;
+        }
+        auto c = GetCachedServiceTickets();
+        return c && (!Settings_.IsIncompleteTicketsSetAnError || c->TicketsById.size() == GetDsts()->size());
+    }
+
+    bool TThreadedUpdater::IsServiceContextOk() const {
+        if (!Settings_.CheckServiceTickets) {
+            return true;
+        }
+
+        return bool(GetCachedServiceContext());
+    }
+
+    bool TThreadedUpdater::IsUserContextOk() const {
+        if (!Settings_.CheckUserTicketsWithBbEnv) {
+            return true;
+        }
+        return bool(GetCachedUserContext());
+    }
+
+    void TThreadedUpdater::Worker() {
+        if (IsInited()) {
+            UpdateServiceTickets();
+            UpdatePublicKeys();
+            UpdateRoles();
+        } else {
+            try {
+                Init();
+            } catch (const TRetriableException& e) {
+                // Still not initialized
+            } catch (const std::exception& e) {
+                // Can't retry, so we mark client as initialized and now GetStatus() will return TClientStatus::Error
+                SetInited(true);
+            }
+        }
+    }
+
+    TServiceTickets::TMapAliasId TThreadedUpdater::MakeAliasMap(const TClientSettings& settings) {
+        TServiceTickets::TMapAliasId res;
+
+        for (const auto& pair : settings.FetchServiceTicketsForDstsWithAliases) {
+            res.insert({pair.first, pair.second.Id});
+        }
+
+        return res;
+    }
+
+    TClientSettings::TDstVector TThreadedUpdater::FindMissingDsts(TServiceTicketsPtr available, const TDstSet& required) {
+        Y_ENSURE(available);
+        TDstSet set;
+        // available->TicketsById is not sorted
+        for (const auto& pair : available->TicketsById) {
+            set.insert(pair.first);
+        }
+        return FindMissingDsts(set, required);
+    }
+
+    TClientSettings::TDstVector TThreadedUpdater::FindMissingDsts(const TDstSet& available, const TDstSet& required) {
+        TClientSettings::TDstVector res;
+        std::set_difference(required.begin(), required.end(),
+                            available.begin(), available.end(),
+                            std::inserter(res, res.begin()));
+        return res;
+    }
+
+    TString TThreadedUpdater::CreateJsonArray(const TSmallVec<TString>& responses) {
+        if (responses.empty()) {
+            return "[]";
+        }
+
+        size_t size = 0;
+        for (const TString& r : responses) {
+            size += r.size() + 1;
+        }
+
+        TString res;
+        res.reserve(size + 2);
+
+        res.push_back('[');
+        for (const TString& r : responses) {
+            res.append(r).push_back(',');
+        }
+        res.back() = ']';
+
+        return res;
+    }
+
+    TString TThreadedUpdater::AppendToJsonArray(const TString& json, const TSmallVec<TString>& responses) {
+        Y_ENSURE(json, "previous body required");
+
+        size_t size = 0;
+        for (const TString& r : responses) {
+            size += r.size() + 1;
+        }
+
+        TString res;
+        res.reserve(size + 2 + json.size());
+
+        res.push_back('[');
+        if (json.StartsWith('[')) {
+            Y_ENSURE(json.EndsWith(']'), "array is broken:" << json);
+            res.append(TStringBuf(json).Chop(1).Skip(1));
+        } else {
+            res.append(json);
+        }
+
+        res.push_back(',');
+        for (const TString& r : responses) {
+            res.append(r).push_back(',');
+        }
+        res.back() = ']';
+
+        return res;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/api/threaded_updater.h b/library/cpp/tvmauth/client/misc/api/threaded_updater.h
new file mode 100644
index 0000000000..8fd68ee678
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/api/threaded_updater.h
@@ -0,0 +1,155 @@
+#pragma once
+
+#include "retry_settings.h"
+#include "roles_fetcher.h"
+#include "settings.h"
+
+#include <library/cpp/tvmauth/client/misc/async_updater.h>
+#include <library/cpp/tvmauth/client/misc/threaded_updater.h>
+
+#include <util/generic/set.h>
+#include <util/random/fast.h>
+
+#include <mutex>
+
+namespace NTvmAuth::NTvmApi {
+    using TDstSet = TSet<TClientSettings::TDst>;
+    using TDstSetPtr = std::shared_ptr<const TDstSet>;
+
+    class TThreadedUpdater: public TThreadedUpdaterBase {
+    public:
+        /*!
+         * Starts thread for updating of in-memory cache in background
+         * Reads cache from disk if specified
+         * @param settings
+         * @param logger is usefull for monitoring and debuging
+         */
+        static TAsyncUpdaterPtr Create(const TClientSettings& settings, TLoggerPtr logger);
+        ~TThreadedUpdater();
+
+        TClientStatus GetStatus() const override;
+        TString GetServiceTicketFor(const TClientSettings::TAlias& dst) const override;
+        TString GetServiceTicketFor(const TTvmId dst) const override;
+        TCheckedServiceTicket CheckServiceTicket(TStringBuf ticket, const TServiceContext::TCheckFlags& flags = TServiceContext::TCheckFlags{}) const override;
+        TCheckedUserTicket CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overrideEnv = {}) const override;
+        NRoles::TRolesPtr GetRoles() const override;
+
+    protected: // for tests
+        TClientStatus::ECode GetState() const;
+
+        TThreadedUpdater(const TClientSettings& settings, TLoggerPtr logger);
+        void Init();
+
+        void UpdateServiceTickets();
+        void UpdateAllServiceTickets();
+        TServiceTicketsPtr UpdateMissingServiceTickets(const TDstSet& required);
+        void UpdatePublicKeys();
+        void UpdateRoles();
+
+        TServiceTicketsPtr UpdateServiceTicketsCachePartly(TPairTicketsErrors&& tickets, size_t got);
+        void UpdateServiceTicketsCache(TPairTicketsErrors&& tickets, TInstant time);
+        void UpdatePublicKeysCache(const TString& publicKeys, TInstant time);
+
+        void ReadStateFromDisk();
+
+        struct TServiceTicketsFromDisk {
+            TPairTicketsErrors TicketsWithErrors;
+            TInstant BornDate;
+            TString FileBody;
+        };
+
+        std::pair<TServiceTicketsFromDisk, TServiceTicketsFromDisk> ReadServiceTicketsFromDisk() const;
+
+        std::pair<TString, TInstant> ReadPublicKeysFromDisk() const;
+        TString ReadRetrySettingsFromDisk() const;
+
+        struct THttpResult {
+            TPairTicketsErrors TicketsWithErrors;
+            TSmallVec<TString> Responses;
+        };
+
+        template <class Dsts>
+        THttpResult GetServiceTicketsFromHttp(const Dsts& dsts, const size_t dstLimit) const;
+        TString GetPublicKeysFromHttp() const;
+        TServiceTickets::TMapIdStr GetRequestedTicketsFromStartUpCache(const TDstSet& dsts) const;
+
+        virtual NUtils::TFetchResult FetchServiceTicketsFromHttp(const TString& body) const;
+        virtual NUtils::TFetchResult FetchPublicKeysFromHttp() const;
+
+        bool UpdateRetrySettings(const TString& header) const;
+
+        template <typename Func>
+        NUtils::TFetchResult FetchWithRetries(Func func, EScope scope) const;
+        void RandomSleep() const;
+
+        static TString PrepareRequestForServiceTickets(TTvmId src,
+                                                       const TServiceContext& ctx,
+                                                       const TClientSettings::TDstVector& dsts,
+                                                       const NUtils::TProcInfo& procInfo,
+                                                       time_t now = time(nullptr));
+        template <class Dsts>
+        void ParseTicketsFromResponse(TStringBuf resp,
+                                      const Dsts& dsts,
+                                      TPairTicketsErrors& out) const;
+
+        void ParseTicketsFromDiskCache(TStringBuf cache,
+                                       TPairTicketsErrors& out) const;
+
+        static TString PrepareTicketsForDisk(TStringBuf tvmResponse, TTvmId selfId);
+        static std::pair<TStringBuf, TTvmId> ParseTicketsFromDisk(TStringBuf data);
+
+        TDstSetPtr GetDsts() const;
+        void SetDsts(TDstSetPtr dsts);
+
+        TInstant GetStartUpCacheBornDate() const;
+
+        bool IsTimeToUpdateServiceTickets(TInstant lastUpdate) const;
+        bool IsTimeToUpdatePublicKeys(TInstant lastUpdate) const;
+
+        bool AreServicesTicketsOk() const;
+        bool IsServiceContextOk() const;
+        bool IsUserContextOk() const;
+
+        void Worker() override;
+
+        static TServiceTickets::TMapAliasId MakeAliasMap(const TClientSettings& settings);
+        static TClientSettings::TDstVector FindMissingDsts(TServiceTicketsPtr available, const TDstSet& required);
+        static TClientSettings::TDstVector FindMissingDsts(const TDstSet& available, const TDstSet& required);
+
+        static TString CreateJsonArray(const TSmallVec<TString>& responses);
+        static TString AppendToJsonArray(const TString& json, const TSmallVec<TString>& responses);
+
+    private:
+        TRetrySettings RetrySettings_;
+
+    protected:
+        mutable TExponentialBackoff ExpBackoff_;
+        std::unique_ptr<std::mutex> ServiceTicketBatchUpdateMutex_;
+
+    private:
+        const TClientSettings Settings_;
+
+        const NUtils::TProcInfo ProcInfo_;
+
+        const TString PublicKeysUrl_;
+
+        const TServiceTickets::TMapAliasId DstAliases_;
+
+        const TKeepAliveHttpClient::THeaders Headers_;
+        TMaybe<TServiceContext> SigningContext_;
+
+        NUtils::TProtectedValue<TDstSetPtr> Destinations_;
+
+        TString DiskCacheServiceTickets_;
+        TServiceTicketsFromDisk StartUpCache_;
+        bool NeedFetchMissingServiceTickets_ = true;
+
+        TString PublicKeysFilepath_;
+        TString ServiceTicketsFilepath_;
+        TString RetrySettingsFilepath_;
+
+        std::unique_ptr<TRolesFetcher> RolesFetcher_;
+
+        mutable TReallyFastRng32 Random_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/async_updater.cpp b/library/cpp/tvmauth/client/misc/async_updater.cpp
new file mode 100644
index 0000000000..670033c684
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/async_updater.cpp
@@ -0,0 +1,180 @@
+#include "async_updater.h"
+
+#include "utils.h"
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <util/string/builder.h>
+#include <util/system/spin_wait.h>
+
+namespace NTvmAuth {
+    TAsyncUpdaterBase::TAsyncUpdaterBase() {
+        ServiceTicketsDurations_.RefreshPeriod = TDuration::Hours(1);
+        ServiceTicketsDurations_.Expiring = TDuration::Hours(2);
+        ServiceTicketsDurations_.Invalid = TDuration::Hours(11);
+
+        PublicKeysDurations_.RefreshPeriod = TDuration::Days(1);
+        PublicKeysDurations_.Expiring = TDuration::Days(2);
+        PublicKeysDurations_.Invalid = TDuration::Days(6);
+    }
+
+    NRoles::TRolesPtr TAsyncUpdaterBase::GetRoles() const {
+        ythrow TIllegalUsage() << "not implemented";
+    }
+
+    TString TAsyncUpdaterBase::GetServiceTicketFor(const TClientSettings::TAlias& dst) const {
+        Y_UNUSED(dst);
+        ythrow TIllegalUsage() << "not implemented";
+    }
+
+    TString TAsyncUpdaterBase::GetServiceTicketFor(const TTvmId dst) const {
+        Y_UNUSED(dst);
+        ythrow TIllegalUsage() << "not implemented";
+    }
+
+    TCheckedServiceTicket TAsyncUpdaterBase::CheckServiceTicket(TStringBuf ticket, const TServiceContext::TCheckFlags& flags) const {
+        Y_UNUSED(ticket, flags);
+        ythrow TIllegalUsage() << "not implemented";
+    }
+
+    TCheckedUserTicket TAsyncUpdaterBase::CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overrideEnv) const {
+        Y_UNUSED(ticket, overrideEnv);
+        ythrow TIllegalUsage() << "not implemented";
+    }
+
+    TInstant TAsyncUpdaterBase::GetUpdateTimeOfPublicKeys() const {
+        return PublicKeysTime_.Get();
+    }
+
+    TInstant TAsyncUpdaterBase::GetUpdateTimeOfServiceTickets() const {
+        return ServiceTicketsTime_.Get();
+    }
+
+    TInstant TAsyncUpdaterBase::GetUpdateTimeOfRoles() const {
+        return RolesTime_.Get();
+    }
+
+    TInstant TAsyncUpdaterBase::GetInvalidationTimeOfPublicKeys() const {
+        TInstant ins = GetUpdateTimeOfPublicKeys();
+        return ins == TInstant() ? TInstant() : ins + PublicKeysDurations_.Invalid;
+    }
+
+    TInstant TAsyncUpdaterBase::GetInvalidationTimeOfServiceTickets() const {
+        TServiceTicketsPtr c = GetCachedServiceTickets();
+        return c ? c->InvalidationTime : TInstant();
+    }
+
+    bool TAsyncUpdaterBase::ArePublicKeysInvalid(TInstant now) const {
+        return IsInvalid(GetInvalidationTimeOfPublicKeys(), now);
+    }
+
+    bool TAsyncUpdaterBase::AreServiceTicketsInvalid(TInstant now) const {
+        TServiceTicketsPtr c = GetCachedServiceTickets();
+        // Empty set of tickets is allways valid.
+        return c && !c->TicketsById.empty() && IsInvalid(GetInvalidationTimeOfServiceTickets(), now);
+    }
+
+    bool TAsyncUpdaterBase::IsInvalid(TInstant invTime, TInstant now) {
+        return invTime -
+                   TDuration::Minutes(1) // lag for closing from balancer
+               < now;
+    }
+
+    void TAsyncUpdaterBase::SetBbEnv(EBlackboxEnv original, TMaybe<EBlackboxEnv> overrided) {
+        if (overrided) {
+            Y_ENSURE_EX(NUtils::CheckBbEnvOverriding(original, *overrided),
+                        TBrokenTvmClientSettings() << "Overriding of BlackboxEnv is illegal: "
+                                                   << original << " -> " << *overrided);
+        }
+
+        Envs_.store({original, overrided}, std::memory_order_relaxed);
+    }
+
+    TServiceTicketsPtr TAsyncUpdaterBase::GetCachedServiceTickets() const {
+        return ServiceTickets_.Get();
+    }
+
+    TServiceContextPtr TAsyncUpdaterBase::GetCachedServiceContext() const {
+        return ServiceContext_.Get();
+    }
+
+    TUserContextPtr TAsyncUpdaterBase::GetCachedUserContext(TMaybe<EBlackboxEnv> overridenEnv) const {
+        TAllUserContextsPtr ctx = AllUserContexts_.Get();
+        if (!ctx) {
+            return nullptr;
+        }
+
+        const TEnvs envs = Envs_.load(std::memory_order_relaxed);
+        if (!envs.Original) {
+            return nullptr;
+        }
+
+        EBlackboxEnv env = *envs.Original;
+
+        if (overridenEnv) {
+            Y_ENSURE_EX(NUtils::CheckBbEnvOverriding(*envs.Original, *overridenEnv),
+                        TBrokenTvmClientSettings() << "Overriding of BlackboxEnv is illegal: "
+                                                   << *envs.Original << " -> " << *overridenEnv);
+            env = *overridenEnv;
+        } else if (envs.Overrided) {
+            env = *envs.Overrided;
+        }
+
+        return ctx->Get(env);
+    }
+
+    void TAsyncUpdaterBase::SetServiceTickets(TServiceTicketsPtr c) {
+        ServiceTickets_.Set(std::move(c));
+    }
+
+    void TAsyncUpdaterBase::SetServiceContext(TServiceContextPtr c) {
+        ServiceContext_.Set(std::move(c));
+    }
+
+    void TAsyncUpdaterBase::SetUserContext(TStringBuf publicKeys) {
+        AllUserContexts_.Set(MakeIntrusiveConst<TAllUserContexts>(publicKeys));
+    }
+
+    void TAsyncUpdaterBase::SetUpdateTimeOfPublicKeys(TInstant ins) {
+        PublicKeysTime_.Set(ins);
+    }
+
+    void TAsyncUpdaterBase::SetUpdateTimeOfServiceTickets(TInstant ins) {
+        ServiceTicketsTime_.Set(ins);
+    }
+
+    void TAsyncUpdaterBase::SetUpdateTimeOfRoles(TInstant ins) {
+        RolesTime_.Set(ins);
+    }
+
+    void TAsyncUpdaterBase::SetInited(bool value) {
+        Inited_.store(value, std::memory_order_relaxed);
+    }
+
+    bool TAsyncUpdaterBase::IsInited() const {
+        return Inited_.load(std::memory_order_relaxed);
+    }
+
+    bool TAsyncUpdaterBase::IsServiceTicketMapOk(TServiceTicketsPtr c, size_t expectedTicketCount, bool strict) {
+        return c &&
+               (strict
+                    ? c->TicketsById.size() == expectedTicketCount
+                    : !c->TicketsById.empty());
+    }
+
+    TAllUserContexts::TAllUserContexts(TStringBuf publicKeys) {
+        auto add = [&, this](EBlackboxEnv env) {
+            Ctx_[(size_t)env] = MakeIntrusiveConst<TUserContext>(env, publicKeys);
+        };
+
+        add(EBlackboxEnv::Prod);
+        add(EBlackboxEnv::Test);
+        add(EBlackboxEnv::ProdYateam);
+        add(EBlackboxEnv::TestYateam);
+        add(EBlackboxEnv::Stress);
+    }
+
+    TUserContextPtr TAllUserContexts::Get(EBlackboxEnv env) const {
+        return Ctx_[(size_t)env];
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/async_updater.h b/library/cpp/tvmauth/client/misc/async_updater.h
new file mode 100644
index 0000000000..0c0e81ccac
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/async_updater.h
@@ -0,0 +1,123 @@
+#pragma once
+
+#include "last_error.h"
+#include "service_tickets.h"
+#include "settings.h"
+#include "roles/roles.h"
+
+#include <library/cpp/tvmauth/client/client_status.h>
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <library/cpp/tvmauth/deprecated/service_context.h>
+#include <library/cpp/tvmauth/deprecated/user_context.h>
+#include <library/cpp/tvmauth/src/utils.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/hash.h>
+#include <util/generic/maybe.h>
+#include <util/generic/noncopyable.h>
+#include <util/generic/ptr.h>
+
+#include <array>
+#include <atomic>
+
+namespace NTvmAuth {
+
+    class TAllUserContexts: public TAtomicRefCount<TAllUserContexts> {
+    public:
+        TAllUserContexts(TStringBuf publicKeys);
+
+        TUserContextPtr Get(EBlackboxEnv env) const;
+
+    private:
+        std::array<TUserContextPtr, 5> Ctx_;
+    };
+    using TAllUserContextsPtr = TIntrusiveConstPtr<TAllUserContexts>;
+
+    class TAsyncUpdaterBase: public TAtomicRefCount<TAsyncUpdaterBase>, protected TLastError, TNonCopyable {
+    public:
+        TAsyncUpdaterBase();
+        virtual ~TAsyncUpdaterBase() = default;
+
+        virtual TClientStatus GetStatus() const = 0;
+        virtual TString GetServiceTicketFor(const TClientSettings::TAlias& dst) const;
+        virtual TString GetServiceTicketFor(const TTvmId dst) const;
+        virtual TCheckedServiceTicket CheckServiceTicket(TStringBuf ticket, const TServiceContext::TCheckFlags& flags = TServiceContext::TCheckFlags{}) const;
+        virtual TCheckedUserTicket CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overrideEnv = {}) const;
+        virtual NRoles::TRolesPtr GetRoles() const;
+
+        TServiceTicketsPtr GetCachedServiceTickets() const;
+        TServiceContextPtr GetCachedServiceContext() const;
+        TUserContextPtr GetCachedUserContext(TMaybe<EBlackboxEnv> overridenEnv = {}) const;
+
+        TInstant GetUpdateTimeOfPublicKeys() const;
+        TInstant GetUpdateTimeOfServiceTickets() const;
+        TInstant GetUpdateTimeOfRoles() const;
+        TInstant GetInvalidationTimeOfPublicKeys() const;
+        TInstant GetInvalidationTimeOfServiceTickets() const;
+
+        bool ArePublicKeysInvalid(TInstant now) const;
+        bool AreServiceTicketsInvalid(TInstant now) const;
+        static bool IsInvalid(TInstant invTime, TInstant now);
+
+    protected:
+        void SetBbEnv(EBlackboxEnv original, TMaybe<EBlackboxEnv> overrided = {});
+
+        void SetServiceTickets(TServiceTicketsPtr c);
+        void SetServiceContext(TServiceContextPtr c);
+        void SetUserContext(TStringBuf publicKeys);
+        void SetUpdateTimeOfPublicKeys(TInstant ins);
+        void SetUpdateTimeOfServiceTickets(TInstant ins);
+        void SetUpdateTimeOfRoles(TInstant ins);
+
+        void SetInited(bool value);
+        bool IsInited() const;
+
+        static bool IsServiceTicketMapOk(TServiceTicketsPtr c, size_t expectedTicketCount, bool strict);
+
+    protected:
+        struct TPairTicketsErrors {
+            TServiceTickets::TMapIdStr Tickets;
+            TServiceTickets::TMapIdStr Errors;
+
+            bool operator==(const TPairTicketsErrors& o) const {
+                return Tickets == o.Tickets && Errors == o.Errors;
+            }
+        };
+
+        struct TStateDurations {
+            TDuration RefreshPeriod;
+            TDuration Expiring;
+            TDuration Invalid;
+        };
+
+        TStateDurations ServiceTicketsDurations_;
+        TStateDurations PublicKeysDurations_;
+
+    protected:
+        virtual void StartTvmClientStopping() const {
+        }
+        virtual bool IsTvmClientStopped() const {
+            return true;
+        }
+        friend class NTvmAuth::NInternal::TClientCaningKnife;
+
+    private:
+        struct TEnvs {
+            TMaybe<EBlackboxEnv> Original;
+            TMaybe<EBlackboxEnv> Overrided;
+        };
+        static_assert(sizeof(TEnvs) <= 8, "Small struct is easy to store as atomic");
+        std::atomic<TEnvs> Envs_ = {{}};
+
+        NUtils::TProtectedValue<TServiceTicketsPtr> ServiceTickets_;
+        NUtils::TProtectedValue<TServiceContextPtr> ServiceContext_;
+        NUtils::TProtectedValue<TAllUserContextsPtr> AllUserContexts_;
+        NUtils::TProtectedValue<TInstant> PublicKeysTime_;
+        NUtils::TProtectedValue<TInstant> ServiceTicketsTime_;
+        NUtils::TProtectedValue<TInstant> RolesTime_;
+
+        std::atomic_bool Inited_{false};
+    };
+    using TAsyncUpdaterPtr = TIntrusiveConstPtr<TAsyncUpdaterBase>;
+}
diff --git a/library/cpp/tvmauth/client/misc/checker.h b/library/cpp/tvmauth/client/misc/checker.h
new file mode 100644
index 0000000000..16f1a95200
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/checker.h
@@ -0,0 +1,38 @@
+#pragma once
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <library/cpp/tvmauth/checked_service_ticket.h>
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+#include <library/cpp/tvmauth/deprecated/service_context.h>
+#include <library/cpp/tvmauth/deprecated/user_context.h>
+
+namespace NTvmAuth {
+    class TServiceTicketChecker {
+    public:
+        /*!
+         * Checking must be enabled in TClientSettings
+         * Can throw exception if cache is out of date or wrong config
+         * @param ticket
+         */
+        static TCheckedServiceTicket Check(
+            TStringBuf ticket,
+            TServiceContextPtr c,
+            const TServiceContext::TCheckFlags& flags = {}) {
+            Y_ENSURE_EX(c, TBrokenTvmClientSettings() << "Need to use TClientSettings::EnableServiceTicketChecking()");
+            return c->Check(ticket, flags);
+        }
+    };
+
+    class TUserTicketChecker {
+    public:
+        /*!
+         * Blackbox enviroment must be cofingured in TClientSettings
+         * Can throw exception if cache is out of date or wrong config
+         */
+        static TCheckedUserTicket Check(TStringBuf ticket, TUserContextPtr c) {
+            Y_ENSURE_EX(c, TBrokenTvmClientSettings() << "Need to use TClientSettings::EnableUserTicketChecking()");
+            return c->Check(ticket);
+        }
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/default_uid_checker.h b/library/cpp/tvmauth/client/misc/default_uid_checker.h
new file mode 100644
index 0000000000..b723d6e918
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/default_uid_checker.h
@@ -0,0 +1,31 @@
+#pragma once
+
+#include "roles/roles.h"
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+#include <library/cpp/tvmauth/src/user_impl.h>
+#include <library/cpp/tvmauth/src/utils.h>
+
+namespace NTvmAuth {
+    class TDefaultUidChecker {
+    public:
+        /*!
+         * Checking must be enabled in TClientSettings
+         * Can throw exception if cache is out of date or wrong config
+         * @param ticket
+         */
+        static TCheckedUserTicket Check(TCheckedUserTicket ticket, NRoles::TRolesPtr r) {
+            Y_ENSURE_EX(r, TBrokenTvmClientSettings() << "Need to use TClientSettings::EnableRolesFetching()");
+            NRoles::TConsumerRolesPtr roles = r->GetRolesForUser(ticket);
+            if (roles) {
+                return ticket;
+            }
+
+            TUserTicketImplPtr impl = THolder(NInternal::TCanningKnife::GetU(ticket));
+            impl->SetStatus(ETicketStatus::NoRoles);
+            return TCheckedUserTicket(std::move(impl));
+        }
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/disk_cache.cpp b/library/cpp/tvmauth/client/misc/disk_cache.cpp
new file mode 100644
index 0000000000..8f3ab7770f
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/disk_cache.cpp
@@ -0,0 +1,162 @@
+#include "disk_cache.h"
+
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <openssl/evp.h>
+#include <openssl/hmac.h>
+
+#include <util/stream/file.h>
+#include <util/stream/str.h>
+#include <util/system/fs.h>
+#include <util/system/sysstat.h>
+
+#include <exception>
+
+namespace NTvmAuth {
+    static const size_t HASH_SIZE = 32;
+    static const size_t TIMESTAMP_SIZE = sizeof(time_t);
+
+    TDiskReader::TDiskReader(const TString& filename, ILogger* logger)
+        : Filename_(filename)
+        , Logger_(logger)
+    {
+    }
+
+    bool TDiskReader::Read() {
+        TStringStream s;
+
+        try {
+            if (!NFs::Exists(Filename_)) {
+                if (Logger_) {
+                    s << "File '" << Filename_ << "' does not exist";
+                    Logger_->Debug(s.Str());
+                }
+                return false;
+            }
+
+            TFile file(Filename_, OpenExisting | RdOnly | Seq);
+            file.Flock(LOCK_SH | LOCK_NB);
+
+            TFileInput input(file);
+            return ParseData(input.ReadAll());
+        } catch (const std::exception& e) {
+            if (Logger_) {
+                s << "Failed to read '" << Filename_ << "': " << e.what();
+                Logger_->Error(s.Str());
+            }
+        }
+
+        return false;
+    }
+
+    bool TDiskReader::ParseData(TStringBuf buf) {
+        TStringStream s;
+
+        if (buf.size() <= HASH_SIZE + TIMESTAMP_SIZE) {
+            if (Logger_) {
+                s << "File '" << Filename_ << "' is too small";
+                Logger_->Warning(s.Str());
+            }
+            return false;
+        }
+
+        TStringBuf hash = buf.SubStr(0, HASH_SIZE);
+        if (hash != GetHash(buf.Skip(HASH_SIZE))) {
+            if (Logger_) {
+                s << "Content of '" << Filename_ << "' was incorrectly changed";
+                Logger_->Warning(s.Str());
+            }
+            return false;
+        }
+
+        Time_ = TInstant::Seconds(GetTimestamp(buf.substr(0, TIMESTAMP_SIZE)));
+        Data_ = buf.Skip(TIMESTAMP_SIZE);
+
+        if (Logger_) {
+            s << "File '" << Filename_ << "' was successfully read";
+            Logger_->Info(s.Str());
+        }
+        return true;
+    }
+
+    TString TDiskReader::GetHash(TStringBuf data) {
+        TString value(EVP_MAX_MD_SIZE, 0);
+        unsigned macLen = 0;
+        if (!::HMAC(EVP_sha256(),
+                    "",
+                    0,
+                    (unsigned char*)data.data(),
+                    data.size(),
+                    (unsigned char*)value.data(),
+                    &macLen)) {
+            return {};
+        }
+
+        if (macLen != EVP_MAX_MD_SIZE) {
+            value.resize(macLen);
+        }
+
+        return value;
+    }
+
+    time_t TDiskReader::GetTimestamp(TStringBuf data) {
+        time_t time = 0;
+        for (int idx = TIMESTAMP_SIZE - 1; idx >= 0; --idx) {
+            time <<= 8;
+            time |= static_cast<unsigned char>(data.at(idx));
+        }
+        return time;
+    }
+
+    TDiskWriter::TDiskWriter(const TString& filename, ILogger* logger)
+        : Filename_(filename)
+        , Logger_(logger)
+    {
+    }
+
+    bool TDiskWriter::Write(TStringBuf data, TInstant now) {
+        TStringStream s;
+
+        try {
+            {
+                if (NFs::Exists(Filename_)) {
+                    Chmod(Filename_.c_str(),
+                          S_IRUSR | S_IWUSR); // 600
+                }
+
+                TFile file(Filename_, CreateAlways | WrOnly | Seq | AWUser | ARUser);
+                file.Flock(LOCK_EX | LOCK_NB);
+
+                TFileOutput output(file);
+                output << PrepareData(now, data);
+            }
+
+            if (Logger_) {
+                s << "File '" << Filename_ << "' was successfully written";
+                Logger_->Info(s.Str());
+            }
+            return true;
+        } catch (const std::exception& e) {
+            if (Logger_) {
+                s << "Failed to write '" << Filename_ << "': " << e.what();
+                Logger_->Error(s.Str());
+            }
+        }
+
+        return false;
+    }
+
+    TString TDiskWriter::PrepareData(TInstant time, TStringBuf data) {
+        TString toHash = WriteTimestamp(time.TimeT()) + data;
+        return TDiskReader::GetHash(toHash) + toHash;
+    }
+
+    TString TDiskWriter::WriteTimestamp(time_t time) {
+        TString res(TIMESTAMP_SIZE, 0);
+        for (size_t idx = 0; idx < TIMESTAMP_SIZE; ++idx) {
+            res[idx] = time & 0xFF;
+            time >>= 8;
+        }
+        return res;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/disk_cache.h b/library/cpp/tvmauth/client/misc/disk_cache.h
new file mode 100644
index 0000000000..9e77556f86
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/disk_cache.h
@@ -0,0 +1,50 @@
+#pragma once
+
+#include <util/datetime/base.h>
+#include <util/generic/string.h>
+
+namespace NTvmAuth {
+    class ILogger;
+
+    class TDiskReader {
+    public:
+        TDiskReader(const TString& filename, ILogger* logger = nullptr);
+
+        bool Read();
+
+        const TString& Data() const {
+            return Data_;
+        }
+
+        TInstant Time() const {
+            return Time_;
+        }
+
+    public: // for tests
+        bool ParseData(TStringBuf buf);
+
+        static TString GetHash(TStringBuf data);
+        static time_t GetTimestamp(TStringBuf data);
+
+    private:
+        TString Filename_;
+        ILogger* Logger_;
+        TInstant Time_;
+        TString Data_;
+    };
+
+    class TDiskWriter {
+    public:
+        TDiskWriter(const TString& filename, ILogger* logger = nullptr);
+
+        bool Write(TStringBuf data, TInstant now = TInstant::Now());
+
+    public: // for tests
+        static TString PrepareData(TInstant time, TStringBuf data);
+        static TString WriteTimestamp(time_t time);
+
+    private:
+        TString Filename_;
+        ILogger* Logger_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/exponential_backoff.h b/library/cpp/tvmauth/client/misc/exponential_backoff.h
new file mode 100644
index 0000000000..89a7a3c8ad
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/exponential_backoff.h
@@ -0,0 +1,94 @@
+#pragma once
+
+#include <util/datetime/base.h>
+#include <util/random/normal.h>
+#include <util/system/event.h>
+
+#include <atomic>
+
+namespace NTvmAuth {
+    // https://habr.com/ru/post/227225/
+    class TExponentialBackoff {
+    public:
+        struct TSettings {
+            TDuration Min;
+            TDuration Max;
+            double Factor = 1.001;
+            double Jitter = 0;
+
+            bool operator==(const TSettings& o) const {
+                return Min == o.Min &&
+                       Max == o.Max &&
+                       Factor == o.Factor &&
+                       Jitter == o.Jitter;
+            }
+        };
+
+        TExponentialBackoff(const TSettings& settings, bool isEnabled = true)
+            : CurrentValue_(settings.Min)
+            , IsEnabled_(isEnabled)
+        {
+            UpdateSettings(settings);
+        }
+
+        void UpdateSettings(const TSettings& settings) {
+            Y_ENSURE(settings.Factor > 1, "factor=" << settings.Factor << ". Should be > 1");
+            Y_ENSURE(settings.Jitter >= 0 && settings.Jitter < 1, "jitter should be in range [0, 1)");
+
+            Min_ = settings.Min;
+            Max_ = settings.Max;
+            Factor_ = settings.Factor;
+            Jitter_ = settings.Jitter;
+        }
+
+        TDuration Increase() {
+            CurrentValue_ = std::min(CurrentValue_ * Factor_, Max_);
+
+            double rnd = StdNormalRandom<double>();
+            const bool isNegative = rnd < 0;
+            rnd = std::abs(rnd);
+
+            const TDuration diff = rnd * Jitter_ * CurrentValue_;
+            if (isNegative) {
+                CurrentValue_ -= diff;
+            } else {
+                CurrentValue_ += diff;
+            }
+
+            return CurrentValue_;
+        }
+
+        TDuration Decrease() {
+            CurrentValue_ = std::max(CurrentValue_ / Factor_, Min_);
+            return CurrentValue_;
+        }
+
+        void Sleep(TDuration add = TDuration()) {
+            if (IsEnabled_.load(std::memory_order_relaxed)) {
+                Ev_.WaitT(CurrentValue_ + add);
+            }
+        }
+
+        void Interrupt() {
+            Ev_.Signal();
+        }
+
+        TDuration GetCurrentValue() const {
+            return CurrentValue_;
+        }
+
+        void SetEnabled(bool val) {
+            IsEnabled_.store(val);
+        }
+
+    private:
+        TDuration Min_;
+        TDuration Max_;
+        double Factor_;
+        double Jitter_;
+        TDuration CurrentValue_;
+        std::atomic_bool IsEnabled_;
+
+        TAutoEvent Ev_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/fetch_result.h b/library/cpp/tvmauth/client/misc/fetch_result.h
new file mode 100644
index 0000000000..4b0774e92f
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/fetch_result.h
@@ -0,0 +1,13 @@
+#pragma once
+
+#include <library/cpp/http/simple/http_client.h>
+
+namespace NTvmAuth::NUtils {
+    struct TFetchResult {
+        TKeepAliveHttpClient::THttpCode Code;
+        THttpHeaders Headers;
+        TStringBuf Path;
+        TString Response;
+        TString RetrySettings;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/getter.h b/library/cpp/tvmauth/client/misc/getter.h
new file mode 100644
index 0000000000..6c7617b418
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/getter.h
@@ -0,0 +1,49 @@
+#pragma once
+
+#include "checker.h"
+#include "service_tickets.h"
+
+namespace NTvmAuth {
+    class TServiceTicketGetter {
+    public:
+        /*!
+         * Fetching must enabled in TClientSettings
+         * Can throw exception if cache is invalid or wrong config
+         * @param dst
+         */
+        static TString GetTicket(const TClientSettings::TAlias& dst, TServiceTicketsPtr c) {
+            Y_ENSURE_EX(c, TBrokenTvmClientSettings() << "Need to use TClientSettings::EnableServiceTicketsFetchOptions()");
+            return GetTicketImpl(dst, c->TicketsByAlias, c->ErrorsByAlias, c->UnfetchedAliases);
+        }
+
+        static TString GetTicket(const TTvmId dst, TServiceTicketsPtr c) {
+            Y_ENSURE_EX(c, TBrokenTvmClientSettings() << "Need to use TClientSettings::EnableServiceTicketsFetchOptions()");
+            return GetTicketImpl(dst, c->TicketsById, c->ErrorsById, c->UnfetchedIds);
+        }
+
+    private:
+        template <class Key, class Cont, class UnfetchedCont>
+        static TString GetTicketImpl(const Key& dst, const Cont& tickets, const Cont& errors, const UnfetchedCont& unfetched) {
+            auto it = tickets.find(dst);
+            if (it != tickets.end()) {
+                return it->second;
+            }
+
+            it = errors.find(dst);
+            if (it != errors.end()) {
+                ythrow TMissingServiceTicket()
+                    << "Failed to get ticket for '" << dst << "': "
+                    << it->second;
+            }
+
+            if (unfetched.contains(dst)) {
+                ythrow TMissingServiceTicket()
+                    << "Failed to get ticket for '" << dst << "': this dst was not fetched yet.";
+            }
+
+            ythrow TBrokenTvmClientSettings()
+                << "Destination '" << dst << "' was not specified in settings. "
+                << "Check your settings (if you use Qloud/YP/tvmtool - check it's settings)";
+        }
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/last_error.cpp b/library/cpp/tvmauth/client/misc/last_error.cpp
new file mode 100644
index 0000000000..a5054b0342
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/last_error.cpp
@@ -0,0 +1,115 @@
+#include "last_error.h"
+
+#include <util/string/builder.h>
+
+namespace NTvmAuth {
+    TLastError::TLastError()
+        : LastErrors_(MakeIntrusiveConst<TLastErrors>())
+    {
+    }
+
+    TString TLastError::GetLastError(bool isOk, EType* type) const {
+        if (isOk) {
+            return OK_;
+        }
+
+        const TLastErrorsPtr ptr = LastErrors_.Get();
+
+        for (const TLastErr& err : ptr->Errors) {
+            if (err && err->first == EType::NonRetriable) {
+                if (type) {
+                    *type = EType::NonRetriable;
+                }
+                return err->second;
+            }
+        }
+
+        for (const TLastErr& err : ptr->Errors) {
+            if (err) {
+                if (type) {
+                    *type = EType::Retriable;
+                }
+                return err->second;
+            }
+        }
+
+        if (type) {
+            *type = EType::NonRetriable;
+        }
+        return "Internal client error: failed to collect last useful error message, please report this message to tvm-dev@yandex-team.ru";
+    }
+
+    TString TLastError::ProcessHttpError(TLastError::EScope scope,
+                                         TStringBuf path,
+                                         int code,
+                                         const TString& msg) const {
+        TString err = TStringBuilder() << "Path:" << path << ".Code=" << code << ": " << msg;
+
+        ProcessError(code >= 400 && code < 500 ? EType::NonRetriable
+                                               : EType::Retriable,
+                     scope,
+                     err);
+
+        return err;
+    }
+
+    void TLastError::ProcessError(TLastError::EType type, TLastError::EScope scope, const TStringBuf msg) const {
+        Update(scope, [&](TLastErr& lastError) {
+            if (lastError && lastError->first == EType::NonRetriable && type == EType::Retriable) {
+                return false;
+            }
+
+            TString err = TStringBuilder() << scope << ": " << msg;
+            err.erase(std::remove(err.begin(), err.vend(), '\r'), err.vend());
+            std::replace(err.begin(), err.vend(), '\n', ' ');
+
+            lastError = {type, std::move(err)};
+            return true;
+        });
+    }
+
+    void TLastError::ClearError(TLastError::EScope scope) {
+        Update(scope, [&](TLastErr& lastError) {
+            if (!lastError) {
+                return false;
+            }
+
+            lastError.Clear();
+            return true;
+        });
+    }
+
+    void TLastError::ClearErrors() {
+        for (size_t idx = 0; idx < (size_t)EScope::COUNT; ++idx) {
+            ClearError((EScope)idx);
+        }
+    }
+
+    void TLastError::ThrowLastError() {
+        EType type;
+        TString err = GetLastError(false, &type);
+
+        switch (type) {
+            case EType::NonRetriable:
+                ythrow TNonRetriableException()
+                    << "Failed to start TvmClient. Do not retry: "
+                    << err;
+            case EType::Retriable:
+                ythrow TRetriableException()
+                    << "Failed to start TvmClient. You can retry: "
+                    << err;
+        }
+    }
+
+    template <typename Func>
+    void TLastError::Update(TLastError::EScope scope, Func func) const {
+        Y_ABORT_UNLESS(scope != EScope::COUNT);
+
+        TLastErrors errs = *LastErrors_.Get();
+        TLastErr& lastError = errs.Errors[(size_t)scope];
+
+        if (func(lastError)) {
+            LastErrors_.Set(MakeIntrusiveConst<TLastErrors>(std::move(errs)));
+        }
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/last_error.h b/library/cpp/tvmauth/client/misc/last_error.h
new file mode 100644
index 0000000000..b0ad33611f
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/last_error.h
@@ -0,0 +1,51 @@
+#pragma once
+
+#include "utils.h"
+
+#include <array>
+
+namespace NTvmAuth {
+    class TLastError {
+    public:
+        enum class EType {
+            NonRetriable,
+            Retriable,
+        };
+
+        enum class EScope {
+            ServiceTickets,
+            PublicKeys,
+            Roles,
+            TvmtoolConfig,
+
+            COUNT,
+        };
+
+        using TLastErr = TMaybe<std::pair<EType, TString>>;
+
+        struct TLastErrors: public TAtomicRefCount<TLastErrors> {
+            std::array<TLastErr, (int)EScope::COUNT> Errors;
+        };
+        using TLastErrorsPtr = TIntrusiveConstPtr<TLastErrors>;
+
+    public:
+        TLastError();
+
+        TString GetLastError(bool isOk, EType* type = nullptr) const;
+
+        TString ProcessHttpError(EScope scope, TStringBuf path, int code, const TString& msg) const;
+        void ProcessError(EType type, EScope scope, const TStringBuf msg) const;
+        void ClearError(EScope scope);
+        void ClearErrors();
+        void ThrowLastError();
+
+    private:
+        template <typename Func>
+        void Update(EScope scope, Func func) const;
+
+    private:
+        const TString OK_ = "OK";
+
+        mutable NUtils::TProtectedValue<TLastErrorsPtr> LastErrors_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/proc_info.cpp b/library/cpp/tvmauth/client/misc/proc_info.cpp
new file mode 100644
index 0000000000..e2e5ec15b9
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/proc_info.cpp
@@ -0,0 +1,53 @@
+#include "proc_info.h"
+
+#include <library/cpp/tvmauth/version.h>
+
+#include <library/cpp/string_utils/quote/quote.h>
+
+#include <util/stream/file.h>
+#include <util/string/cast.h>
+#include <util/system/getpid.h>
+
+namespace NTvmAuth::NUtils {
+    void TProcInfo::AddToRequest(IOutputStream& out) const {
+        out << "_pid=" << Pid;
+        if (ProcessName) {
+            out << "&_procces_name=" << *ProcessName;
+        }
+        out << "&lib_version=client_" << VersionPrefix << LibVersion();
+    }
+
+    TProcInfo TProcInfo::Create(const TString& versionPrefix) {
+        TProcInfo res;
+        res.Pid = IntToString<10>(GetPID());
+        res.ProcessName = GetProcessName();
+        res.VersionPrefix = versionPrefix;
+        return res;
+    }
+
+    std::optional<TString> TProcInfo::GetProcessName() {
+        try {
+            // works only for linux
+            TFileInput proc("/proc/self/status");
+
+            TString line;
+            while (proc.ReadLine(line)) {
+                TStringBuf buf(line);
+                if (!buf.SkipPrefix("Name:")) {
+                    continue;
+                }
+
+                while (buf && isspace(buf.front())) {
+                    buf.Skip(1);
+                }
+
+                TString res(buf);
+                CGIEscape(res);
+                return res;
+            }
+        } catch (...) {
+        }
+
+        return {};
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/proc_info.h b/library/cpp/tvmauth/client/misc/proc_info.h
new file mode 100644
index 0000000000..b1526e5c47
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/proc_info.h
@@ -0,0 +1,18 @@
+#pragma once
+
+#include <util/generic/string.h>
+
+#include <optional>
+
+namespace NTvmAuth::NUtils {
+    struct TProcInfo {
+        TString Pid;
+        std::optional<TString> ProcessName;
+        TString VersionPrefix;
+
+        void AddToRequest(IOutputStream& out) const;
+
+        static TProcInfo Create(const TString& versionPrefix);
+        static std::optional<TString> GetProcessName();
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/retry_settings/v1/settings.proto b/library/cpp/tvmauth/client/misc/retry_settings/v1/settings.proto
new file mode 100644
index 0000000000..ddf1648777
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/retry_settings/v1/settings.proto
@@ -0,0 +1,21 @@
+syntax = "proto2";
+
+package retry_settings.v1;
+
+option cc_enable_arenas = true;
+option go_package = "github.com/ydb-platform/ydb/library/cpp/tvmauth/client/misc/retry_settings/v1";
+
+message Settings {
+    optional uint32 exponential_backoff_min_sec = 1;
+    optional uint32 exponential_backoff_max_sec = 2;
+    optional double exponential_backoff_factor = 3;
+    optional double exponential_backoff_jitter = 4;
+    optional uint32 max_random_sleep_default = 5;
+    optional uint32 max_random_sleep_when_ok = 12;
+    optional uint32 retries_on_start = 6;
+    optional uint32 worker_awaking_period_sec = 7;
+    optional uint32 dsts_limit = 8;
+    optional uint32 retries_in_background = 9;
+    optional uint32 roles_update_period_sec = 10;
+    optional uint32 roles_warn_period_sec = 11;
+}
diff --git a/library/cpp/tvmauth/client/misc/retry_settings/v1/ya.make b/library/cpp/tvmauth/client/misc/retry_settings/v1/ya.make
new file mode 100644
index 0000000000..7ade82ac74
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/retry_settings/v1/ya.make
@@ -0,0 +1,13 @@
+PROTO_LIBRARY()
+
+EXCLUDE_TAGS(
+    JAVA_PROTO
+    PY_PROTO
+    PY3_PROTO
+)
+
+SRCS(
+    settings.proto
+)
+
+END()
diff --git a/library/cpp/tvmauth/client/misc/roles/decoder.cpp b/library/cpp/tvmauth/client/misc/roles/decoder.cpp
new file mode 100644
index 0000000000..6337fb91c2
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/decoder.cpp
@@ -0,0 +1,93 @@
+#include "decoder.h"
+
+#include <library/cpp/tvmauth/client/misc/utils.h>
+
+#include <library/cpp/openssl/crypto/sha.h>
+#include <library/cpp/streams/brotli/brotli.h>
+#include <library/cpp/streams/zstd/zstd.h>
+
+#include <util/generic/yexception.h>
+#include <util/stream/zlib.h>
+#include <util/string/ascii.h>
+
+namespace NTvmAuth::NRoles {
+    TString TDecoder::Decode(const TStringBuf codec, TString&& blob) {
+        if (codec.empty()) {
+            return std::move(blob);
+        }
+
+        const TCodecInfo info = ParseCodec(codec);
+        TString decoded = DecodeImpl(info.Type, blob);
+
+        VerifySize(decoded, info.Size);
+        VerifyChecksum(decoded, info.Sha256);
+
+        return decoded;
+    }
+
+    TDecoder::TCodecInfo TDecoder::ParseCodec(TStringBuf codec) {
+        const char delim = ':';
+
+        const TStringBuf version = codec.NextTok(delim);
+        Y_ENSURE(version == "1",
+                 "unknown codec format version; known: 1; got: " << version);
+
+        TCodecInfo res;
+        res.Type = codec.NextTok(delim);
+        Y_ENSURE(res.Type, "codec type is empty");
+
+        const TStringBuf size = codec.NextTok(delim);
+        Y_ENSURE(TryIntFromString<10>(size, res.Size),
+                 "decoded blob size is not number");
+
+        res.Sha256 = codec;
+        const size_t expectedSha256Size = 2 * NOpenSsl::NSha256::DIGEST_LENGTH;
+        Y_ENSURE(res.Sha256.size() == expectedSha256Size,
+                 "sha256 of decoded blob has invalid length: expected "
+                     << expectedSha256Size << ", got " << res.Sha256.size());
+
+        return res;
+    }
+
+    TString TDecoder::DecodeImpl(TStringBuf codec, const TString& blob) {
+        if (AsciiEqualsIgnoreCase(codec, "brotli")) {
+            return DecodeBrolti(blob);
+        } else if (AsciiEqualsIgnoreCase(codec, "gzip")) {
+            return DecodeGzip(blob);
+        } else if (AsciiEqualsIgnoreCase(codec, "zstd")) {
+            return DecodeZstd(blob);
+        }
+
+        ythrow yexception() << "unknown codec: '" << codec << "'";
+    }
+
+    TString TDecoder::DecodeBrolti(const TString& blob) {
+        TStringInput in(blob);
+        return TBrotliDecompress(&in).ReadAll();
+    }
+
+    TString TDecoder::DecodeGzip(const TString& blob) {
+        TStringInput in(blob);
+        return TZLibDecompress(&in).ReadAll();
+    }
+
+    TString TDecoder::DecodeZstd(const TString& blob) {
+        TStringInput in(blob);
+        return TZstdDecompress(&in).ReadAll();
+    }
+
+    void TDecoder::VerifySize(const TStringBuf decoded, size_t expected) {
+        Y_ENSURE(expected == decoded.size(),
+                 "Decoded blob has bad size: expected " << expected << ", actual " << decoded.size());
+    }
+
+    void TDecoder::VerifyChecksum(const TStringBuf decoded, const TStringBuf expected) {
+        using namespace NOpenSsl::NSha256;
+
+        const TDigest dig = Calc(decoded);
+        const TString actual = NUtils::ToHex(TStringBuf((char*)dig.data(), dig.size()));
+
+        Y_ENSURE(AsciiEqualsIgnoreCase(actual, expected),
+                 "Decoded blob has bad sha256: expected=" << expected << ", actual=" << actual);
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/decoder.h b/library/cpp/tvmauth/client/misc/roles/decoder.h
new file mode 100644
index 0000000000..de5cdb37e0
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/decoder.h
@@ -0,0 +1,32 @@
+#pragma once
+
+#include <util/generic/string.h>
+
+namespace NTvmAuth::NRoles {
+    class TDecoder {
+    public:
+        static TString Decode(const TStringBuf codec, TString&& blob);
+
+    public:
+        struct TCodecInfo {
+            TStringBuf Type;
+            size_t Size = 0;
+            TStringBuf Sha256;
+
+            bool operator==(const TCodecInfo& o) const {
+                return Type == o.Type &&
+                       Size == o.Size &&
+                       Sha256 == o.Sha256;
+            }
+        };
+
+        static TCodecInfo ParseCodec(TStringBuf codec);
+        static TString DecodeImpl(TStringBuf codec, const TString& blob);
+        static TString DecodeBrolti(const TString& blob);
+        static TString DecodeGzip(const TString& blob);
+        static TString DecodeZstd(const TString& blob);
+
+        static void VerifySize(const TStringBuf decoded, size_t expected);
+        static void VerifyChecksum(const TStringBuf decoded, const TStringBuf expected);
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/entities_index.cpp b/library/cpp/tvmauth/client/misc/roles/entities_index.cpp
new file mode 100644
index 0000000000..6c3cd5c192
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/entities_index.cpp
@@ -0,0 +1,111 @@
+#include "entities_index.h"
+
+#include <util/stream/str.h>
+
+#include <set>
+
+namespace NTvmAuth::NRoles {
+    TEntitiesIndex::TStage::TStage(const std::set<TString>& k)
+        : Keys_(k.begin(), k.end())
+    {
+    }
+
+    // TODO TStringBuf
+    bool TEntitiesIndex::TStage::GetNextKeySet(std::vector<TString>& out) {
+        out.clear();
+        out.reserve(Keys_.size());
+
+        ++Id_;
+        for (size_t idx = 0; idx < Keys_.size(); ++idx) {
+            bool need = (Id_ >> idx) & 0x01;
+
+            if (need) {
+                out.push_back(Keys_[idx]);
+            }
+        }
+
+        return !out.empty();
+    }
+
+    TEntitiesIndex::TEntitiesIndex(const std::vector<TEntityPtr>& entities) {
+        const std::set<TString> uniqueKeys = GetUniqueSortedKeys(entities);
+        Idx_.Entities = entities;
+        Idx_.SubTree.reserve(uniqueKeys.size() * entities.size());
+
+        TStage stage(uniqueKeys);
+        std::vector<TString> keyset;
+        while (stage.GetNextKeySet(keyset)) {
+            for (const TEntityPtr& e : entities) {
+                TSubTree* currentBranch = &Idx_;
+
+                for (const TString& key : keyset) {
+                    auto it = e->find(key);
+                    if (it == e->end()) {
+                        continue;
+                    }
+
+                    auto [i, ok] = currentBranch->SubTree.emplace(
+                        TKeyValue{it->first, it->second},
+                        TSubTree());
+
+                    currentBranch = &i->second;
+                    currentBranch->Entities.push_back(e);
+                }
+            }
+        }
+
+        MakeUnique(Idx_);
+    }
+
+    std::set<TString> TEntitiesIndex::GetUniqueSortedKeys(const std::vector<TEntityPtr>& entities) {
+        std::set<TString> res;
+
+        for (const TEntityPtr& e : entities) {
+            for (const auto& [key, value] : *e) {
+                res.insert(key);
+            }
+        }
+
+        return res;
+    }
+
+    void TEntitiesIndex::MakeUnique(TSubTree& branch) {
+        auto& vec = branch.Entities;
+        std::sort(vec.begin(), vec.end());
+        vec.erase(std::unique(vec.begin(), vec.end()), vec.end());
+
+        for (auto& [_, restPart] : branch.SubTree) {
+            MakeUnique(restPart);
+        }
+    }
+
+    static void Print(const TEntitiesIndex::TSubTree& part, IOutputStream& out, size_t offset = 0) {
+        std::vector<std::pair<TKeyValue, const TEntitiesIndex::TSubTree*>> vec;
+        vec.reserve(part.SubTree.size());
+
+        for (const auto& [key, value] : part.SubTree) {
+            vec.push_back({key, &value});
+        }
+
+        std::sort(vec.begin(), vec.end(), [](const auto& l, const auto& r) {
+            if (l.first.Key != r.first.Key) {
+                return l.first.Key < r.first.Key;
+            }
+            return l.first.Value < r.first.Value;
+        });
+
+        for (const auto& [key, value] : vec) {
+            out << TString(offset, ' ') << "\"" << key.Key << "/" << key.Value << "\"" << Endl;
+            Print(*value, out, offset + 4);
+        }
+    }
+
+    TString TEntitiesIndex::PrintDebugString() const {
+        TStringStream res;
+        res << Endl;
+
+        Print(Idx_, res);
+
+        return res.Str();
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/entities_index.h b/library/cpp/tvmauth/client/misc/roles/entities_index.h
new file mode 100644
index 0000000000..bf42750d52
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/entities_index.h
@@ -0,0 +1,107 @@
+#pragma once
+
+#include "types.h"
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <set>
+#include <vector>
+
+namespace NTvmAuth::NRoles {
+    class TEntitiesIndex: TMoveOnly {
+    public:
+        struct TSubTree;
+        using TIdxByAttrs = THashMap<TKeyValue, TSubTree>;
+
+        struct TSubTree {
+            std::vector<TEntityPtr> Entities;
+            TIdxByAttrs SubTree;
+        };
+
+        class TStage {
+        public:
+            TStage(const std::set<TString>& k);
+
+            bool GetNextKeySet(std::vector<TString>& out);
+
+        private:
+            std::vector<TString> Keys_;
+            size_t Id_ = 0;
+        };
+
+    public:
+        TEntitiesIndex(const std::vector<TEntityPtr>& entities);
+
+        /**
+         * Iterators must be to sorted unique key/value
+         */
+        template <typename Iterator>
+        bool ContainsExactEntity(Iterator begin, Iterator end) const;
+
+        /**
+         * Iterators must be to sorted unique key/value
+         */
+        template <typename Iterator>
+        const std::vector<TEntityPtr>& GetEntitiesWithAttrs(Iterator begin, Iterator end) const;
+
+    public: // for tests
+        static std::set<TString> GetUniqueSortedKeys(const std::vector<TEntityPtr>& entities);
+        static void MakeUnique(TEntitiesIndex::TSubTree& branch);
+
+        TString PrintDebugString() const;
+
+    private:
+        template <typename Iterator>
+        const TSubTree* FindSubtree(Iterator begin, Iterator end, size_t& size) const;
+
+    private:
+        TSubTree Idx_;
+        std::vector<TEntityPtr> EmptyResult_;
+    };
+
+    template <typename Iterator>
+    bool TEntitiesIndex::ContainsExactEntity(Iterator begin, Iterator end) const {
+        size_t size = 0;
+        const TSubTree* subtree = FindSubtree(begin, end, size);
+        if (!subtree) {
+            return false;
+        }
+
+        auto res = std::find_if(
+            subtree->Entities.begin(),
+            subtree->Entities.end(),
+            [size](const auto& e) { return size == e->size(); });
+        return res != subtree->Entities.end();
+    }
+
+    template <typename Iterator>
+    const std::vector<TEntityPtr>& TEntitiesIndex::GetEntitiesWithAttrs(Iterator begin, Iterator end) const {
+        size_t size = 0;
+        const TSubTree* subtree = FindSubtree(begin, end, size);
+        if (!subtree) {
+            return EmptyResult_;
+        }
+
+        return subtree->Entities;
+    }
+
+    template <typename Iterator>
+    const TEntitiesIndex::TSubTree* TEntitiesIndex::FindSubtree(Iterator begin,
+                                                                Iterator end,
+                                                                size_t& size) const {
+        const TSubTree* subtree = &Idx_;
+        size = 0;
+
+        for (auto attr = begin; attr != end; ++attr) {
+            auto it = subtree->SubTree.find(TKeyValueView{attr->first, attr->second});
+            if (it == subtree->SubTree.end()) {
+                return nullptr;
+            }
+
+            ++size;
+            subtree = &it->second;
+        }
+
+        return subtree;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/parser.cpp b/library/cpp/tvmauth/client/misc/roles/parser.cpp
new file mode 100644
index 0000000000..28faf4c057
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/parser.cpp
@@ -0,0 +1,149 @@
+#include "parser.h"
+
+#include <library/cpp/json/json_reader.h>
+
+#include <util/string/cast.h>
+
+namespace NTvmAuth::NRoles {
+    static void GetRequiredValue(const NJson::TJsonValue& doc,
+                                 TStringBuf key,
+                                 NJson::TJsonValue& obj) {
+        Y_ENSURE(doc.GetValue(key, &obj), "Missing '" << key << "'");
+    }
+
+    static ui64 GetRequiredUInt(const NJson::TJsonValue& doc,
+                                TStringBuf key) {
+        NJson::TJsonValue obj;
+        GetRequiredValue(doc, key, obj);
+        Y_ENSURE(obj.IsUInteger(), "key '" << key << "' must be uint");
+        return obj.GetUInteger();
+    }
+
+    static bool GetOptionalMap(const NJson::TJsonValue& doc,
+                               TStringBuf key,
+                               NJson::TJsonValue& obj) {
+        if (!doc.GetValue(key, &obj)) {
+            return false;
+        }
+
+        Y_ENSURE(obj.IsMap(), "'" << key << "' must be object");
+        return true;
+    }
+
+    TRolesPtr TParser::Parse(TRawPtr decodedBlob) {
+        try {
+            return ParseImpl(decodedBlob);
+        } catch (const std::exception& e) {
+            throw yexception() << "Failed to parse roles from tirole: " << e.what()
+                               << ". '" << *decodedBlob << "'";
+        }
+    }
+
+    TRolesPtr TParser::ParseImpl(TRawPtr decodedBlob) {
+        NJson::TJsonValue doc;
+        Y_ENSURE(NJson::ReadJsonTree(*decodedBlob, &doc), "Invalid json");
+        Y_ENSURE(doc.IsMap(), "Json must be object");
+
+        TRoles::TTvmConsumers tvm = GetConsumers<TTvmId>(doc, "tvm");
+        TRoles::TUserConsumers user = GetConsumers<TUid>(doc, "user");
+
+        // fetch it last to provide more correct apply instant
+        TRoles::TMeta meta = GetMeta(doc);
+
+        return std::make_shared<TRoles>(
+            std::move(meta),
+            std::move(tvm),
+            std::move(user),
+            std::move(decodedBlob));
+    }
+
+    TRoles::TMeta TParser::GetMeta(const NJson::TJsonValue& doc) {
+        TRoles::TMeta res;
+
+        NJson::TJsonValue obj;
+        GetRequiredValue(doc, "revision", obj);
+        if (obj.IsString()) {
+            res.Revision = obj.GetString();
+        } else if (obj.IsUInteger()) {
+            res.Revision = ToString(obj.GetUInteger());
+        } else {
+            ythrow yexception() << "'revision' has unexpected type: " << obj.GetType();
+        }
+
+        res.BornTime = TInstant::Seconds(GetRequiredUInt(doc, "born_date"));
+
+        return res;
+    }
+
+    template <typename Id>
+    THashMap<Id, TConsumerRolesPtr> TParser::GetConsumers(const NJson::TJsonValue& doc,
+                                                          TStringBuf type) {
+        THashMap<Id, TConsumerRolesPtr> res;
+
+        NJson::TJsonValue obj;
+        if (!GetOptionalMap(doc, type, obj)) {
+            return res;
+        }
+
+        for (const auto& [key, value] : obj.GetMap()) {
+            Y_ENSURE(value.IsMap(),
+                     "roles for consumer must be map: '" << key << "' is " << value.GetType());
+
+            Id id = 0;
+            Y_ENSURE(TryIntFromString<10>(key, id),
+                     "id must be valid positive number of proper size for "
+                         << type << ". got '"
+                         << key << "'");
+
+            Y_ENSURE(res.emplace(id, GetConsumer(value, key)).second,
+                     "consumer duplicate detected: '" << key << "' for " << type);
+        }
+
+        return res;
+    }
+
+    TConsumerRolesPtr TParser::GetConsumer(const NJson::TJsonValue& obj, TStringBuf consumer) {
+        TEntitiesByRoles entities;
+
+        for (const auto& [key, value] : obj.GetMap()) {
+            Y_ENSURE(value.IsArray(),
+                     "entities for roles must be array: '" << key << "' is " << value.GetType());
+
+            entities.emplace(key, GetEntities(value, consumer, key));
+        }
+
+        return std::make_shared<TConsumerRoles>(std::move(entities));
+    }
+
+    TEntitiesPtr TParser::GetEntities(const NJson::TJsonValue& obj,
+                                      TStringBuf consumer,
+                                      TStringBuf role) {
+        std::vector<TEntityPtr> entities;
+        entities.reserve(obj.GetArray().size());
+
+        for (const NJson::TJsonValue& e : obj.GetArray()) {
+            Y_ENSURE(e.IsMap(),
+                     "role entity for role must be map: consumer '"
+                         << consumer << "' with role '" << role << "' has " << e.GetType());
+
+            entities.push_back(GetEntity(e, consumer, role));
+        }
+
+        return std::make_shared<TEntities>(TEntities(entities));
+    }
+
+    TEntityPtr TParser::GetEntity(const NJson::TJsonValue& obj, TStringBuf consumer, TStringBuf role) {
+        TEntityPtr res = std::make_shared<TEntity>();
+
+        for (const auto& [key, value] : obj.GetMap()) {
+            Y_ENSURE(value.IsString(),
+                     "entity is map (str->str), got value "
+                         << value.GetType() << ". consumer '"
+                         << consumer << "' with role '" << role << "'");
+
+            res->emplace(key, value.GetString());
+        }
+
+        return res;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/parser.h b/library/cpp/tvmauth/client/misc/roles/parser.h
new file mode 100644
index 0000000000..0982ba78c6
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/parser.h
@@ -0,0 +1,36 @@
+#pragma once
+
+#include "roles.h"
+#include "types.h"
+
+namespace NJson {
+    class TJsonValue;
+}
+
+namespace NTvmAuth::NRoles {
+    class TParser {
+    public:
+        static TRolesPtr Parse(TRawPtr decodedBlob);
+
+    public:
+        static TRolesPtr ParseImpl(TRawPtr decodedBlob);
+        static TRoles::TMeta GetMeta(const NJson::TJsonValue& doc);
+
+        template <typename Id>
+        static THashMap<Id, TConsumerRolesPtr> GetConsumers(
+            const NJson::TJsonValue& doc,
+            TStringBuf key);
+
+        static TConsumerRolesPtr GetConsumer(
+            const NJson::TJsonValue& obj,
+            TStringBuf consumer);
+        static TEntitiesPtr GetEntities(
+            const NJson::TJsonValue& obj,
+            TStringBuf consumer,
+            TStringBuf role);
+        static TEntityPtr GetEntity(
+            const NJson::TJsonValue& obj,
+            TStringBuf consumer,
+            TStringBuf role);
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/roles.cpp b/library/cpp/tvmauth/client/misc/roles/roles.cpp
new file mode 100644
index 0000000000..0761033104
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/roles.cpp
@@ -0,0 +1,101 @@
+#include "roles.h"
+
+#include <library/cpp/tvmauth/checked_service_ticket.h>
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+
+namespace NTvmAuth::NRoles {
+    TRoles::TRoles(TMeta&& meta,
+                   TTvmConsumers tvm,
+                   TUserConsumers user,
+                   TRawPtr raw)
+        : Meta_(std::move(meta))
+        , TvmIds_(std::move(tvm))
+        , Users_(std::move(user))
+        , Raw_(std::move(raw))
+    {
+        Y_ENSURE(Raw_);
+    }
+
+    TConsumerRolesPtr TRoles::GetRolesForService(const TCheckedServiceTicket& t) const {
+        Y_ENSURE_EX(t,
+                    TIllegalUsage() << "Service ticket must be valid, got: " << t.GetStatus());
+        auto it = TvmIds_.find(t.GetSrc());
+        return it == TvmIds_.end() ? TConsumerRolesPtr() : it->second;
+    }
+
+    TConsumerRolesPtr TRoles::GetRolesForUser(const TCheckedUserTicket& t,
+                                              std::optional<TUid> selectedUid) const {
+        Y_ENSURE_EX(t,
+                    TIllegalUsage() << "User ticket must be valid, got: " << t.GetStatus());
+        Y_ENSURE_EX(t.GetEnv() == EBlackboxEnv::ProdYateam,
+                    TIllegalUsage() << "User ticket must be from ProdYateam, got from " << t.GetEnv());
+
+        TUid uid = t.GetDefaultUid();
+        if (selectedUid) {
+            auto it = std::find(t.GetUids().begin(), t.GetUids().end(), *selectedUid);
+            Y_ENSURE_EX(it != t.GetUids().end(),
+                        TIllegalUsage() << "selectedUid must be in user ticket but it's not: "
+                                        << *selectedUid);
+            uid = *selectedUid;
+        }
+
+        auto it = Users_.find(uid);
+        return it == Users_.end() ? TConsumerRolesPtr() : it->second;
+    }
+
+    const TRoles::TMeta& TRoles::GetMeta() const {
+        return Meta_;
+    }
+
+    const TString& TRoles::GetRaw() const {
+        return *Raw_;
+    }
+
+    bool TRoles::CheckServiceRole(const TCheckedServiceTicket& t,
+                                  const TStringBuf roleName) const {
+        TConsumerRolesPtr c = GetRolesForService(t);
+        return c ? c->HasRole(roleName) : false;
+    }
+
+    bool TRoles::CheckUserRole(const TCheckedUserTicket& t,
+                               const TStringBuf roleName,
+                               std::optional<TUid> selectedUid) const {
+        TConsumerRolesPtr c = GetRolesForUser(t, selectedUid);
+        return c ? c->HasRole(roleName) : false;
+    }
+
+    bool TRoles::CheckServiceRoleForExactEntity(const TCheckedServiceTicket& t,
+                                                const TStringBuf roleName,
+                                                const TEntity& exactEntity) const {
+        TConsumerRolesPtr c = GetRolesForService(t);
+        return c ? c->CheckRoleForExactEntity(roleName, exactEntity) : false;
+    }
+
+    bool TRoles::CheckUserRoleForExactEntity(const TCheckedUserTicket& t,
+                                             const TStringBuf roleName,
+                                             const TEntity& exactEntity,
+                                             std::optional<TUid> selectedUid) const {
+        TConsumerRolesPtr c = GetRolesForUser(t, selectedUid);
+        return c ? c->CheckRoleForExactEntity(roleName, exactEntity) : false;
+    }
+
+    TConsumerRoles::TConsumerRoles(TEntitiesByRoles roles)
+        : Roles_(std::move(roles))
+    {
+    }
+
+    bool TConsumerRoles::CheckRoleForExactEntity(const TStringBuf roleName,
+                                                 const TEntity& exactEntity) const {
+        auto it = Roles_.find(roleName);
+        if (it == Roles_.end()) {
+            return false;
+        }
+
+        return it->second->Contains(exactEntity);
+    }
+
+    TEntities::TEntities(TEntitiesIndex idx)
+        : Idx_(std::move(idx))
+    {
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/roles.h b/library/cpp/tvmauth/client/misc/roles/roles.h
new file mode 100644
index 0000000000..6d510ee8a1
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/roles.h
@@ -0,0 +1,186 @@
+#pragma once
+
+#include "entities_index.h"
+#include "types.h"
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <library/cpp/tvmauth/type.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/array_ref.h>
+#include <util/generic/hash.h>
+
+#include <vector>
+
+namespace NTvmAuth {
+    class TCheckedServiceTicket;
+    class TCheckedUserTicket;
+}
+
+namespace NTvmAuth::NRoles {
+    class TRoles {
+    public:
+        struct TMeta {
+            TString Revision;
+            TInstant BornTime;
+            TInstant Applied = TInstant::Now();
+        };
+
+        using TTvmConsumers = THashMap<TTvmId, TConsumerRolesPtr>;
+        using TUserConsumers = THashMap<TUid, TConsumerRolesPtr>;
+
+        TRoles(TMeta&& meta,
+               TTvmConsumers tvm,
+               TUserConsumers user,
+               TRawPtr raw);
+
+        /**
+         * @return ptr to roles. It will be nullptr if there are no roles
+         */
+        TConsumerRolesPtr GetRolesForService(const TCheckedServiceTicket& t) const;
+
+        /**
+         * @return ptr to roles. It will be nullptr if there are no roles
+         */
+        TConsumerRolesPtr GetRolesForUser(const TCheckedUserTicket& t,
+                                          std::optional<TUid> selectedUid = {}) const;
+
+        const TMeta& GetMeta() const;
+        const TString& GetRaw() const;
+
+    public: // shortcuts
+        /**
+         * @brief CheckServiceRole() is shortcut for simple role checking - for any possible entity
+         */
+        bool CheckServiceRole(
+            const TCheckedServiceTicket& t,
+            const TStringBuf roleName) const;
+
+        /**
+         * @brief CheckUserRole() is shortcut for simple role checking - for any possible entity
+         */
+        bool CheckUserRole(
+            const TCheckedUserTicket& t,
+            const TStringBuf roleName,
+            std::optional<TUid> selectedUid = {}) const;
+
+        /**
+         * @brief CheckServiceRoleForExactEntity() is shortcut for simple role checking for exact entity
+         */
+        bool CheckServiceRoleForExactEntity(
+            const TCheckedServiceTicket& t,
+            const TStringBuf roleName,
+            const TEntity& exactEntity) const;
+
+        /**
+         * @brief CheckUserRoleForExactEntity() is shortcut for simple role checking for exact entity
+         */
+        bool CheckUserRoleForExactEntity(
+            const TCheckedUserTicket& t,
+            const TStringBuf roleName,
+            const TEntity& exactEntity,
+            std::optional<TUid> selectedUid = {}) const;
+
+    private:
+        TMeta Meta_;
+        TTvmConsumers TvmIds_;
+        TUserConsumers Users_;
+        TRawPtr Raw_;
+    };
+
+    class TConsumerRoles {
+    public:
+        TConsumerRoles(TEntitiesByRoles roles);
+
+        bool HasRole(const TStringBuf roleName) const {
+            return Roles_.contains(roleName);
+        }
+
+        const TEntitiesByRoles& GetRoles() const {
+            return Roles_;
+        }
+
+        /**
+         * @return ptr to entries. It will be nullptr if there is no role
+         */
+        TEntitiesPtr GetEntitiesForRole(const TStringBuf roleName) const {
+            auto it = Roles_.find(roleName);
+            return it == Roles_.end() ? TEntitiesPtr() : it->second;
+        }
+
+        /**
+         * @brief CheckRoleForExactEntity() is shortcut for simple role checking for exact entity
+         */
+        bool CheckRoleForExactEntity(const TStringBuf roleName,
+                                     const TEntity& exactEntity) const;
+
+    private:
+        TEntitiesByRoles Roles_;
+    };
+
+    class TEntities {
+    public:
+        TEntities(TEntitiesIndex idx);
+
+        /**
+         * @brief Contains() provides info about entity presence
+         */
+        bool Contains(const TEntity& exactEntity) const {
+            return Idx_.ContainsExactEntity(exactEntity.begin(), exactEntity.end());
+        }
+
+        /**
+         * @brief The same as Contains()
+         * It checks span for sorted and unique properties.
+         */
+        template <class StrKey = TString, class StrValue = TString>
+        bool ContainsSortedUnique(
+            const TArrayRef<const std::pair<StrKey, StrValue>>& exactEntity) const {
+            CheckSpan(exactEntity);
+            return Idx_.ContainsExactEntity(exactEntity.begin(), exactEntity.end());
+        }
+
+        /**
+         * @brief GetEntitiesWithAttrs() collects entities with ALL attributes from `attrs`
+         */
+        template <class StrKey = TString, class StrValue = TString>
+        const std::vector<TEntityPtr>& GetEntitiesWithAttrs(
+            const std::map<StrKey, StrValue>& attrs) const {
+            return Idx_.GetEntitiesWithAttrs(attrs.begin(), attrs.end());
+        }
+
+        /**
+         * @brief The same as GetEntitiesWithAttrs()
+         * It checks span for sorted and unique properties.
+         */
+        template <class StrKey = TString, class StrValue = TString>
+        const std::vector<TEntityPtr>& GetEntitiesWithSortedUniqueAttrs(
+            const TArrayRef<const std::pair<StrKey, StrValue>>& attrs) const {
+            CheckSpan(attrs);
+            return Idx_.GetEntitiesWithAttrs(attrs.begin(), attrs.end());
+        }
+
+    private:
+        template <class StrKey, class StrValue>
+        static void CheckSpan(const TArrayRef<const std::pair<StrKey, StrValue>>& attrs) {
+            if (attrs.empty()) {
+                return;
+            }
+
+            auto prev = attrs.begin();
+            for (auto it = prev + 1; it != attrs.end(); ++it) {
+                Y_ENSURE_EX(prev->first != it->first,
+                            TIllegalUsage() << "attrs are not unique: '" << it->first << "'");
+                Y_ENSURE_EX(prev->first < it->first,
+                            TIllegalUsage() << "attrs are not sorted: '" << prev->first
+                                            << "' before '" << it->first << "'");
+
+                prev = it;
+            }
+        }
+
+    private:
+        TEntitiesIndex Idx_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/roles/types.h b/library/cpp/tvmauth/client/misc/roles/types.h
new file mode 100644
index 0000000000..de0745e72e
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/roles/types.h
@@ -0,0 +1,70 @@
+#pragma once
+
+#include <util/generic/hash_set.h>
+
+#include <map>
+#include <memory>
+
+namespace NTvmAuth::NRoles {
+    using TEntity = std::map<TString, TString>;
+    using TEntityPtr = std::shared_ptr<TEntity>;
+
+    class TEntities;
+    using TEntitiesPtr = std::shared_ptr<TEntities>;
+
+    using TEntitiesByRoles = THashMap<TString, TEntitiesPtr>;
+
+    class TConsumerRoles;
+    using TConsumerRolesPtr = std::shared_ptr<TConsumerRoles>;
+
+    class TRoles;
+    using TRolesPtr = std::shared_ptr<TRoles>;
+
+    using TRawPtr = std::shared_ptr<TString>;
+
+    template <class T>
+    struct TKeyValueBase {
+        T Key;
+        T Value;
+
+        template <typename U>
+        bool operator==(const TKeyValueBase<U>& o) const {
+            return Key == o.Key && Value == o.Value;
+        }
+    };
+
+    using TKeyValue = TKeyValueBase<TString>;
+    using TKeyValueView = TKeyValueBase<TStringBuf>;
+}
+
+// Traits
+
+template <>
+struct THash<NTvmAuth::NRoles::TKeyValue> {
+    std::size_t operator()(const NTvmAuth::NRoles::TKeyValue& e) const {
+        return std::hash<std::string_view>()(e.Key) + std::hash<std::string_view>()(e.Value);
+    }
+
+    std::size_t operator()(const NTvmAuth::NRoles::TKeyValueView& e) const {
+        return std::hash<std::string_view>()(e.Key) + std::hash<std::string_view>()(e.Value);
+    }
+};
+
+template <>
+struct TEqualTo<NTvmAuth::NRoles::TKeyValue> {
+    using is_transparent = std::true_type;
+
+    template <typename T, typename U>
+    bool operator()(const NTvmAuth::NRoles::TKeyValueBase<T>& l,
+                    const NTvmAuth::NRoles::TKeyValueBase<U>& r) {
+        return l == r;
+    }
+};
+
+inline bool operator<(const NTvmAuth::NRoles::TEntityPtr& l, const NTvmAuth::NRoles::TEntityPtr& r) {
+    return *l < *r;
+}
+
+inline bool operator==(const NTvmAuth::NRoles::TEntityPtr& l, const NTvmAuth::NRoles::TEntityPtr& r) {
+    return *l == *r;
+}
diff --git a/library/cpp/tvmauth/client/misc/service_tickets.h b/library/cpp/tvmauth/client/misc/service_tickets.h
new file mode 100644
index 0000000000..6a24bd5689
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/service_tickets.h
@@ -0,0 +1,86 @@
+#pragma once
+
+#include "settings.h"
+#include "roles/roles.h"
+
+#include <library/cpp/tvmauth/src/utils.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/hash.h>
+#include <util/generic/maybe.h>
+#include <util/generic/noncopyable.h>
+#include <util/generic/ptr.h>
+
+namespace NTvmAuth::NInternal {
+    class TClientCaningKnife;
+}
+
+namespace NTvmAuth {
+    class TServiceTickets: public TAtomicRefCount<TServiceTickets> {
+    public:
+        using TMapAliasStr = THashMap<TClientSettings::TAlias, TString>;
+        using TMapIdStr = THashMap<TTvmId, TString>;
+        using TIdSet = THashSet<TTvmId>;
+        using TAliasSet = THashSet<TClientSettings::TAlias>;
+        using TMapAliasId = THashMap<TClientSettings::TAlias, TTvmId>;
+
+        TServiceTickets(TMapIdStr&& tickets, TMapIdStr&& errors, const TMapAliasId& dstMap)
+            : TicketsById(std::move(tickets))
+            , ErrorsById(std::move(errors))
+        {
+            InitAliasesAndUnfetchedIds(dstMap);
+            InitInvalidationTime();
+        }
+
+        static TInstant GetInvalidationTime(const TMapIdStr& ticketsById) {
+            TInstant res;
+
+            for (const auto& pair : ticketsById) {
+                TMaybe<TInstant> t = NTvmAuth::NInternal::TCanningKnife::GetExpirationTime(pair.second);
+                if (!t) {
+                    continue;
+                }
+
+                res = res == TInstant() ? *t : std::min(res, *t);
+            }
+
+            return res;
+        }
+
+    public:
+        TMapIdStr TicketsById;
+        TMapIdStr ErrorsById;
+        TMapAliasStr TicketsByAlias;
+        TMapAliasStr ErrorsByAlias;
+        TInstant InvalidationTime;
+        TIdSet UnfetchedIds;
+        TAliasSet UnfetchedAliases;
+
+    private:
+        void InitAliasesAndUnfetchedIds(const TMapAliasId& dstMap) {
+            for (const auto& pair : dstMap) {
+                auto it = TicketsById.find(pair.second);
+                auto errIt = ErrorsById.find(pair.second);
+
+                if (it == TicketsById.end()) {
+                    if (errIt != ErrorsById.end()) {
+                        Y_ENSURE(ErrorsByAlias.insert({pair.first, errIt->second}).second,
+                                 "failed to add: " << pair.first);
+                    } else {
+                        UnfetchedAliases.insert(pair.first);
+                        UnfetchedIds.insert(pair.second);
+                    }
+                } else {
+                    Y_ENSURE(TicketsByAlias.insert({pair.first, it->second}).second,
+                             "failed to add: " << pair.first);
+                }
+            }
+        }
+
+        void InitInvalidationTime() {
+            InvalidationTime = GetInvalidationTime(TicketsById);
+        }
+    };
+
+    using TServiceTicketsPtr = TIntrusiveConstPtr<TServiceTickets>;
+}
diff --git a/library/cpp/tvmauth/client/misc/settings.h b/library/cpp/tvmauth/client/misc/settings.h
new file mode 100644
index 0000000000..8fae6c34d3
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/settings.h
@@ -0,0 +1,13 @@
+#pragma once
+
+#include <util/generic/fwd.h>
+
+namespace NTvmAuth {
+    class TClientSettings {
+    public:
+        /*!
+         * Look at description in relevant settings: NTvmApi::TClientSettings or NTvmTool::TClientSettings
+         */
+        using TAlias = TString;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/src_checker.h b/library/cpp/tvmauth/client/misc/src_checker.h
new file mode 100644
index 0000000000..bb99fe8884
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/src_checker.h
@@ -0,0 +1,31 @@
+#pragma once
+
+#include "roles/roles.h"
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <library/cpp/tvmauth/checked_service_ticket.h>
+#include <library/cpp/tvmauth/src/service_impl.h>
+#include <library/cpp/tvmauth/src/utils.h>
+
+namespace NTvmAuth {
+    class TSrcChecker {
+    public:
+        /*!
+         * Checking must be enabled in TClientSettings
+         * Can throw exception if cache is out of date or wrong config
+         * @param ticket
+         */
+        static TCheckedServiceTicket Check(TCheckedServiceTicket ticket, NRoles::TRolesPtr r) {
+            Y_ENSURE_EX(r, TBrokenTvmClientSettings() << "Need to use TClientSettings::EnableRolesFetching()");
+            NRoles::TConsumerRolesPtr roles = r->GetRolesForService(ticket);
+            if (roles) {
+                return ticket;
+            }
+
+            TServiceTicketImplPtr impl = THolder(NInternal::TCanningKnife::GetS(ticket));
+            impl->SetStatus(ETicketStatus::NoRoles);
+            return TCheckedServiceTicket(std::move(impl));
+        }
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/threaded_updater.cpp b/library/cpp/tvmauth/client/misc/threaded_updater.cpp
new file mode 100644
index 0000000000..5d21ce67a7
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/threaded_updater.cpp
@@ -0,0 +1,111 @@
+#include "threaded_updater.h"
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <util/string/builder.h>
+#include <util/system/spin_wait.h>
+#include <util/system/thread.h>
+
+namespace NTvmAuth {
+    TThreadedUpdaterBase::TThreadedUpdaterBase(TDuration workerAwakingPeriod,
+                                               TLoggerPtr logger,
+                                               const TString& url,
+                                               ui16 port,
+                                               TDuration socketTimeout,
+                                               TDuration connectTimeout)
+        : WorkerAwakingPeriod_(workerAwakingPeriod)
+        , Logger_(std::move(logger))
+        , TvmUrl_(url)
+        , TvmPort_(port)
+        , TvmSocketTimeout_(socketTimeout)
+        , TvmConnectTimeout_(connectTimeout)
+        , IsStopped_(true)
+    {
+        Y_ENSURE_EX(Logger_, TNonRetriableException() << "Logger is required");
+
+        ServiceTicketsDurations_.RefreshPeriod = TDuration::Hours(1);
+        ServiceTicketsDurations_.Expiring = TDuration::Hours(2);
+        ServiceTicketsDurations_.Invalid = TDuration::Hours(11);
+
+        PublicKeysDurations_.RefreshPeriod = TDuration::Days(1);
+        PublicKeysDurations_.Expiring = TDuration::Days(2);
+        PublicKeysDurations_.Invalid = TDuration::Days(6);
+    }
+
+    TThreadedUpdaterBase::~TThreadedUpdaterBase() {
+        StopWorker();
+    }
+
+    void TThreadedUpdaterBase::StartWorker() {
+        if (HttpClient_) {
+            HttpClient_->ResetConnection();
+        }
+        Thread_ = MakeHolder<TThread>(WorkerWrap, this);
+        Thread_->Start();
+        Started_.Wait();
+        IsStopped_ = false;
+    }
+
+    void TThreadedUpdaterBase::StopWorker() {
+        Event_.Signal();
+        if (Thread_) {
+            Thread_.Reset();
+        }
+    }
+
+    TKeepAliveHttpClient& TThreadedUpdaterBase::GetClient() const {
+        if (!HttpClient_) {
+            HttpClient_ = MakeHolder<TKeepAliveHttpClient>(TvmUrl_, TvmPort_, TvmSocketTimeout_, TvmConnectTimeout_);
+        }
+
+        return *HttpClient_;
+    }
+
+    void TThreadedUpdaterBase::LogDebug(const TString& msg) const {
+        if (Logger_) {
+            Logger_->Debug(msg);
+        }
+    }
+
+    void TThreadedUpdaterBase::LogInfo(const TString& msg) const {
+        if (Logger_) {
+            Logger_->Info(msg);
+        }
+    }
+
+    void TThreadedUpdaterBase::LogWarning(const TString& msg) const {
+        if (Logger_) {
+            Logger_->Warning(msg);
+        }
+    }
+
+    void TThreadedUpdaterBase::LogError(const TString& msg) const {
+        if (Logger_) {
+            Logger_->Error(msg);
+        }
+    }
+
+    void* TThreadedUpdaterBase::WorkerWrap(void* arg) {
+        TThread::SetCurrentThreadName("TicketParserUpd");
+        TThreadedUpdaterBase& this_ = *reinterpret_cast<TThreadedUpdaterBase*>(arg);
+        this_.Started_.Signal();
+        this_.LogDebug("Thread-worker started");
+
+        while (true) {
+            if (this_.Event_.WaitT(this_.WorkerAwakingPeriod_)) {
+                break;
+            }
+
+            try {
+                this_.Worker();
+                this_.GetClient().ResetConnection();
+            } catch (const std::exception& e) { // impossible now
+                this_.LogError(TStringBuilder() << "Failed to generate new cache: " << e.what());
+            }
+        }
+
+        this_.LogDebug("Thread-worker stopped");
+        this_.IsStopped_ = true;
+        return nullptr;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/threaded_updater.h b/library/cpp/tvmauth/client/misc/threaded_updater.h
new file mode 100644
index 0000000000..783684ba3b
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/threaded_updater.h
@@ -0,0 +1,76 @@
+#pragma once
+
+#include "async_updater.h"
+#include "settings.h"
+
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <library/cpp/http/simple/http_client.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/ptr.h>
+#include <util/system/event.h>
+#include <util/system/thread.h>
+
+class TKeepAliveHttpClient;
+
+namespace NTvmAuth::NInternal {
+    class TClientCaningKnife;
+}
+namespace NTvmAuth {
+    class TThreadedUpdaterBase: public TAsyncUpdaterBase {
+    public:
+        TThreadedUpdaterBase(TDuration workerAwakingPeriod,
+                             TLoggerPtr logger,
+                             const TString& url,
+                             ui16 port,
+                             TDuration socketTimeout,
+                             TDuration connectTimeout);
+        virtual ~TThreadedUpdaterBase();
+
+    protected:
+        void StartWorker();
+        void StopWorker();
+
+        virtual void Worker() {
+        }
+
+        TKeepAliveHttpClient& GetClient() const;
+
+        void LogDebug(const TString& msg) const;
+        void LogInfo(const TString& msg) const;
+        void LogWarning(const TString& msg) const;
+        void LogError(const TString& msg) const;
+
+    protected:
+        TDuration WorkerAwakingPeriod_;
+
+        const TLoggerPtr Logger_;
+
+    protected:
+        const TString TvmUrl_;
+
+    private:
+        static void* WorkerWrap(void* arg);
+
+        void StartTvmClientStopping() const override {
+            Event_.Signal();
+        }
+
+        bool IsTvmClientStopped() const override {
+            return IsStopped_;
+        }
+
+    private:
+        mutable THolder<TKeepAliveHttpClient> HttpClient_;
+
+        const ui32 TvmPort_;
+        const TDuration TvmSocketTimeout_;
+        const TDuration TvmConnectTimeout_;
+
+        mutable TAutoEvent Event_;
+        mutable TAutoEvent Started_;
+        std::atomic_bool IsStopped_;
+        THolder<TThread> Thread_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/meta_info.cpp b/library/cpp/tvmauth/client/misc/tool/meta_info.cpp
new file mode 100644
index 0000000000..9a0ae228fe
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/meta_info.cpp
@@ -0,0 +1,208 @@
+#include "meta_info.h"
+
+#include <library/cpp/json/json_reader.h>
+
+#include <util/string/builder.h>
+
+namespace NTvmAuth::NTvmTool {
+    TString TMetaInfo::TConfig::ToString() const {
+        TStringStream s;
+        s << "self_tvm_id=" << SelfTvmId << ", "
+          << "bb_env=" << BbEnv << ", "
+          << "idm_slug=" << (IdmSlug ? IdmSlug : "<NULL>") << ", "
+          << "dsts=[";
+
+        for (const auto& pair : DstAliases) {
+            s << "(" << pair.first << ":" << pair.second << ")";
+        }
+
+        s << "]";
+
+        return std::move(s.Str());
+    }
+
+    TMetaInfo::TMetaInfo(TLoggerPtr logger)
+        : Logger_(std::move(logger))
+    {
+    }
+
+    TMetaInfo::TConfigPtr TMetaInfo::Init(TKeepAliveHttpClient& client,
+                                          const TClientSettings& settings) {
+        ApplySettings(settings);
+
+        TryPing(client);
+        const TString metaString = Fetch(client);
+        if (Logger_) {
+            TStringStream s;
+            s << "Meta info fetched from " << settings.GetHostname() << ":" << settings.GetPort();
+            Logger_->Debug(s.Str());
+        }
+
+        try {
+            Config_.Set(ParseMetaString(metaString, SelfAlias_));
+        } catch (const yexception& e) {
+            ythrow TNonRetriableException() << "Malformed json from tvmtool: " << e.what();
+        }
+        TConfigPtr cfg = Config_.Get();
+        Y_ENSURE_EX(cfg, TNonRetriableException() << "Alias '" << SelfAlias_ << "' not found in meta info");
+
+        if (Logger_) {
+            Logger_->Info("Meta: " + cfg->ToString());
+        }
+
+        return cfg;
+    }
+
+    TString TMetaInfo::GetRequestForTickets(const TConfig& config) {
+        Y_ENSURE(!config.DstAliases.empty());
+
+        TStringStream s;
+        s << "/tvm/tickets"
+          << "?src=" << config.SelfTvmId
+          << "&dsts=";
+
+        for (const auto& pair : config.DstAliases) {
+            s << pair.second << ","; // avoid aliases - url-encoding required
+        }
+        s.Str().pop_back();
+
+        return s.Str();
+    }
+
+    bool TMetaInfo::TryUpdateConfig(TKeepAliveHttpClient& client) {
+        const TString metaString = Fetch(client);
+
+        TConfigPtr config;
+        try {
+            config = ParseMetaString(metaString, SelfAlias_);
+        } catch (const yexception& e) {
+            ythrow TNonRetriableException() << "Malformed json from tvmtool: " << e.what();
+        }
+        Y_ENSURE_EX(config, TNonRetriableException() << "Alias '" << SelfAlias_ << "' not found in meta info");
+
+        TConfigPtr oldConfig = Config_.Get();
+        if (*config == *oldConfig) {
+            return false;
+        }
+
+        if (Logger_) {
+            Logger_->Info(TStringBuilder()
+                          << "Meta was updated. Old: (" << oldConfig->ToString()
+                          << "). New: (" << config->ToString() << ")");
+        }
+
+        Config_ = config;
+        return true;
+    }
+
+    void TMetaInfo::TryPing(TKeepAliveHttpClient& client) {
+        try {
+            TStringStream s;
+            TKeepAliveHttpClient::THttpCode code = client.DoGet("/tvm/ping", &s);
+            if (code < 200 || 300 <= code) {
+                throw yexception() << "(" << code << ") " << s.Str();
+            }
+        } catch (const std::exception& e) {
+            ythrow TNonRetriableException() << "Failed to connect to tvmtool: " << e.what();
+        }
+    }
+
+    TString TMetaInfo::Fetch(TKeepAliveHttpClient& client) const {
+        TStringStream res;
+        TKeepAliveHttpClient::THttpCode code;
+        try {
+            code = client.DoGet("/tvm/private_api/__meta__", &res, AuthHeader_);
+        } catch (const std::exception& e) {
+            ythrow TRetriableException() << "Failed to fetch meta data from tvmtool: " << e.what();
+        }
+
+        if (code != 200) {
+            Y_ENSURE_EX(code != 404,
+                        TNonRetriableException() << "Library does not support so old tvmtool. You need tvmtool>=1.1.0");
+
+            TStringStream err;
+            err << "Failed to fetch meta from tvmtool: " << client.GetHost() << ":" << client.GetPort()
+                << " (" << code << "): " << res.Str();
+            Y_ENSURE_EX(!(500 <= code && code < 600), TRetriableException() << err.Str());
+            ythrow TNonRetriableException() << err.Str();
+        }
+
+        return res.Str();
+    }
+
+    static TMetaInfo::TDstAliases::value_type ParsePair(const NJson::TJsonValue& val, const TString& meta) {
+        NJson::TJsonValue jAlias;
+        Y_ENSURE(val.GetValue("alias", &jAlias), meta);
+        Y_ENSURE(jAlias.IsString(), meta);
+
+        NJson::TJsonValue jClientId;
+        Y_ENSURE(val.GetValue("client_id", &jClientId), meta);
+        Y_ENSURE(jClientId.IsInteger(), meta);
+
+        return {jAlias.GetString(), jClientId.GetInteger()};
+    }
+
+    TMetaInfo::TConfigPtr TMetaInfo::ParseMetaString(const TString& meta, const TString& self) {
+        NJson::TJsonValue jDoc;
+        Y_ENSURE(NJson::ReadJsonTree(meta, &jDoc), meta);
+
+        NJson::TJsonValue jEnv;
+        Y_ENSURE(jDoc.GetValue("bb_env", &jEnv), meta);
+
+        NJson::TJsonValue jTenants;
+        Y_ENSURE(jDoc.GetValue("tenants", &jTenants), meta);
+        Y_ENSURE(jTenants.IsArray(), meta);
+
+        for (const NJson::TJsonValue& jTen : jTenants.GetArray()) {
+            NJson::TJsonValue jSelf;
+            Y_ENSURE(jTen.GetValue("self", &jSelf), meta);
+            auto selfPair = ParsePair(jSelf, meta);
+            if (selfPair.first != self) {
+                continue;
+            }
+
+            TConfigPtr config = std::make_shared<TConfig>();
+            config->SelfTvmId = selfPair.second;
+            config->BbEnv = BbEnvFromString(jEnv.GetString(), meta);
+
+            {
+                NJson::TJsonValue jSlug;
+                if (jTen.GetValue("idm_slug", &jSlug)) {
+                    config->IdmSlug = jSlug.GetString();
+                }
+            }
+
+            NJson::TJsonValue jDsts;
+            Y_ENSURE(jTen.GetValue("dsts", &jDsts), meta);
+            Y_ENSURE(jDsts.IsArray(), meta);
+            for (const NJson::TJsonValue& jDst : jDsts.GetArray()) {
+                config->DstAliases.insert(ParsePair(jDst, meta));
+            }
+
+            return config;
+        }
+
+        return {};
+    }
+
+    void TMetaInfo::ApplySettings(const TClientSettings& settings) {
+        AuthHeader_ = {{"Authorization", settings.GetAuthToken()}};
+        SelfAlias_ = settings.GetSelfAlias();
+    }
+
+    EBlackboxEnv TMetaInfo::BbEnvFromString(const TString& env, const TString& meta) {
+        if (env == "Prod") {
+            return EBlackboxEnv::Prod;
+        } else if (env == "Test") {
+            return EBlackboxEnv::Test;
+        } else if (env == "ProdYaTeam") {
+            return EBlackboxEnv::ProdYateam;
+        } else if (env == "TestYaTeam") {
+            return EBlackboxEnv::TestYateam;
+        } else if (env == "Stress") {
+            return EBlackboxEnv::Stress;
+        }
+
+        ythrow yexception() << "'bb_env'=='" << env << "'. " << meta;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/meta_info.h b/library/cpp/tvmauth/client/misc/tool/meta_info.h
new file mode 100644
index 0000000000..9dd4f0dbf8
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/meta_info.h
@@ -0,0 +1,69 @@
+#pragma once
+
+#include "settings.h"
+
+#include <library/cpp/tvmauth/client/misc/utils.h>
+
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <library/cpp/http/simple/http_client.h>
+
+namespace NTvmAuth::NTvmTool {
+    class TMetaInfo {
+    public:
+        using TDstAliases = THashMap<TClientSettings::TAlias, TTvmId>;
+
+        struct TConfig {
+            TTvmId SelfTvmId = 0;
+            EBlackboxEnv BbEnv = EBlackboxEnv::Prod;
+            TString IdmSlug;
+            TDstAliases DstAliases;
+
+            bool AreTicketsRequired() const {
+                return !DstAliases.empty();
+            }
+
+            TString ToString() const;
+
+            bool operator==(const TConfig& c) const {
+                return SelfTvmId == c.SelfTvmId &&
+                       BbEnv == c.BbEnv &&
+                       IdmSlug == c.IdmSlug &&
+                       DstAliases == c.DstAliases;
+            }
+        };
+        using TConfigPtr = std::shared_ptr<TConfig>;
+
+    public:
+        TMetaInfo(TLoggerPtr logger);
+
+        TConfigPtr Init(TKeepAliveHttpClient& client,
+                        const TClientSettings& settings);
+
+        static TString GetRequestForTickets(const TMetaInfo::TConfig& config);
+
+        const TKeepAliveHttpClient::THeaders& GetAuthHeader() const {
+            return AuthHeader_;
+        }
+
+        TConfigPtr GetConfig() const {
+            return Config_.Get();
+        }
+
+        bool TryUpdateConfig(TKeepAliveHttpClient& client);
+
+    protected:
+        void TryPing(TKeepAliveHttpClient& client);
+        TString Fetch(TKeepAliveHttpClient& client) const;
+        static TConfigPtr ParseMetaString(const TString& meta, const TString& self);
+        void ApplySettings(const TClientSettings& settings);
+        static EBlackboxEnv BbEnvFromString(const TString& env, const TString& meta);
+
+    protected:
+        NUtils::TProtectedValue<TConfigPtr> Config_;
+        TKeepAliveHttpClient::THeaders AuthHeader_;
+
+        TLoggerPtr Logger_;
+        TString SelfAlias_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/roles_fetcher.cpp b/library/cpp/tvmauth/client/misc/tool/roles_fetcher.cpp
new file mode 100644
index 0000000000..05b0856edc
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/roles_fetcher.cpp
@@ -0,0 +1,81 @@
+#include "roles_fetcher.h"
+
+#include <library/cpp/tvmauth/client/misc/roles/parser.h>
+
+#include <library/cpp/http/misc/httpcodes.h>
+#include <library/cpp/string_utils/quote/quote.h>
+
+#include <util/string/builder.h>
+#include <util/string/join.h>
+
+namespace NTvmAuth::NTvmTool {
+    TRolesFetcher::TRolesFetcher(const TRolesFetcherSettings& settings, TLoggerPtr logger)
+        : Settings_(settings)
+        , Logger_(std::move(logger))
+    {
+    }
+
+    bool TRolesFetcher::IsTimeToUpdate(TDuration sinceUpdate) const {
+        return Settings_.UpdatePeriod < sinceUpdate;
+    }
+
+    bool TRolesFetcher::ShouldWarn(TDuration sinceUpdate) const {
+        return Settings_.WarnPeriod < sinceUpdate;
+    }
+
+    bool TRolesFetcher::AreRolesOk() const {
+        return bool(GetCurrentRoles());
+    }
+
+    NUtils::TFetchResult TRolesFetcher::FetchActualRoles(const TKeepAliveHttpClient::THeaders& authHeader,
+                                                         TKeepAliveHttpClient& client) const {
+        const TRequest req = CreateRequest(authHeader);
+
+        TStringStream out;
+        THttpHeaders outHeaders;
+
+        TKeepAliveHttpClient::THttpCode code = client.DoGet(
+            req.Url,
+            &out,
+            req.Headers,
+            &outHeaders);
+
+        return {code, std::move(outHeaders), "/v2/roles", out.Str(), {}};
+    }
+
+    void TRolesFetcher::Update(NUtils::TFetchResult&& fetchResult) {
+        if (fetchResult.Code == HTTP_NOT_MODIFIED) {
+            Y_ENSURE(CurrentRoles_.Get(),
+                     "tvmtool did not return any roles because current roles are actual,"
+                     " but there are no roles in memory - this should never happen");
+            return;
+        }
+
+        Y_ENSURE(fetchResult.Code == HTTP_OK,
+                 "Unexpected code from tvmtool: " << fetchResult.Code << ". " << fetchResult.Response);
+
+        CurrentRoles_.Set(NRoles::TParser::Parse(std::make_shared<TString>(std::move(fetchResult.Response))));
+
+        Logger_->Debug(
+            TStringBuilder() << "Succeed to update roles with revision "
+                             << CurrentRoles_.Get()->GetMeta().Revision);
+    }
+
+    NTvmAuth::NRoles::TRolesPtr TRolesFetcher::GetCurrentRoles() const {
+        return CurrentRoles_.Get();
+    }
+
+    TRolesFetcher::TRequest TRolesFetcher::CreateRequest(const TKeepAliveHttpClient::THeaders& authHeader) const {
+        TRequest request{
+            .Url = "/v2/roles?self=" + CGIEscapeRet(Settings_.SelfAlias),
+            .Headers = authHeader,
+        };
+
+        NRoles::TRolesPtr roles = CurrentRoles_.Get();
+        if (roles) {
+            request.Headers.emplace(IfNoneMatch_, Join("", "\"", roles->GetMeta().Revision, "\""));
+        }
+
+        return request;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/roles_fetcher.h b/library/cpp/tvmauth/client/misc/tool/roles_fetcher.h
new file mode 100644
index 0000000000..8c60b59610
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/roles_fetcher.h
@@ -0,0 +1,49 @@
+#pragma once
+
+#include <library/cpp/tvmauth/client/misc/fetch_result.h>
+#include <library/cpp/tvmauth/client/misc/utils.h>
+#include <library/cpp/tvmauth/client/misc/roles/roles.h>
+
+#include <library/cpp/tvmauth/client/logger.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/string.h>
+
+namespace NTvmAuth::NTvmTool {
+    struct TRolesFetcherSettings {
+        TString SelfAlias;
+        TDuration UpdatePeriod = TDuration::Minutes(1);
+        TDuration WarnPeriod = TDuration::Minutes(20);
+    };
+
+    class TRolesFetcher {
+    public:
+        TRolesFetcher(const TRolesFetcherSettings& settings, TLoggerPtr logger);
+
+        bool IsTimeToUpdate(TDuration sinceUpdate) const;
+        bool ShouldWarn(TDuration sinceUpdate) const;
+        bool AreRolesOk() const;
+
+        NUtils::TFetchResult FetchActualRoles(const TKeepAliveHttpClient::THeaders& authHeader,
+                                              TKeepAliveHttpClient& client) const;
+        void Update(NUtils::TFetchResult&& fetchResult);
+
+        NTvmAuth::NRoles::TRolesPtr GetCurrentRoles() const;
+
+    protected:
+        struct TRequest {
+            TString Url;
+            TKeepAliveHttpClient::THeaders Headers;
+        };
+
+    protected:
+        TRequest CreateRequest(const TKeepAliveHttpClient::THeaders& authHeader) const;
+
+    private:
+        const TRolesFetcherSettings Settings_;
+        const TLoggerPtr Logger_;
+        const TString IfNoneMatch_ = "If-None-Match";
+
+        NUtils::TProtectedValue<NTvmAuth::NRoles::TRolesPtr> CurrentRoles_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/settings.cpp b/library/cpp/tvmauth/client/misc/tool/settings.cpp
new file mode 100644
index 0000000000..894501f19d
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/settings.cpp
@@ -0,0 +1,37 @@
+#include "settings.h"
+
+#include <library/cpp/string_utils/url/url.h>
+
+#include <util/system/env.h>
+
+namespace NTvmAuth::NTvmTool {
+    TClientSettings::TClientSettings(const TAlias& selfAias)
+        : SelfAias_(selfAias)
+        , Hostname_("localhost")
+        , Port_(1)
+        , SocketTimeout_(TDuration::Seconds(5))
+        , ConnectTimeout_(TDuration::Seconds(30))
+    {
+        AuthToken_ = GetEnv("TVMTOOL_LOCAL_AUTHTOKEN");
+        if (!AuthToken_) {
+            AuthToken_ = GetEnv("QLOUD_TVM_TOKEN");
+        }
+        TStringBuf auth(AuthToken_);
+        FixSpaces(auth);
+        AuthToken_ = auth;
+
+        const TString url = GetEnv("DEPLOY_TVM_TOOL_URL");
+        if (url) {
+            TStringBuf scheme, host;
+            TryGetSchemeHostAndPort(url, scheme, host, Port_);
+        }
+
+        Y_ENSURE_EX(SelfAias_, TBrokenTvmClientSettings() << "Alias for your TVM client cannot be empty");
+    }
+
+    void TClientSettings::FixSpaces(TStringBuf& str) {
+        while (str && isspace(str.back())) {
+            str.Chop(1);
+        }
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/settings.h b/library/cpp/tvmauth/client/misc/tool/settings.h
new file mode 100644
index 0000000000..1267ca1527
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/settings.h
@@ -0,0 +1,178 @@
+#pragma once
+
+#include <library/cpp/tvmauth/client/misc/settings.h>
+
+#include <library/cpp/tvmauth/client/exception.h>
+
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/maybe.h>
+
+namespace NTvmAuth::NTvmTool {
+    /**
+     * Uses local http-interface to get state: http://localhost/tvm/.
+     * This interface can be provided with tvmtool (local daemon) or Qloud/YP (local http api in container).
+     * See more: https://wiki.yandex-team.ru/passport/tvm2/qloud/.
+     *
+     * Most part of settings will be fetched from tvmtool on start of client.
+     * You need to use aliases for TVM-clients (src and dst) which you specified in tvmtool or Qloud/YP interface
+     */
+    class TClientSettings: public NTvmAuth::TClientSettings {
+    public:
+        /*!
+         * Sets default values:
+         * - hostname == "localhost"
+         * - port detected with env["DEPLOY_TVM_TOOL_URL"] (provided with Yandex.Deploy),
+         *      otherwise port == 1 (it is ok for Qloud)
+         * - authToken: env["TVMTOOL_LOCAL_AUTHTOKEN"] (provided with Yandex.Deploy),
+         *      otherwise env["QLOUD_TVM_TOKEN"] (provided with Qloud)
+         *
+         * AuthToken is protection from SSRF.
+         *
+         * @param selfAias - alias for your TVM client, which you specified in tvmtool or YD interface
+         */
+        TClientSettings(const TAlias& selfAias);
+
+        /*!
+         * Look at comment for ctor
+         * @param port
+         */
+        TClientSettings& SetPort(ui16 port) {
+            Port_ = port;
+            return *this;
+        }
+
+        /*!
+         * Default value: hostname == "localhost"
+         * @param hostname
+         */
+        TClientSettings& SetHostname(const TString& hostname) {
+            Y_ENSURE_EX(hostname, TBrokenTvmClientSettings() << "Hostname cannot be empty");
+            Hostname_ = hostname;
+            return *this;
+        }
+
+        TClientSettings& SetSocketTimeout(TDuration socketTimeout) {
+            SocketTimeout_ = socketTimeout;
+            return *this;
+        }
+
+        TClientSettings& SetConnectTimeout(TDuration connectTimeout) {
+            ConnectTimeout_ = connectTimeout;
+            return *this;
+        }
+
+        /*!
+         * Look at comment for ctor
+         * @param token
+         */
+        TClientSettings& SetAuthToken(TStringBuf token) {
+            FixSpaces(token);
+            Y_ENSURE_EX(token, TBrokenTvmClientSettings() << "Auth token cannot be empty");
+            AuthToken_ = token;
+            return *this;
+        }
+
+        /*!
+         * Blackbox environmet is provided by tvmtool for client.
+         * You can override it for your purpose with limitations:
+         *   (env from tvmtool) -> (override)
+         *  - Prod/ProdYateam -> Prod/ProdYateam
+         *  - Test/TestYateam -> Test/TestYateam
+         *  - Stress -> Stress
+         *
+         * You can contact tvm-dev@yandex-team.ru if limitations are too strict
+         * @param env
+         */
+        TClientSettings& OverrideBlackboxEnv(EBlackboxEnv env) {
+            BbEnv_ = env;
+            return *this;
+        }
+
+        /*!
+         * By default client checks src from ServiceTicket or default uid from UserTicket -
+         *   to prevent you from forgetting to check it yourself.
+         * It does binary checks only:
+         *   ticket gets status NoRoles, if there is no role for src or default uid.
+         * You need to check roles on your own if you have a non-binary role system or
+         *     you have disabled ShouldCheckSrc/ShouldCheckDefaultUid
+         *
+         * You may need to disable this check in the following cases:
+         *   - You use GetRoles() to provide verbose message (with revision).
+         *     Double check may be inconsistent:
+         *       binary check inside client uses revision of roles X - i.e. src 100500 has no role,
+         *       exact check in your code uses revision of roles Y -  i.e. src 100500 has some roles.
+         */
+        bool ShouldCheckSrc = true;
+        bool ShouldCheckDefaultUid = true;
+        /*!
+         * By default client checks dst from ServiceTicket. If this check is switched off
+         *   incorrect dst does not result in error of checked ticket status
+         * DANGEROUS: This case you must check dst manualy using @link TCheckedServiceTicket::GetDst()
+         */
+        bool ShouldCheckDst = true;
+
+        // In case of unsuccessful initialization at startup the client will be initialized in the background
+        bool EnableLazyInitialization = false;
+
+        // DEPRECATED API
+        // TODO: get rid of it: PASSP-35377
+    public:
+        // Deprecated: set attributes directly
+        TClientSettings& SetShouldCheckSrc(bool val = true) {
+            ShouldCheckSrc = val;
+            return *this;
+        }
+
+        // Deprecated: set attributes directly
+        TClientSettings& SetSShouldCheckDefaultUid(bool val = true) {
+            ShouldCheckDefaultUid = val;
+            return *this;
+        }
+
+    public: // for TAsyncUpdaterBase
+        const TAlias& GetSelfAlias() const {
+            return SelfAias_;
+        }
+
+        const TString& GetHostname() const {
+            return Hostname_;
+        }
+
+        ui16 GetPort() const {
+            return Port_;
+        }
+
+        TDuration GetSocketTimeout() const {
+            return SocketTimeout_;
+        }
+
+        TDuration GetConnectTimeout() const {
+            return ConnectTimeout_;
+        }
+
+        const TString& GetAuthToken() const {
+            Y_ENSURE_EX(AuthToken_, TBrokenTvmClientSettings()
+                                        << "Auth token cannot be empty. "
+                                        << "Env 'TVMTOOL_LOCAL_AUTHTOKEN' and 'QLOUD_TVM_TOKEN' are empty.");
+            return AuthToken_;
+        }
+
+        TMaybe<EBlackboxEnv> GetOverridedBlackboxEnv() const {
+            return BbEnv_;
+        }
+
+    private:
+        void FixSpaces(TStringBuf& str);
+
+    private:
+        TAlias SelfAias_;
+        TString Hostname_;
+        ui16 Port_;
+        TDuration SocketTimeout_;
+        TDuration ConnectTimeout_;
+        TString AuthToken_;
+        TMaybe<EBlackboxEnv> BbEnv_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/threaded_updater.cpp b/library/cpp/tvmauth/client/misc/tool/threaded_updater.cpp
new file mode 100644
index 0000000000..82dd57a77a
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/threaded_updater.cpp
@@ -0,0 +1,442 @@
+#include "threaded_updater.h"
+
+#include <library/cpp/tvmauth/client/misc/checker.h>
+#include <library/cpp/tvmauth/client/misc/default_uid_checker.h>
+#include <library/cpp/tvmauth/client/misc/getter.h>
+#include <library/cpp/tvmauth/client/misc/src_checker.h>
+#include <library/cpp/tvmauth/client/misc/utils.h>
+
+#include <library/cpp/json/json_reader.h>
+
+#include <util/generic/hash_set.h>
+#include <util/stream/str.h>
+#include <util/string/ascii.h>
+#include <util/string/builder.h>
+#include <util/string/cast.h>
+
+namespace NTvmAuth::NTvmTool {
+    TAsyncUpdaterPtr TThreadedUpdater::Create(const TClientSettings& settings, TLoggerPtr logger) {
+        Y_ENSURE_EX(logger, TNonRetriableException() << "Logger is required");
+        THolder<TThreadedUpdater> p(new TThreadedUpdater(settings, std::move(logger)));
+
+        try {
+            p->Init(settings);
+        } catch (const TRetriableException& e) {
+            if (!settings.EnableLazyInitialization) {
+                throw e;
+            }
+        }
+
+        p->StartWorker();
+        return p.Release();
+    }
+
+    TThreadedUpdater::~TThreadedUpdater() {
+        StopWorker(); // Required here to avoid using of deleted members
+    }
+
+    TClientStatus TThreadedUpdater::GetStatus() const {
+        const TClientStatus::ECode state = GetState();
+        return TClientStatus(state, GetLastError(state == TClientStatus::Ok));
+    }
+
+    TString TThreadedUpdater::GetServiceTicketFor(const TClientSettings::TAlias& dst) const {
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        if (!MetaInfo_.GetConfig()->AreTicketsRequired()) {
+            throw TBrokenTvmClientSettings() << "Need to enable ServiceTickets fetching";
+        }
+        auto c = GetCachedServiceTickets();
+        return TServiceTicketGetter::GetTicket(dst, c);
+    }
+
+    TString TThreadedUpdater::GetServiceTicketFor(const TTvmId dst) const {
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        if (!MetaInfo_.GetConfig()->AreTicketsRequired()) {
+            throw TBrokenTvmClientSettings() << "Need to enable ServiceTickets fetching";
+        }
+        auto c = GetCachedServiceTickets();
+        return TServiceTicketGetter::GetTicket(dst, c);
+    }
+
+    TCheckedServiceTicket TThreadedUpdater::CheckServiceTicket(TStringBuf ticket, const TServiceContext::TCheckFlags& flags) const {
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        TServiceContextPtr c = GetCachedServiceContext();
+        TCheckedServiceTicket res = TServiceTicketChecker::Check(ticket, c, flags);
+        if (Settings_.ShouldCheckSrc && RolesFetcher_ && res) {
+            NRoles::TRolesPtr roles = GetRoles();
+            return TSrcChecker::Check(std::move(res), roles);
+        }
+        return res;
+    }
+
+    TCheckedUserTicket TThreadedUpdater::CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overridenEnv) const {
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        auto c = GetCachedUserContext(overridenEnv);
+        TCheckedUserTicket res = TUserTicketChecker::Check(ticket, c);
+        if (Settings_.ShouldCheckDefaultUid && RolesFetcher_ && res && res.GetEnv() == EBlackboxEnv::ProdYateam) {
+            NRoles::TRolesPtr roles = GetRoles();
+            return TDefaultUidChecker::Check(std::move(res), roles);
+        }
+        return res;
+    }
+
+    NRoles::TRolesPtr TThreadedUpdater::GetRoles() const {
+        Y_ENSURE_EX(IsInited(), TNotInitializedException() << "Client is not initialized");
+
+        Y_ENSURE_EX(RolesFetcher_,
+                    TBrokenTvmClientSettings() << "Roles were not configured in settings");
+
+        return RolesFetcher_->GetCurrentRoles();
+    }
+
+    TClientStatus::ECode TThreadedUpdater::GetState() const {
+        const TInstant now = TInstant::Now();
+
+        if (!IsInited()) {
+            return TClientStatus::NotInitialized;
+        }
+
+        const TMetaInfo::TConfigPtr config = MetaInfo_.GetConfig();
+
+        if ((config->AreTicketsRequired() && AreServiceTicketsInvalid(now)) || ArePublicKeysInvalid(now)) {
+            return TClientStatus::Error;
+        }
+
+        if (config->AreTicketsRequired()) {
+            if (!GetCachedServiceTickets() || config->DstAliases.size() > GetCachedServiceTickets()->TicketsByAlias.size()) {
+                return TClientStatus::Error;
+            }
+        }
+
+        const TDuration st = now - GetUpdateTimeOfServiceTickets();
+        const TDuration pk = now - GetUpdateTimeOfPublicKeys();
+
+        if ((config->AreTicketsRequired() && st > ServiceTicketsDurations_.Expiring) || pk > PublicKeysDurations_.Expiring) {
+            return TClientStatus::Warning;
+        }
+
+        if (RolesFetcher_ && RolesFetcher_->ShouldWarn(now - GetUpdateTimeOfRoles())) {
+            return TClientStatus::Warning;
+        }
+
+        if (IsConfigWarnTime()) {
+            return TClientStatus::Warning;
+        }
+
+        return TClientStatus::Ok;
+    }
+
+    TThreadedUpdater::TThreadedUpdater(const TClientSettings& settings, TLoggerPtr logger)
+        : TThreadedUpdaterBase(TDuration::Seconds(5), logger, settings.GetHostname(), settings.GetPort(), settings.GetSocketTimeout(), settings.GetConnectTimeout())
+        , MetaInfo_(logger)
+        , ConfigWarnDelay_(TDuration::Seconds(30))
+        , Settings_(settings)
+    {
+        ServiceTicketsDurations_.RefreshPeriod = TDuration::Minutes(10);
+        PublicKeysDurations_.RefreshPeriod = TDuration::Minutes(10);
+    }
+
+    void TThreadedUpdater::Init(const TClientSettings& settings) {
+        const TMetaInfo::TConfigPtr config = MetaInfo_.Init(GetClient(), settings);
+        LastVisitForConfig_ = TInstant::Now();
+
+        SetBbEnv(config->BbEnv, settings.GetOverridedBlackboxEnv());
+        if (settings.GetOverridedBlackboxEnv()) {
+            LogInfo(TStringBuilder()
+                    << "Meta: override blackbox env: " << config->BbEnv
+                    << "->" << *settings.GetOverridedBlackboxEnv());
+        }
+
+        if (config->IdmSlug) {
+            RolesFetcher_ = std::make_unique<TRolesFetcher>(
+                TRolesFetcherSettings{
+                    .SelfAlias = settings.GetSelfAlias(),
+                },
+                Logger_);
+        }
+
+        ui8 tries = 3;
+        do {
+            UpdateState();
+        } while (!IsEverythingOk(*config) && --tries > 0);
+
+        if (!IsEverythingOk(*config)) {
+            ThrowLastError();
+        }
+        SetInited(true);
+    }
+
+    void TThreadedUpdater::UpdateState() {
+        bool wasUpdated = false;
+        try {
+            wasUpdated = MetaInfo_.TryUpdateConfig(GetClient());
+            LastVisitForConfig_ = TInstant::Now();
+            ClearError(EScope::TvmtoolConfig);
+        } catch (const std::exception& e) {
+            ProcessError(EType::Retriable, EScope::TvmtoolConfig, e.what());
+            LogWarning(TStringBuilder() << "Error while fetching of tvmtool config: " << e.what());
+        }
+        if (IsConfigWarnTime()) {
+            LogError(TStringBuilder() << "Tvmtool config have not been refreshed for too long period");
+        }
+
+        TMetaInfo::TConfigPtr config = MetaInfo_.GetConfig();
+
+        if (wasUpdated || IsTimeToUpdateServiceTickets(*config, LastVisitForServiceTickets_)) {
+            try {
+                const TInstant updateTime = UpdateServiceTickets(*config);
+                SetUpdateTimeOfServiceTickets(updateTime);
+                LastVisitForServiceTickets_ = TInstant::Now();
+
+                if (AreServiceTicketsOk(*config)) {
+                    ClearError(EScope::ServiceTickets);
+                }
+                LogDebug(TStringBuilder() << "Tickets fetched from tvmtool: " << updateTime);
+            } catch (const std::exception& e) {
+                ProcessError(EType::Retriable, EScope::ServiceTickets, e.what());
+                LogWarning(TStringBuilder() << "Error while fetching of tickets: " << e.what());
+            }
+
+            if (TInstant::Now() - GetUpdateTimeOfServiceTickets() > ServiceTicketsDurations_.Expiring) {
+                LogError("Service tickets have not been refreshed for too long period");
+            }
+        }
+
+        if (wasUpdated || IsTimeToUpdatePublicKeys(LastVisitForPublicKeys_)) {
+            try {
+                const TInstant updateTime = UpdateKeys(*config);
+                SetUpdateTimeOfPublicKeys(updateTime);
+                LastVisitForPublicKeys_ = TInstant::Now();
+
+                if (ArePublicKeysOk()) {
+                    ClearError(EScope::PublicKeys);
+                }
+                LogDebug(TStringBuilder() << "Public keys fetched from tvmtool: " << updateTime);
+            } catch (const std::exception& e) {
+                ProcessError(EType::Retriable, EScope::PublicKeys, e.what());
+                LogWarning(TStringBuilder() << "Error while fetching of public keys: " << e.what());
+            }
+
+            if (TInstant::Now() - GetUpdateTimeOfPublicKeys() > PublicKeysDurations_.Expiring) {
+                LogError("Public keys have not been refreshed for too long period");
+            }
+        }
+
+        if (RolesFetcher_ && (wasUpdated || RolesFetcher_->IsTimeToUpdate(TInstant::Now() - GetUpdateTimeOfRoles()))) {
+            try {
+                RolesFetcher_->Update(RolesFetcher_->FetchActualRoles(MetaInfo_.GetAuthHeader(), GetClient()));
+                SetUpdateTimeOfRoles(TInstant::Now());
+
+                if (RolesFetcher_->AreRolesOk()) {
+                    ClearError(EScope::Roles);
+                }
+            } catch (const std::exception& e) {
+                ProcessError(EType::Retriable, EScope::Roles, e.what());
+                LogWarning(TStringBuilder() << "Failed to update roles: " << e.what());
+            }
+
+            if (RolesFetcher_->ShouldWarn(TInstant::Now() - GetUpdateTimeOfRoles())) {
+                LogError("Roles have not been refreshed for too long period");
+            }
+        }
+    }
+
+    TInstant TThreadedUpdater::UpdateServiceTickets(const TMetaInfo::TConfig& config) {
+        const std::pair<TString, TInstant> tickets = FetchServiceTickets(config);
+
+        if (TInstant::Now() - tickets.second >= ServiceTicketsDurations_.Invalid) {
+            throw yexception() << "Service tickets are too old: " << tickets.second;
+        }
+
+        TPairTicketsErrors p = ParseFetchTicketsResponse(tickets.first, config.DstAliases);
+        SetServiceTickets(MakeIntrusiveConst<TServiceTickets>(std::move(p.Tickets),
+                                                              std::move(p.Errors),
+                                                              config.DstAliases));
+        return tickets.second;
+    }
+
+    std::pair<TString, TInstant> TThreadedUpdater::FetchServiceTickets(const TMetaInfo::TConfig& config) const {
+        TStringStream s;
+        THttpHeaders headers;
+
+        const TString request = TMetaInfo::GetRequestForTickets(config);
+        auto code = GetClient().DoGet(request, &s, MetaInfo_.GetAuthHeader(), &headers);
+        Y_ENSURE(code == 200, ProcessHttpError(EScope::ServiceTickets, request, code, s.Str()));
+
+        return {s.Str(), GetBirthTimeFromResponse(headers, "tickets")};
+    }
+
+    static THashSet<TTvmId> GetAllTvmIds(const TMetaInfo::TDstAliases& dsts) {
+        THashSet<TTvmId> res;
+        res.reserve(dsts.size());
+
+        for (const auto& pair : dsts) {
+            res.insert(pair.second);
+        }
+
+        return res;
+    }
+
+    TAsyncUpdaterBase::TPairTicketsErrors TThreadedUpdater::ParseFetchTicketsResponse(const TString& resp,
+                                                                                      const TMetaInfo::TDstAliases& dsts) const {
+        const THashSet<TTvmId> allTvmIds = GetAllTvmIds(dsts);
+
+        TServiceTickets::TMapIdStr tickets;
+        TServiceTickets::TMapIdStr errors;
+
+        auto procErr = [this](const TString& msg) {
+            ProcessError(EType::NonRetriable, EScope::ServiceTickets, msg);
+            LogError(msg);
+        };
+
+        NJson::TJsonValue doc;
+        Y_ENSURE(NJson::ReadJsonTree(resp, &doc), "Invalid json from tvmtool: " << resp);
+
+        for (const auto& pair : doc.GetMap()) {
+            NJson::TJsonValue tvmId;
+            unsigned long long tvmIdNum = 0;
+
+            if (!pair.second.GetValue("tvm_id", &tvmId) ||
+                !tvmId.GetUInteger(&tvmIdNum)) {
+                procErr(TStringBuilder()
+                        << "Failed to get 'tvm_id' from key, should never happend '"
+                        << pair.first << "': " << resp);
+                continue;
+            }
+
+            if (!allTvmIds.contains(tvmIdNum)) {
+                continue;
+            }
+
+            NJson::TJsonValue val;
+            if (!pair.second.GetValue("ticket", &val)) {
+                TString err;
+                if (pair.second.GetValue("error", &val)) {
+                    err = val.GetString();
+                } else {
+                    err = "Failed to get 'ticket' and 'error', should never happend: " + pair.first;
+                }
+
+                procErr(TStringBuilder()
+                        << "Failed to get ServiceTicket for " << pair.first
+                        << " (" << tvmIdNum << "): " << err);
+
+                errors.insert({tvmIdNum, std::move(err)});
+                continue;
+            }
+
+            tickets.insert({tvmIdNum, val.GetString()});
+        }
+
+        // This work-around is required because of bug in old verions of tvmtool: PASSP-24829
+        for (const auto& pair : dsts) {
+            if (!tickets.contains(pair.second) && !errors.contains(pair.second)) {
+                TString err = "Missing tvm_id in response, should never happend: " + pair.first;
+
+                procErr(TStringBuilder()
+                        << "Failed to get ServiceTicket for " << pair.first
+                        << " (" << pair.second << "): " << err);
+
+                errors.emplace(pair.second, std::move(err));
+            }
+        }
+
+        return {std::move(tickets), std::move(errors)};
+    }
+
+    TInstant TThreadedUpdater::UpdateKeys(const TMetaInfo::TConfig& config) {
+        const std::pair<TString, TInstant> keys = FetchPublicKeys();
+
+        if (TInstant::Now() - keys.second >= PublicKeysDurations_.Invalid) {
+            throw yexception() << "Public keys are too old: " << keys.second;
+        }
+
+        SetServiceContext(MakeIntrusiveConst<TServiceContext>(
+            TServiceContext::CheckingFactory(config.SelfTvmId, keys.first)));
+        SetUserContext(keys.first);
+
+        return keys.second;
+    }
+
+    std::pair<TString, TInstant> TThreadedUpdater::FetchPublicKeys() const {
+        TStringStream s;
+        THttpHeaders headers;
+
+        auto code = GetClient().DoGet("/tvm/keys", &s, MetaInfo_.GetAuthHeader(), &headers);
+        Y_ENSURE(code == 200, ProcessHttpError(EScope::PublicKeys, "/tvm/keys", code, s.Str()));
+
+        return {s.Str(), GetBirthTimeFromResponse(headers, "public keys")};
+    }
+
+    TInstant TThreadedUpdater::GetBirthTimeFromResponse(const THttpHeaders& headers, TStringBuf errMsg) {
+        auto it = std::find_if(headers.begin(),
+                               headers.end(),
+                               [](const THttpInputHeader& h) {
+                                   return AsciiEqualsIgnoreCase(h.Name(), "X-Ya-Tvmtool-Data-Birthtime");
+                               });
+        Y_ENSURE(it != headers.end(), "Failed to fetch bithtime of " << errMsg << " from tvmtool");
+
+        ui64 time = 0;
+        Y_ENSURE(TryIntFromString<10>(it->Value(), time),
+                 "Bithtime of " << errMsg << " from tvmtool must be unixtime. Got: " << it->Value());
+
+        return TInstant::Seconds(time);
+    }
+
+    bool TThreadedUpdater::IsTimeToUpdateServiceTickets(const TMetaInfo::TConfig& config,
+                                                        TInstant lastUpdate) const {
+        return config.AreTicketsRequired() &&
+               TInstant::Now() - lastUpdate > ServiceTicketsDurations_.RefreshPeriod;
+    }
+
+    bool TThreadedUpdater::IsTimeToUpdatePublicKeys(TInstant lastUpdate) const {
+        return TInstant::Now() - lastUpdate > PublicKeysDurations_.RefreshPeriod;
+    }
+
+    bool TThreadedUpdater::IsEverythingOk(const TMetaInfo::TConfig& config) const {
+        if (RolesFetcher_ && !RolesFetcher_->AreRolesOk()) {
+            return false;
+        }
+        return AreServiceTicketsOk(config) && ArePublicKeysOk();
+    }
+
+    bool TThreadedUpdater::AreServiceTicketsOk(const TMetaInfo::TConfig& config) const {
+        return AreServiceTicketsOk(config.DstAliases.size());
+    }
+
+    bool TThreadedUpdater::AreServiceTicketsOk(size_t requiredCount) const {
+        if (requiredCount == 0) {
+            return true;
+        }
+
+        auto c = GetCachedServiceTickets();
+        return c && c->TicketsByAlias.size() == requiredCount;
+    }
+
+    bool TThreadedUpdater::ArePublicKeysOk() const {
+        return GetCachedServiceContext() && GetCachedUserContext();
+    }
+
+    bool TThreadedUpdater::IsConfigWarnTime() const {
+        return LastVisitForConfig_ + ConfigWarnDelay_ < TInstant::Now();
+    }
+
+    void TThreadedUpdater::Worker() {
+        if (IsInited()) {
+            UpdateState();
+        } else {
+            try {
+                Init(Settings_);
+            } catch (const TRetriableException& e) {
+                // Still not initialized
+            } catch (const std::exception& e) {
+                // Can't retry, so we mark client as initialized and now GetStatus() will return TClientStatus::Error
+                SetInited(true);
+            }
+        }
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/tool/threaded_updater.h b/library/cpp/tvmauth/client/misc/tool/threaded_updater.h
new file mode 100644
index 0000000000..e007553f81
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/tool/threaded_updater.h
@@ -0,0 +1,65 @@
+#pragma once
+
+#include "meta_info.h"
+#include "roles_fetcher.h"
+
+#include <library/cpp/tvmauth/client/misc/async_updater.h>
+#include <library/cpp/tvmauth/client/misc/threaded_updater.h>
+
+#include <atomic>
+
+namespace NTvmAuth::NTvmTool {
+    class TThreadedUpdater: public TThreadedUpdaterBase {
+    public:
+        static TAsyncUpdaterPtr Create(const TClientSettings& settings, TLoggerPtr logger);
+        ~TThreadedUpdater();
+
+        TClientStatus GetStatus() const override;
+        TString GetServiceTicketFor(const TClientSettings::TAlias& dst) const override;
+        TString GetServiceTicketFor(const TTvmId dst) const override;
+        TCheckedServiceTicket CheckServiceTicket(TStringBuf ticket, const TServiceContext::TCheckFlags& flags = TServiceContext::TCheckFlags{}) const override;
+        TCheckedUserTicket CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overrideEnv = {}) const override;
+        NRoles::TRolesPtr GetRoles() const override;
+
+    protected: // for tests
+        TClientStatus::ECode GetState() const;
+
+        TThreadedUpdater(const TClientSettings& settings, TLoggerPtr logger);
+
+        void Init(const TClientSettings& settings);
+        void UpdateState();
+
+        TInstant UpdateServiceTickets(const TMetaInfo::TConfig& config);
+        std::pair<TString, TInstant> FetchServiceTickets(const TMetaInfo::TConfig& config) const;
+        TPairTicketsErrors ParseFetchTicketsResponse(const TString& resp,
+                                                     const TMetaInfo::TDstAliases& dsts) const;
+
+        TInstant UpdateKeys(const TMetaInfo::TConfig& config);
+        std::pair<TString, TInstant> FetchPublicKeys() const;
+
+        static TInstant GetBirthTimeFromResponse(const THttpHeaders& headers, TStringBuf errMsg);
+
+        bool IsTimeToUpdateServiceTickets(const TMetaInfo::TConfig& config, TInstant lastUpdate) const;
+        bool IsTimeToUpdatePublicKeys(TInstant lastUpdate) const;
+
+        bool IsEverythingOk(const TMetaInfo::TConfig& config) const;
+        bool AreServiceTicketsOk(const TMetaInfo::TConfig& config) const;
+        bool AreServiceTicketsOk(size_t requiredCount) const;
+        bool ArePublicKeysOk() const;
+        bool IsConfigWarnTime() const;
+
+    private:
+        void Worker() override;
+
+    protected:
+        TMetaInfo MetaInfo_;
+        TInstant LastVisitForServiceTickets_;
+        TInstant LastVisitForPublicKeys_;
+        TInstant LastVisitForConfig_;
+        TDuration ConfigWarnDelay_;
+        std::unique_ptr<TRolesFetcher> RolesFetcher_;
+
+    private:
+        const TClientSettings Settings_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/misc/utils.cpp b/library/cpp/tvmauth/client/misc/utils.cpp
new file mode 100644
index 0000000000..a124c7b11c
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/utils.cpp
@@ -0,0 +1,46 @@
+#include "utils.h"
+
+#include <library/cpp/tvmauth/client/facade.h>
+
+#include <util/stream/format.h>
+
+namespace NTvmAuth::NInternal {
+    void TClientCaningKnife::StartTvmClientStopping(TTvmClient* c) {
+        if (c && c->Updater_) {
+            c->Updater_->StartTvmClientStopping();
+        }
+    }
+
+    bool TClientCaningKnife::IsTvmClientStopped(TTvmClient* c) {
+        return c && c->Updater_ ? c->Updater_->IsTvmClientStopped() : true;
+    }
+}
+
+namespace NTvmAuth::NUtils {
+    TString ToHex(const TStringBuf s) {
+        TStringStream res;
+        res.Reserve(2 * s.size());
+
+        for (char c : s) {
+            res << Hex(c, HF_FULL);
+        }
+
+        return std::move(res.Str());
+    }
+
+    bool CheckBbEnvOverriding(EBlackboxEnv original, EBlackboxEnv override) noexcept {
+        switch (original) {
+            case EBlackboxEnv::Prod:
+            case EBlackboxEnv::ProdYateam:
+                return override == EBlackboxEnv::Prod || override == EBlackboxEnv::ProdYateam;
+            case EBlackboxEnv::Test:
+                return true;
+            case EBlackboxEnv::TestYateam:
+                return override == EBlackboxEnv::Test || override == EBlackboxEnv::TestYateam;
+            case EBlackboxEnv::Stress:
+                return override == EBlackboxEnv::Stress;
+        }
+
+        return false;
+    }
+}
diff --git a/library/cpp/tvmauth/client/misc/utils.h b/library/cpp/tvmauth/client/misc/utils.h
new file mode 100644
index 0000000000..1aa5e61bf1
--- /dev/null
+++ b/library/cpp/tvmauth/client/misc/utils.h
@@ -0,0 +1,95 @@
+#pragma once
+
+#include "api/settings.h"
+#include "tool/settings.h"
+
+#include <util/string/cast.h>
+#include <util/system/spinlock.h>
+
+#include <optional>
+
+namespace NTvmAuth {
+    class TTvmClient;
+}
+
+namespace NTvmAuth::NInternal {
+    class TClientCaningKnife {
+    public:
+        static void StartTvmClientStopping(TTvmClient* c);
+        static bool IsTvmClientStopped(TTvmClient* c);
+    };
+}
+
+namespace NTvmAuth::NUtils {
+    TString ToHex(const TStringBuf s);
+
+    inline NTvmAuth::NTvmApi::TClientSettings::TDstMap ParseDstMap(TStringBuf dsts) {
+        NTvmAuth::NTvmApi::TClientSettings::TDstMap res;
+
+        while (dsts) {
+            TStringBuf pair = dsts.NextTok(';');
+            TStringBuf alias = pair.NextTok(':');
+            res.insert(decltype(res)::value_type(
+                alias,
+                IntFromString<TTvmId, 10>(pair)));
+        }
+
+        return res;
+    }
+
+    inline NTvmAuth::NTvmApi::TClientSettings::TDstVector ParseDstVector(TStringBuf dsts) {
+        NTvmAuth::NTvmApi::TClientSettings::TDstVector res;
+
+        while (dsts) {
+            res.push_back(IntFromString<TTvmId, 10>(dsts.NextTok(';')));
+        }
+
+        return res;
+    }
+
+    bool CheckBbEnvOverriding(EBlackboxEnv original, EBlackboxEnv override) noexcept;
+
+    template <class T>
+    class TProtectedValue {
+        class TAssignOp {
+        public:
+            static void Assign(T& l, const T& r) {
+                l = r;
+            }
+
+            template <typename U>
+            static void Assign(std::shared_ptr<U>& l, std::shared_ptr<U>& r) {
+                l.swap(r);
+            }
+
+            template <typename U>
+            static void Assign(TIntrusiveConstPtr<U>& l, TIntrusiveConstPtr<U>& r) {
+                l.Swap(r);
+            }
+        };
+
+    public:
+        TProtectedValue() = default;
+
+        TProtectedValue(T value)
+            : Value_(value)
+        {
+        }
+
+        T Get() const {
+            with_lock (Lock_) {
+                return Value_;
+            }
+        }
+
+        void Set(T o) {
+            with_lock (Lock_) {
+                TAssignOp::Assign(Value_, o);
+            }
+        }
+
+    private:
+        T Value_;
+        mutable TAdaptiveLock Lock_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/mocked_updater.cpp b/library/cpp/tvmauth/client/mocked_updater.cpp
new file mode 100644
index 0000000000..54f94bc92a
--- /dev/null
+++ b/library/cpp/tvmauth/client/mocked_updater.cpp
@@ -0,0 +1,60 @@
+#include "mocked_updater.h"
+
+#include <library/cpp/tvmauth/unittest.h>
+
+namespace NTvmAuth {
+    TMockedUpdater::TSettings TMockedUpdater::TSettings::CreateDeafult() {
+        TMockedUpdater::TSettings res;
+
+        res.SelfTvmId = 100500;
+
+        res.Backends = {
+            {
+                /*.Alias_ = */ "my_dest",
+                /*.Id_ = */ 42,
+                /*.Value_ = */ "3:serv:CBAQ__________9_IgYIlJEGECo:O9-vbod_8czkKrpwJAZCI8UgOIhNr2xKPcS-LWALrVC224jga2nIT6vLiw6q3d6pAT60g9K7NB39LEmh7vMuePtUMjzuZuL-uJg17BsH2iTLCZSxDjWxbU9piA2T6u607jiSyiy-FI74pEPqkz7KKJ28aPsefuC1VUweGkYFzNY",
+            },
+        };
+
+        res.BadBackends = {
+            {
+                /*.Alias_ = */ "my_bad_dest",
+                /*.Id_ = */ 43,
+                /*.Value_ = */ "Dst is not found",
+            },
+        };
+
+        return res;
+    }
+
+    TMockedUpdater::TMockedUpdater(const TSettings& settings)
+        : Roles_(settings.Roles)
+    {
+        SetServiceContext(MakeIntrusiveConst<TServiceContext>(TServiceContext::CheckingFactory(
+            settings.SelfTvmId,
+            NUnittest::TVMKNIFE_PUBLIC_KEYS)));
+
+        SetBbEnv(settings.UserTicketEnv);
+        SetUserContext(NUnittest::TVMKNIFE_PUBLIC_KEYS);
+
+        TServiceTickets::TMapIdStr tickets, errors;
+        TServiceTickets::TMapAliasId aliases;
+
+        for (const TSettings::TTuple& t : settings.Backends) {
+            tickets[t.Id] = t.Value;
+            aliases[t.Alias] = t.Id;
+        }
+        for (const TSettings::TTuple& t : settings.BadBackends) {
+            errors[t.Id] = t.Value;
+            aliases[t.Alias] = t.Id;
+        }
+
+        SetServiceTickets(MakeIntrusiveConst<TServiceTickets>(
+            std::move(tickets),
+            std::move(errors),
+            std::move(aliases)));
+
+        SetUpdateTimeOfPublicKeys(TInstant::Now());
+        SetUpdateTimeOfServiceTickets(TInstant::Now());
+    }
+}
diff --git a/library/cpp/tvmauth/client/mocked_updater.h b/library/cpp/tvmauth/client/mocked_updater.h
new file mode 100644
index 0000000000..2b6daedb03
--- /dev/null
+++ b/library/cpp/tvmauth/client/mocked_updater.h
@@ -0,0 +1,81 @@
+#pragma once
+
+#include "misc/async_updater.h"
+#include "misc/checker.h"
+#include "misc/default_uid_checker.h"
+#include "misc/getter.h"
+#include "misc/src_checker.h"
+
+namespace NTvmAuth {
+    class TMockedUpdater: public TAsyncUpdaterBase {
+    public:
+        struct TSettings {
+            struct TTuple {
+                TClientSettings::TAlias Alias;
+                TTvmId Id = 0;
+                TString Value; // ticket or error
+            };
+
+            TTvmId SelfTvmId = 0;
+            TVector<TTuple> Backends;
+            TVector<TTuple> BadBackends;
+            EBlackboxEnv UserTicketEnv = EBlackboxEnv::Test;
+            NRoles::TRolesPtr Roles;
+
+            static TSettings CreateDeafult();
+        };
+
+        TMockedUpdater(const TSettings& settings = TSettings::CreateDeafult());
+
+        TClientStatus GetStatus() const override {
+            return TClientStatus();
+        }
+
+        NRoles::TRolesPtr GetRoles() const override {
+            Y_ENSURE_EX(Roles_, TIllegalUsage() << "Roles are not provided");
+            return Roles_;
+        }
+
+        TString GetServiceTicketFor(const TClientSettings::TAlias& dst) const override {
+            auto c = GetCachedServiceTickets();
+            return TServiceTicketGetter::GetTicket(dst, c);
+        }
+
+        TString GetServiceTicketFor(const TTvmId dst) const override {
+            auto c = GetCachedServiceTickets();
+            return TServiceTicketGetter::GetTicket(dst, c);
+        }
+
+        TCheckedServiceTicket CheckServiceTicket(TStringBuf ticket, const TServiceContext::TCheckFlags& flags) const override {
+            TServiceContextPtr c = GetCachedServiceContext();
+            TCheckedServiceTicket res = TServiceTicketChecker::Check(ticket, c, flags);
+
+            if (Roles_ && res) {
+                NRoles::TRolesPtr roles = GetRoles();
+                return TSrcChecker::Check(std::move(res), roles);
+            }
+
+            return res;
+        }
+
+        TCheckedUserTicket CheckUserTicket(TStringBuf ticket, TMaybe<EBlackboxEnv> overridenEnv) const override {
+            auto c = GetCachedUserContext(overridenEnv);
+            TCheckedUserTicket res = TUserTicketChecker::Check(ticket, c);
+
+            if (Roles_ && res && res.GetEnv() == EBlackboxEnv::ProdYateam) {
+                NRoles::TRolesPtr roles = GetRoles();
+                return TDefaultUidChecker::Check(std::move(res), roles);
+            }
+            return res;
+        }
+
+        using TAsyncUpdaterBase::SetServiceContext;
+        using TAsyncUpdaterBase::SetServiceTickets;
+        using TAsyncUpdaterBase::SetUpdateTimeOfPublicKeys;
+        using TAsyncUpdaterBase::SetUpdateTimeOfServiceTickets;
+        using TAsyncUpdaterBase::SetUserContext;
+
+    protected:
+        NRoles::TRolesPtr Roles_;
+    };
+}
diff --git a/library/cpp/tvmauth/client/ya.make b/library/cpp/tvmauth/client/ya.make
new file mode 100644
index 0000000000..2c958f7b16
--- /dev/null
+++ b/library/cpp/tvmauth/client/ya.make
@@ -0,0 +1,48 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/http/simple
+    library/cpp/json
+    library/cpp/openssl/crypto
+    library/cpp/streams/brotli
+    library/cpp/streams/zstd
+    library/cpp/string_utils/quote
+    library/cpp/tvmauth
+    library/cpp/tvmauth/client/misc/retry_settings/v1
+)
+
+SRCS(
+    client_status.cpp
+    facade.cpp
+    logger.cpp
+    misc/api/roles_fetcher.cpp
+    misc/api/settings.cpp
+    misc/api/threaded_updater.cpp
+    misc/async_updater.cpp
+    misc/disk_cache.cpp
+    misc/last_error.cpp
+    misc/proc_info.cpp
+    misc/roles/decoder.cpp
+    misc/roles/entities_index.cpp
+    misc/roles/parser.cpp
+    misc/roles/roles.cpp
+    misc/threaded_updater.cpp
+    misc/tool/meta_info.cpp
+    misc/tool/roles_fetcher.cpp
+    misc/tool/settings.cpp
+    misc/tool/threaded_updater.cpp
+    misc/utils.cpp
+    mocked_updater.cpp
+)
+
+GENERATE_ENUM_SERIALIZATION(client_status.h)
+GENERATE_ENUM_SERIALIZATION(misc/async_updater.h)
+GENERATE_ENUM_SERIALIZATION(misc/last_error.h)
+
+END()
+
+RECURSE_FOR_TESTS(
+    examples
+    misc/api/dynamic_dst
+    ut
+)
diff --git a/library/cpp/tvmauth/deprecated/service_context.h b/library/cpp/tvmauth/deprecated/service_context.h
new file mode 100644
index 0000000000..bdf1bb5224
--- /dev/null
+++ b/library/cpp/tvmauth/deprecated/service_context.h
@@ -0,0 +1,72 @@
+#pragma once
+
+#include <library/cpp/tvmauth/checked_service_ticket.h>
+
+#include <util/generic/ptr.h>
+
+namespace NTvmAuth {
+    class TServiceContext: public TAtomicRefCount<TServiceContext> {
+    public:
+        /*!
+         * @struct TCheckFlags holds flags that control checking
+         */
+        struct TCheckFlags {
+            TCheckFlags() {
+            }
+            bool NeedDstCheck = true;
+        };
+
+        /*!
+         * Create service context. Serivce contexts are used to store TVM keys and parse service tickets.
+         * @param selfTvmId
+         * @param secretBase64
+         * @param tvmKeysResponse
+         */
+        TServiceContext(TStringBuf secretBase64, TTvmId selfTvmId, TStringBuf tvmKeysResponse);
+        TServiceContext(TServiceContext&&);
+        ~TServiceContext();
+
+        /*!
+         * Create service context only for checking service tickets
+         * \param[in] selfTvmId
+         * \param[in] tvmKeysResponse
+         * \return
+         */
+        static TServiceContext CheckingFactory(TTvmId selfTvmId, TStringBuf tvmKeysResponse);
+
+        /*!
+         * Create service context only for signing HTTP request to TVM-API
+         * \param[in] secretBase64
+         * \return
+         */
+        static TServiceContext SigningFactory(TStringBuf secretBase64);
+
+        TServiceContext& operator=(TServiceContext&&);
+
+        /*!
+         * Parse and validate service ticket body then create TCheckedServiceTicket object.
+         * @param ticketBody
+         * @return TCheckedServiceTicket object
+         */
+        TCheckedServiceTicket Check(TStringBuf ticketBody, const TCheckFlags& flags = {}) const;
+
+        /*!
+         * Sign params for TVM API
+         * @param ts Param 'ts' of request to TVM
+         * @param dst Param 'dst' of request to TVM
+         * @param scopes Param 'scopes' of request to TVM
+         * @return Signed string
+         */
+        TString SignCgiParamsForTvm(TStringBuf ts, TStringBuf dst, TStringBuf scopes = TStringBuf()) const;
+
+        class TImpl;
+
+    private:
+        TServiceContext() = default;
+
+    private:
+        THolder<TImpl> Impl_;
+    };
+
+    using TServiceContextPtr = TIntrusiveConstPtr<TServiceContext>;
+}
diff --git a/library/cpp/tvmauth/deprecated/user_context.h b/library/cpp/tvmauth/deprecated/user_context.h
new file mode 100644
index 0000000000..f7fe67d02e
--- /dev/null
+++ b/library/cpp/tvmauth/deprecated/user_context.h
@@ -0,0 +1,30 @@
+#pragma once
+
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+
+#include <util/generic/ptr.h>
+
+namespace NTvmAuth {
+    class TUserContext: public TAtomicRefCount<TUserContext> {
+    public:
+        TUserContext(EBlackboxEnv env, TStringBuf tvmKeysResponse);
+        TUserContext(TUserContext&&);
+        ~TUserContext();
+
+        TUserContext& operator=(TUserContext&&);
+
+        /*!
+         * Parse and validate user ticket body then create TCheckedUserTicket object.
+         * @param ticketBody
+         * @return TCheckedUserTicket object
+         */
+        TCheckedUserTicket Check(TStringBuf ticketBody) const;
+
+        class TImpl;
+
+    private:
+        THolder<TImpl> Impl_;
+    };
+
+    using TUserContextPtr = TIntrusiveConstPtr<TUserContext>;
+}
diff --git a/library/cpp/tvmauth/exception.h b/library/cpp/tvmauth/exception.h
new file mode 100644
index 0000000000..f528886b95
--- /dev/null
+++ b/library/cpp/tvmauth/exception.h
@@ -0,0 +1,20 @@
+#pragma once
+
+#include <util/generic/yexception.h>
+
+#include <exception>
+
+namespace NTvmAuth {
+    class TTvmException: public yexception {
+    };
+    class TContextException: public TTvmException {
+    };
+    class TMalformedTvmSecretException: public TContextException {
+    };
+    class TMalformedTvmKeysException: public TContextException {
+    };
+    class TEmptyTvmKeysException: public TContextException {
+    };
+    class TNotAllowedException: public TTvmException {
+    };
+}
diff --git a/library/cpp/tvmauth/src/parser.h b/library/cpp/tvmauth/src/parser.h
new file mode 100644
index 0000000000..678e709444
--- /dev/null
+++ b/library/cpp/tvmauth/src/parser.h
@@ -0,0 +1,51 @@
+#pragma once
+
+#include <library/cpp/tvmauth/src/protos/ticket2.pb.h>
+#include <library/cpp/tvmauth/src/rw/keys.h>
+
+#include <library/cpp/tvmauth/ticket_status.h>
+
+#include <util/generic/fwd.h>
+
+#include <string>
+
+namespace NTvmAuth {
+    struct TParserTvmKeys {
+        static inline const char DELIM = ':';
+        static TString ParseStrV1(TStringBuf str);
+    };
+
+    struct TParserTickets {
+        static const char DELIM = ':';
+
+        static TStringBuf UserFlag();
+        static TStringBuf ServiceFlag();
+
+        struct TRes {
+            TRes(ETicketStatus status)
+                : Status(status)
+            {
+            }
+
+            ETicketStatus Status;
+
+            ticket2::Ticket Ticket;
+        };
+        static TRes ParseV3(TStringBuf body, const NRw::TPublicKeys& keys, TStringBuf type);
+
+        // private:
+        struct TStrRes {
+            const ETicketStatus Status;
+
+            TString Proto;
+            TString Sign;
+
+            TStringBuf ForCheck;
+
+            bool operator==(const TStrRes& o) const { // for tests
+                return Status == o.Status && Proto == o.Proto && Sign == o.Sign && ForCheck == o.ForCheck;
+            }
+        };
+        static TStrRes ParseStrV3(TStringBuf body, TStringBuf type);
+    };
+}
diff --git a/library/cpp/tvmauth/src/protos/ticket2.proto b/library/cpp/tvmauth/src/protos/ticket2.proto
new file mode 100644
index 0000000000..47950a8861
--- /dev/null
+++ b/library/cpp/tvmauth/src/protos/ticket2.proto
@@ -0,0 +1,33 @@
+package ticket2;
+
+option go_package = "github.com/ydb-platform/ydb/library/cpp/tvmauth/src/protos";
+
+import "library/cpp/tvmauth/src/protos/tvm_keys.proto";
+
+message User {
+    required uint64 uid = 1;
+    optional uint64 porgId = 2;
+}
+
+message UserTicket {
+    repeated User users = 1;
+    required uint64 defaultUid = 2;
+    repeated string scopes = 3;
+    required uint32 entryPoint = 4;
+    required tvm_keys.BbEnvType env = 5;
+    optional string loginId = 6;
+}
+
+message ServiceTicket {
+    required uint32 srcClientId = 1;
+    required uint32 dstClientId = 2;
+    repeated string scopes = 3;
+    optional uint64 issuerUid = 4;
+}
+
+message Ticket {
+    required uint32 keyId = 1;
+    required int64  expirationTime = 2;
+    optional UserTicket user = 3;
+    optional ServiceTicket service = 4;
+}
diff --git a/library/cpp/tvmauth/src/protos/tvm_keys.proto b/library/cpp/tvmauth/src/protos/tvm_keys.proto
new file mode 100644
index 0000000000..d931e52071
--- /dev/null
+++ b/library/cpp/tvmauth/src/protos/tvm_keys.proto
@@ -0,0 +1,36 @@
+package tvm_keys;
+
+option go_package = "github.com/ydb-platform/ydb/library/cpp/tvmauth/src/protos";
+
+enum KeyType {
+    RabinWilliams = 0;
+}
+
+enum BbEnvType {
+   Prod = 0;
+   Test = 1;
+   ProdYateam = 2;
+   TestYateam = 3;
+   Stress = 4;
+}
+
+message General {
+    required uint32 id = 1;
+    required KeyType type = 2;
+    required bytes body = 3;
+    optional int64 createdTime = 4;
+}
+
+message BbKey {
+    required General gen = 1;
+    required BbEnvType env = 2;
+}
+
+message TvmKey {
+    required General gen = 1;
+}
+
+message Keys {
+    repeated BbKey bb = 1;
+    repeated TvmKey tvm = 2;
+}
diff --git a/library/cpp/tvmauth/src/protos/ya.make b/library/cpp/tvmauth/src/protos/ya.make
new file mode 100644
index 0000000000..6a7fab902a
--- /dev/null
+++ b/library/cpp/tvmauth/src/protos/ya.make
@@ -0,0 +1,10 @@
+PROTO_LIBRARY()
+
+INCLUDE_TAGS(GO_PROTO)
+
+SRCS(
+    ticket2.proto
+    tvm_keys.proto
+)
+
+END()
diff --git a/library/cpp/tvmauth/src/rw/keys.h b/library/cpp/tvmauth/src/rw/keys.h
new file mode 100644
index 0000000000..e02b7e72a1
--- /dev/null
+++ b/library/cpp/tvmauth/src/rw/keys.h
@@ -0,0 +1,65 @@
+#pragma once
+
+#include <util/generic/ptr.h>
+#include <util/generic/string.h>
+
+#include <unordered_map>
+
+struct TRwInternal;
+
+namespace NTvmAuth {
+    namespace NRw {
+        namespace NPrivate {
+            class TRwDestroyer {
+            public:
+                static void Destroy(TRwInternal* o);
+            };
+        }
+
+        using TRw = THolder<TRwInternal, NPrivate::TRwDestroyer>;
+        using TKeyId = ui32;
+
+        struct TKeyPair {
+            TString Private;
+            TString Public;
+        };
+        TKeyPair GenKeyPair(size_t size);
+
+        class TRwPrivateKey {
+        public:
+            TRwPrivateKey(TStringBuf body, TKeyId id);
+
+            TKeyId GetId() const;
+            TString SignTicket(TStringBuf ticket) const;
+
+        private:
+            static TRw Deserialize(TStringBuf key);
+
+            TKeyId Id_;
+            TRw Rw_;
+            int SignLen_;
+        };
+
+        class TRwPublicKey {
+        public:
+            TRwPublicKey(TStringBuf body);
+
+            bool CheckSign(TStringBuf ticket, TStringBuf sign) const;
+
+        private:
+            static TRw Deserialize(TStringBuf key);
+
+            TRw Rw_;
+        };
+
+        using TPublicKeys = std::unordered_map<TKeyId, TRwPublicKey>;
+
+        class TSecureHeap {
+        public:
+            TSecureHeap(size_t totalSize, int minChunkSize);
+            ~TSecureHeap();
+
+            static void Init(size_t totalSize = 16 * 1024 * 1024, int minChunkSize = 16);
+        };
+    }
+}
diff --git a/library/cpp/tvmauth/src/service_impl.h b/library/cpp/tvmauth/src/service_impl.h
new file mode 100644
index 0000000000..76400cffea
--- /dev/null
+++ b/library/cpp/tvmauth/src/service_impl.h
@@ -0,0 +1,78 @@
+#pragma once
+
+#include <library/cpp/tvmauth/src/protos/ticket2.pb.h>
+#include <library/cpp/tvmauth/src/protos/tvm_keys.pb.h>
+#include <library/cpp/tvmauth/src/rw/keys.h>
+
+#include <library/cpp/tvmauth/type.h>
+#include <library/cpp/tvmauth/deprecated/service_context.h>
+
+#include <library/cpp/charset/ci_string.h>
+#include <library/cpp/string_utils/secret_string/secret_string.h>
+
+#include <util/generic/maybe.h>
+
+#include <string>
+
+namespace NTvmAuth {
+    using TServiceTicketImplPtr = THolder<TCheckedServiceTicket::TImpl>;
+    class TCheckedServiceTicket::TImpl {
+    public:
+        explicit operator bool() const;
+
+        TTvmId GetDst() const;
+        TTvmId GetSrc() const;
+        const TScopes& GetScopes() const;
+        bool HasScope(TStringBuf scopeName) const;
+        ETicketStatus GetStatus() const;
+        time_t GetExpirationTime() const;
+
+        TString DebugInfo() const;
+        TMaybe<TUid> GetIssuerUid() const;
+
+        void SetStatus(ETicketStatus status);
+
+        /*!
+         * Constructor for creation invalid ticket storing error status in TServiceContext
+         * @param status
+         * @param protobufTicket
+         */
+        TImpl(ETicketStatus status, ticket2::Ticket&& protobufTicket);
+
+        static TServiceTicketImplPtr CreateTicketForTests(ETicketStatus status,
+                                                          TTvmId src,
+                                                          TMaybe<TUid> issuerUid,
+                                                          TTvmId dst = 100500);
+
+    private:
+        ETicketStatus Status_;
+        ticket2::Ticket ProtobufTicket_;
+        mutable TScopes CachedScopes_;
+        mutable TString CachedDebugInfo_;
+    };
+
+    class TServiceContext::TImpl {
+    public:
+        TImpl(TStringBuf secretBase64, TTvmId selfTvmId, TStringBuf tvmKeysResponse);
+        TImpl(TTvmId selfTvmId, TStringBuf tvmKeysResponse);
+        TImpl(TStringBuf secretBase64);
+
+        void ResetKeys(TStringBuf tvmKeysResponse);
+
+        TServiceTicketImplPtr Check(TStringBuf ticketBody, const TServiceContext::TCheckFlags& flags = {}) const;
+        TString SignCgiParamsForTvm(TStringBuf ts, TStringBuf dst, TStringBuf scopes = TStringBuf()) const;
+
+        const NRw::TPublicKeys& GetKeys() const { // for tests
+            return Keys_;
+        }
+
+    private:
+        static TString ParseSecret(TStringBuf secretBase64);
+
+        NRw::TPublicKeys Keys_;
+        const NSecretString::TSecretString Secret_;
+        const TTvmId SelfTvmId_ = 0;
+
+        ::google::protobuf::LogSilencer LogSilencer_;
+    };
+}
diff --git a/library/cpp/tvmauth/src/user_impl.h b/library/cpp/tvmauth/src/user_impl.h
new file mode 100644
index 0000000000..b1190bd626
--- /dev/null
+++ b/library/cpp/tvmauth/src/user_impl.h
@@ -0,0 +1,76 @@
+#pragma once
+
+#include <library/cpp/tvmauth/src/protos/ticket2.pb.h>
+#include <library/cpp/tvmauth/src/protos/tvm_keys.pb.h>
+#include <library/cpp/tvmauth/src/rw/keys.h>
+
+#include <library/cpp/tvmauth/deprecated/user_context.h>
+
+#include <library/cpp/charset/ci_string.h>
+
+#include <optional>
+#include <unordered_map>
+
+namespace NTvmAuth {
+    using TUserTicketImplPtr = THolder<TCheckedUserTicket::TImpl>;
+    class TCheckedUserTicket::TImpl {
+    public:
+        explicit operator bool() const;
+
+        TUid GetDefaultUid() const;
+        time_t GetExpirationTime() const;
+        const TScopes& GetScopes() const;
+        bool HasScope(TStringBuf scopeName) const;
+        ETicketStatus GetStatus() const;
+        const TUids& GetUids() const;
+        TUidsExtFieldsMap GetUidsExtFields() const;
+        std::optional<TUserExtFields> GetDefaultUidExtFields() const;
+        const TString& GetLoginId() const;
+
+        TString DebugInfo() const;
+
+        EBlackboxEnv GetEnv() const;
+
+        void SetStatus(ETicketStatus status);
+
+        /*!
+         * Constructor for creation invalid ticket storing error status in TServiceContext
+         * @param status
+         * @param protobufTicket
+         */
+        TImpl(ETicketStatus status, ticket2::Ticket&& protobufTicket);
+
+        static TUserTicketImplPtr CreateTicketForTests(ETicketStatus status,
+                                                       TUid defaultUid,
+                                                       TScopes scopes,
+                                                       TUids uids,
+                                                       EBlackboxEnv env = EBlackboxEnv::Test);
+
+    private:
+        static const int MaxUserCount = 15;
+
+        ETicketStatus Status_;
+        ticket2::Ticket ProtobufTicket_;
+        mutable TScopes CachedScopes_;
+        mutable TUids CachedUids_;
+        mutable TString CachedDebugInfo_;
+    };
+
+    class TUserContext::TImpl {
+    public:
+        TImpl(EBlackboxEnv env, TStringBuf tvmKeysResponse);
+        void ResetKeys(TStringBuf tvmKeysResponse);
+
+        TUserTicketImplPtr Check(TStringBuf ticketBody) const;
+        const NRw::TPublicKeys& GetKeys() const;
+
+        bool IsAllowed(tvm_keys::BbEnvType env) const;
+
+    private:
+        ETicketStatus CheckProtobufUserTicket(const ticket2::Ticket& ticket) const;
+
+        NRw::TPublicKeys Keys_;
+        EBlackboxEnv Env_;
+        ::google::protobuf::LogSilencer LogSilencer_;
+    };
+}
diff --git a/library/cpp/tvmauth/src/utils.h b/library/cpp/tvmauth/src/utils.h
new file mode 100644
index 0000000000..e5847ac89f
--- /dev/null
+++ b/library/cpp/tvmauth/src/utils.h
@@ -0,0 +1,30 @@
+#pragma once
+
+#include <library/cpp/tvmauth/checked_service_ticket.h>
+#include <library/cpp/tvmauth/checked_user_ticket.h>
+#include <library/cpp/tvmauth/ticket_status.h>
+
+#include <util/datetime/base.h>
+#include <util/generic/fwd.h>
+
+namespace NTvmAuth::NUtils {
+    TString Bin2base64url(TStringBuf buf);
+    TString Base64url2bin(TStringBuf buf);
+
+    TString SignCgiParamsForTvm(TStringBuf secret, TStringBuf ts, TStringBuf dstTvmId, TStringBuf scopes);
+}
+
+namespace NTvmAuth::NInternal {
+    class TCanningKnife {
+    public:
+        static TCheckedServiceTicket::TImpl* GetS(TCheckedServiceTicket& t) {
+            return t.Impl_.Release();
+        }
+
+        static TCheckedUserTicket::TImpl* GetU(TCheckedUserTicket& t) {
+            return t.Impl_.Release();
+        }
+
+        static TMaybe<TInstant> GetExpirationTime(TStringBuf ticket);
+    };
+}
diff --git a/library/cpp/tvmauth/ticket_status.h b/library/cpp/tvmauth/ticket_status.h
new file mode 100644
index 0000000000..532d4de56e
--- /dev/null
+++ b/library/cpp/tvmauth/ticket_status.h
@@ -0,0 +1,23 @@
+#pragma once
+
+#include <util/generic/strbuf.h>
+
+namespace NTvmAuth {
+    /*!
+     * Status mean result of ticket check
+     */
+    enum class ETicketStatus {
+        Ok,
+        Expired,
+        InvalidBlackboxEnv,
+        InvalidDst,
+        InvalidTicketType,
+        Malformed,
+        MissingKey,
+        SignBroken,
+        UnsupportedVersion,
+        NoRoles,
+    };
+
+    TStringBuf StatusToString(ETicketStatus st);
+}
diff --git a/library/cpp/tvmauth/type.h b/library/cpp/tvmauth/type.h
new file mode 100644
index 0000000000..acf0f9e1aa
--- /dev/null
+++ b/library/cpp/tvmauth/type.h
@@ -0,0 +1,27 @@
+#pragma once
+
+#include <library/cpp/containers/stack_vector/stack_vec.h>
+
+#include <util/generic/hash.h>
+
+namespace NTvmAuth {
+    struct TUserExtFields;
+
+    using TScopes = TSmallVec<TStringBuf>;
+    using TTvmId = ui32;
+    using TUid = ui64;
+    using TUids = TSmallVec<TUid>;
+    using TUidsExtFieldsMap = THashMap<TUid, TUserExtFields>;
+    using TAlias = TString;
+    using TPorgId = ui64;
+
+    struct TUserExtFields {
+        bool operator==(const TUserExtFields& o) const {
+            return Uid == o.Uid &&
+                   CurrentPorgId == o.CurrentPorgId;
+        }
+
+        TUid Uid = 0;
+        TPorgId CurrentPorgId = 0;
+    };
+}
diff --git a/library/cpp/tvmauth/unittest.h b/library/cpp/tvmauth/unittest.h
new file mode 100644
index 0000000000..79c9c6bf18
--- /dev/null
+++ b/library/cpp/tvmauth/unittest.h
@@ -0,0 +1,21 @@
+#pragma once
+
+#include "checked_service_ticket.h"
+#include "checked_user_ticket.h"
+
+#include <util/generic/maybe.h>
+
+namespace NTvmAuth::NUnittest {
+    static const TString TVMKNIFE_PUBLIC_KEYS = "1:CpgCCpMCCAEQABqIAjCCAQQCggEAcLEXeH67FQESFUn4_7wnX7wN0PUrBoUsm3QQ4W5vC-qz6sXaEjSwnTV8w1o-z6X9KPLlhzMQvuS38NCNfK4uvJ4Zvfp3YsXJ25-rYtbnrYJHNvHohD-kPCCw_yZpMp21JdWigzQGuV7CtrxUhF-NNrsnUaJrE5-OpEWNt4X6nCItKIYeVcSK6XJUbEWbrNCRbvkSc4ak2ymFeMuHYJVjxh4eQbk7_ZPzodP0WvF6eUYrYeb42imVEOR8ofVLQWE5DVnb1z_TqZm4i1XkS7jMwZuBxBRw8DGdYei0lT_sAf7KST2jC0590NySB3vsBgWEVs1OdUUWA6r-Dvx9dsOQtSCVkQYQAAqZAgqUAggCEAAaiQIwggEFAoIBAQDhEBM5-6YsPWfogKtbluJoCX1WV2KdzOaQ0-OlRbBzeCzw-eQKu12c8WakHBbeCMd1I1TU64SDkDorWjXGIa_2xT6N3zzNAE50roTbPCcmeQrps26woTYfYIuqDdoxYKZNr0lvNLLW47vBr7EKqo1S4KSj7aXK_XYeEvUgIgf3nVIcNrio7VTnFmGGVQCepaL1Hi1gN4yIXjVZ06PBPZ-DxSRu6xOGbFrfKMJeMPs7KOyE-26Q3xOXdTIa1X-zYIucTd_bxUCL4BVbwW2AvbbFsaG7ISmVdGu0XUTmhXs1KrEfUVLRJhE4Dx99hAZXm1_HlYMUeJcMQ_oHOhV94ENFIJaRBhACCpYBCpEBCAMQABqGATCBgwKBgF9t2YJGAJkRRFq6fWhi3m1TFW1UOE0f6ZrfYhHAkpqGlKlh0QVfeTNPpeJhi75xXzCe6oReRUm-0DbqDNhTShC7uGUv1INYnRBQWH6E-5Fc5XrbDFSuGQw2EYjNfHy_HefHJXxQKAqPvxBDKMKkHgV58WtM6rC8jRi9sdX_ig2NIJeRBhABCpYBCpEBCAQQABqGATCBgwKBgGB4d6eLGUBv-Q6EPLehC4S-yuE2HB-_rJ7WkeYwyp-xIPolPrd-PQme2utHB4ZgpXHIu_OFksDe_0bPgZniNRSVRbl7W49DgS5Ya3kMfrYB4DnF5Fta5tn1oV6EwxYD4JONpFTenOJALPGTPawxXEfon_peiHOSBuQMu3_Vn-l1IJiRBhADCpcBCpIBCAUQABqHATCBhAKBgQCTJMKIfmfeZpaI7Q9rnsc29gdWawK7TnpVKRHws1iY7EUlYROeVcMdAwEqVM6f8BVCKLGgzQ7Gar_uuxfUGKwqEQzoppDraw4F75J464-7D5f6_oJQuGIBHZxqbMONtLjBCXRUhQW5szBLmTQ_R3qaJb5vf-h0APZfkYhq1cTttSCZkQYQBAqWAQqRAQgLEAAahgEwgYMCgYBvvGVH_M2H8qxxv94yaDYUTWbRnJ1uiIYc59KIQlfFimMPhSS7x2tqUa2-hI55JiII0Xym6GNkwLhyc1xtWChpVuIdSnbvttbrt4weDMLHqTwNOF6qAsVKGKT1Yh8yf-qb-DSmicgvFc74mBQm_6gAY1iQsf33YX8578ClhKBWHSCVkQYQAAqXAQqSAQgMEAAahwEwgYQCgYEAkuzFcd5TJu7lYWYe2hQLFfUWIIj91BvQQLa_Thln4YtGCO8gG1KJqJm-YlmJOWQG0B7H_5RVhxUxV9KpmFnsDVkzUFKOsCBaYGXc12xPVioawUlAwp5qp3QQtZyx_se97YIoLzuLr46UkLcLnkIrp-Jo46QzYi_QHq45WTm8MQ0glpEGEAIKlwEKkgEIDRAAGocBMIGEAoGBAIUzbxOknXf_rNt17_ir8JlWvrtnCWsQd1MAnl5mgArvavDtKeBYHzi5_Ak7DHlLzuA6YE8W175FxLFKpN2hkz-l-M7ltUSd8N1BvJRhK4t6WffWfC_1wPyoAbeSN2Yb1jygtZJQ8wGoXHcJQUXiMit3eFNyylwsJFj1gzAR4JCdIJeRBhABCpYBCpEBCA4QABqGATCBgwKBgFMcbEpl9ukVR6AO_R6sMyiU11I8b8MBSUCEC15iKsrVO8v_m47_TRRjWPYtQ9eZ7o1ocNJHaGUU7qqInFqtFaVnIceP6NmCsXhjs3MLrWPS8IRAy4Zf4FKmGOx3N9O2vemjUygZ9vUiSkULdVrecinRaT8JQ5RG4bUMY04XGIwFIJiRBhADCpYBCpEBCA8QABqGATCBgwKBgGpCkW-NR3li8GlRvqpq2YZGSIgm_PTyDI2Zwfw69grsBmPpVFW48Vw7xoMN35zcrojEpialB_uQzlpLYOvsMl634CRIuj-n1QE3-gaZTTTE8mg-AR4mcxnTKThPnRQpbuOlYAnriwiasWiQEMbGjq_HmWioYYxFo9USlklQn4-9IJmRBhAEEpUBCpIBCAYQABqHATCBhAKBgQCoZkFGm9oLTqjeXZAq6j5S6i7K20V0lNdBBLqfmFBIRuTkYxhs4vUYnWjZrKRAd5bp6_py0csmFmpl_5Yh0b-2pdo_E5PNP7LGRzKyKSiFddyykKKzVOazH8YYldDAfE8Z5HoS9e48an5JsPg0jr-TPu34DnJq3yv2a6dqiKL9zSCakQYSlQEKkgEIEBAAGocBMIGEAoGBALhrihbf3EpjDQS2sCQHazoFgN0nBbE9eesnnFTfzQELXb2gnJU9enmV_aDqaHKjgtLIPpCgn40lHrn5k6mvH5OdedyI6cCzE-N-GFp3nAq0NDJyMe0fhtIRD__CbT0ulcvkeow65ubXWfw6dBC2gR_34rdMe_L_TGRLMWjDULbNIJqRBg";
+
+    TCheckedServiceTicket CreateServiceTicket(ETicketStatus status,
+                                              TTvmId src,
+                                              TMaybe<TUid> issuerUid = TMaybe<TUid>(),
+                                              TTvmId dst = 100500);
+
+    TCheckedUserTicket CreateUserTicket(ETicketStatus status,
+                                        TUid defaultUid,
+                                        const TScopes& scopes,
+                                        const TUids& uids = TUids(),
+                                        EBlackboxEnv env = EBlackboxEnv::Test);
+}
diff --git a/library/cpp/tvmauth/utils.h b/library/cpp/tvmauth/utils.h
new file mode 100644
index 0000000000..ad8950cab5
--- /dev/null
+++ b/library/cpp/tvmauth/utils.h
@@ -0,0 +1,12 @@
+#pragma once
+
+#include <util/generic/strbuf.h>
+
+namespace NTvmAuth::NUtils {
+    /*!
+     * Remove signature from ticket string - rest part can be parsed later with `tvmknife parse_ticket ...`
+     * @param ticketBody Raw ticket body
+     * @return safe for logging part of ticket
+     */
+    TStringBuf RemoveTicketSignature(TStringBuf ticketBody);
+}
diff --git a/library/cpp/tvmauth/version.h b/library/cpp/tvmauth/version.h
new file mode 100644
index 0000000000..48ec279829
--- /dev/null
+++ b/library/cpp/tvmauth/version.h
@@ -0,0 +1,7 @@
+#pragma once
+
+#include <util/generic/strbuf.h>
+
+namespace NTvmAuth {
+    TStringBuf LibVersion();
+}
diff --git a/library/cpp/tvmauth/ya.make b/library/cpp/tvmauth/ya.make
new file mode 100644
index 0000000000..94be4cabd1
--- /dev/null
+++ b/library/cpp/tvmauth/ya.make
@@ -0,0 +1,40 @@
+LIBRARY()
+
+PEERDIR(
+    library/cpp/string_utils/secret_string
+    library/cpp/tvmauth/src/protos
+    library/cpp/tvmauth/src/rw
+)
+
+SRCS(
+    deprecated/service_context.cpp
+    deprecated/user_context.cpp
+    src/parser.cpp
+    src/service_impl.cpp
+    src/service_ticket.cpp
+    src/status.cpp
+    src/unittest.cpp
+    src/user_impl.cpp
+    src/user_ticket.cpp
+    src/utils.cpp
+    src/version.cpp
+    utils.cpp
+)
+
+GENERATE_ENUM_SERIALIZATION(checked_user_ticket.h)
+GENERATE_ENUM_SERIALIZATION(ticket_status.h)
+
+RESOURCE(
+    src/version /builtin/version
+)
+
+NO_BUILD_IF(OPENSOURCE)
+
+END()
+
+RECURSE(
+    client
+    src/rw
+    src/ut
+    test_all
+)