YT-24021: Support signatures in job proxy via exec node

commit_hash:b6af9463fe3d052031f6de19a0d349b2296c2e23

Author: p4vook

yt/yt/client/signature/signature.cpp

@@ -31,6 +31,19 @@ void Serialize(const TSignature& signature, IYsonConsumer* consumer)
     consumer->OnEndMap();
 }
 
+void ToProto(NProto::TSignature* protoSignature, const TSignature& signature)
+{
+    auto headerBuf = signature.Header_.AsStringBuf();
+    protoSignature->set_header(headerBuf.Data(), headerBuf.Size());
+    protoSignature->set_payload(signature.Payload_);
+    protoSignature->set_signature(signature.Signature_);
+}
+
+void ToProto(NProto::TSignature* protoSignature, const TSignaturePtr& signature)
+{
+    ToProto(protoSignature, *signature);
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 
 void Deserialize(TSignature& signature, INodePtr node)
@@ -46,6 +59,19 @@ void Deserialize(TSignature& signature, TYsonPullParserCursor* cursor)
     Deserialize(signature, ExtractTo<INodePtr>(cursor));
 }
 
+void FromProto(TSignature* signature, const NProto::TSignature& protoSignature)
+{
+    signature->Header_ = TYsonString(protoSignature.header());
+    signature->Payload_ = protoSignature.payload();
+    signature->Signature_ = protoSignature.signature();
+}
+
+void FromProto(TSignaturePtr* signature, const NProto::TSignature& protoSignature)
+{
+    *signature = New<TSignature>();
+    FromProto(signature->Get(), protoSignature);
+}
+
 ////////////////////////////////////////////////////////////////////////////////
 
 } // namespace NYT::NSignature

yt/yt/client/signature/signature.h

@@ -6,6 +6,8 @@
 
 #include <yt/yt/core/ytree/public.h>
 
+#include <yt/yt_proto/yt/client/misc/proto/signature.pb.h>
+
 #include <vector>
 
 namespace NYT::NSignature {
@@ -36,6 +38,12 @@ class TSignature final
     friend void Serialize(const TSignature& signature, NYson::IYsonConsumer* consumer);
     friend void Deserialize(TSignature& signature, NYTree::INodePtr node);
     friend void Deserialize(TSignature& signature, NYson::TYsonPullParserCursor* cursor);
+
+    friend void FromProto(TSignature* signature, const NProto::TSignature& protoSignature);
+    friend void ToProto(NProto::TSignature* protoSignature, const TSignature& signature);
+
+    friend void FromProto(TSignaturePtr* signature, const NProto::TSignature& protoSignature);
+    friend void ToProto(NProto::TSignature* protoSignature, const TSignaturePtr& signature);
 };
 
 DEFINE_REFCOUNTED_TYPE(TSignature)

yt/yt_proto/yt/client/misc/proto/signature.proto

@@ -0,0 +1,12 @@
+package NYT.NSignature.NProto;
+
+////////////////////////////////////////////////////////////////////////////////
+
+message TSignature
+{
+    required bytes header = 1;
+    required bytes payload = 2;
+    required bytes signature = 3;
+}
+
+////////////////////////////////////////////////////////////////////////////////

yt/yt_proto/yt/client/ya.make

@@ -49,6 +49,7 @@ SRCS(
     scheduler/proto/spec_patch.proto
 
     misc/proto/workload.proto
+    misc/proto/signature.proto
 )
 
 EXCLUDE_TAGS(GO_PROTO)