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

Unified Diff: mojo/public/dart/third_party/barback/lib/src/asset/internal_asset.dart

Issue 1346773002: Stop running pub get at gclient sync time and fix build bugs (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 3 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: mojo/public/dart/third_party/barback/lib/src/asset/internal_asset.dart
diff --git a/mojo/public/dart/third_party/barback/lib/src/asset/internal_asset.dart b/mojo/public/dart/third_party/barback/lib/src/asset/internal_asset.dart
new file mode 100644
index 0000000000000000000000000000000000000000..dfacba5c80e1f90c24ad564288001cf20077f1a2
--- /dev/null
+++ b/mojo/public/dart/third_party/barback/lib/src/asset/internal_asset.dart
@@ -0,0 +1,187 @@
+// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
+// for details. All rights reserved. Use of this source code is governed by a
+// BSD-style license that can be found in the LICENSE file.
+
+library barback.asset.internal_asset;
+
+import 'dart:async';
+import 'dart:convert';
+import 'dart:typed_data';
+
+import '../serialize.dart';
+import '../utils.dart';
+import '../utils/file_pool.dart';
+import '../utils/stream_replayer.dart';
+import 'asset.dart';
+import 'asset_id.dart';
+
+/// Serialize an asset to a form that's safe to send across isolates.
+Map serializeAsset(Asset asset) {
+ var id = serializeId(asset.id);
+ if (asset is BinaryAsset) {
+ return {
+ 'type': 'binary',
+ 'id': id,
+ 'contents': asset._contents
+ };
+ } else if (asset is FileAsset) {
+ return {
+ 'type': 'file',
+ 'id': id,
+ 'path': asset._path
+ };
+ } else if (asset is StringAsset) {
+ return {
+ 'type': 'string',
+ 'id': id,
+ 'contents': asset._contents
+ };
+ } else {
+ // [asset] is probably a [StreamAsset], but it's possible that the user has
+ // created a custom subclass, in which case we just serialize the stream
+ // anyway.
+ return {
+ 'type': 'stream',
+ 'id': id,
+ 'stream': serializeStream(asset.read())
+ };
+ }
+}
+
+/// Deserialize an asset from the form returned by [serialize].
+Asset deserializeAsset(Map asset) {
+ var id = deserializeId(asset['id']);
+ switch (asset['type']) {
+ case 'binary': return new BinaryAsset(id, asset['contents']);
+ case 'file': return new FileAsset(id, asset['path']);
+ case 'string': return new StringAsset(id, asset['contents']);
+ case 'stream':
+ return new StreamAsset(id, deserializeStream(asset['stream']));
+ default:
+ throw new FormatException('Unknown asset type "${asset['type']}".');
+ }
+}
+
+/// An asset whose data is stored in a list of bytes.
+class BinaryAsset implements Asset {
+ final AssetId id;
+
+ final Uint8List _contents;
+
+ BinaryAsset(this.id, List<int> contents)
+ : _contents = toUint8List(contents);
+
+ Future<String> readAsString({Encoding encoding}) {
+ if (encoding == null) encoding = UTF8;
+
+ return new Future.value(encoding.decode(_contents));
+ }
+
+ Stream<List<int>> read() => new Future<List<int>>.value(_contents).asStream();
+
+ String toString() {
+ var buffer = new StringBuffer();
+ buffer.write("Bytes [");
+
+ // Don't show the whole list if it's long.
+ if (_contents.length > 11) {
+ for (var i = 0; i < 5; i++) {
+ buffer.write(byteToHex(_contents[i]));
+ buffer.write(" ");
+ }
+
+ buffer.write("...");
+
+ for (var i = _contents.length - 5; i < _contents.length; i++) {
+ buffer.write(" ");
+ buffer.write(byteToHex(_contents[i]));
+ }
+ } else {
+ for (var i = 0; i < _contents.length; i++) {
+ if (i > 0) buffer.write(" ");
+ buffer.write(byteToHex(_contents[i]));
+ }
+ }
+
+ buffer.write("]");
+ return buffer.toString();
+ }
+}
+
+/// An asset backed by a file on the local file system.
+class FileAsset implements Asset {
+ final AssetId id;
+
+ /// Use a [FilePool] to handle reads so we can try to cope with running out
+ /// of file descriptors more gracefully.
+ static final _pool = new FilePool();
+
+ final String _path;
+ FileAsset(this.id, this._path);
+
+ Future<String> readAsString({Encoding encoding}) {
+ if (encoding == null) encoding = UTF8;
+ return _pool.readAsString(_path, encoding);
+ }
+
+ Stream<List<int>> read() => _pool.openRead(_path);
+
+ String toString() => 'File "${_path}"';
+}
+
+/// An asset whose data is stored in a string.
+class StringAsset implements Asset {
+ final AssetId id;
+
+ final String _contents;
+
+ StringAsset(this.id, this._contents);
+
+ Future<String> readAsString({Encoding encoding}) =>
+ new Future.value(_contents);
+
+ Stream<List<int>> read() =>
+ new Future<List<int>>.value(UTF8.encode(_contents)).asStream();
+
+ String toString() {
+ // Don't show the whole string if it's long.
+ var contents = _contents;
+ if (contents.length > 40) {
+ contents = contents.substring(0, 20) + " ... " +
+ contents.substring(contents.length - 20);
+ }
+
+ contents = _escape(contents);
+ return 'String "$contents"';
+ }
+
+ String _escape(String string) {
+ return string
+ .replaceAll("\"", r'\"')
+ .replaceAll("\n", r"\n")
+ .replaceAll("\r", r"\r")
+ .replaceAll("\t", r"\t");
+ }
+}
+
+/// An asset whose data is available from a stream.
+class StreamAsset implements Asset {
+ final AssetId id;
+
+ /// A stream replayer that records and replays the contents of the input
+ /// stream.
+ final StreamReplayer<List<int>> _replayer;
+
+ StreamAsset(this.id, Stream<List<int>> stream)
+ : _replayer = new StreamReplayer(stream);
+
+ Future<String> readAsString({Encoding encoding}) {
+ if (encoding == null) encoding = UTF8;
+ return _replayer.getReplay().toList()
+ .then((chunks) => encoding.decode(flatten(chunks)));
+ }
+
+ Stream<List<int>> read() => _replayer.getReplay();
+
+ String toString() => "Stream";
+}

Powered by Google App Engine
This is Rietveld 408576698