// Copyright 2014 The Flutter Authors. All rights reserved. // Use of this source code is governed by a BSD-style license that can be // found in the LICENSE file. import 'dart:convert'; import 'dart:io' hide Platform; import 'dart:typed_data'; import 'package:mockito/mockito.dart'; import 'package:path/path.dart' as path; import 'package:platform/platform.dart' show FakePlatform; import '../prepare_package.dart'; import 'common.dart'; import 'fake_process_manager.dart'; void main() { const String testRef = 'deadbeefdeadbeefdeadbeefdeadbeefdeadbeef'; test('Throws on missing executable', () async { // Uses a *real* process manager, since we want to know what happens if // it can't find an executable. final ProcessRunner processRunner = ProcessRunner(subprocessOutput: false); expect( expectAsync1((List<String> commandLine) async { return processRunner.runProcess(commandLine); })(<String>['this_executable_better_not_exist_2857632534321']), throwsA(isA<PreparePackageException>())); try { await processRunner.runProcess(<String>['this_executable_better_not_exist_2857632534321']); } on PreparePackageException catch (e) { expect( e.message, contains('Invalid argument(s): Cannot find executable for this_executable_better_not_exist_2857632534321.'), ); } }); for (final String platformName in <String>['macos', 'linux', 'windows']) { final FakePlatform platform = FakePlatform( operatingSystem: platformName, environment: <String, String>{ 'DEPOT_TOOLS': path.join('D:', 'depot_tools'), }, ); group('ProcessRunner for $platform', () { test('Returns stdout', () async { final FakeProcessManager fakeProcessManager = FakeProcessManager(); fakeProcessManager.fakeResults = <String, List<ProcessResult>>{ 'echo test': <ProcessResult>[ProcessResult(0, 0, 'output', 'error')], }; final ProcessRunner processRunner = ProcessRunner( subprocessOutput: false, platform: platform, processManager: fakeProcessManager); final String output = await processRunner.runProcess(<String>['echo', 'test']); expect(output, equals('output')); }); test('Throws on process failure', () async { final FakeProcessManager fakeProcessManager = FakeProcessManager(); fakeProcessManager.fakeResults = <String, List<ProcessResult>>{ 'echo test': <ProcessResult>[ProcessResult(0, -1, 'output', 'error')], }; final ProcessRunner processRunner = ProcessRunner( subprocessOutput: false, platform: platform, processManager: fakeProcessManager); expect( expectAsync1((List<String> commandLine) async { return processRunner.runProcess(commandLine); })(<String>['echo', 'test']), throwsA(isA<PreparePackageException>())); }); }); group('ArchiveCreator for $platformName', () { ArchiveCreator creator; Directory tempDir; Directory flutterDir; FakeProcessManager processManager; final List<List<String>> args = <List<String>>[]; final List<Map<Symbol, dynamic>> namedArgs = <Map<Symbol, dynamic>>[]; String flutter; Future<Uint8List> fakeHttpReader(Uri url, {Map<String, String> headers}) { return Future<Uint8List>.value(Uint8List(0)); } setUp(() async { processManager = FakeProcessManager(); args.clear(); namedArgs.clear(); tempDir = Directory.systemTemp.createTempSync('flutter_prepage_package_test.'); flutterDir = Directory(path.join(tempDir.path, 'flutter')); flutterDir.createSync(recursive: true); creator = ArchiveCreator( tempDir, tempDir, testRef, Branch.dev, processManager: processManager, subprocessOutput: false, platform: platform, httpReader: fakeHttpReader, ); flutter = path.join(creator.flutterRoot.absolute.path, 'bin', 'flutter'); }); tearDown(() async { tryToDelete(tempDir); }); test('sets PUB_CACHE properly', () async { final String createBase = path.join(tempDir.absolute.path, 'create_'); final String archiveName = path.join(tempDir.absolute.path, 'flutter_${platformName}_v1.2.3-dev${platform.isLinux ? '.tar.xz' : '.zip'}'); processManager.fakeResults = <String, List<ProcessResult>>{ 'git clone -b dev https://chromium.googlesource.com/external/github.com/flutter/flutter': null, 'git reset --hard $testRef': null, 'git remote set-url origin https://github.com/flutter/flutter.git': null, 'git describe --tags --exact-match $testRef': <ProcessResult>[ProcessResult(0, 0, 'v1.2.3', '')], if (platform.isWindows) '7za x ${path.join(tempDir.path, 'mingit.zip')}': null, '$flutter doctor': null, '$flutter update-packages': null, '$flutter precache': null, '$flutter ide-config': null, '$flutter create --template=app ${createBase}app': null, '$flutter create --template=package ${createBase}package': null, '$flutter create --template=plugin ${createBase}plugin': null, 'git clean -f -X **/.packages': null, 'git clean -f -X **/.dart_tool': null, if (platform.isWindows) 'attrib -h .git': null, if (platform.isWindows) '7za a -tzip -mx=9 $archiveName flutter': null else if (platform.isMacOS) 'zip -r -9 $archiveName flutter': null else if (platform.isLinux) 'tar cJf $archiveName flutter': null, }; await creator.initializeRepo(); await creator.createArchive(); expect( verify(processManager.start( captureAny, workingDirectory: captureAnyNamed('workingDirectory'), environment: captureAnyNamed('environment'), )).captured[2]['PUB_CACHE'], endsWith(path.join('flutter', '.pub-cache')), ); }); test('calls the right commands for archive output', () async { final String createBase = path.join(tempDir.absolute.path, 'create_'); final String archiveName = path.join(tempDir.absolute.path, 'flutter_${platformName}_v1.2.3-dev${platform.isLinux ? '.tar.xz' : '.zip'}'); final Map<String, List<ProcessResult>> calls = <String, List<ProcessResult>>{ 'git clone -b dev https://chromium.googlesource.com/external/github.com/flutter/flutter': null, 'git reset --hard $testRef': null, 'git remote set-url origin https://github.com/flutter/flutter.git': null, 'git describe --tags --exact-match $testRef': <ProcessResult>[ProcessResult(0, 0, 'v1.2.3', '')], if (platform.isWindows) '7za x ${path.join(tempDir.path, 'mingit.zip')}': null, '$flutter doctor': null, '$flutter update-packages': null, '$flutter precache': null, '$flutter ide-config': null, '$flutter create --template=app ${createBase}app': null, '$flutter create --template=package ${createBase}package': null, '$flutter create --template=plugin ${createBase}plugin': null, 'git clean -f -X **/.packages': null, 'git clean -f -X **/.dart_tool': null, if (platform.isWindows) 'attrib -h .git': null, if (platform.isWindows) '7za a -tzip -mx=9 $archiveName flutter': null else if (platform.isMacOS) 'zip -r -9 $archiveName flutter': null else if (platform.isLinux) 'tar cJf $archiveName flutter': null, }; processManager.fakeResults = calls; creator = ArchiveCreator( tempDir, tempDir, testRef, Branch.dev, processManager: processManager, subprocessOutput: false, platform: platform, httpReader: fakeHttpReader, ); await creator.initializeRepo(); await creator.createArchive(); processManager.verifyCalls(calls.keys.toList()); }); test('throws when a command errors out', () async { final Map<String, List<ProcessResult>> calls = <String, List<ProcessResult>>{ 'git clone -b dev https://chromium.googlesource.com/external/github.com/flutter/flutter': <ProcessResult>[ProcessResult(0, 0, 'output1', '')], 'git reset --hard $testRef': <ProcessResult>[ProcessResult(0, -1, 'output2', '')], }; processManager.fakeResults = calls; expect(expectAsync0(creator.initializeRepo), throwsA(isA<PreparePackageException>())); }); test('non-strict mode calls the right commands', () async { final String createBase = path.join(tempDir.absolute.path, 'create_'); final String archiveName = path.join(tempDir.absolute.path, 'flutter_${platformName}_v1.2.3-dev${platform.isLinux ? '.tar.xz' : '.zip'}'); final Map<String, List<ProcessResult>> calls = <String, List<ProcessResult>>{ 'git clone -b dev https://chromium.googlesource.com/external/github.com/flutter/flutter': null, 'git reset --hard $testRef': null, 'git remote set-url origin https://github.com/flutter/flutter.git': null, 'git describe --tags --abbrev=0 $testRef': <ProcessResult>[ProcessResult(0, 0, 'v1.2.3', '')], if (platform.isWindows) '7za x ${path.join(tempDir.path, 'mingit.zip')}': null, '$flutter doctor': null, '$flutter update-packages': null, '$flutter precache': null, '$flutter ide-config': null, '$flutter create --template=app ${createBase}app': null, '$flutter create --template=package ${createBase}package': null, '$flutter create --template=plugin ${createBase}plugin': null, 'git clean -f -X **/.packages': null, 'git clean -f -X **/.dart_tool': null, if (platform.isWindows) 'attrib -h .git': null, if (platform.isWindows) '7za a -tzip -mx=9 $archiveName flutter': null else if (platform.isMacOS) 'zip -r -9 $archiveName flutter': null else if (platform.isLinux) 'tar cJf $archiveName flutter': null, }; processManager.fakeResults = calls; creator = ArchiveCreator( tempDir, tempDir, testRef, Branch.dev, strict: false, processManager: processManager, subprocessOutput: false, platform: platform, httpReader: fakeHttpReader, ); await creator.initializeRepo(); await creator.createArchive(); processManager.verifyCalls(calls.keys.toList()); }); }); group('ArchivePublisher for $platformName', () { FakeProcessManager processManager; Directory tempDir; setUp(() async { processManager = FakeProcessManager(); tempDir = Directory.systemTemp.createTempSync('flutter_prepage_package_test.'); }); tearDown(() async { tryToDelete(tempDir); }); test('calls the right processes', () async { final String releasesName = 'releases_$platformName.json'; final String archiveName = platform.isLinux ? 'archive.tar.xz' : 'archive.zip'; final String archiveMime = platform.isLinux ? 'application/x-gtar' : 'application/zip'; final String archivePath = path.join(tempDir.absolute.path, archiveName); final String gsArchivePath = 'gs://flutter_infra/releases/stable/$platformName/$archiveName'; final String jsonPath = path.join(tempDir.absolute.path, releasesName); final String gsJsonPath = 'gs://flutter_infra/releases/$releasesName'; final String releasesJson = ''' { "base_url": "https://storage.googleapis.com/flutter_infra/releases", "current_release": { "beta": "3ea4d06340a97a1e9d7cae97567c64e0569dcaa2", "dev": "5a58b36e36b8d7aace89d3950e6deb307956a6a0" }, "releases": [ { "hash": "5a58b36e36b8d7aace89d3950e6deb307956a6a0", "channel": "dev", "version": "v0.2.3", "release_date": "2018-03-20T01:47:02.851729Z", "archive": "dev/$platformName/flutter_${platformName}_v0.2.3-dev.zip", "sha256": "4fe85a822093e81cb5a66c7fc263f68de39b5797b294191b6d75e7afcc86aff8" }, { "hash": "b9bd51cc36b706215915711e580851901faebb40", "channel": "beta", "version": "v0.2.2", "release_date": "2018-03-16T18:48:13.375013Z", "archive": "dev/$platformName/flutter_${platformName}_v0.2.2-dev.zip", "sha256": "6073331168cdb37a4637a5dc073d6a7ef4e466321effa2c529fa27d2253a4d4b" }, { "hash": "$testRef", "channel": "stable", "version": "v0.0.0", "release_date": "2018-03-20T01:47:02.851729Z", "archive": "stable/$platformName/flutter_${platformName}_v0.0.0-dev.zip", "sha256": "5dd34873b3a3e214a32fd30c2c319a0f46e608afb72f0d450b2d621a6d02aebd" } ] } '''; File(jsonPath).writeAsStringSync(releasesJson); File(archivePath).writeAsStringSync('archive contents'); final String gsutilCall = platform.isWindows ? 'python ${path.join("D:", "depot_tools", "gsutil.py")}' : 'gsutil.py'; final Map<String, List<ProcessResult>> calls = <String, List<ProcessResult>>{ '$gsutilCall -- rm $gsArchivePath': null, '$gsutilCall -- -h Content-Type:$archiveMime cp $archivePath $gsArchivePath': null, '$gsutilCall -- cp $gsJsonPath $jsonPath': null, '$gsutilCall -- rm $gsJsonPath': null, '$gsutilCall -- -h Content-Type:application/json cp $jsonPath $gsJsonPath': null, }; processManager.fakeResults = calls; final File outputFile = File(path.join(tempDir.absolute.path, archiveName)); assert(tempDir.existsSync()); final ArchivePublisher publisher = ArchivePublisher( tempDir, testRef, Branch.stable, 'v1.2.3', outputFile, processManager: processManager, subprocessOutput: false, platform: platform, ); assert(tempDir.existsSync()); await publisher.publishArchive(); processManager.verifyCalls(calls.keys.toList()); final File releaseFile = File(jsonPath); expect(releaseFile.existsSync(), isTrue); final String contents = releaseFile.readAsStringSync(); // Make sure new data is added. expect(contents, contains('"hash": "$testRef"')); expect(contents, contains('"channel": "stable"')); expect(contents, contains('"archive": "stable/$platformName/$archiveName"')); expect(contents, contains('"sha256": "f69f4865f861193a91d1c5544a894167a7137b788d10bac8edbf5d095f45cb4d"')); // Make sure existing entries are preserved. expect(contents, contains('"hash": "5a58b36e36b8d7aace89d3950e6deb307956a6a0"')); expect(contents, contains('"hash": "b9bd51cc36b706215915711e580851901faebb40"')); expect(contents, contains('"channel": "beta"')); expect(contents, contains('"channel": "dev"')); // Make sure old matching entries are removed. expect(contents, isNot(contains('v0.0.0'))); final Map<String, dynamic> jsonData = json.decode(contents) as Map<String, dynamic>; final List<dynamic> releases = jsonData['releases'] as List<dynamic>; expect(releases.length, equals(3)); // Make sure the new entry is first (and hopefully it takes less than a // minute to go from publishArchive above to this line!). expect( DateTime.now().difference(DateTime.parse(releases[0]['release_date'] as String)), lessThan(const Duration(minutes: 1)), ); const JsonEncoder encoder = JsonEncoder.withIndent(' '); expect(contents, equals(encoder.convert(jsonData))); }); }); } }