-
Notifications
You must be signed in to change notification settings - Fork 577
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: callback support for callbackSNI
- Loading branch information
csg01123119
committed
Aug 6, 2024
1 parent
05214d4
commit 6835c32
Showing
9 changed files
with
227 additions
and
20,288 deletions.
There are no files selected for viewing
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,208 @@ | ||
| /* eslint-disable @typescript-eslint/no-require-imports */ | ||
| // TODO callback server is disable | ||
| const fs = require('fs'); | ||
| const assert = require('assert'); | ||
| const utils = require('./utils'); | ||
| const oss = require('../../lib/client'); | ||
| const { sts } = require('../config'); | ||
| const config = require('../config').oss; | ||
| const mm = require('mm'); | ||
|
|
||
| /* | ||
| * temp test callback | ||
| * multipartUpload | ||
| * put | ||
| */ | ||
| describe.skip('test/callback.test.js', () => { | ||
| const { prefix } = utils; | ||
| let store; | ||
| let bucket; | ||
| let bucketRegion; | ||
| const { | ||
| env: { ALI_SDK_CALLBACK_IP: callbackServer } | ||
| } = process; | ||
|
|
||
| before(async () => { | ||
| store = oss(config); | ||
| bucket = sts.bucket; | ||
| bucketRegion = config.region; | ||
| store.useBucket(bucket, bucketRegion); | ||
| }); | ||
|
|
||
| after(async () => { | ||
| // await utils.cleanBucket(store, bucket, bucketRegion); | ||
| }); | ||
|
|
||
| describe('upload callback', () => { | ||
| afterEach(mm.restore); | ||
| it('should multipart upload parse response with callback false', async () => { | ||
| const fileName = await utils.createTempFile('upload-with-callback', 1024 * 1024); | ||
|
|
||
| const name = `${prefix}multipart/upload-with-callback`; | ||
| const host = 'oss-cn-hangzhou.aliyuncs.com'; | ||
| const var1 = 'value1'; | ||
| const result = await store.multipartUpload(name, fileName, { | ||
| partSize: 300 * 1024, | ||
| callback: { | ||
| url: callbackServer, | ||
| host, | ||
| /* eslint no-template-curly-in-string: [0] */ | ||
| body: 'bucket=${bucket}&object=${object}&var1=${x:var1}', | ||
| contentType: 'application/x-www-form-urlencoded', | ||
| callbackSNI: false, | ||
| customValue: { | ||
| var1, | ||
| var2: 'value2' | ||
| } | ||
| } | ||
| }); | ||
| assert.equal(result.res.status, 200); | ||
| const { sni } = result.data; | ||
| assert.equal(sni, false); | ||
| }); | ||
|
|
||
| it('should multipart upload parse response with callback', async () => { | ||
| const fileName = await utils.createTempFile('upload-with-callback', 1024 * 1024); | ||
|
|
||
| const name = `${prefix}multipart/upload-with-callback`; | ||
| const host = 'oss-cn-hangzhou.aliyuncs.com'; | ||
| const var1 = 'value1'; | ||
| const result = await store.multipartUpload(name, fileName, { | ||
| partSize: 300 * 1024, | ||
| callback: { | ||
| url: callbackServer, | ||
| host, | ||
| /* eslint no-template-curly-in-string: [0] */ | ||
| body: 'bucket=${bucket}&object=${object}&var1=${x:var1}', | ||
| contentType: 'application/x-www-form-urlencoded', | ||
| callbackSNI: true, | ||
| customValue: { | ||
| var1, | ||
| var2: 'value2' | ||
| } | ||
| } | ||
| }); | ||
| assert.equal(result.res.status, 200); | ||
| const { sni, var1: va, object: obj } = result.data; | ||
| assert.equal(sni, host); | ||
| assert.equal(var1, va); | ||
| assert.equal(obj, name); | ||
| }); | ||
|
|
||
| it('should multipart upload copy with callback', async () => { | ||
| const fileName = await utils.createTempFile('multipart-upload-file-copy-callback', 2 * 1024 * 1024); | ||
| const name = `${prefix}multipart/upload-file-with-copy-callback`; | ||
| await store.multipartUpload(name, fileName); | ||
|
|
||
| const client = store; | ||
| const copyName = `${prefix}multipart/upload-file-with-copy-new-callback`; | ||
| const result = await client.multipartUploadCopy( | ||
| copyName, | ||
| { | ||
| sourceKey: name, | ||
| sourceBucketName: bucket | ||
| }, | ||
| { | ||
| partSize: 256 * 1024, | ||
| callback: { | ||
| url: callbackServer, | ||
| host: 'oss-cn-hangzhou.aliyuncs.com', | ||
| body: 'bucket=${bucket}&object=${object}&var1=${x:var1}', | ||
| contentType: 'application/x-www-form-urlencoded', | ||
| callbackSNI: true, | ||
| customValue: { | ||
| var1: 'value1', | ||
| var2: 'value2' | ||
| } | ||
| }, | ||
| copyheaders: { | ||
| 'x-oss-copy-source-if-match': '' | ||
| } | ||
| } | ||
| ); | ||
|
|
||
| assert.equal(result.res.status, 200); | ||
| assert.equal(result.data.object, copyName); | ||
| }); | ||
|
|
||
| it('should multipart upload with no more 100k file parse response with callback', async () => { | ||
| const fileName = await utils.createTempFile('upload-with-callback', 50 * 1024); | ||
|
|
||
| const name = `${prefix}multipart/upload-with-callback`; | ||
| const result = await store.multipartUpload(name, fileName, { | ||
| partSize: 100 * 1024, | ||
| callback: { | ||
| url: callbackServer, | ||
| host: 'oss-cn-hangzhou.aliyuncs.com', | ||
| body: 'bucket=${bucket}&object=${object}&var1=${x:var1}', | ||
| contentType: 'application/x-www-form-urlencoded', | ||
| callbackSNI: true, | ||
| customValue: { | ||
| var1: 'value1', | ||
| var2: 'value2' | ||
| } | ||
| } | ||
| }); | ||
| assert.equal(result.res.status, 200); | ||
| assert.equal(result.data.object, name); | ||
| }); | ||
|
|
||
| it('should putStream parse response with callback', async () => { | ||
| const name = `${prefix}ali-sdk/oss/putstream-callback.js`; | ||
| const result = await store.putStream(name, fs.createReadStream(__filename), { | ||
| callback: { | ||
| url: callbackServer, | ||
| host: 'oss-cn-hangzhou.aliyuncs.com', | ||
| body: 'bucket=${bucket}&object=${object}&var1=${x:var1}', | ||
| contentType: 'application/x-www-form-urlencoded', | ||
| callbackSNI: true, | ||
| customValue: { | ||
| var1: 'value1', | ||
| var2: 'value2' | ||
| } | ||
| } | ||
| }); | ||
|
|
||
| assert.equal(result.res.status, 200); | ||
| assert.equal(result.data.object, name); | ||
| }); | ||
|
|
||
| it('should put parse response with callback', async () => { | ||
| const name = `${prefix}ali-sdk/oss/put-callback.js`; | ||
| const result = await store.put(name, __filename, { | ||
| callback: { | ||
| url: callbackServer, | ||
| host: 'oss-cn-hangzhou.aliyuncs.com', | ||
| body: 'bucket=${bucket}&object=${object}&var1=${x:var1}', | ||
| contentType: 'application/x-www-form-urlencoded', | ||
| callbackSNI: true, | ||
| customValue: { | ||
| var1: 'value1', | ||
| var2: 'value2' | ||
| } | ||
| } | ||
| }); | ||
|
|
||
| assert.equal(result.res.status, 200); | ||
| assert.equal(result.data.object, name); | ||
| }); | ||
|
|
||
| it('should multipart upload with no more 100k file use header x-oss-callback', async () => { | ||
| // create a file with 1M random data | ||
| const fileName = await utils.createTempFile('upload-with-callback', 50 * 1024); | ||
| const callback = { | ||
| url: callbackServer, | ||
| body: 'bucket=${bucket}&object=${object}&var1=${x:var1}' | ||
| }; | ||
| const name = `${prefix}multipart/upload-with-callback`; | ||
| const result = await store.multipartUpload(name, fileName, { | ||
| partSize: 100 * 1024, | ||
| headers: { | ||
| 'x-oss-callback': utils.encodeCallback(callback) | ||
| } | ||
| }); | ||
| assert.equal(result.res.status, 200); | ||
| assert.equal(result.data.object, name); | ||
| }); | ||
| }); | ||
| }); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Binary file not shown.
Binary file not shown.