processObjectSave.js 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445
  1. /* eslint-disable no-use-before-define */
  2. const { checkBucketName: _checkBucketName } = require('../utils/checkBucketName');
  3. const querystring = require('querystring');
  4. const {
  5. Base64: { encode: str2Base64 }
  6. } = require('js-base64');
  7. const proto = exports;
  8. proto.processObjectSave = async function processObjectSave(sourceObject, targetObject, process, targetBucket) {
  9. checkArgs(sourceObject, 'sourceObject');
  10. checkArgs(targetObject, 'targetObject');
  11. checkArgs(process, 'process');
  12. targetObject = this._objectName(targetObject);
  13. if (targetBucket) {
  14. _checkBucketName(targetBucket);
  15. }
  16. const params = this._objectRequestParams('POST', sourceObject, {
  17. subres: 'x-oss-process'
  18. });
  19. const bucketParam = targetBucket ? `,b_${str2Base64(targetBucket)}` : '';
  20. targetObject = str2Base64(targetObject);
  21. const content = {
  22. 'x-oss-process': `${process}|sys/saveas,o_${targetObject}${bucketParam}`
  23. };
  24. params.content = querystring.stringify(content);
  25. const result = await this.request(params);
  26. return {
  27. res: result.res,
  28. status: result.res.status
  29. };
  30. };
  31. function checkArgs(name, key) {
  32. if (!name) {
  33. throw new Error(`${key} is required`);
  34. }
  35. if (typeof name !== 'string') {
  36. throw new Error(`${key} must be String`);
  37. }
  38. }