www.aleph1.co.uk Git - yaffs-website/blob - node_modules/node-gyp/node_modules/graceful-fs/legacy-streams.js

   1 var Stream = require('stream').Stream
   2
   3 module.exports = legacy
   4
   5 function 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 }