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

Unified Diff: blimp/engine/feature/geolocation/engine_geolocation_feature.cc

Issue 2091023006: Adds EngineGeolocationFeature for Blimp Geolocation project. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: In response to Wez's #23 comment 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: blimp/engine/feature/geolocation/engine_geolocation_feature.cc
diff --git a/blimp/engine/feature/geolocation/engine_geolocation_feature.cc b/blimp/engine/feature/geolocation/engine_geolocation_feature.cc
new file mode 100644
index 0000000000000000000000000000000000000000..8af873bef4be9ffb13939970717ada974593d5eb
--- /dev/null
+++ b/blimp/engine/feature/geolocation/engine_geolocation_feature.cc
@@ -0,0 +1,151 @@
+// Copyright 2016 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 "blimp/engine/feature/geolocation/engine_geolocation_feature.h"
+
+#include "base/memory/weak_ptr.h"
+#include "blimp/common/create_blimp_message.h"
+#include "blimp/common/proto/blimp_message.pb.h"
+#include "blimp/common/proto/geolocation.pb.h"
+#include "content/public/browser/location_provider.h"
+#include "content/public/common/geoposition.h"
+#include "net/base/net_errors.h"
+
+namespace blimp {
+namespace engine {
+namespace {
+
+content::Geoposition::ErrorCode ConvertErrorCode(
+ const GeolocationErrorMessage::ErrorCode& error_code) {
+ switch (error_code) {
+ case GeolocationErrorMessage::PERMISSION_DENIED:
+ return content::Geoposition::ErrorCode::ERROR_CODE_PERMISSION_DENIED;
+ case GeolocationErrorMessage::POSITION_UNAVAILABLE:
+ return content::Geoposition::ErrorCode::ERROR_CODE_POSITION_UNAVAILABLE;
+ case GeolocationErrorMessage::TIMEOUT:
+ return content::Geoposition::ErrorCode::ERROR_CODE_TIMEOUT;
+ }
+}
+
+content::Geoposition ConvertLocationMessage(
+ const GeolocationPositionMessage& location) {
+ content::Geoposition output;
+ output.latitude = location.coordinates().latitude();
+ output.longitude = location.coordinates().longitude();
+ output.altitude = location.coordinates().altitude();
+ output.accuracy = location.coordinates().accuracy();
+ output.altitude_accuracy = location.coordinates().altitude_accuracy();
+ output.heading = location.coordinates().heading();
+ output.speed = location.coordinates().speed();
+ output.timestamp = base::Time::FromJsTime(location.timestamp_millis());
+ output.error_code = content::Geoposition::ErrorCode::ERROR_CODE_NONE;
+ return output;
+}
+
+} // namespace
+
+EngineGeolocationFeature::EngineGeolocationFeature() : weak_factory_(this) {}
+
+EngineGeolocationFeature::~EngineGeolocationFeature() {}
+
+void EngineGeolocationFeature::set_outgoing_message_processor(
+ std::unique_ptr<BlimpMessageProcessor> message_processor) {
+ DCHECK(message_processor);
+ outgoing_message_processor_ = std::move(message_processor);
+}
+
+base::WeakPtr<EngineGeolocationFeature> EngineGeolocationFeature::GetWeakPtr() {
+ return weak_factory_.GetWeakPtr();
+}
+
+void EngineGeolocationFeature::StartProvider(bool enable_high_accuracy) {
+ GeolocationMessage* geolocation_message = nullptr;
+ std::unique_ptr<BlimpMessage> blimp_message =
+ CreateBlimpMessage(&geolocation_message);
+
+ GeolocationInterestMessage* geolocation_interest =
+ geolocation_message->mutable_update_listen_state();
+ if (enable_high_accuracy) {
+ geolocation_interest->set_listen_state(
+ GeolocationInterestMessage::ACCURACY_HIGH);
+ } else {
+ geolocation_interest->set_listen_state(
+ GeolocationInterestMessage::ACCURACY_LOW);
+ }
+
+ outgoing_message_processor_->ProcessMessage(std::move(blimp_message),
+ net::CompletionCallback());
+}
+
+void EngineGeolocationFeature::StopProvider() {
+ GeolocationMessage* geolocation_message = nullptr;
+ std::unique_ptr<BlimpMessage> blimp_message =
+ CreateBlimpMessage(&geolocation_message);
+
+ GeolocationInterestMessage* geolocation_interest =
+ geolocation_message->mutable_update_listen_state();
+ geolocation_interest->set_listen_state(
+ GeolocationInterestMessage::REQUEST_NONE);
+
+ outgoing_message_processor_->ProcessMessage(std::move(blimp_message),
+ net::CompletionCallback());
+}
+
+void EngineGeolocationFeature::RequestRefresh() {
+ GeolocationMessage* geolocation_message = nullptr;
+ std::unique_ptr<BlimpMessage> blimp_message =
+ CreateBlimpMessage(&geolocation_message);
+
+ geolocation_message->mutable_request_refresh();
+
+ outgoing_message_processor_->ProcessMessage(std::move(blimp_message),
+ net::CompletionCallback());
+}
+
+void EngineGeolocationFeature::SetUpdateCallback(
+ const base::Callback<void(const content::Geoposition&)>& callback) {
+ geolocation_received_callback_ = callback;
+}
+
+void EngineGeolocationFeature::ProcessMessage(
+ std::unique_ptr<BlimpMessage> message,
+ const net::CompletionCallback& callback) {
+ DCHECK(!callback.is_null());
+ DCHECK_EQ(BlimpMessage::kGeolocation, message->feature_case());
+
+ const GeolocationMessage& geolocation_message = message->geolocation();
+
+ switch (geolocation_message.type_case()) {
+ case GeolocationMessage::kLocation: {
+ const GeolocationPositionMessage location =
Wez 2016/07/14 01:19:22 nit: const& here
CJ 2016/07/14 23:55:09 Done.
+ geolocation_message.location();
+ content::Geoposition output = ConvertLocationMessage(location);
+ NotifyCallback(output);
+ break;
+ }
+ case GeolocationMessage::kError: {
+ content::Geoposition output;
Wez 2016/07/14 01:19:22 nit: As per style-guide, only declare |output| imm
CJ 2016/07/14 23:55:09 Done.
+ const GeolocationErrorMessage error_message = geolocation_message.error();
Wez 2016/07/14 01:19:22 nit: const &
CJ 2016/07/14 23:55:09 Done.
+ output.error_message = error_message.error_message();
+ output.error_code = ConvertErrorCode(error_message.error_code());
+ NotifyCallback(output);
+ break;
+ }
+ case GeolocationMessage::kUpdateListenState:
+ case GeolocationMessage::kRequestRefresh:
+ case GeolocationMessage::TYPE_NOT_SET:
+ DLOG(FATAL) << "Client sent unexpected message type."
+ << geolocation_message.type_case();
+ break;
+ }
+ callback.Run(net::OK);
+}
+
+void EngineGeolocationFeature::NotifyCallback(
+ const content::Geoposition& position) {
+ geolocation_received_callback_.Run(position);
+}
+
+} // namespace engine
+} // namespace blimp

Powered by Google App Engine
This is Rietveld 408576698