(fields, cb)
| 71 | let s3; |
| 72 | |
| 73 | function requestGet(fields, cb) { |
| 74 | s3.send(new GetObjectCommand(Object.assign({ |
| 75 | Bucket: bucketName, |
| 76 | Key: objectName, |
| 77 | }, fields))).then(data => cb(null, data)).catch(err => { |
| 78 | if (err.$metadata.httpStatusCode === 304) { |
| 79 | const notModifiedError = new Error('NotModified'); |
| 80 | notModifiedError.name = 'NotModified'; |
| 81 | notModifiedError.$metadata = err.$metadata; |
| 82 | return cb(notModifiedError); |
| 83 | } |
| 84 | return cb(err); |
| 85 | }); |
| 86 | } |
| 87 | |
| 88 | const requestGetPromise = promisify(requestGet); |
| 89 |