added query script

Author: StekPerepolnen

ydb/core/grpc_services/local_rpc/local_rpc.h

@@ -293,12 +293,12 @@ concept TRequestWithOperationParams = requires(TRequest& request) {
 };
 
 template<TRequestWithOperationParams TRequest>
-void SetRequestSyncOperationMode(TRequest& request) {
-    request.mutable_operation_params()->set_operation_mode(Ydb::Operations::OperationParams::SYNC);
+void SetRequestSyncOperationMode(TRequest& request, Ydb::Operations::OperationParams::OperationMode operationMode = Ydb::Operations::OperationParams::SYNC) {
+    request.mutable_operation_params()->set_operation_mode(operationMode);
 }
 
 template<class TRequest>
-void SetRequestSyncOperationMode(TRequest&) {
+void SetRequestSyncOperationMode(TRequest&, Ydb::Operations::OperationParams::OperationMode) {
     // nothing
 }
 
@@ -308,7 +308,7 @@ NThreading::TFuture<typename TRpc::TResponse> DoLocalRpc(typename TRpc::TRequest
         TActorSystem* actorSystem, bool internalCall = false) {
     auto promise = NThreading::NewPromise<typename TRpc::TResponse>();
 
-    SetRequestSyncOperationMode(proto);
+    SetRequestSyncOperationMode(proto, operationMode);
 
     using TCbWrapper = TPromiseWrapper<typename TRpc::TResponse>;
     auto req = new TLocalRpcCtx<TRpc, TCbWrapper>(std::move(proto), TCbWrapper(promise), database, token, requestType, internalCall);
@@ -319,8 +319,8 @@ NThreading::TFuture<typename TRpc::TResponse> DoLocalRpc(typename TRpc::TRequest
 }
 
 template<typename TRpc>
-NThreading::TFuture<typename TRpc::TResponse> DoLocalRpc(typename TRpc::TRequest&& proto, const TString& database, const TMaybe<TString>& token, TActorSystem* actorSystem, bool internalCall = false) {
-    return DoLocalRpc<TRpc>(std::move(proto), database, token, Nothing(), actorSystem, internalCall);
+NThreading::TFuture<typename TRpc::TResponse> DoLocalRpc(typename TRpc::TRequest&& proto, const TString& database, const TMaybe<TString>& token, TActorSystem* actorSystem, bool internalCall = false, Ydb::Operations::OperationParams::OperationMode operationMode = Ydb::Operations::OperationParams::SYNC) {
+    return DoLocalRpc<TRpc>(std::move(proto), database, token, Nothing(), actorSystem, internalCall, operationMode);
 }
 
 template<typename TRpc>

ydb/core/viewer/json_local_rpc.h

@@ -33,6 +33,7 @@ class TJsonLocalRpc : public TViewerPipeClient {
     std::vector<HTTP_METHOD> AllowedMethods = {};
     TAutoPtr<TEvLocalRpcPrivate::TEvGrpcRequestResult<TProtoResult>> Result;
     NThreading::TFuture<TProtoResponse> RpcFuture;
+    Ydb::Operations::OperationParams::OperationMode OperationMode = Ydb::Operations::OperationParams::SYNC;
 
 public:
     static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
@@ -142,6 +143,7 @@ class TJsonLocalRpc : public TViewerPipeClient {
     void SendGrpcRequest(TProtoRequest&& request) {
         // TODO(xenoxeno): pass trace id
         RpcFuture = NRpcService::DoLocalRpc<TRpcEv>(std::move(request), Database, Event->Get()->UserToken, TlsActivationContext->ActorSystem());
+
         RpcFuture.Subscribe([actorId = TBase::SelfId(), actorSystem = TlsActivationContext->ActorSystem()]
                             (const NThreading::TFuture<TProtoResponse>& future) {
             auto& response = future.GetValueSync();

ydb/core/viewer/viewer_ut.cpp

@@ -1885,7 +1885,6 @@ Y_UNIT_TEST_SUITE(Viewer) {
     }
 
     Y_UNIT_TEST(QueryExecuteScript) {
-        Cerr << "iiiiiii 0 " << Endl;
         TPortManager tp;
         ui16 port = tp.GetPort(2134);
         ui16 grpcPort = tp.GetPort(2135);