OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "mojo/shell/application_manager.h" | 5 #include "mojo/shell/application_manager.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/at_exit.h" | 9 #include "base/at_exit.h" |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
11 #include "base/macros.h" | 11 #include "base/macros.h" |
12 #include "base/memory/scoped_vector.h" | 12 #include "base/memory/scoped_vector.h" |
13 #include "base/message_loop/message_loop.h" | 13 #include "base/message_loop/message_loop.h" |
14 #include "base/run_loop.h" | 14 #include "base/run_loop.h" |
15 #include "mojo/public/cpp/bindings/strong_binding.h" | 15 #include "mojo/public/cpp/bindings/strong_binding.h" |
16 #include "mojo/shell/application_loader.h" | 16 #include "mojo/shell/application_loader.h" |
17 #include "mojo/shell/connect_util.h" | 17 #include "mojo/shell/connect_util.h" |
18 #include "mojo/shell/fetcher.h" | 18 #include "mojo/shell/fetcher.h" |
19 #include "mojo/shell/package_manager.h" | 19 #include "mojo/shell/package_manager.h" |
20 #include "mojo/shell/public/cpp/interface_factory.h" | 20 #include "mojo/shell/public/cpp/interface_factory.h" |
21 #include "mojo/shell/public/cpp/shell_client.h" | 21 #include "mojo/shell/public/cpp/shell_client.h" |
22 #include "mojo/shell/public/cpp/shell_connection.h" | 22 #include "mojo/shell/public/cpp/shell_connection.h" |
23 #include "mojo/shell/public/interfaces/service_provider.mojom.h" | 23 #include "mojo/shell/public/interfaces/interface_provider.mojom.h" |
24 #include "mojo/shell/test.mojom.h" | 24 #include "mojo/shell/test.mojom.h" |
25 #include "mojo/shell/test_package_manager.h" | 25 #include "mojo/shell/test_package_manager.h" |
26 #include "testing/gtest/include/gtest/gtest.h" | 26 #include "testing/gtest/include/gtest/gtest.h" |
27 | 27 |
28 namespace mojo { | 28 namespace mojo { |
29 namespace shell { | 29 namespace shell { |
30 namespace test { | 30 namespace test { |
31 | 31 |
32 const char kTestURLString[] = "test:testService"; | 32 const char kTestURLString[] = "test:testService"; |
33 const char kTestAURLString[] = "test:TestA"; | 33 const char kTestAURLString[] = "test:TestA"; |
(...skipping 361 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
395 | 395 |
396 void SetUp() override { | 396 void SetUp() override { |
397 application_manager_.reset(new ApplicationManager( | 397 application_manager_.reset(new ApplicationManager( |
398 make_scoped_ptr(new TestPackageManager))); | 398 make_scoped_ptr(new TestPackageManager))); |
399 test_loader_ = new TestApplicationLoader; | 399 test_loader_ = new TestApplicationLoader; |
400 test_loader_->set_context(&context_); | 400 test_loader_->set_context(&context_); |
401 application_manager_->set_default_loader( | 401 application_manager_->set_default_loader( |
402 scoped_ptr<ApplicationLoader>(test_loader_)); | 402 scoped_ptr<ApplicationLoader>(test_loader_)); |
403 | 403 |
404 TestServicePtr service_proxy; | 404 TestServicePtr service_proxy; |
405 ConnectToService(application_manager_.get(), GURL(kTestURLString), | 405 ConnectToInterface(application_manager_.get(), GURL(kTestURLString), |
406 &service_proxy); | 406 &service_proxy); |
407 test_client_.reset(new TestClient(std::move(service_proxy))); | 407 test_client_.reset(new TestClient(std::move(service_proxy))); |
408 } | 408 } |
409 | 409 |
410 void TearDown() override { | 410 void TearDown() override { |
411 test_client_.reset(); | 411 test_client_.reset(); |
412 application_manager_.reset(); | 412 application_manager_.reset(); |
413 } | 413 } |
414 | 414 |
415 void AddLoaderForURL(const GURL& url, const std::string& requestor_url) { | 415 void AddLoaderForURL(const GURL& url, const std::string& requestor_url) { |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
472 TEST_F(ApplicationManagerTest, SetLoaders) { | 472 TEST_F(ApplicationManagerTest, SetLoaders) { |
473 TestApplicationLoader* default_loader = new TestApplicationLoader; | 473 TestApplicationLoader* default_loader = new TestApplicationLoader; |
474 TestApplicationLoader* url_loader = new TestApplicationLoader; | 474 TestApplicationLoader* url_loader = new TestApplicationLoader; |
475 application_manager_->set_default_loader( | 475 application_manager_->set_default_loader( |
476 scoped_ptr<ApplicationLoader>(default_loader)); | 476 scoped_ptr<ApplicationLoader>(default_loader)); |
477 application_manager_->SetLoaderForURL( | 477 application_manager_->SetLoaderForURL( |
478 scoped_ptr<ApplicationLoader>(url_loader), GURL("test:test1")); | 478 scoped_ptr<ApplicationLoader>(url_loader), GURL("test:test1")); |
479 | 479 |
480 // test::test1 should go to url_loader. | 480 // test::test1 should go to url_loader. |
481 TestServicePtr test_service; | 481 TestServicePtr test_service; |
482 ConnectToService(application_manager_.get(), GURL("test:test1"), | 482 ConnectToInterface(application_manager_.get(), GURL("test:test1"), |
483 &test_service); | 483 &test_service); |
484 EXPECT_EQ(1, url_loader->num_loads()); | 484 EXPECT_EQ(1, url_loader->num_loads()); |
485 EXPECT_EQ(0, default_loader->num_loads()); | 485 EXPECT_EQ(0, default_loader->num_loads()); |
486 | 486 |
487 // http::test1 should go to default loader. | 487 // http::test1 should go to default loader. |
488 ConnectToService(application_manager_.get(), GURL("http:test1"), | 488 ConnectToInterface(application_manager_.get(), GURL("http:test1"), |
489 &test_service); | 489 &test_service); |
490 EXPECT_EQ(1, url_loader->num_loads()); | 490 EXPECT_EQ(1, url_loader->num_loads()); |
491 EXPECT_EQ(1, default_loader->num_loads()); | 491 EXPECT_EQ(1, default_loader->num_loads()); |
492 } | 492 } |
493 | 493 |
494 // Confirm that the url of a service is correctly passed to another service that | 494 // Confirm that the url of a service is correctly passed to another service that |
495 // it loads. | 495 // it loads. |
496 TEST_F(ApplicationManagerTest, ACallB) { | 496 TEST_F(ApplicationManagerTest, ACallB) { |
497 // Any url can load a. | 497 // Any url can load a. |
498 AddLoaderForURL(GURL(kTestAURLString), std::string()); | 498 AddLoaderForURL(GURL(kTestAURLString), std::string()); |
499 | 499 |
500 // Only a can load b. | 500 // Only a can load b. |
501 AddLoaderForURL(GURL(kTestBURLString), kTestAURLString); | 501 AddLoaderForURL(GURL(kTestBURLString), kTestAURLString); |
502 | 502 |
503 TestAPtr a; | 503 TestAPtr a; |
504 ConnectToService(application_manager_.get(), GURL(kTestAURLString), &a); | 504 ConnectToInterface(application_manager_.get(), GURL(kTestAURLString), &a); |
505 a->CallB(); | 505 a->CallB(); |
506 loop_.Run(); | 506 loop_.Run(); |
507 EXPECT_EQ(1, tester_context_.num_b_calls()); | 507 EXPECT_EQ(1, tester_context_.num_b_calls()); |
508 EXPECT_TRUE(tester_context_.a_called_quit()); | 508 EXPECT_TRUE(tester_context_.a_called_quit()); |
509 } | 509 } |
510 | 510 |
511 // A calls B which calls C. | 511 // A calls B which calls C. |
512 TEST_F(ApplicationManagerTest, BCallC) { | 512 TEST_F(ApplicationManagerTest, BCallC) { |
513 // Any url can load a. | 513 // Any url can load a. |
514 AddLoaderForURL(GURL(kTestAURLString), std::string()); | 514 AddLoaderForURL(GURL(kTestAURLString), std::string()); |
515 | 515 |
516 // Only a can load b. | 516 // Only a can load b. |
517 AddLoaderForURL(GURL(kTestBURLString), kTestAURLString); | 517 AddLoaderForURL(GURL(kTestBURLString), kTestAURLString); |
518 | 518 |
519 TestAPtr a; | 519 TestAPtr a; |
520 ConnectToService(application_manager_.get(), GURL(kTestAURLString), &a); | 520 ConnectToInterface(application_manager_.get(), GURL(kTestAURLString), &a); |
521 a->CallCFromB(); | 521 a->CallCFromB(); |
522 loop_.Run(); | 522 loop_.Run(); |
523 | 523 |
524 EXPECT_EQ(1, tester_context_.num_b_calls()); | 524 EXPECT_EQ(1, tester_context_.num_b_calls()); |
525 EXPECT_EQ(1, tester_context_.num_c_calls()); | 525 EXPECT_EQ(1, tester_context_.num_c_calls()); |
526 EXPECT_TRUE(tester_context_.a_called_quit()); | 526 EXPECT_TRUE(tester_context_.a_called_quit()); |
527 } | 527 } |
528 | 528 |
529 // Confirm that a service impl will be deleted if the app that connected to | 529 // Confirm that a service impl will be deleted if the app that connected to |
530 // it goes away. | 530 // it goes away. |
531 TEST_F(ApplicationManagerTest, BDeleted) { | 531 TEST_F(ApplicationManagerTest, BDeleted) { |
532 AddLoaderForURL(GURL(kTestAURLString), std::string()); | 532 AddLoaderForURL(GURL(kTestAURLString), std::string()); |
533 AddLoaderForURL(GURL(kTestBURLString), std::string()); | 533 AddLoaderForURL(GURL(kTestBURLString), std::string()); |
534 | 534 |
535 TestAPtr a; | 535 TestAPtr a; |
536 ConnectToService(application_manager_.get(), GURL(kTestAURLString), &a); | 536 ConnectToInterface(application_manager_.get(), GURL(kTestAURLString), &a); |
537 | 537 |
538 a->CallB(); | 538 a->CallB(); |
539 loop_.Run(); | 539 loop_.Run(); |
540 | 540 |
541 // Kills the a app. | 541 // Kills the a app. |
542 application_manager_->SetLoaderForURL(scoped_ptr<ApplicationLoader>(), | 542 application_manager_->SetLoaderForURL(scoped_ptr<ApplicationLoader>(), |
543 GURL(kTestAURLString)); | 543 GURL(kTestAURLString)); |
544 loop_.Run(); | 544 loop_.Run(); |
545 | 545 |
546 EXPECT_EQ(1, tester_context_.num_b_deletes()); | 546 EXPECT_EQ(1, tester_context_.num_b_deletes()); |
547 } | 547 } |
548 | 548 |
549 // Confirm that the url of a service is correctly passed to another service that | 549 // Confirm that the url of a service is correctly passed to another service that |
550 // it loads, and that it can be rejected. | 550 // it loads, and that it can be rejected. |
551 TEST_F(ApplicationManagerTest, ANoLoadB) { | 551 TEST_F(ApplicationManagerTest, ANoLoadB) { |
552 // Any url can load a. | 552 // Any url can load a. |
553 AddLoaderForURL(GURL(kTestAURLString), std::string()); | 553 AddLoaderForURL(GURL(kTestAURLString), std::string()); |
554 | 554 |
555 // Only c can load b, so this will fail. | 555 // Only c can load b, so this will fail. |
556 AddLoaderForURL(GURL(kTestBURLString), "test:TestC"); | 556 AddLoaderForURL(GURL(kTestBURLString), "test:TestC"); |
557 | 557 |
558 TestAPtr a; | 558 TestAPtr a; |
559 ConnectToService(application_manager_.get(), GURL(kTestAURLString), &a); | 559 ConnectToInterface(application_manager_.get(), GURL(kTestAURLString), &a); |
560 a->CallB(); | 560 a->CallB(); |
561 loop_.Run(); | 561 loop_.Run(); |
562 EXPECT_EQ(0, tester_context_.num_b_calls()); | 562 EXPECT_EQ(0, tester_context_.num_b_calls()); |
563 | 563 |
564 EXPECT_FALSE(tester_context_.a_called_quit()); | 564 EXPECT_FALSE(tester_context_.a_called_quit()); |
565 EXPECT_TRUE(tester_context_.tester_called_quit()); | 565 EXPECT_TRUE(tester_context_.tester_called_quit()); |
566 } | 566 } |
567 | 567 |
568 TEST_F(ApplicationManagerTest, NoServiceNoLoad) { | 568 TEST_F(ApplicationManagerTest, NoServiceNoLoad) { |
569 AddLoaderForURL(GURL(kTestAURLString), std::string()); | 569 AddLoaderForURL(GURL(kTestAURLString), std::string()); |
570 | 570 |
571 // There is no TestC service implementation registered with | 571 // There is no TestC service implementation registered with |
572 // ApplicationManager, so this cannot succeed (but also shouldn't crash). | 572 // ApplicationManager, so this cannot succeed (but also shouldn't crash). |
573 TestCPtr c; | 573 TestCPtr c; |
574 ConnectToService(application_manager_.get(), GURL(kTestAURLString), &c); | 574 ConnectToInterface(application_manager_.get(), GURL(kTestAURLString), &c); |
575 c.set_connection_error_handler( | 575 c.set_connection_error_handler( |
576 []() { base::MessageLoop::current()->QuitWhenIdle(); }); | 576 []() { base::MessageLoop::current()->QuitWhenIdle(); }); |
577 | 577 |
578 loop_.Run(); | 578 loop_.Run(); |
579 EXPECT_TRUE(c.encountered_error()); | 579 EXPECT_TRUE(c.encountered_error()); |
580 } | 580 } |
581 | 581 |
582 TEST_F(ApplicationManagerTest, TestEndApplicationClosure) { | 582 TEST_F(ApplicationManagerTest, TestEndApplicationClosure) { |
583 ClosingApplicationLoader* loader = new ClosingApplicationLoader(); | 583 ClosingApplicationLoader* loader = new ClosingApplicationLoader(); |
584 application_manager_->SetLoaderForURL( | 584 application_manager_->SetLoaderForURL( |
585 scoped_ptr<ApplicationLoader>(loader), GURL("test:test")); | 585 scoped_ptr<ApplicationLoader>(loader), GURL("test:test")); |
586 | 586 |
587 bool called = false; | 587 bool called = false; |
588 scoped_ptr<ConnectToApplicationParams> params(new ConnectToApplicationParams); | 588 scoped_ptr<ConnectToApplicationParams> params(new ConnectToApplicationParams); |
589 params->SetTargetURL(GURL("test:test")); | 589 params->SetTargetURL(GURL("test:test")); |
590 params->set_on_application_end( | 590 params->set_on_application_end( |
591 base::Bind(&QuitClosure, base::Unretained(&called))); | 591 base::Bind(&QuitClosure, base::Unretained(&called))); |
592 application_manager_->ConnectToApplication(std::move(params)); | 592 application_manager_->ConnectToApplication(std::move(params)); |
593 loop_.Run(); | 593 loop_.Run(); |
594 EXPECT_TRUE(called); | 594 EXPECT_TRUE(called); |
595 } | 595 } |
596 | 596 |
597 TEST_F(ApplicationManagerTest, SameIdentityShouldNotCauseDuplicateLoad) { | 597 TEST_F(ApplicationManagerTest, SameIdentityShouldNotCauseDuplicateLoad) { |
598 // 1 because ApplicationManagerTest connects once at startup. | 598 // 1 because ApplicationManagerTest connects once at startup. |
599 EXPECT_EQ(1, test_loader_->num_loads()); | 599 EXPECT_EQ(1, test_loader_->num_loads()); |
600 | 600 |
601 TestServicePtr test_service; | 601 TestServicePtr test_service; |
602 ConnectToService(application_manager_.get(), | 602 ConnectToInterface(application_manager_.get(), |
603 GURL("http://www.example.org/abc?def"), &test_service); | 603 GURL("http://www.example.org/abc?def"), &test_service); |
604 EXPECT_EQ(2, test_loader_->num_loads()); | 604 EXPECT_EQ(2, test_loader_->num_loads()); |
605 | 605 |
606 // Exactly the same URL as above. | 606 // Exactly the same URL as above. |
607 ConnectToService(application_manager_.get(), | 607 ConnectToInterface(application_manager_.get(), |
608 GURL("http://www.example.org/abc?def"), &test_service); | 608 GURL("http://www.example.org/abc?def"), &test_service); |
609 EXPECT_EQ(2, test_loader_->num_loads()); | 609 EXPECT_EQ(2, test_loader_->num_loads()); |
610 | 610 |
611 // The same identity as the one above because only the query string is | 611 // The same identity as the one above because only the query string is |
612 // different. | 612 // different. |
613 ConnectToService(application_manager_.get(), | 613 ConnectToInterface(application_manager_.get(), |
614 GURL("http://www.example.org/abc"), &test_service); | 614 GURL("http://www.example.org/abc"), &test_service); |
615 EXPECT_EQ(2, test_loader_->num_loads()); | 615 EXPECT_EQ(2, test_loader_->num_loads()); |
616 | 616 |
617 // A different identity because the path is different. | 617 // A different identity because the path is different. |
618 ConnectToService(application_manager_.get(), | 618 ConnectToInterface(application_manager_.get(), |
619 GURL("http://www.example.org/another_path"), &test_service); | 619 GURL("http://www.example.org/another_path"), &test_service)
; |
620 EXPECT_EQ(3, test_loader_->num_loads()); | 620 EXPECT_EQ(3, test_loader_->num_loads()); |
621 | 621 |
622 // A different identity because the domain is different. | 622 // A different identity because the domain is different. |
623 ConnectToService(application_manager_.get(), | 623 ConnectToInterface(application_manager_.get(), |
624 GURL("http://www.another_domain.org/abc"), &test_service); | 624 GURL("http://www.another_domain.org/abc"), &test_service); |
625 EXPECT_EQ(4, test_loader_->num_loads()); | 625 EXPECT_EQ(4, test_loader_->num_loads()); |
626 } | 626 } |
627 | 627 |
628 } // namespace test | 628 } // namespace test |
629 } // namespace shell | 629 } // namespace shell |
630 } // namespace mojo | 630 } // namespace mojo |
OLD | NEW |