| OLD | NEW |
|---|
| (Empty) |
| 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 | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "mojo/tools/package_manager/package_manager_application.h" | |
| 6 | |
| 7 #include "base/files/file_util.h" | |
| 8 #include "mojo/tools/package_manager/manifest.h" | |
| 9 #include "mojo/tools/package_manager/unpacker.h" | |
| 10 #include "base/message_loop/message_loop.h" | |
| 11 #include "base/stl_util.h" | |
| 12 #include "mojo/public/cpp/application/application_impl.h" | |
| 13 | |
| 14 namespace mojo { | |
| 15 | |
| 16 namespace { | |
| 17 | |
| 18 const base::FilePath::CharType kManifestFileName[] = | |
| 19 FILE_PATH_LITERAL("manifest.json"); | |
| 20 | |
| 21 } // namespace | |
| 22 | |
| 23 PackageManagerApplication::PendingLoad::PendingLoad() { | |
| 24 } | |
| 25 | |
| 26 PackageManagerApplication::PendingLoad::~PendingLoad() { | |
| 27 } | |
| 28 | |
| 29 PackageManagerApplication::PackageManagerApplication() { | |
| 30 } | |
| 31 | |
| 32 PackageManagerApplication::~PackageManagerApplication() { | |
| 33 STLDeleteContainerPairSecondPointers(pending_.begin(), pending_.end()); | |
| 34 } | |
| 35 | |
| 36 void PackageManagerApplication::Initialize(ApplicationImpl* app) { | |
| 37 app->ConnectToService("mojo:network_service", &network_service_); | |
| 38 | |
| 39 printf("Enter URL> "); | |
| 40 char buf[1024]; | |
| 41 if (scanf("%1023s", buf) != 1) { | |
| 42 printf("No input, exiting\n"); | |
| 43 base::MessageLoop::current()->Quit(); | |
| 44 return; | |
| 45 } | |
| 46 GURL url(buf); | |
| 47 if (!url.is_valid()) { | |
| 48 printf("Invalid URL\n"); | |
| 49 base::MessageLoop::current()->Quit(); | |
| 50 return; | |
| 51 } | |
| 52 | |
| 53 StartLoad(url); | |
| 54 } | |
| 55 | |
| 56 void PackageManagerApplication::StartLoad(const GURL& url) { | |
| 57 if (completed_.find(url) != completed_.end() || | |
| 58 pending_.find(url) != pending_.end()) | |
| 59 return; // Already loaded or are loading this one. | |
| 60 | |
| 61 PendingLoad* load = new PendingLoad; | |
| 62 load->fetcher.reset(new mojo::PackageFetcher( | |
| 63 network_service_.get(), this, url)); | |
| 64 pending_[url] = load; | |
| 65 } | |
| 66 | |
| 67 void PackageManagerApplication::LoadDeps(const Manifest& manifest) { | |
| 68 for (size_t i = 0; i < manifest.deps().size(); i++) | |
| 69 StartLoad(manifest.deps()[i]); | |
| 70 } | |
| 71 | |
| 72 void PackageManagerApplication::PendingLoadComplete(const GURL& url) { | |
| 73 pending_.erase(pending_.find(url)); | |
| 74 completed_.insert(url); | |
| 75 if (pending_.empty()) | |
| 76 base::MessageLoop::current()->Quit(); | |
| 77 } | |
| 78 | |
| 79 void PackageManagerApplication::FetchSucceeded( | |
| 80 const GURL& url, | |
| 81 const base::FilePath& name) { | |
| 82 Unpacker unpacker; | |
| 83 if (!unpacker.Unpack(name)) { | |
| 84 base::DeleteFile(name, false); | |
| 85 printf("Failed to unpack\n"); | |
| 86 PendingLoadComplete(url); | |
| 87 return; | |
| 88 } | |
| 89 // The downloaded .zip file is no longer necessary. | |
| 90 base::DeleteFile(name, false); | |
| 91 | |
| 92 // Load the manifest. | |
| 93 base::FilePath manifest_path = unpacker.dir().Append(kManifestFileName); | |
| 94 Manifest manifest; | |
| 95 std::string err_msg; | |
| 96 if (!manifest.ParseFromFile(manifest_path, &err_msg)) { | |
| 97 printf("%s\n", err_msg.c_str()); | |
| 98 PendingLoadComplete(url); | |
| 99 return; | |
| 100 } | |
| 101 | |
| 102 // Enqueue loads for any deps. | |
| 103 LoadDeps(manifest); | |
| 104 | |
| 105 printf("Loaded %s\n", url.spec().c_str()); | |
| 106 PendingLoadComplete(url); | |
| 107 } | |
| 108 | |
| 109 void PackageManagerApplication::FetchFailed(const GURL& url) { | |
| 110 PendingLoadComplete(url); | |
| 111 } | |
| 112 | |
| 113 } // namespace mojo | |
| OLD | NEW |
|---|
Chromium Code Reviews
Issue 1078813002:
Remove //mojo/tools/package_manager. (Closed)
Base URL: https://github.com/domokit/mojo.git@master