| OLD | NEW |
| 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 // VMOptions=--error_on_bad_type --error_on_bad_override | 4 // VMOptions=--error_on_bad_type --error_on_bad_override |
| 5 | 5 |
| 6 import 'dart:convert'; | 6 import 'dart:convert'; |
| 7 import 'package:observatory/service_io.dart'; | 7 import 'package:observatory/service_io.dart'; |
| 8 import 'package:unittest/unittest.dart'; | 8 import 'package:unittest/unittest.dart'; |
| 9 import 'test_helper.dart'; | 9 import 'test_helper.dart'; |
| 10 | 10 |
| 11 var tests = [ | 11 var tests = [ |
| 12 (VM vm) async { | 12 (VM vm) async { |
| 13 var result = await vm.invokeRpcNoUpgrade('_listDevFS', {}); | 13 var result = await vm.invokeRpcNoUpgrade('_listDevFS', {}); |
| 14 expect(result['type'], equals('FileSystemList')); | 14 expect(result['type'], equals('FileSystemList')); |
| 15 expect(result['fsNames'].toString(), equals("[]")); | 15 expect(result['fsNames'].toString(), equals("[]")); |
| 16 | 16 |
| 17 var params = {'fsName': 'alpha'}; | 17 var params = { |
| 18 'fsName': 'alpha' |
| 19 }; |
| 18 result = await vm.invokeRpcNoUpgrade('_createDevFS', params); | 20 result = await vm.invokeRpcNoUpgrade('_createDevFS', params); |
| 19 expect(result['type'], equals('FileSystem')); | 21 expect(result['type'], equals('FileSystem')); |
| 20 expect(result['name'], equals('alpha')); | 22 expect(result['name'], equals('alpha')); |
| 21 expect(result['uri'], new isInstanceOf<String>()); | 23 expect(result['uri'], new isInstanceOf<String>()); |
| 22 | 24 |
| 23 result = await vm.invokeRpcNoUpgrade('_listDevFS', {}); | 25 result = await vm.invokeRpcNoUpgrade('_listDevFS', {}); |
| 24 expect(result['type'], equals('FileSystemList')); | 26 expect(result['type'], equals('FileSystemList')); |
| 25 expect(result['fsNames'].toString(), equals('[alpha]')); | 27 expect(result['fsNames'].toString(), equals('[alpha]')); |
| 26 | 28 |
| 27 bool caughtException; | 29 bool caughtException; |
| 28 try { | 30 try { |
| 29 await vm.invokeRpcNoUpgrade('_createDevFS', params); | 31 await vm.invokeRpcNoUpgrade('_createDevFS', params); |
| 30 expect(false, isTrue, reason: 'Unreachable'); | 32 expect(false, isTrue, reason:'Unreachable'); |
| 31 } on ServerRpcException catch (e) { | 33 } on ServerRpcException catch(e) { |
| 32 caughtException = true; | 34 caughtException = true; |
| 33 expect(e.code, equals(ServerRpcException.kFileSystemAlreadyExists)); | 35 expect(e.code, equals(ServerRpcException.kFileSystemAlreadyExists)); |
| 34 expect(e.message, "_createDevFS: file system 'alpha' already exists"); | 36 expect(e.message, "_createDevFS: file system 'alpha' already exists"); |
| 35 } | 37 } |
| 36 expect(caughtException, isTrue); | 38 expect(caughtException, isTrue); |
| 37 | 39 |
| 38 result = await vm.invokeRpcNoUpgrade('_deleteDevFS', params); | 40 result = await vm.invokeRpcNoUpgrade('_deleteDevFS', params); |
| 39 expect(result['type'], equals('Success')); | 41 expect(result['type'], equals('Success')); |
| 40 | 42 |
| 41 result = await vm.invokeRpcNoUpgrade('_listDevFS', {}); | 43 result = await vm.invokeRpcNoUpgrade('_listDevFS', {}); |
| 42 expect(result['type'], equals('FileSystemList')); | 44 expect(result['type'], equals('FileSystemList')); |
| 43 expect(result['fsNames'].toString(), equals("[]")); | 45 expect(result['fsNames'].toString(), equals("[]")); |
| 44 | 46 |
| 45 caughtException = false; | 47 caughtException = false; |
| 46 try { | 48 try { |
| 47 await vm.invokeRpcNoUpgrade('_deleteDevFS', params); | 49 await vm.invokeRpcNoUpgrade('_deleteDevFS', params); |
| 48 expect(false, isTrue, reason: 'Unreachable'); | 50 expect(false, isTrue, reason:'Unreachable'); |
| 49 } on ServerRpcException catch (e) { | 51 } on ServerRpcException catch(e) { |
| 50 caughtException = true; | 52 caughtException = true; |
| 51 expect(e.code, equals(ServerRpcException.kFileSystemDoesNotExist)); | 53 expect(e.code, equals(ServerRpcException.kFileSystemDoesNotExist)); |
| 52 expect(e.message, "_deleteDevFS: file system 'alpha' does not exist"); | 54 expect(e.message, "_deleteDevFS: file system 'alpha' does not exist"); |
| 53 } | 55 } |
| 54 expect(caughtException, isTrue); | 56 expect(caughtException, isTrue); |
| 55 }, | 57 }, |
| 58 |
| 56 (VM vm) async { | 59 (VM vm) async { |
| 57 var fsId = 'banana'; | 60 var fsId = 'banana'; |
| 58 var filePath = '/foo/bar.dat'; | 61 var filePath = '/foo/bar.dat'; |
| 59 var fileContents = BASE64.encode(UTF8.encode('fileContents')); | 62 var fileContents = BASE64.encode(UTF8.encode('fileContents')); |
| 60 | 63 |
| 61 var result; | 64 var result; |
| 62 // Create DevFS. | 65 // Create DevFS. |
| 63 result = await vm.invokeRpcNoUpgrade('_createDevFS', {'fsName': fsId}); | 66 result = await vm.invokeRpcNoUpgrade('_createDevFS', { 'fsName': fsId }); |
| 64 expect(result['type'], equals('FileSystem')); | 67 expect(result['type'], equals('FileSystem')); |
| 65 expect(result['name'], equals(fsId)); | 68 expect(result['name'], equals(fsId)); |
| 66 expect(result['uri'], new isInstanceOf<String>()); | 69 expect(result['uri'], new isInstanceOf<String>()); |
| 67 | 70 |
| 68 bool caughtException = false; | 71 bool caughtException = false; |
| 69 try { | 72 try { |
| 70 await vm.invokeRpcNoUpgrade('_readDevFSFile', { | 73 await vm.invokeRpcNoUpgrade('_readDevFSFile', { |
| 71 'fsName': fsId, | 74 'fsName': fsId, |
| 72 'path': filePath, | 75 'path': filePath, |
| 73 }); | 76 }); |
| 74 expect(false, isTrue, reason: 'Unreachable'); | 77 expect(false, isTrue, reason:'Unreachable'); |
| 75 } on ServerRpcException catch (e) { | 78 } on ServerRpcException catch(e) { |
| 76 caughtException = true; | 79 caughtException = true; |
| 77 expect(e.code, equals(ServerRpcException.kFileDoesNotExist)); | 80 expect(e.code, equals(ServerRpcException.kFileDoesNotExist)); |
| 78 expect(e.message, startsWith("_readDevFSFile: FileSystemException: ")); | 81 expect(e.message, startsWith("_readDevFSFile: FileSystemException: ")); |
| 79 } | 82 } |
| 80 expect(caughtException, isTrue); | 83 expect(caughtException, isTrue); |
| 81 | 84 |
| 82 // Write a file. | 85 // Write a file. |
| 83 result = await vm.invokeRpcNoUpgrade('_writeDevFSFile', | 86 result = await vm.invokeRpcNoUpgrade('_writeDevFSFile', { |
| 84 {'fsName': fsId, 'path': filePath, 'fileContents': fileContents}); | 87 'fsName': fsId, |
| 88 'path': filePath, |
| 89 'fileContents': fileContents |
| 90 }); |
| 85 expect(result['type'], equals('Success')); | 91 expect(result['type'], equals('Success')); |
| 86 | 92 |
| 87 // Read the file back. | 93 // Read the file back. |
| 88 result = await vm.invokeRpcNoUpgrade('_readDevFSFile', { | 94 result = await vm.invokeRpcNoUpgrade('_readDevFSFile', { |
| 89 'fsName': fsId, | 95 'fsName': fsId, |
| 90 'path': filePath, | 96 'path': filePath, |
| 91 }); | 97 }); |
| 92 expect(result['type'], equals('FSFile')); | 98 expect(result['type'], equals('FSFile')); |
| 93 expect(result['fileContents'], equals(fileContents)); | 99 expect(result['fileContents'], equals(fileContents)); |
| 94 | 100 |
| 95 // The leading '/' is optional. | 101 // The leading '/' is optional. |
| 96 result = await vm.invokeRpcNoUpgrade('_readDevFSFile', { | 102 result = await vm.invokeRpcNoUpgrade('_readDevFSFile', { |
| 97 'fsName': fsId, | 103 'fsName': fsId, |
| 98 'path': filePath.substring(1), | 104 'path': filePath.substring(1), |
| 99 }); | 105 }); |
| 100 expect(result['type'], equals('FSFile')); | 106 expect(result['type'], equals('FSFile')); |
| 101 expect(result['fileContents'], equals(fileContents)); | 107 expect(result['fileContents'], equals(fileContents)); |
| 102 | 108 |
| 103 // Read a file outside of the fs. | 109 // Read a file outside of the fs. |
| 104 caughtException = false; | 110 caughtException = false; |
| 105 try { | 111 try { |
| 106 await vm.invokeRpcNoUpgrade('_readDevFSFile', { | 112 await vm.invokeRpcNoUpgrade('_readDevFSFile', { |
| 107 'fsName': fsId, | 113 'fsName': fsId, |
| 108 'path': '../foo', | 114 'path': '../foo', |
| 109 }); | 115 }); |
| 110 expect(false, isTrue, reason: 'Unreachable'); | 116 expect(false, isTrue, reason:'Unreachable'); |
| 111 } on ServerRpcException catch (e) { | 117 } on ServerRpcException catch(e) { |
| 112 caughtException = true; | 118 caughtException = true; |
| 113 expect(e.code, equals(ServerRpcException.kInvalidParams)); | 119 expect(e.code, equals(ServerRpcException.kInvalidParams)); |
| 114 expect(e.message, "_readDevFSFile: invalid 'path' parameter: ../foo"); | 120 expect(e.message, "_readDevFSFile: invalid 'path' parameter: ../foo"); |
| 115 } | 121 } |
| 116 expect(caughtException, isTrue); | 122 expect(caughtException, isTrue); |
| 117 | 123 |
| 118 // Write a set of files. | 124 // Write a set of files. |
| 119 result = await vm.invokeRpcNoUpgrade('_writeDevFSFiles', { | 125 result = await vm.invokeRpcNoUpgrade('_writeDevFSFiles', { |
| 120 'fsName': fsId, | 126 'fsName': fsId, |
| 121 'files': [ | 127 'files': [ |
| 122 ['/a', BASE64.encode(UTF8.encode('a_contents'))], | 128 ['/a', BASE64.encode(UTF8.encode('a_contents'))], |
| 123 ['/b', BASE64.encode(UTF8.encode('b_contents'))] | 129 ['/b', BASE64.encode(UTF8.encode('b_contents'))] |
| 124 ] | 130 ] |
| 125 }); | 131 }); |
| 126 expect(result['type'], equals('Success')); | 132 expect(result['type'], equals('Success')); |
| 127 | 133 |
| 128 // Read one of the files back. | 134 // Read one of the files back. |
| 129 result = await vm.invokeRpcNoUpgrade('_readDevFSFile', { | 135 result = await vm.invokeRpcNoUpgrade('_readDevFSFile', { |
| 130 'fsName': fsId, | 136 'fsName': fsId, |
| 131 'path': '/b', | 137 'path': '/b', |
| 132 }); | 138 }); |
| 133 expect(result['type'], equals('FSFile')); | 139 expect(result['type'], equals('FSFile')); |
| 134 expect(result['fileContents'], | 140 expect(result['fileContents'], |
| 135 equals(BASE64.encode(UTF8.encode('b_contents')))); | 141 equals(BASE64.encode(UTF8.encode('b_contents')))); |
| 136 | 142 |
| 137 // List all the files in the file system. | 143 // List all the files in the file system. |
| 138 result = await vm.invokeRpcNoUpgrade('_listDevFSFiles', { | 144 result = await vm.invokeRpcNoUpgrade('_listDevFSFiles', { |
| 139 'fsName': fsId, | 145 'fsName': fsId, |
| 140 }); | 146 }); |
| 141 expect(result['type'], equals('FSFileList')); | 147 expect(result['type'], equals('FSFileList')); |
| 142 expect(result['files'].length, equals(3)); | 148 expect(result['files'].length, equals(3)); |
| 143 | 149 |
| 144 // Delete DevFS. | 150 // Delete DevFS. |
| 145 result = await vm.invokeRpcNoUpgrade('_deleteDevFS', { | 151 result = await vm.invokeRpcNoUpgrade('_deleteDevFS', { |
| 146 'fsName': fsId, | 152 'fsName': fsId, |
| 147 }); | 153 }); |
| 148 expect(result['type'], equals('Success')); | 154 expect(result['type'], equals('Success')); |
| 149 }, | 155 }, |
| 150 ]; | 156 ]; |
| 151 | 157 |
| 152 main(args) async => runVMTests(args, tests); | 158 main(args) async => runVMTests(args, tests); |
| OLD | NEW |