@@ -522,7 +522,7 @@ group('putObject(),cancelTask()', function () {
522522 assert ( info ) ;
523523 done ( ) ;
524524 } )
525- } ) ;
525+ } ) ;
526526} ) ;
527527
528528group ( 'task 队列' , function ( ) {
@@ -820,9 +820,9 @@ group('headBucket()', function () {
820820 } ) ;
821821 } ) ;
822822
823- test ( 'headBucket() not exist' , function ( done , assert ) {
823+ test ( 'headBucket() bucket not exist' , function ( done , assert ) {
824824 cos . headBucket ( {
825- Bucket : config . Bucket + Date . now ( ) . toString ( 36 ) ,
825+ Bucket : Date . now ( ) . toString ( 36 ) + config . Bucket ,
826826 Region : config . Region
827827 } , function ( err , data ) {
828828 assert . ok ( err , 'bucket 不存在' ) ;
@@ -832,7 +832,7 @@ group('headBucket()', function () {
832832
833833 test ( 'deleteBucket()' , function ( done , assert ) {
834834 cos . deleteBucket ( {
835- Bucket : config . Bucket + Date . now ( ) . toString ( 36 ) ,
835+ Bucket : Date . now ( ) . toString ( 36 ) + config . Bucket ,
836836 Region : config . Region
837837 } , function ( err , data ) {
838838 assert . ok ( err , 'deleteBucket 不存在' ) ;
@@ -1139,6 +1139,43 @@ group('getObject(),getObjectStream()', function () {
11391139 } ) ;
11401140 } ) ;
11411141 } ) ;
1142+ test ( 'getObject() stream2' , function ( done , assert ) {
1143+ var key = '1.txt' ;
1144+ var objectContent = Buffer . from ( [ ] ) ;
1145+ var outputStream = new Writable ( {
1146+ write : function ( chunk , encoding , callback ) {
1147+ objectContent = Buffer . concat ( [ objectContent , chunk ] ) ;
1148+ callback ( ) ;
1149+ }
1150+ } ) ;
1151+ var content = Date . now ( ) . toString ( 36 ) ;
1152+ cos . putObject ( {
1153+ Bucket : config . Bucket ,
1154+ Region : config . Region ,
1155+ Key : key ,
1156+ Body : Buffer . from ( content )
1157+ } , function ( err , data ) {
1158+ cos . getObject ( {
1159+ Bucket : config . Bucket ,
1160+ Region : config . Region ,
1161+ Key : key ,
1162+ Output : './1.txt'
1163+ } , function ( err , data ) {
1164+ if ( err ) throw err ;
1165+ objectContent = objectContent . toString ( ) ;
1166+ assert . ok ( data . headers [ 'content-length' ] === '' + content . length ) ;
1167+ assert . ok ( objectContent === content ) ;
1168+ cos . headObject ( {
1169+ Bucket : config . Bucket ,
1170+ Region : config . Region ,
1171+ Key : key
1172+ } , function ( err , data ) {
1173+ assert . ok ( ! err ) ;
1174+ done ( ) ;
1175+ } ) ;
1176+ } ) ;
1177+ } ) ;
1178+ } ) ;
11421179 test ( 'getObjectStream' , function ( done , assert ) {
11431180 var content = Date . now ( ) . toString ( ) ;
11441181 var key = '1.json' ;
@@ -1199,7 +1236,7 @@ group('deleteObject() 404', function () {
11991236 cos . deleteObject ( {
12001237 Bucket : config . Bucket ,
12011238 Region : config . Region ,
1202- Key : Date . now ( ) . toString ( 36 ) ,
1239+ Key : '123' + Date . now ( ) . toString ( 36 ) ,
12031240 } , function ( err , data ) {
12041241 assert . ok ( data . statusCode === 404 ) ;
12051242 done ( ) ;
@@ -1413,7 +1450,7 @@ group('sliceCopyFile()', function () {
14131450 Bucket : config . Bucket ,
14141451 Region : config . Region ,
14151452 Key : Key ,
1416- CopySource : 'www.qq .com/1.txt' ,
1453+ CopySource : 'www.123 .com/1.txt' ,
14171454 } , function ( err , data ) {
14181455 assert . ok ( err ) ;
14191456 done ( ) ;
@@ -2468,7 +2505,16 @@ group('BucketWebsite', function () {
24682505 assert . ok ( err ) ;
24692506 done ( ) ;
24702507 } ) ;
2471- } ) ;
2508+ } ) ;
2509+ test ( 'putBucketWebsite() bucket not exist' , function ( done , assert ) {
2510+ cos . putBucketWebsite ( {
2511+ Bucket : config . Bucket ,
2512+ Region : config . Region ,
2513+ } , function ( err , data ) {
2514+ assert . ok ( err ) ;
2515+ done ( ) ;
2516+ } ) ;
2517+ } ) ;
24722518 test ( 'putBucketWebsite(),getBucketWebsite()' , function ( done , assert ) {
24732519 cos . putBucketWebsite ( {
24742520 Bucket : config . Bucket ,
@@ -3261,6 +3307,16 @@ group('BucketInventory', function () {
32613307 } ) ;
32623308 } ) ;
32633309 } ) ;
3310+ test ( 'deleteBucketInventory() bucket not exist' , function ( done , assert ) {
3311+ cos . deleteBucketInventory ( {
3312+ Bucket : Date . now ( ) . toString ( 36 ) + config . Bucket ,
3313+ Region : config . Region ,
3314+ Id : InventoryConfiguration . Id
3315+ } , function ( err , data ) {
3316+ assert . ok ( err ) ;
3317+ done ( ) ;
3318+ } ) ;
3319+ } ) ;
32643320} ) ;
32653321
32663322group ( 'Content-Type: false Bug' , function ( ) {
@@ -3455,6 +3511,19 @@ group('ObjectTagging', function () {
34553511 } , 1000 ) ;
34563512 } ) ;
34573513 } ) ;
3514+ test ( 'putObjectTagging() object not exist' , function ( done , assert ) {
3515+ cos . putObjectTagging ( {
3516+ Bucket : config . Bucket ,
3517+ Region : config . Region ,
3518+ Key : Date . now ( ) . toString ( 36 ) + key ,
3519+ Tagging : {
3520+ Tags : Tags
3521+ } ,
3522+ } , function ( err , data ) {
3523+ assert . ok ( err ) ;
3524+ done ( ) ;
3525+ } ) ;
3526+ } ) ;
34583527 test ( 'getObjectTagging() object not exist' , function ( done , assert ) {
34593528 cos . getObjectTagging ( {
34603529 Bucket : config . Bucket ,
@@ -3870,7 +3939,6 @@ group('BucketReplication', function () {
38703939 Status : 'Suspended'
38713940 }
38723941 } , function ( err , data ) {
3873- assert . ok ( ! err ) ;
38743942 setTimeout ( function ( ) {
38753943 cos . getBucketReplication ( {
38763944 Bucket : config . Bucket ,
@@ -3882,6 +3950,18 @@ group('BucketReplication', function () {
38823950 } , 2000 ) ;
38833951 } ) ;
38843952 } ) ;
3953+ test ( 'deleteBucketReplication() bucket not exist' , function ( done , assert ) {
3954+ cos . deleteBucketReplication ( {
3955+ Bucket : Date . now ( ) . toString ( 36 ) + config . Bucket , // Bucket 格式:test-1250000000
3956+ Region : config . Region ,
3957+ VersioningConfiguration : {
3958+ Status : 'Suspended'
3959+ }
3960+ } , function ( err , data ) {
3961+ assert . ok ( err ) ;
3962+ done ( ) ;
3963+ } ) ;
3964+ } ) ;
38853965} ) ;
38863966
38873967group ( 'putBucketVersioning(),getBucketVersioning()' , function ( ) {
0 commit comments