recursive listing is default for YDS

2 files changed, 6 insertions, 10 deletions

diff --git a/ydb/core/http_proxy/http_req.cpp b/ydb/core/http_proxy/http_req.cpp
index 9b07c0cbef0..ebd161e5862 100644
--- a/ydb/core/http_proxy/http_req.cpp
+++ b/ydb/core/http_proxy/http_req.cpp
@@ -583,15 +583,6 @@ namespace NKikimr::NHttpProxy {
     bool THttpRequestProcessors::Execute(const TString& name, THttpRequestContext&& context,
                                          THolder<NKikimr::NSQS::TAwsRequestSignV4> signature,
                                          const TActorContext& ctx) {
-        // TODO: To be removed by CLOUD-79086
-        if (name == "RegisterStreamConsumer" ||
-            name == "DeregisterStreamConsumer" ||
-            name == "ListStreamConsumers") {
-            context.SendBadRequest(NYdb::EStatus::BAD_REQUEST,
-                                   TStringBuilder() << "Unsupported method name " << name, ctx);
-            return false;
-        }
-
         if (auto proc = Name2Processor.find(name); proc != Name2Processor.end()) {
             proc->second->Execute(std::move(context), std::move(signature), ctx);
             return true;
@@ -728,6 +719,11 @@ namespace NKikimr::NHttpProxy {
                 "Empty body";
         }
 
+        // recursive is default setting
+        if (auto listStreamsRequest = dynamic_cast<Ydb::DataStreams::V1::ListStreamsRequest*>(request)) {
+            listStreamsRequest->set_recurse(true);
+        }
+
         std::string bufferStr;
         switch (ContentType) {
         case MIME_CBOR: {
diff --git a/ydb/public/sdk/cpp/client/ydb_datastreams/datastreams.h b/ydb/public/sdk/cpp/client/ydb_datastreams/datastreams.h
index ef1f475d16a..3fbb83f3e54 100644
--- a/ydb/public/sdk/cpp/client/ydb_datastreams/datastreams.h
+++ b/ydb/public/sdk/cpp/client/ydb_datastreams/datastreams.h
@@ -111,7 +111,7 @@ namespace NYdb::NDataStreams::V1 {
     struct TListStreamsSettings : public NYdb::TOperationRequestSettings<TListStreamsSettings> {
         FLUENT_SETTING(ui32, Limit);
         FLUENT_SETTING(TString, ExclusiveStartStreamName);
-        FLUENT_SETTING_DEFAULT(bool, Recurse, false);
+        FLUENT_SETTING_DEFAULT(bool, Recurse, true);
     };
     struct TDeleteStreamSettings : public NYdb::TOperationRequestSettings<TDeleteStreamSettings> {
         FLUENT_SETTING_DEFAULT(bool, EnforceConsumerDeletion, false);