Index: components/copresence/rpc/rpc_handler.cc |
diff --git a/components/copresence/rpc/rpc_handler.cc b/components/copresence/rpc/rpc_handler.cc |
index 72c4f906bc4a42d7789fbd9321a699c296a92278..0b60a77fa92fb53fe5e61287ec9bcd0c383d21f6 100644 |
--- a/components/copresence/rpc/rpc_handler.cc |
+++ b/components/copresence/rpc/rpc_handler.cc |
@@ -206,40 +206,6 @@ void AddTokenToRequest(ReportRequest* request, const AudioToken& token) { |
signals->set_observed_time_millis(base::Time::Now().ToJsTime()); |
} |
-OptInStateFilter* CreateOptedInOrOutFilter() { |
- OptInStateFilter* filter = new OptInStateFilter; |
- filter->add_allowed_opt_in_state(copresence::OPTED_IN); |
- filter->add_allowed_opt_in_state(copresence::OPTED_OUT); |
- return filter; |
-} |
- |
-void AllowOptedOutMessages(ReportRequest* request) { |
- // TODO(ckehoe): Collapse this pattern into ProcessPublish() |
- // and ProcessSubscribe() methods. |
- |
- if (request->has_manage_messages_request()) { |
- RepeatedPtrField<PublishedMessage>* messages = request |
- ->mutable_manage_messages_request()->mutable_message_to_publish(); |
- for (int i = 0; i < messages->size(); ++i) { |
- PublishedMessage* message = messages->Mutable(i); |
- if (!message->has_opt_in_state_filter()) |
- message->set_allocated_opt_in_state_filter(CreateOptedInOrOutFilter()); |
- } |
- } |
- |
- if (request->has_manage_subscriptions_request()) { |
- RepeatedPtrField<Subscription>* subscriptions = |
- request->mutable_manage_subscriptions_request()->mutable_subscription(); |
- for (int i = 0; i < subscriptions->size(); ++i) { |
- Subscription* subscription = subscriptions->Mutable(i); |
- if (!subscription->has_opt_in_state_filter()) { |
- subscription->set_allocated_opt_in_state_filter( |
- CreateOptedInOrOutFilter()); |
- } |
- } |
- } |
-} |
- |
} // namespace |
// Public methods |
@@ -306,7 +272,25 @@ void RpcHandler::SendReportRequest(scoped_ptr<ReportRequest> request, |
AddPlayingTokens(request.get()); |
- AllowOptedOutMessages(request.get()); |
+ // TODO(ckehoe): Currently the server supports only BROADCAST_AND_SCAN. |
+ // Remove this once b/16715253 is fixed. |
+ if (request->has_manage_messages_request()) { |
+ RepeatedPtrField<PublishedMessage>* messages = request |
+ ->mutable_manage_messages_request()->mutable_message_to_publish(); |
+ for (int i = 0; i < messages->size(); ++i) { |
+ messages->Mutable(i)->mutable_token_exchange_strategy() |
+ ->set_broadcast_scan_configuration(BROADCAST_AND_SCAN); |
+ } |
+ } |
+ if (request->has_manage_subscriptions_request()) { |
+ RepeatedPtrField<Subscription>* subscriptions = |
+ request->mutable_manage_subscriptions_request()->mutable_subscription(); |
+ for (int i = 0; i < subscriptions->size(); ++i) { |
+ subscriptions->Mutable(i)->mutable_token_exchange_strategy() |
+ ->set_broadcast_scan_configuration(BROADCAST_AND_SCAN); |
+ } |
+ } |
+ |
SendServerRequest(kReportRequestRpcName, |
app_id, |
request.Pass(), |