1var Stream = require('stream').Stream
2
3module.exports = legacy
4
5function legacy (fs) {
6  return {
7    ReadStream: ReadStream,
8    WriteStream: WriteStream
9  }
10
11  function ReadStream (path, options) {
12    if (!(this instanceof ReadStream)) return new ReadStream(path, options);
13
14    Stream.call(this);
15
16    var self = this;
17
18    this.path = path;
19    this.fd = null;
20    this.readable = true;
21    this.paused = false;
22
23    this.flags = 'r';
24    this.mode = 438; /*=0666*/
25    this.bufferSize = 64 * 1024;
26
27    options = options || {};
28
29    // Mixin options into this
30    var keys = Object.keys(options);
31    for (var index = 0, length = keys.length; index < length; index++) {
32      var key = keys[index];
33      this[key] = options[key];
34    }
35
36    if (this.encoding) this.setEncoding(this.encoding);
37
38    if (this.start !== undefined) {
39      if ('number' !== typeof this.start) {
40        throw TypeError('start must be a Number');
41      }
42      if (this.end === undefined) {
43        this.end = Infinity;
44      } else if ('number' !== typeof this.end) {
45        throw TypeError('end must be a Number');
46      }
47
48      if (this.start > this.end) {
49        throw new Error('start must be <= end');
50      }
51
52      this.pos = this.start;
53    }
54
55    if (this.fd !== null) {
56      process.nextTick(function() {
57        self._read();
58      });
59      return;
60    }
61
62    fs.open(this.path, this.flags, this.mode, function (err, fd) {
63      if (err) {
64        self.emit('error', err);
65        self.readable = false;
66        return;
67      }
68
69      self.fd = fd;
70      self.emit('open', fd);
71      self._read();
72    })
73  }
74
75  function WriteStream (path, options) {
76    if (!(this instanceof WriteStream)) return new WriteStream(path, options);
77
78    Stream.call(this);
79
80    this.path = path;
81    this.fd = null;
82    this.writable = true;
83
84    this.flags = 'w';
85    this.encoding = 'binary';
86    this.mode = 438; /*=0666*/
87    this.bytesWritten = 0;
88
89    options = options || {};
90
91    // Mixin options into this
92    var keys = Object.keys(options);
93    for (var index = 0, length = keys.length; index < length; index++) {
94      var key = keys[index];
95      this[key] = options[key];
96    }
97
98    if (this.start !== undefined) {
99      if ('number' !== typeof this.start) {
100        throw TypeError('start must be a Number');
101      }
102      if (this.start < 0) {
103        throw new Error('start must be >= zero');
104      }
105
106      this.pos = this.start;
107    }
108
109    this.busy = false;
110    this._queue = [];
111
112    if (this.fd === null) {
113      this._open = fs.open;
114      this._queue.push([this._open, this.path, this.flags, this.mode, undefined]);
115      this.flush();
116    }
117  }
118}
119