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