fix: getStream support options.process (#304)

closes #300

lib/object.js

@@ -204,6 +204,12 @@ proto.get = function* get(name, file, options) {
 
 proto.getStream = function* getStream(name, options) {
  options = options || {};
+
+ if (options.process) {
+ options.subres = options.subres || {};
+ options.subres['x-oss-process'] = options.process;
+ }
+
  var params = this._objectRequestParams('GET', name, options);
  params.customResponse = true;
  params.successStatuses = [200, 206, 304];

package.json

@@ -60,6 +60,7 @@
  "mocha": "^3.0.0",
  "should": "^11.0.0",
  "sinon": "^1.17.6",
+ "stream-equal": "^1.1.0",
  "thunk-mocha": "^1.0.3",
  "uglify-js": "^2.7.1"
  },

test/object.test.js

@@ -13,6 +13,7 @@ var stsConfig = require('./config').sts;
 var urllib = require('urllib');
 var copy = require('copy-to');
 var mm = require('mm');
+const streamEqual = require('stream-equal');
 
 var tmpdir = path.join(__dirname, '.tmp');
 if (!fs.existsSync(tmpdir)) {
@@ -914,6 +915,25 @@ describe('test/object.test.js', function () {
  assert.equal(fs.readFileSync(tmpfile, 'utf8'), fs.readFileSync(__filename, 'utf8'));
  });
 
+ it('should get image stream with image process', function* () {
+ var name = prefix + 'ali-sdk/oss/nodejs-test-getstream-image-1024x768.png';
+ var originImagePath = path.join(__dirname, 'nodejs-1024x768.png');
+ var processedImagePath = path.join(__dirname, 'nodejs-processed-w200.png');
+ var object = yield this.store.put(name, originImagePath, {
+ mime: 'image/png'
+ });
+
+ var result = yield this.store.getStream(name, {process: 'image/resize,w_200'});
+ assert.equal(result.res.status, 200);
+ var isEqual = yield streamEqual(result.stream, fs.createReadStream(processedImagePath));
+ assert(isEqual);
+ result = yield this.store.getStream(name,
+ {process: 'image/resize,w_200', subres: {'x-oss-process': 'image/resize,w_100'}});
+ assert.equal(result.res.status, 200);
+ isEqual = yield streamEqual(result.stream, fs.createReadStream(processedImagePath));
+ assert(isEqual);
+ });
+
  it('should throw error when object not exists', function* () {
  try {
  yield this.store.getStream(this.name + 'not-exists');