OLD | NEW |
(Empty) | |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. |
| 4 |
| 5 import 'dart:async'; |
| 6 import 'dart:core'; |
| 7 import 'mojo:core'; |
| 8 import 'package:services/files/file.mojom.dart' as files; |
| 9 import 'package:services/files/types.mojom.dart' as files; |
| 10 |
| 11 import 'terminal_display.dart'; |
| 12 |
| 13 // This implements a |mojo.files.File| that acts like a (pseudo)terminal. Bytes |
| 14 // written to the |File| will be read by this implementation and passed on to |
| 15 // the (Dart) |TerminalDisplay| (using |putChar()|). A read from the |File| will |
| 16 // be completed if/when |TerminalDisplay| makes a byte available (via |
| 17 // |getChar()|). |
| 18 // TODO(vtl): This implementation is very incomplete. |
| 19 class TerminalFileImpl implements files.File { |
| 20 final files.FileStub stub; |
| 21 final TerminalDisplay _display; |
| 22 |
| 23 TerminalFileImpl(this._display) : stub = new files.FileStub.unbound() { |
| 24 stub.impl = this; |
| 25 } |
| 26 |
| 27 // |files.File| implementation: |
| 28 |
| 29 @override |
| 30 Future close(Function responseFactory) async { |
| 31 // TODO(vtl): We should probably do more than just say OK. |
| 32 return responseFactory(files.Error_OK); |
| 33 } |
| 34 |
| 35 @override |
| 36 Future read(int numBytesToRead, int offset, int whence, |
| 37 Function responseFactory) async { |
| 38 if (numBytesToRead < 0) { |
| 39 return responseFactory(files.Error_INVALID_ARGUMENT, null); |
| 40 } |
| 41 |
| 42 // TODO(vtl): Error if |offset|/|whence| not appropriate. |
| 43 |
| 44 if (numBytesToRead == 0) { |
| 45 return responseFactory(files.Error_OK, []); |
| 46 } |
| 47 |
| 48 return responseFactory(files.Error_OK, [await _display.getChar()]); |
| 49 } |
| 50 |
| 51 @override |
| 52 Future write(List<int> bytesToWrite, int offset, int whence, |
| 53 Function responseFactory) async { |
| 54 // TODO(vtl): Error if |offset|/|whence| not appropriate. |
| 55 |
| 56 for (var c in bytesToWrite) { |
| 57 _display.putChar(c); |
| 58 } |
| 59 return responseFactory(files.Error_OK, bytesToWrite.length); |
| 60 } |
| 61 |
| 62 @override |
| 63 Future readToStream(MojoDataPipeProducer source, int offset, int whence, |
| 64 int numBytesToRead, Function responseFactory) async { |
| 65 // TODO(vtl) |
| 66 return responseFactory(files.Error_UNIMPLEMENTED); |
| 67 } |
| 68 |
| 69 @override |
| 70 Future writeFromStream(MojoDataPipeConsumer sink, int offset, int whence, |
| 71 Function responseFactory) async { |
| 72 // TODO(vtl) |
| 73 return responseFactory(files.Error_UNIMPLEMENTED); |
| 74 } |
| 75 |
| 76 @override |
| 77 Future tell(Function responseFactory) async { |
| 78 // TODO(vtl) |
| 79 return responseFactory(files.Error_UNIMPLEMENTED, 0); |
| 80 } |
| 81 |
| 82 @override |
| 83 Future seek(int offset, int whence, Function responseFactory) async { |
| 84 // TODO(vtl) |
| 85 return responseFactory(files.Error_UNIMPLEMENTED, 0); |
| 86 } |
| 87 |
| 88 @override |
| 89 Future stat(Function responseFactory) async { |
| 90 // TODO(vtl) |
| 91 return responseFactory(files.Error_UNIMPLEMENTED, null); |
| 92 } |
| 93 |
| 94 @override |
| 95 Future truncate(int size, Function responseFactory) async { |
| 96 // TODO(vtl) |
| 97 return responseFactory(files.Error_UNIMPLEMENTED); |
| 98 } |
| 99 |
| 100 @override |
| 101 Future touch(files.TimespecOrNow atime, files.TimespecOrNow mtime, |
| 102 Function responseFactory) async { |
| 103 // TODO(vtl) |
| 104 return responseFactory(files.Error_UNIMPLEMENTED); |
| 105 } |
| 106 |
| 107 @override |
| 108 Future dup(Object file, Function responseFactory) async { |
| 109 // TODO(vtl) |
| 110 return responseFactory(files.Error_UNIMPLEMENTED); |
| 111 } |
| 112 |
| 113 @override |
| 114 Future reopen(Object file, int openFlags, Function responseFactory) async { |
| 115 // TODO(vtl) |
| 116 return responseFactory(files.Error_UNIMPLEMENTED); |
| 117 } |
| 118 |
| 119 @override |
| 120 Future asBuffer(Function responseFactory) async { |
| 121 // TODO(vtl) |
| 122 return responseFactory(files.Error_UNIMPLEMENTED, null); |
| 123 } |
| 124 } |
OLD | NEW |