Skip to content

Commit eae6dc6

Browse files
committed
tweak event, lifecycle API for BucketManager
1 parent 3006e2b commit eae6dc6

File tree

1 file changed

+14
-8
lines changed

1 file changed

+14
-8
lines changed

qiniu/storage/rs.js

Lines changed: 14 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1039,14 +1039,15 @@ BucketManager.prototype.putBucketLifecycleRule = function (
10391039
options
10401040
);
10411041
const reqSpec = querystring.stringify(reqParams);
1042-
const reqOp = `/rules/add?${reqSpec}`;
1042+
const reqOp = '/rules/add';
10431043

10441044
return this._tryReq({
10451045
serviceName: SERVICE_NAME.UC,
10461046
func: context => {
10471047
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
10481048
return this._httpClient.post({
10491049
url: requestURL,
1050+
data: reqSpec,
10501051
callback: wrapTryCallback(callbackFunc)
10511052
});
10521053
}
@@ -1067,13 +1068,14 @@ BucketManager.prototype.deleteBucketLifecycleRule = function (bucket, name, call
10671068
name: name
10681069
};
10691070
const reqSpec = querystring.stringify(reqParams);
1070-
const reqOp = `/rules/delete?${reqSpec}`;
1071+
const reqOp = '/rules/delete';
10711072
return this._tryReq({
10721073
serviceName: SERVICE_NAME.UC,
10731074
func: context => {
10741075
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
10751076
return this._httpClient.post({
10761077
url: requestURL,
1078+
data: reqSpec,
10771079
callback: wrapTryCallback(callbackFunc)
10781080
});
10791081
}
@@ -1107,14 +1109,15 @@ BucketManager.prototype.updateBucketLifecycleRule = function (bucket, options, c
11071109
options
11081110
);
11091111
const reqSpec = querystring.stringify(reqParams);
1110-
const reqOp = `/rules/update?${reqSpec}`;
1112+
const reqOp = '/rules/update';
11111113

11121114
return this._tryReq({
11131115
serviceName: SERVICE_NAME.UC,
11141116
func: context => {
11151117
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
11161118
return this._httpClient.post({
11171119
url: requestURL,
1120+
data: reqSpec,
11181121
callback: wrapTryCallback(callbackFunc)
11191122
});
11201123
}
@@ -1134,7 +1137,7 @@ BucketManager.prototype.getBucketLifecycleRule = function (bucket, callbackFunc)
11341137
serviceName: SERVICE_NAME.UC,
11351138
func: context => {
11361139
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
1137-
return this._httpClient.post({
1140+
return this._httpClient.get({
11381141
url: requestURL,
11391142
callback: wrapTryCallback(callbackFunc)
11401143
});
@@ -1177,14 +1180,15 @@ BucketManager.prototype.putBucketEvent = function (bucket, options, callbackFunc
11771180

11781181
// in docs the params should be putted into body
11791182
// keep compatibility with old sdk versions
1180-
const reqOp = `/events/add?${reqSpec}`;
1183+
const reqOp = '/events/add';
11811184

11821185
return this._tryReq({
11831186
serviceName: SERVICE_NAME.UC,
11841187
func: context => {
11851188
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
11861189
return this._httpClient.post({
11871190
url: requestURL,
1191+
data: reqSpec,
11881192
callback: wrapTryCallback(callbackFunc)
11891193
});
11901194
}
@@ -1213,14 +1217,15 @@ BucketManager.prototype.updateBucketEvent = function (bucket, options, callbackF
12131217
);
12141218

12151219
const reqSpec = querystring.stringify(reqParams);
1216-
const reqOp = `/events/update?${reqSpec}`;
1220+
const reqOp = '/events/update';
12171221

12181222
return this._tryReq({
12191223
serviceName: SERVICE_NAME.UC,
12201224
func: context => {
12211225
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
12221226
return this._httpClient.post({
12231227
url: requestURL,
1228+
data: reqSpec,
12241229
callback: wrapTryCallback(callbackFunc)
12251230
});
12261231
}
@@ -1239,7 +1244,7 @@ BucketManager.prototype.getBucketEvent = function (bucket, callbackFunc) {
12391244
serviceName: SERVICE_NAME.UC,
12401245
func: context => {
12411246
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
1242-
return this._httpClient.post({
1247+
return this._httpClient.get({
12431248
url: requestURL,
12441249
callback: wrapTryCallback(callbackFunc)
12451250
});
@@ -1260,14 +1265,15 @@ BucketManager.prototype.deleteBucketEvent = function (bucket, name, callbackFunc
12601265
name: name
12611266
};
12621267
const reqSpec = querystring.stringify(reqParams);
1263-
const reqOp = `/events/delete?${reqSpec}`;
1268+
const reqOp = '/events/delete';
12641269

12651270
return this._tryReq({
12661271
serviceName: SERVICE_NAME.UC,
12671272
func: context => {
12681273
const requestURL = this._getEndpointVal(context.endpoint) + reqOp;
12691274
return this._httpClient.post({
12701275
url: requestURL,
1276+
data: reqSpec,
12711277
callback: wrapTryCallback(callbackFunc)
12721278
});
12731279
}

0 commit comments

Comments
 (0)