rnystrom@google.com
344249b02f
Future.then() will now implicitly wrap the callback result in a future if it isn't one, so this manual wrapping can be removed. Also take advantage of the fact that Future.immediate() is always async now and remove some workarounds. Finally, noticed there were two copies of the git-related code floating around so killed the old one. Review URL: https://codereview.chromium.org//12042053 git-svn-id: https://dart.googlecode.com/svn/branches/bleeding_edge/dart@17519 260f80e4-7a28-3924-810f-c04153c831b5
101 lines
3.3 KiB
Dart
101 lines
3.3 KiB
Dart
// Copyright (c) 2012, 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 system_cache;
|
|
|
|
import 'dart:io';
|
|
import 'dart:async';
|
|
|
|
import 'git_source.dart';
|
|
import 'hosted_source.dart';
|
|
import 'io.dart';
|
|
import 'io.dart' as io show createTempDir;
|
|
import 'log.dart' as log;
|
|
import 'package.dart';
|
|
import 'sdk_source.dart';
|
|
import 'source.dart';
|
|
import 'source_registry.dart';
|
|
import 'utils.dart';
|
|
import 'version.dart';
|
|
|
|
/// The system-wide cache of installed packages.
|
|
///
|
|
/// This cache contains all packages that are downloaded from the internet.
|
|
/// Packages that are available locally (e.g. from the SDK) don't use this
|
|
/// cache.
|
|
class SystemCache {
|
|
/// The root directory where this package cache is located.
|
|
final String rootDir;
|
|
|
|
String get tempDir => join(rootDir, '_temp');
|
|
|
|
/// Packages which are currently being asynchronously installed to the cache.
|
|
final Map<PackageId, Future<Package>> _pendingInstalls;
|
|
|
|
/// The sources from which to install packages.
|
|
final SourceRegistry sources;
|
|
|
|
/// Creates a new package cache which is backed by the given directory on the
|
|
/// user's file system.
|
|
SystemCache(this.rootDir)
|
|
: _pendingInstalls = new Map<PackageId, Future<Package>>(),
|
|
sources = new SourceRegistry();
|
|
|
|
/// Creates a system cache and registers the standard set of sources.
|
|
factory SystemCache.withSources(String rootDir) {
|
|
var cache = new SystemCache(rootDir);
|
|
cache.register(new SdkSource());
|
|
cache.register(new GitSource());
|
|
cache.register(new HostedSource());
|
|
cache.sources.setDefault('hosted');
|
|
return cache;
|
|
}
|
|
|
|
/// Registers a new source. This source must not have the same name as a
|
|
/// source that's already been registered.
|
|
void register(Source source) {
|
|
source.bind(this);
|
|
sources.register(source);
|
|
}
|
|
|
|
/// Ensures that the package identified by [id] is installed to the cache,
|
|
/// loads it, and returns it.
|
|
///
|
|
/// It is an error to try installing a package from a source with `shouldCache
|
|
/// == false` to the system cache.
|
|
Future<Package> install(PackageId id) {
|
|
if (!id.source.shouldCache) {
|
|
throw new ArgumentError("Package $id is not cacheable.");
|
|
}
|
|
|
|
var pending = _pendingInstalls[id];
|
|
if (pending != null) return pending;
|
|
|
|
var future = id.source.installToSystemCache(id)
|
|
.whenComplete(() { _pendingInstalls.remove(id); });
|
|
_pendingInstalls[id] = future;
|
|
return future;
|
|
}
|
|
|
|
/// Create a new temporary directory within the system cache. The system
|
|
/// cache maintains its own temporary directory that it uses to stage
|
|
/// packages into while installing. It uses this instead of the OS's system
|
|
/// temp directory to ensure that it's on the same volume as the pub system
|
|
/// cache so that it can move the directory from it.
|
|
Future<Directory> createTempDir() {
|
|
return ensureDir(tempDir).then((temp) {
|
|
return io.createTempDir(join(temp, 'dir'));
|
|
});
|
|
}
|
|
|
|
/// Delete's the system cache's internal temp directory.
|
|
Future deleteTempDir() {
|
|
log.fine('Clean up system cache temp directory $tempDir.');
|
|
return dirExists(tempDir).then((exists) {
|
|
if (!exists) return;
|
|
return deleteDir(tempDir);
|
|
});
|
|
}
|
|
}
|