| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/browser/payments/payment_app_database.h" | 5 #include "content/browser/payments/payment_app_database.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/optional.h" | 10 #include "base/optional.h" |
| 11 #include "content/browser/payments/payment_app.pb.h" | 11 #include "content/browser/payments/payment_app.pb.h" |
| 12 #include "content/browser/payments/payment_app_context_impl.h" | 12 #include "content/browser/payments/payment_app_context_impl.h" |
| 13 #include "content/browser/service_worker/service_worker_context_wrapper.h" | 13 #include "content/browser/service_worker/service_worker_context_wrapper.h" |
| 14 #include "content/browser/service_worker/service_worker_registration.h" | 14 #include "content/browser/service_worker/service_worker_registration.h" |
| 15 #include "content/public/browser/browser_thread.h" | 15 #include "content/public/browser/browser_thread.h" |
| 16 | 16 |
| 17 namespace content { | 17 namespace content { |
| 18 namespace { | 18 namespace { |
| 19 | 19 |
| 20 using ::payments::mojom::PaymentHandlerStatus; | 20 using ::payments::mojom::PaymentHandlerStatus; |
| 21 using ::payments::mojom::PaymentInstrument; | 21 using ::payments::mojom::PaymentInstrument; |
| 22 using ::payments::mojom::PaymentInstrumentPtr; | 22 using ::payments::mojom::PaymentInstrumentPtr; |
| 23 | 23 |
| 24 const char kPaymentAppManifestDataKey[] = "PaymentAppManifestData"; | 24 const char kPaymentAppManifestDataKey[] = "PaymentAppManifestData"; |
| 25 const char kPaymentInstrumentKeyPrefix[] = "PaymentInstrument:"; |
| 26 |
| 27 std::string CreatePaymentInstrumentKey(const std::string& instrument_key) { |
| 28 return kPaymentInstrumentKeyPrefix + instrument_key; |
| 29 } |
| 25 | 30 |
| 26 payments::mojom::PaymentAppManifestPtr DeserializePaymentAppManifest( | 31 payments::mojom::PaymentAppManifestPtr DeserializePaymentAppManifest( |
| 27 const std::string& input) { | 32 const std::string& input) { |
| 28 PaymentAppManifestProto manifest_proto; | 33 PaymentAppManifestProto manifest_proto; |
| 29 if (!manifest_proto.ParseFromString(input)) | 34 if (!manifest_proto.ParseFromString(input)) |
| 30 return nullptr; | 35 return nullptr; |
| 31 | 36 |
| 32 payments::mojom::PaymentAppManifestPtr manifest = | 37 payments::mojom::PaymentAppManifestPtr manifest = |
| 33 payments::mojom::PaymentAppManifest::New(); | 38 payments::mojom::PaymentAppManifest::New(); |
| 34 manifest->name = manifest_proto.name(); | 39 manifest->name = manifest_proto.name(); |
| (...skipping 246 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 281 DeletePaymentInstrumentCallback callback, | 286 DeletePaymentInstrumentCallback callback, |
| 282 ServiceWorkerStatusCode status, | 287 ServiceWorkerStatusCode status, |
| 283 scoped_refptr<ServiceWorkerRegistration> registration) { | 288 scoped_refptr<ServiceWorkerRegistration> registration) { |
| 284 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 289 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 285 if (status != SERVICE_WORKER_OK) { | 290 if (status != SERVICE_WORKER_OK) { |
| 286 std::move(callback).Run(PaymentHandlerStatus::NO_ACTIVE_WORKER); | 291 std::move(callback).Run(PaymentHandlerStatus::NO_ACTIVE_WORKER); |
| 287 return; | 292 return; |
| 288 } | 293 } |
| 289 | 294 |
| 290 service_worker_context_->GetRegistrationUserData( | 295 service_worker_context_->GetRegistrationUserData( |
| 291 registration->id(), {instrument_key}, | 296 registration->id(), {CreatePaymentInstrumentKey(instrument_key)}, |
| 292 base::Bind(&PaymentAppDatabase::DidFindPaymentInstrument, | 297 base::Bind(&PaymentAppDatabase::DidFindPaymentInstrument, |
| 293 weak_ptr_factory_.GetWeakPtr(), registration->id(), | 298 weak_ptr_factory_.GetWeakPtr(), registration->id(), |
| 294 instrument_key, base::Passed(std::move(callback)))); | 299 instrument_key, base::Passed(std::move(callback)))); |
| 295 } | 300 } |
| 296 | 301 |
| 297 void PaymentAppDatabase::DidFindPaymentInstrument( | 302 void PaymentAppDatabase::DidFindPaymentInstrument( |
| 298 int64_t registration_id, | 303 int64_t registration_id, |
| 299 const std::string& instrument_key, | 304 const std::string& instrument_key, |
| 300 DeletePaymentInstrumentCallback callback, | 305 DeletePaymentInstrumentCallback callback, |
| 301 const std::vector<std::string>& data, | 306 const std::vector<std::string>& data, |
| 302 ServiceWorkerStatusCode status) { | 307 ServiceWorkerStatusCode status) { |
| 303 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 308 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 304 if (status != SERVICE_WORKER_OK || data.size() != 1) { | 309 if (status != SERVICE_WORKER_OK || data.size() != 1) { |
| 305 std::move(callback).Run(PaymentHandlerStatus::NOT_FOUND); | 310 std::move(callback).Run(PaymentHandlerStatus::NOT_FOUND); |
| 306 return; | 311 return; |
| 307 } | 312 } |
| 308 | 313 |
| 309 service_worker_context_->ClearRegistrationUserData( | 314 service_worker_context_->ClearRegistrationUserData( |
| 310 registration_id, {instrument_key}, | 315 registration_id, {CreatePaymentInstrumentKey(instrument_key)}, |
| 311 base::Bind(&PaymentAppDatabase::DidDeletePaymentInstrument, | 316 base::Bind(&PaymentAppDatabase::DidDeletePaymentInstrument, |
| 312 weak_ptr_factory_.GetWeakPtr(), | 317 weak_ptr_factory_.GetWeakPtr(), |
| 313 base::Passed(std::move(callback)))); | 318 base::Passed(std::move(callback)))); |
| 314 } | 319 } |
| 315 | 320 |
| 316 void PaymentAppDatabase::DidDeletePaymentInstrument( | 321 void PaymentAppDatabase::DidDeletePaymentInstrument( |
| 317 DeletePaymentInstrumentCallback callback, | 322 DeletePaymentInstrumentCallback callback, |
| 318 ServiceWorkerStatusCode status) { | 323 ServiceWorkerStatusCode status) { |
| 319 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 324 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 320 return std::move(callback).Run(status == SERVICE_WORKER_OK | 325 return std::move(callback).Run(status == SERVICE_WORKER_OK |
| 321 ? PaymentHandlerStatus::SUCCESS | 326 ? PaymentHandlerStatus::SUCCESS |
| 322 : PaymentHandlerStatus::NOT_FOUND); | 327 : PaymentHandlerStatus::NOT_FOUND); |
| 323 } | 328 } |
| 324 | 329 |
| 325 void PaymentAppDatabase::DidFindRegistrationToReadPaymentInstrument( | 330 void PaymentAppDatabase::DidFindRegistrationToReadPaymentInstrument( |
| 326 const std::string& instrument_key, | 331 const std::string& instrument_key, |
| 327 ReadPaymentInstrumentCallback callback, | 332 ReadPaymentInstrumentCallback callback, |
| 328 ServiceWorkerStatusCode status, | 333 ServiceWorkerStatusCode status, |
| 329 scoped_refptr<ServiceWorkerRegistration> registration) { | 334 scoped_refptr<ServiceWorkerRegistration> registration) { |
| 330 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 335 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 331 if (status != SERVICE_WORKER_OK) { | 336 if (status != SERVICE_WORKER_OK) { |
| 332 std::move(callback).Run(PaymentInstrument::New(), | 337 std::move(callback).Run(PaymentInstrument::New(), |
| 333 PaymentHandlerStatus::NO_ACTIVE_WORKER); | 338 PaymentHandlerStatus::NO_ACTIVE_WORKER); |
| 334 return; | 339 return; |
| 335 } | 340 } |
| 336 | 341 |
| 337 service_worker_context_->GetRegistrationUserData( | 342 service_worker_context_->GetRegistrationUserData( |
| 338 registration->id(), {instrument_key}, | 343 registration->id(), {CreatePaymentInstrumentKey(instrument_key)}, |
| 339 base::Bind(&PaymentAppDatabase::DidReadPaymentInstrument, | 344 base::Bind(&PaymentAppDatabase::DidReadPaymentInstrument, |
| 340 weak_ptr_factory_.GetWeakPtr(), | 345 weak_ptr_factory_.GetWeakPtr(), |
| 341 base::Passed(std::move(callback)))); | 346 base::Passed(std::move(callback)))); |
| 342 } | 347 } |
| 343 | 348 |
| 344 void PaymentAppDatabase::DidReadPaymentInstrument( | 349 void PaymentAppDatabase::DidReadPaymentInstrument( |
| 345 ReadPaymentInstrumentCallback callback, | 350 ReadPaymentInstrumentCallback callback, |
| 346 const std::vector<std::string>& data, | 351 const std::vector<std::string>& data, |
| 347 ServiceWorkerStatusCode status) { | 352 ServiceWorkerStatusCode status) { |
| 348 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 353 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| (...skipping 18 matching lines...) Expand all Loading... |
| 367 HasPaymentInstrumentCallback callback, | 372 HasPaymentInstrumentCallback callback, |
| 368 ServiceWorkerStatusCode status, | 373 ServiceWorkerStatusCode status, |
| 369 scoped_refptr<ServiceWorkerRegistration> registration) { | 374 scoped_refptr<ServiceWorkerRegistration> registration) { |
| 370 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 375 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 371 if (status != SERVICE_WORKER_OK) { | 376 if (status != SERVICE_WORKER_OK) { |
| 372 std::move(callback).Run(PaymentHandlerStatus::NO_ACTIVE_WORKER); | 377 std::move(callback).Run(PaymentHandlerStatus::NO_ACTIVE_WORKER); |
| 373 return; | 378 return; |
| 374 } | 379 } |
| 375 | 380 |
| 376 service_worker_context_->GetRegistrationUserData( | 381 service_worker_context_->GetRegistrationUserData( |
| 377 registration->id(), {instrument_key}, | 382 registration->id(), {CreatePaymentInstrumentKey(instrument_key)}, |
| 378 base::Bind(&PaymentAppDatabase::DidHasPaymentInstrument, | 383 base::Bind(&PaymentAppDatabase::DidHasPaymentInstrument, |
| 379 weak_ptr_factory_.GetWeakPtr(), registration->id(), | 384 weak_ptr_factory_.GetWeakPtr(), registration->id(), |
| 380 instrument_key, base::Passed(std::move(callback)))); | 385 instrument_key, base::Passed(std::move(callback)))); |
| 381 } | 386 } |
| 382 | 387 |
| 383 void PaymentAppDatabase::DidHasPaymentInstrument( | 388 void PaymentAppDatabase::DidHasPaymentInstrument( |
| 384 int64_t registration_id, | 389 int64_t registration_id, |
| 385 const std::string& instrument_key, | 390 const std::string& instrument_key, |
| 386 DeletePaymentInstrumentCallback callback, | 391 DeletePaymentInstrumentCallback callback, |
| 387 const std::vector<std::string>& data, | 392 const std::vector<std::string>& data, |
| (...skipping 26 matching lines...) Expand all Loading... |
| 414 } | 419 } |
| 415 instrument_proto.set_stringified_capabilities( | 420 instrument_proto.set_stringified_capabilities( |
| 416 instrument->stringified_capabilities); | 421 instrument->stringified_capabilities); |
| 417 | 422 |
| 418 std::string serialized; | 423 std::string serialized; |
| 419 bool success = instrument_proto.SerializeToString(&serialized); | 424 bool success = instrument_proto.SerializeToString(&serialized); |
| 420 DCHECK(success); | 425 DCHECK(success); |
| 421 | 426 |
| 422 service_worker_context_->StoreRegistrationUserData( | 427 service_worker_context_->StoreRegistrationUserData( |
| 423 registration->id(), registration->pattern().GetOrigin(), | 428 registration->id(), registration->pattern().GetOrigin(), |
| 424 {{instrument_key, serialized}}, | 429 {{CreatePaymentInstrumentKey(instrument_key), serialized}}, |
| 425 base::Bind(&PaymentAppDatabase::DidWritePaymentInstrument, | 430 base::Bind(&PaymentAppDatabase::DidWritePaymentInstrument, |
| 426 weak_ptr_factory_.GetWeakPtr(), | 431 weak_ptr_factory_.GetWeakPtr(), |
| 427 base::Passed(std::move(callback)))); | 432 base::Passed(std::move(callback)))); |
| 428 } | 433 } |
| 429 | 434 |
| 430 void PaymentAppDatabase::DidWritePaymentInstrument( | 435 void PaymentAppDatabase::DidWritePaymentInstrument( |
| 431 WritePaymentInstrumentCallback callback, | 436 WritePaymentInstrumentCallback callback, |
| 432 ServiceWorkerStatusCode status) { | 437 ServiceWorkerStatusCode status) { |
| 433 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 438 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 434 return std::move(callback).Run( | 439 return std::move(callback).Run( |
| 435 status == SERVICE_WORKER_OK | 440 status == SERVICE_WORKER_OK |
| 436 ? PaymentHandlerStatus::SUCCESS | 441 ? PaymentHandlerStatus::SUCCESS |
| 437 : PaymentHandlerStatus::STORAGE_OPERATION_FAILED); | 442 : PaymentHandlerStatus::STORAGE_OPERATION_FAILED); |
| 438 } | 443 } |
| 439 | 444 |
| 440 } // namespace content | 445 } // namespace content |
| OLD | NEW |