blob: e0f48ec2a0ab5a911bdf02272d0054c24ef0df17 [file] [log] [blame]
// Copyright (c) 2016, 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.
import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:observatory_2/service_io.dart';
import 'package:test/test.dart';
import 'test_helper.dart';
Future<String> readResponse(HttpClientResponse response) {
var completer = new Completer<String>();
var contents = new StringBuffer();
response.cast<List<int>>().transform(utf8.decoder).listen((String data) {
contents.write(data);
}, onDone: () => completer.complete(contents.toString()));
return completer.future;
}
var tests = <VMTest>[
// Write a file with the ? character in the filename.
(VM vm) async {
var fsId = 'test';
var filePath = '/foo/bar.dat';
var fileContents = [0, 1, 2, 3, 4, 5, 6, 255];
var fileContentsBase64 = base64Encode(fileContents);
var result;
// Create DevFS.
result = await vm.invokeRpcNoUpgrade('_createDevFS', {'fsName': fsId});
expect(result['type'], equals('FileSystem'));
expect(result['name'], equals(fsId));
expect(result['uri'], isA<String>());
// Write the file by issuing an HTTP PUT.
HttpClient client = new HttpClient();
HttpClientRequest request =
await client.putUrl(Uri.parse(serviceHttpAddress));
request.headers.add('dev_fs_name', fsId);
request.headers.add('dev_fs_path', filePath);
request.add(gzip.encode([9]));
HttpClientResponse response = await request.close();
String responseBody = await readResponse(response);
result = jsonDecode(responseBody);
expect(result['result']['type'], equals('Success'));
// Trigger an error by issuing an HTTP PUT.
request = await client.putUrl(Uri.parse(serviceHttpAddress));
request.headers.add('dev_fs_name', fsId);
// omit the 'dev_fs_path' parameter.
request.write(gzip.encode(fileContents));
response = await request.close();
responseBody = await readResponse(response);
result = jsonDecode(responseBody);
Map error = result['error']['data'];
expect(error, isNotNull);
expect(error['details'].contains("expects the 'path' parameter"), isTrue);
// Write the file again but this time with the true file contents.
client = new HttpClient();
request = await client.putUrl(Uri.parse(serviceHttpAddress));
request.headers.add('dev_fs_name', fsId);
request.headers.add('dev_fs_path', filePath);
request.add(gzip.encode(fileContents));
response = await request.close();
responseBody = await readResponse(response);
result = jsonDecode(responseBody);
expect(result['result']['type'], equals('Success'));
// Close the HTTP client.
client.close();
// Read the file back.
result = await vm.invokeRpcNoUpgrade('_readDevFSFile', {
'fsName': fsId,
'path': filePath,
});
expect(result['type'], equals('FSFile'));
expect(result['fileContents'], equals(fileContentsBase64));
// List all the files in the file system.
result = await vm.invokeRpcNoUpgrade('_listDevFSFiles', {
'fsName': fsId,
});
expect(result['type'], equals('FSFileList'));
expect(result['files'].length, equals(1));
expect(result['files'][0]['name'], equals(filePath));
// Delete DevFS.
result = await vm.invokeRpcNoUpgrade('_deleteDevFS', {
'fsName': fsId,
});
expect(result['type'], equals('Success'));
},
];
main(args) async => runVMTests(args, tests);