| 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 "services/catalog/reader.h" | 5 #include "services/catalog/reader.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/files/file_enumerator.h" | 8 #include "base/files/file_enumerator.h" |
| 9 #include "base/files/file_util.h" | 9 #include "base/files/file_util.h" |
| 10 #include "base/json/json_file_value_serializer.h" | 10 #include "base/json/json_file_value_serializer.h" |
| (...skipping 18 matching lines...) Expand all Loading... |
| 29 if (type == shell::kNameType_Mojo) { | 29 if (type == shell::kNameType_Mojo) { |
| 30 return package_dir.AppendASCII(kMojoApplicationsDirName).AppendASCII( | 30 return package_dir.AppendASCII(kMojoApplicationsDirName).AppendASCII( |
| 31 path + "/manifest.json"); | 31 path + "/manifest.json"); |
| 32 } | 32 } |
| 33 if (type == shell::kNameType_Exe) | 33 if (type == shell::kNameType_Exe) |
| 34 return package_dir.AppendASCII(path + "_manifest.json"); | 34 return package_dir.AppendASCII(path + "_manifest.json"); |
| 35 return base::FilePath(); | 35 return base::FilePath(); |
| 36 } | 36 } |
| 37 | 37 |
| 38 | 38 |
| 39 base::FilePath GetPackagePath(const base::FilePath& package_dir, | 39 base::FilePath GetExecutablePath(const base::FilePath& package_dir, |
| 40 const std::string& name) { | 40 const std::string& name) { |
| 41 std::string type = shell::GetNameType(name); | 41 std::string type = shell::GetNameType(name); |
| 42 if (type == shell::kNameType_Mojo) { | 42 if (type == shell::kNameType_Mojo) { |
| 43 // It's still a mojo: URL, use the default mapping scheme. | 43 // It's still a mojo: URL, use the default mapping scheme. |
| 44 const std::string host = shell::GetNamePath(name); | 44 const std::string host = shell::GetNamePath(name); |
| 45 return package_dir.AppendASCII(host + "/" + host + ".mojo"); | 45 return package_dir.AppendASCII(host + "/" + host + ".library"); |
| 46 } | 46 } |
| 47 if (type == shell::kNameType_Exe) { | 47 if (type == shell::kNameType_Exe) { |
| 48 #if defined OS_WIN | 48 #if defined OS_WIN |
| 49 std::string extension = ".exe"; | 49 std::string extension = ".exe"; |
| 50 #else | 50 #else |
| 51 std::string extension; | 51 std::string extension; |
| 52 #endif | 52 #endif |
| 53 return package_dir.AppendASCII(shell::GetNamePath(name) + extension); | 53 return package_dir.AppendASCII(shell::GetNamePath(name) + extension); |
| 54 } | 54 } |
| 55 return base::FilePath(); | 55 return base::FilePath(); |
| 56 } | 56 } |
| 57 | 57 |
| 58 std::unique_ptr<Entry> ProcessManifest( | 58 std::unique_ptr<Entry> ProcessManifest( |
| 59 std::unique_ptr<base::Value> manifest_root, | 59 std::unique_ptr<base::Value> manifest_root, |
| 60 const base::FilePath& package_dir) { | 60 const base::FilePath& package_dir) { |
| 61 // Manifest was malformed or did not exist. | 61 // Manifest was malformed or did not exist. |
| 62 if (!manifest_root) | 62 if (!manifest_root) |
| 63 return nullptr; | 63 return nullptr; |
| 64 | 64 |
| 65 const base::DictionaryValue* dictionary = nullptr; | 65 const base::DictionaryValue* dictionary = nullptr; |
| 66 if (!manifest_root->GetAsDictionary(&dictionary)) | 66 if (!manifest_root->GetAsDictionary(&dictionary)) |
| 67 return nullptr; | 67 return nullptr; |
| 68 | 68 |
| 69 std::unique_ptr<Entry> entry = Entry::Deserialize(*dictionary); | 69 std::unique_ptr<Entry> entry = Entry::Deserialize(*dictionary); |
| 70 if (!entry) | 70 if (!entry) |
| 71 return nullptr; | 71 return nullptr; |
| 72 entry->set_path(GetPackagePath(package_dir, entry->name())); | 72 entry->set_path(GetExecutablePath(package_dir, entry->name())); |
| 73 return entry; | 73 return entry; |
| 74 } | 74 } |
| 75 | 75 |
| 76 std::unique_ptr<Entry> CreateEntryForManifestAt( | 76 std::unique_ptr<Entry> CreateEntryForManifestAt( |
| 77 const base::FilePath& manifest_path, | 77 const base::FilePath& manifest_path, |
| 78 const base::FilePath& package_dir) { | 78 const base::FilePath& package_dir) { |
| 79 JSONFileValueDeserializer deserializer(manifest_path); | 79 JSONFileValueDeserializer deserializer(manifest_path); |
| 80 int error = 0; | 80 int error = 0; |
| 81 std::string message; | 81 std::string message; |
| 82 | 82 |
| (...skipping 16 matching lines...) Expand all Loading... |
| 99 break; | 99 break; |
| 100 base::FilePath manifest_path = path.AppendASCII("manifest.json"); | 100 base::FilePath manifest_path = path.AppendASCII("manifest.json"); |
| 101 std::unique_ptr<Entry> entry = | 101 std::unique_ptr<Entry> entry = |
| 102 CreateEntryForManifestAt(manifest_path, package_dir); | 102 CreateEntryForManifestAt(manifest_path, package_dir); |
| 103 if (!entry) | 103 if (!entry) |
| 104 continue; | 104 continue; |
| 105 | 105 |
| 106 // Skip over subdirs that contain only manifests, they're artifacts of the | 106 // Skip over subdirs that contain only manifests, they're artifacts of the |
| 107 // build (e.g. for applications that are packaged into others) and are not | 107 // build (e.g. for applications that are packaged into others) and are not |
| 108 // valid standalone packages. | 108 // valid standalone packages. |
| 109 base::FilePath package_path = GetPackagePath(package_dir, entry->name()); | 109 base::FilePath package_path = GetExecutablePath(package_dir, entry->name()); |
| 110 if (entry->name() != "mojo:shell" && entry->name() != "mojo:catalog" && | 110 if (entry->name() != "mojo:shell" && entry->name() != "mojo:catalog" && |
| 111 !base::PathExists(package_path)) { | 111 !base::PathExists(package_path)) { |
| 112 continue; | 112 continue; |
| 113 } | 113 } |
| 114 | 114 |
| 115 original_thread_task_runner->PostTask( | 115 original_thread_task_runner->PostTask( |
| 116 FROM_HERE, | 116 FROM_HERE, |
| 117 base::Bind(read_manifest_callback, base::Passed(&entry))); | 117 base::Bind(read_manifest_callback, base::Passed(&entry))); |
| 118 } | 118 } |
| 119 | 119 |
| 120 original_thread_task_runner->PostTask(FROM_HERE, read_complete_closure); | 120 original_thread_task_runner->PostTask(FROM_HERE, read_complete_closure); |
| 121 } | 121 } |
| 122 | 122 |
| 123 std::unique_ptr<Entry> ReadManifest(const base::FilePath& package_dir, | 123 std::unique_ptr<Entry> ReadManifest(const base::FilePath& package_dir, |
| 124 const std::string& mojo_name) { | 124 const std::string& mojo_name) { |
| 125 std::unique_ptr<Entry> entry = CreateEntryForManifestAt( | 125 std::unique_ptr<Entry> entry = CreateEntryForManifestAt( |
| 126 GetManifestPath(package_dir, mojo_name), package_dir); | 126 GetManifestPath(package_dir, mojo_name), package_dir); |
| 127 if (!entry) { | 127 if (!entry) { |
| 128 entry.reset(new Entry(mojo_name)); | 128 entry.reset(new Entry(mojo_name)); |
| 129 entry->set_path(GetPackagePath( | 129 entry->set_path(GetExecutablePath( |
| 130 package_dir.AppendASCII(kMojoApplicationsDirName), mojo_name)); | 130 package_dir.AppendASCII(kMojoApplicationsDirName), mojo_name)); |
| 131 } | 131 } |
| 132 return entry; | 132 return entry; |
| 133 } | 133 } |
| 134 | 134 |
| 135 void AddEntryToCache(EntryCache* cache, std::unique_ptr<Entry> entry) { | 135 void AddEntryToCache(EntryCache* cache, std::unique_ptr<Entry> entry) { |
| 136 for (auto* child : entry->applications()) | 136 for (auto* child : entry->services()) |
| 137 AddEntryToCache(cache, base::WrapUnique(child)); | 137 AddEntryToCache(cache, base::WrapUnique(child)); |
| 138 (*cache)[entry->name()] = std::move(entry); | 138 (*cache)[entry->name()] = std::move(entry); |
| 139 } | 139 } |
| 140 | 140 |
| 141 void DoNothing(shell::mojom::ResolveResultPtr) {} | 141 void DoNothing(shell::mojom::ResolveResultPtr) {} |
| 142 | 142 |
| 143 } // namespace | 143 } // namespace |
| 144 | 144 |
| 145 // A sequenced task runner is used to guarantee requests are serviced in the | 145 // A sequenced task runner is used to guarantee requests are serviced in the |
| 146 // order requested. To do otherwise means we may run callbacks in an | 146 // order requested. To do otherwise means we may run callbacks in an |
| (...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 207 EntryCache* cache, | 207 EntryCache* cache, |
| 208 const CreateEntryForNameCallback& entry_created_callback, | 208 const CreateEntryForNameCallback& entry_created_callback, |
| 209 std::unique_ptr<Entry> entry) { | 209 std::unique_ptr<Entry> entry) { |
| 210 shell::mojom::ResolveResultPtr result = | 210 shell::mojom::ResolveResultPtr result = |
| 211 shell::mojom::ResolveResult::From(*entry); | 211 shell::mojom::ResolveResult::From(*entry); |
| 212 AddEntryToCache(cache, std::move(entry)); | 212 AddEntryToCache(cache, std::move(entry)); |
| 213 entry_created_callback.Run(std::move(result)); | 213 entry_created_callback.Run(std::move(result)); |
| 214 } | 214 } |
| 215 | 215 |
| 216 } // namespace catalog | 216 } // namespace catalog |
| OLD | NEW |