pub/archive/lib/src/io/output_file_stream.dart

part of archive_io;

class OutputFileStream {
  String path;
  final int byteOrder;
  int length;
  io.File _file;
  io.RandomAccessFile _fp;

  OutputFileStream(this.path, {this.byteOrder: LITTLE_ENDIAN})
    : length = 0 {
    _file = new io.File(path);
    _fp = _file.openSync(mode: io.FileMode.WRITE);
  }

  void close() {
    _fp.closeSync();
    _file = null;
  }

  /**
   * Write a byte to the end of the buffer.
   */
  void writeByte(int value) {
    _fp.writeByteSync(value);
    length++;
  }

  /**
   * Write a set of bytes to the end of the buffer.
   */
  void writeBytes(bytes, [int len]) {
    if (len == null) {
      len = bytes.length;
    }
    if (bytes is InputFileStream) {
      InputFileStream in_stream = bytes as InputFileStream;
      while (!in_stream.isEOS) {
        int len = in_stream.bufferRemaining;
        InputStream data = in_stream.readBytes(len);
        writeInputStream(data);
      }
    } else {
      _fp.writeFromSync(bytes, 0, len);
    }
    length += len;
  }

  void writeInputStream(InputStream bytes) {
    _fp.writeFromSync(bytes.buffer, bytes.offset, bytes.length);
  }

  /**
   * Write a 16-bit word to the end of the buffer.
   */
  void writeUint16(int value) {
    if (byteOrder == BIG_ENDIAN) {
      writeByte((value >> 8) & 0xff);
      writeByte((value) & 0xff);
      return;
    }
    writeByte((value) & 0xff);
    writeByte((value >> 8) & 0xff);
  }

  /**
   * Write a 32-bit word to the end of the buffer.
   */
  void writeUint32(int value) {
    if (byteOrder == BIG_ENDIAN) {
      writeByte((value >> 24) & 0xff);
      writeByte((value >> 16) & 0xff);
      writeByte((value >> 8) & 0xff);
      writeByte((value) & 0xff);
      return;
    }
    writeByte((value) & 0xff);
    writeByte((value >> 8) & 0xff);
    writeByte((value >> 16) & 0xff);
    writeByte((value >> 24) & 0xff);
  }

  List<int> subset(int start, [int end]) {
    int pos = _fp.positionSync();
    if (start < 0) {
      start = pos + start;
    }
    int length = 0;
    if (end == null) {
      end = pos;
    } else if (end < 0) {
      end = pos + end;
    }
    length = (end - start);
    _fp.setPositionSync(start);
    Uint8List buffer = new Uint8List(length);
    _fp.readIntoSync(buffer);
    _fp.setPositionSync(pos);
    return buffer;
  }
}