Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2173)

Unified Diff: chrome/browser/extensions/api/copresence/copresence_translations.cc

Issue 2130803002: Deleting the copresence API. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: . Created 4 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: chrome/browser/extensions/api/copresence/copresence_translations.cc
diff --git a/chrome/browser/extensions/api/copresence/copresence_translations.cc b/chrome/browser/extensions/api/copresence/copresence_translations.cc
deleted file mode 100644
index 3537e2cd99b0afd3391037c46d51713f7f22df1a..0000000000000000000000000000000000000000
--- a/chrome/browser/extensions/api/copresence/copresence_translations.cc
+++ /dev/null
@@ -1,234 +0,0 @@
-// Copyright 2014 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#include "chrome/browser/extensions/api/copresence/copresence_translations.h"
-
-#include "chrome/common/extensions/api/copresence.h"
-#include "components/copresence/proto/data.pb.h"
-#include "components/copresence/proto/enums.pb.h"
-#include "components/copresence/proto/rpcs.pb.h"
-
-using copresence::AUDIO_CONFIGURATION_AUDIBLE;
-using copresence::AUDIO_CONFIGURATION_UNKNOWN;
-using copresence::BROADCAST_AND_SCAN;
-using copresence::BROADCAST_ONLY;
-using copresence::BROADCAST_SCAN_CONFIGURATION_UNKNOWN;
-using copresence::BroadcastScanConfiguration;
-using copresence::ReportRequest;
-using copresence::SCAN_ONLY;
-using copresence::TokenExchangeStrategy;
-
-using extensions::api::copresence::Strategy;
-
-namespace {
-
-const int kDefaultTimeToLiveMs = 5 * 60 * 1000; // 5 minutes.
-const int kMaxTimeToLiveMs = 24 * 60 * 60 * 1000; // 24 hours.
-
-// Checks and returns the ttl provided by the user. If invalid, returns -1.
-int SanitizeTtl(int* user_ttl) {
- return !user_ttl
- ? kDefaultTimeToLiveMs
- : (*user_ttl <= 0 || *user_ttl > kMaxTimeToLiveMs ? -1 : *user_ttl);
-}
-
-BroadcastScanConfiguration TranslateStrategy(const Strategy& strategy) {
- bool only_broadcast = strategy.only_broadcast && *strategy.only_broadcast;
- bool only_scan = strategy.only_scan && *strategy.only_scan;
-
- if (only_broadcast && only_scan)
- return BROADCAST_AND_SCAN;
- if (only_broadcast)
- return BROADCAST_ONLY;
- if (only_scan)
- return SCAN_ONLY;
-
- return BROADCAST_SCAN_CONFIGURATION_UNKNOWN;
-}
-
-// The strategy may be null (unspecified), so we pass it as a pointer.
-void SetTokenExchangeStrategy(const Strategy* strategy,
- BroadcastScanConfiguration default_config,
- TokenExchangeStrategy* strategy_proto) {
- if (strategy) {
- BroadcastScanConfiguration config;
- if (strategy->low_power && *(strategy->low_power)) {
- config = BROADCAST_SCAN_CONFIGURATION_UNKNOWN;
- } else {
- config = TranslateStrategy(*strategy);
- if (config == BROADCAST_SCAN_CONFIGURATION_UNKNOWN)
- config = default_config;
- }
-
- strategy_proto->set_broadcast_scan_configuration(config);
- strategy_proto->set_audio_configuration(
- strategy->audible && *strategy->audible ? AUDIO_CONFIGURATION_AUDIBLE
- : AUDIO_CONFIGURATION_UNKNOWN);
- } else {
- strategy_proto->set_broadcast_scan_configuration(default_config);
- strategy_proto->set_audio_configuration(AUDIO_CONFIGURATION_UNKNOWN);
- }
-}
-
-} // namespace
-
-namespace extensions {
-
-using api::copresence::Operation;
-
-// Adds a publish operation to the report request. Returns false if the
-// publish operation was invalid.
-bool AddPublishToRequest(const std::string& app_id,
- const api::copresence::PublishOperation& publish,
- ReportRequest* request) {
- copresence::PublishedMessage* publish_proto =
- request->mutable_manage_messages_request()->add_message_to_publish();
- publish_proto->mutable_access_policy()->mutable_acl()->set_acl_type(
- copresence::NO_ACL_CHECK);
- publish_proto->set_id(publish.id);
- publish_proto->mutable_message()->mutable_type()->set_type(
- publish.message.type);
- publish_proto->mutable_message()->set_payload(publish.message.payload.data(),
- publish.message.payload.size());
-
- int ttl = SanitizeTtl(publish.time_to_live_millis.get());
- if (ttl < 0)
- return false;
- publish_proto->mutable_access_policy()->set_ttl_millis(ttl);
-
- SetTokenExchangeStrategy(publish.strategies.get(),
- BROADCAST_ONLY,
- publish_proto->mutable_token_exchange_strategy());
-
- DVLOG(2) << "Publishing message of type " << publish.message.type << ":\n"
- << std::string(publish.message.payload.begin(),
- publish.message.payload.end());
- // TODO(ckehoe): Validate that required fields are non-empty, etc.
- return true;
-}
-
-// Adds an unpublish operation to the report request. Returns false if the
-// publish id was invalid.
-bool AddUnpublishToRequest(const std::string& publish_id,
- ReportRequest* request) {
- if (publish_id.empty())
- return false;
-
- request->mutable_manage_messages_request()->add_id_to_unpublish(publish_id);
- DVLOG(2) << "Unpublishing message \"" << publish_id << "\"";
- return true;
-}
-
-// Adds a subscribe operation to the report request. Returns false if the
-// subscription operation was invalid.
-bool AddSubscribeToRequest(
- const std::string& app_id,
- const api::copresence::SubscribeOperation& subscription,
- SubscriptionToAppMap* apps_by_subscription_id,
- ReportRequest* request) {
- // Associate the subscription id with the app id.
- SubscriptionToAppMap::iterator previous_subscription =
- apps_by_subscription_id->find(subscription.id);
- if (previous_subscription == apps_by_subscription_id->end()) {
- (*apps_by_subscription_id)[subscription.id] = app_id;
- } else if (previous_subscription->second == app_id) {
- VLOG(2) << "Overwriting subscription id \"" << subscription.id
- << "\" for app \"" << app_id << "\"";
- } else {
- // A conflicting association exists already.
- VLOG(1) << "Subscription id \"" << subscription.id
- << "\" used by two apps: \"" << previous_subscription->second
- << "\" and \"" << app_id << "\"";
- return false;
- }
-
- // Convert from IDL to server subscription format.
- copresence::Subscription* subscription_proto =
- request->mutable_manage_subscriptions_request()->add_subscription();
- subscription_proto->set_id(subscription.id);
- int ttl = SanitizeTtl(subscription.time_to_live_millis.get());
- if (ttl < 0)
- return false;
- subscription_proto->set_ttl_millis(ttl);
-
- subscription_proto->mutable_message_type()->set_type(
- subscription.filter.type);
-
- SetTokenExchangeStrategy(
- subscription.strategies.get(),
- SCAN_ONLY,
- subscription_proto->mutable_token_exchange_strategy());
-
- DVLOG(2) << "Subscribing for messages of type " << subscription.filter.type;
- // TODO(ckehoe): Validate that required fields are non-empty, etc.
- return true;
-}
-
-// Adds an unpublish operation to the report request. Returns false if the
-// subscription id was invalid.
-bool AddUnsubscribeToRequest(const std::string& app_id,
- const std::string& subscription_id,
- SubscriptionToAppMap* apps_by_subscription_id,
- ReportRequest* request) {
- if (subscription_id.empty())
- return false;
-
- // Check that this subscription id belongs to this app.
- SubscriptionToAppMap::iterator subscription =
- apps_by_subscription_id->find(subscription_id);
- if (subscription == apps_by_subscription_id->end()) {
- LOG(ERROR) << "No such subscription \"" << subscription_id
- << "\". Cannot unsubscribe.";
- return false;
- } else if (subscription->second != app_id) {
- LOG(ERROR) << "Subscription \"" << subscription_id
- << "\" does not belong to app \"" << app_id
- << "\". Cannot unsubscribe.";
- return false;
- } else {
- apps_by_subscription_id->erase(subscription);
- }
-
- request->mutable_manage_subscriptions_request()->add_id_to_unsubscribe(
- subscription_id);
- DVLOG(2) << "Cancelling subscription \"" << subscription_id << "\" for app \""
- << app_id << "\"";
- return true;
-}
-
-bool PrepareReportRequestProto(const std::vector<Operation>& operations,
- const std::string& app_id,
- SubscriptionToAppMap* apps_by_subscription_id,
- ReportRequest* request) {
- for (const Operation& op : operations) {
- // Verify our object has exactly one operation.
- if (static_cast<int>(op.publish != nullptr) +
- static_cast<int>(op.subscribe != nullptr) +
- static_cast<int>(op.unpublish != nullptr) +
- static_cast<int>(op.unsubscribe != nullptr) !=
- 1) {
- return false;
- }
-
- if (op.publish) {
- if (!AddPublishToRequest(app_id, *(op.publish), request))
- return false;
- } else if (op.subscribe) {
- if (!AddSubscribeToRequest(app_id, *(op.subscribe),
- apps_by_subscription_id, request))
- return false;
- } else if (op.unpublish) {
- if (!AddUnpublishToRequest(op.unpublish->unpublish_id, request))
- return false;
- } else { // if (op.unsubscribe)
- if (!AddUnsubscribeToRequest(app_id, op.unsubscribe->unsubscribe_id,
- apps_by_subscription_id, request))
- return false;
- }
- }
-
- return true;
-}
-
-} // namespace extensions
« no previous file with comments | « chrome/browser/extensions/api/copresence/copresence_translations.h ('k') | chrome/browser/prefs/browser_prefs.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698