| #!/usr/bin/env node |
| |
| var program = require('commander'); |
| var Bunzip = require('../'); |
| var fs = require('fs'); |
| |
| program |
| .version(Bunzip.version) |
| .usage('[infile]') |
| .option('-m, --multistream', |
| 'Read a multistream bzip2 file'); |
| program.on('--help', function() { |
| console.log(' If <infile> is omitted, reads from stdin.'); |
| }); |
| program.parse(process.argv); |
| |
| var makeInStream = function(in_fd) { |
| var stat = fs.fstatSync(in_fd); |
| var stream = { |
| buffer: new Buffer(4096), |
| totalPos: 0, |
| pos: 0, |
| end: 0, |
| _fillBuffer: function() { |
| this.end = fs.readSync(in_fd, this.buffer, 0, this.buffer.length); |
| this.pos = 0; |
| }, |
| readByte: function() { |
| if (this.pos >= this.end) { this._fillBuffer(); } |
| if (this.pos < this.end) { |
| this.totalPos++; |
| return this.buffer[this.pos++]; |
| } |
| return -1; |
| }, |
| read: function(buffer, bufOffset, length) { |
| if (this.pos >= this.end) { this._fillBuffer(); } |
| var bytesRead = 0; |
| while (bytesRead < length && this.pos < this.end) { |
| buffer[bufOffset++] = this.buffer[this.pos++]; |
| bytesRead++; |
| } |
| this.totalPos += bytesRead; |
| return bytesRead; |
| }, |
| eof: function() { |
| if (this.pos >= this.end) { this._fillBuffer(); } |
| return !(this.pos < this.end); |
| } |
| }; |
| if (stat.size) { |
| stream.size = stat.size; |
| } |
| return stream; |
| }; |
| |
| var in_fd = 0, close_in = function(){}; |
| if (program.args.length > 0) { |
| in_fd = fs.openSync(program.args.shift(), 'r'); |
| close_in = function() { fs.closeSync(in_fd); }; |
| } |
| |
| var inStream = makeInStream(in_fd); |
| |
| var report = function(position, blocksize) { |
| console.log(position+'\t'+blocksize); |
| }; |
| |
| Bunzip.table(inStream, report, program.multistream); |
| close_in(); |
| return 0; |