Skip to content

Commit 8de3efe

Browse files
committed
merge: pick up Filter API removal from #545
2 parents 440ee68 + afe78d6 commit 8de3efe

6 files changed

Lines changed: 15 additions & 25 deletions

File tree

libs/server-sdk/include/launchdarkly/server_side/config/builders/data_system/fdv2_builder.hpp

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@ class FDv2Builder {
1515
class Streaming {
1616
public:
1717
Streaming& InitialReconnectDelay(std::chrono::milliseconds delay);
18-
Streaming& Filter(std::string filter_key);
1918
Streaming& BaseUrl(std::string base_url);
2019
[[nodiscard]] built::FDv2Config::StreamingConfig Build() const;
2120

@@ -28,7 +27,6 @@ class FDv2Builder {
2827
class Polling {
2928
public:
3029
Polling& PollInterval(std::chrono::seconds interval);
31-
Polling& Filter(std::string filter_key);
3230
Polling& BaseUrl(std::string base_url);
3331
[[nodiscard]] built::FDv2Config::PollingConfig Build() const;
3432

libs/server-sdk/include/launchdarkly/server_side/config/built/data_system/fdv2_config.hpp

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,26 +14,22 @@ namespace launchdarkly::server_side::config::built {
1414
struct FDv2Config {
1515
struct StreamingConfig {
1616
std::chrono::milliseconds initial_reconnect_delay;
17-
std::optional<std::string> filter_key;
1817
std::optional<std::string> base_url_override;
1918

2019
friend bool operator==(StreamingConfig const& lhs,
2120
StreamingConfig const& rhs) {
2221
return lhs.initial_reconnect_delay == rhs.initial_reconnect_delay &&
23-
lhs.filter_key == rhs.filter_key &&
2422
lhs.base_url_override == rhs.base_url_override;
2523
}
2624
};
2725

2826
struct PollingConfig {
2927
std::chrono::seconds poll_interval;
30-
std::optional<std::string> filter_key;
3128
std::optional<std::string> base_url_override;
3229

3330
friend bool operator==(PollingConfig const& lhs,
3431
PollingConfig const& rhs) {
3532
return lhs.poll_interval == rhs.poll_interval &&
36-
lhs.filter_key == rhs.filter_key &&
3733
lhs.base_url_override == rhs.base_url_override;
3834
}
3935
};

libs/server-sdk/src/config/builders/data_system/fdv2_builder.cpp

Lines changed: 2 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -10,18 +10,13 @@ FDv2Builder::Streaming& FDv2Builder::Streaming::InitialReconnectDelay(
1010
return *this;
1111
}
1212

13-
FDv2Builder::Streaming& FDv2Builder::Streaming::Filter(std::string filter_key) {
14-
filter_key_ = std::move(filter_key);
15-
return *this;
16-
}
17-
1813
FDv2Builder::Streaming& FDv2Builder::Streaming::BaseUrl(std::string base_url) {
1914
base_url_override_ = std::move(base_url);
2015
return *this;
2116
}
2217

2318
built::FDv2Config::StreamingConfig FDv2Builder::Streaming::Build() const {
24-
return {initial_reconnect_delay_, filter_key_, base_url_override_};
19+
return {initial_reconnect_delay_, base_url_override_};
2520
}
2621

2722
FDv2Builder::Polling& FDv2Builder::Polling::PollInterval(
@@ -30,18 +25,13 @@ FDv2Builder::Polling& FDv2Builder::Polling::PollInterval(
3025
return *this;
3126
}
3227

33-
FDv2Builder::Polling& FDv2Builder::Polling::Filter(std::string filter_key) {
34-
filter_key_ = std::move(filter_key);
35-
return *this;
36-
}
37-
3828
FDv2Builder::Polling& FDv2Builder::Polling::BaseUrl(std::string base_url) {
3929
base_url_override_ = std::move(base_url);
4030
return *this;
4131
}
4232

4333
built::FDv2Config::PollingConfig FDv2Builder::Polling::Build() const {
44-
return {poll_interval_, filter_key_, base_url_override_};
34+
return {poll_interval_, base_url_override_};
4535
}
4636

4737
FDv2Builder::FDv2Builder()

libs/server-sdk/src/data_systems/fdv2/initializer_factories.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ std::unique_ptr<data_interfaces::IFDv2Initializer>
2525
FDv2PollingInitializerFactory::Build() {
2626
return std::make_unique<FDv2PollingInitializer>(
2727
executor_, logger_, polling_base_url_, http_properties_,
28-
data_model::Selector{}, polling_.filter_key);
28+
data_model::Selector{}, std::nullopt);
2929
}
3030

3131
} // namespace launchdarkly::server_side::data_systems

libs/server-sdk/src/data_systems/fdv2/synchronizer_factories.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,8 @@ FDv2StreamingSynchronizerFactory::FDv2StreamingSynchronizerFactory(
2828
std::unique_ptr<data_interfaces::IFDv2Synchronizer>
2929
FDv2StreamingSynchronizerFactory::Build() {
3030
return std::make_unique<FDv2StreamingSynchronizer>(
31-
executor_, logger_, streaming_base_url_, http_properties_,
32-
streaming_.filter_key, streaming_.initial_reconnect_delay);
31+
executor_, logger_, streaming_base_url_, http_properties_, std::nullopt,
32+
streaming_.initial_reconnect_delay);
3333
}
3434

3535
FDv2PollingSynchronizerFactory::FDv2PollingSynchronizerFactory(
@@ -48,8 +48,8 @@ FDv2PollingSynchronizerFactory::FDv2PollingSynchronizerFactory(
4848
std::unique_ptr<data_interfaces::IFDv2Synchronizer>
4949
FDv2PollingSynchronizerFactory::Build() {
5050
return std::make_unique<FDv2PollingSynchronizer>(
51-
executor_, logger_, polling_base_url_, http_properties_,
52-
polling_.filter_key, polling_.poll_interval);
51+
executor_, logger_, polling_base_url_, http_properties_, std::nullopt,
52+
polling_.poll_interval);
5353
}
5454

5555
FDv1StreamingAdapterFactory::FDv1StreamingAdapterFactory(

libs/server-sdk/tests/config_builder_test.cpp

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,8 @@ TEST_F(ConfigBuilderTest, FDv2_MultipleSynchronizers) {
181181
builders::DataSystemBuilder::FDv2::Custom()
182182
.Synchronizer(builders::FDv2Builder::Polling().PollInterval(
183183
std::chrono::seconds{45}))
184-
.Synchronizer(builders::FDv2Builder::Streaming().Filter("filt")));
184+
.Synchronizer(builders::FDv2Builder::Streaming()
185+
/* .Filter("filt") -- public API removed */));
185186

186187
auto cfg = builder.Build();
187188
auto const fdv2_config =
@@ -192,24 +193,29 @@ TEST_F(ConfigBuilderTest, FDv2_MultipleSynchronizers) {
192193
fdv2_config.synchronizers[0]));
193194
ASSERT_TRUE(std::holds_alternative<built::FDv2Config::StreamingConfig>(
194195
fdv2_config.synchronizers[1]));
196+
/* filter_key field removed from public StreamingConfig
195197
EXPECT_EQ(std::get<built::FDv2Config::StreamingConfig>(
196198
fdv2_config.synchronizers[1])
197199
.filter_key,
198200
"filt");
201+
*/
199202
}
200203

201204
TEST_F(ConfigBuilderTest, FDv2_AddingInitializerClearsDefaults) {
202205
ConfigBuilder builder("sdk-123");
203206
builder.DataSystem().Method(
204207
builders::DataSystemBuilder::FDv2::Custom().Initializer(
205-
builders::FDv2Builder::Polling().Filter("flag-subset")));
208+
builders::FDv2Builder::Polling()
209+
/* .Filter("flag-subset") -- public API removed */));
206210

207211
auto cfg = builder.Build();
208212
auto const fdv2_config =
209213
std::get<built::FDv2Config>(cfg->DataSystemConfig().system_);
210214

211215
ASSERT_EQ(fdv2_config.initializers.size(), 1u);
216+
/* filter_key field removed from public PollingConfig
212217
EXPECT_EQ(fdv2_config.initializers[0].filter_key, "flag-subset");
218+
*/
213219
}
214220

215221
TEST_F(ConfigBuilderTest, FDv2_PerSourceBaseUrlOverride) {

0 commit comments

Comments
 (0)