@@ -8,14 +8,14 @@ angular.module('web').factory('QiniuClient', [
88 'Config' ,
99 'AuthInfo' ,
1010 'settingsSvs' ,
11- function ( $q , $rootScope , $translate , $timeout , $state , Toast , Config , AuthInfo , settingsSvs ) {
11+ function ( $q , $rootScope , $translate , $timeout , $state , Toast , Config , AuthInfo , settingsSvs ) {
1212 const { Qiniu, Region, KODO_MODE , S3_MODE , RegionService } = require ( 'kodo-s3-adapter-sdk' ) ,
13- path = require ( 'path' ) ,
14- { Semaphore } = require ( 'semaphore-promise' ) ,
15- T = $translate . instant ,
16- kodoAdaptersCache = { } ,
17- s3AdaptersCache = { } ,
18- regionServicesCache = { } ;
13+ path = require ( 'path' ) ,
14+ { Semaphore } = require ( 'semaphore-promise' ) ,
15+ T = $translate . instant ,
16+ kodoAdaptersCache = { } ,
17+ s3AdaptersCache = { } ,
18+ regionServicesCache = { } ;
1919
2020 return {
2121 isQueryRegionAPIAvaiable : isQueryRegionAPIAvaiable ,
@@ -210,7 +210,7 @@ angular.module('web').factory('QiniuClient', [
210210
211211 function headFile ( region , bucket , key , opt ) {
212212 let promise = getDefaultClient ( opt )
213- . getObjectInfo ( region , { bucket : bucket , key : key } ) ;
213+ . getObjectInfo ( region , { bucket : bucket , key : key } ) ;
214214 if ( ! opt . ignoreError ) {
215215 promise = promise . catch ( ( err ) => {
216216 handleError ( err ) ;
@@ -232,12 +232,11 @@ angular.module('web').factory('QiniuClient', [
232232 } ) ;
233233 }
234234
235- function saveContent ( region , bucket , key , content , domain , opt ) {
235+ function saveContent ( region , bucket , key , content , domain , getOpt , putOpt ) {
236236 return new Promise ( ( resolve , reject ) => {
237- const client = getDefaultClient ( opt ) ;
238- client . getObjectHeader ( region , { bucket : bucket , key : key } , domain ) . then ( ( headers ) => {
237+ getDefaultClient ( getOpt ) . getObjectHeader ( region , { bucket : bucket , key : key } , domain ) . then ( ( headers ) => {
239238 const basename = path . basename ( key ) ;
240- client . putObject ( region , { bucket : bucket , key : key } , Buffer . from ( content ) , basename ,
239+ getDefaultClient ( putOpt ) . putObject ( region , { bucket : bucket , key : key } , Buffer . from ( content ) , basename ,
241240 { metadata : headers . metadata } ,
242241 ) . then ( ( ) => { resolve ( ) ; } ) . catch ( ( err ) => {
243242 handleError ( err ) ;
@@ -592,7 +591,7 @@ angular.module('web').factory('QiniuClient', [
592591 function clientBackendMode ( opt ) {
593592 const adapterOption = getAdapterOption ( opt ) ;
594593 const usePublicCloud = AuthInfo . usePublicCloud ( ) ;
595- if ( adapterOption . regions && adapterOption . regions . length > 0 && ! adapterOption . preferKodoAdapter || adapterOption . preferS3Adapter || ! usePublicCloud ) {
594+ if ( adapterOption . regions && adapterOption . regions . length > 0 && ! adapterOption . preferKodoAdapter || adapterOption . preferS3Adapter || ! usePublicCloud ) {
596595 return S3_MODE ;
597596 } else {
598597 return KODO_MODE ;
@@ -613,11 +612,11 @@ angular.module('web').factory('QiniuClient', [
613612 }
614613
615614 function getDefaultClient ( opt ) {
616- switch ( clientBackendMode ( opt ) ) {
617- case S3_MODE :
618- return getS3Client ( opt ) ;
619- case KODO_MODE :
620- return getKodoClient ( opt ) ;
615+ switch ( clientBackendMode ( opt ) ) {
616+ case S3_MODE :
617+ return getS3Client ( opt ) ;
618+ case KODO_MODE :
619+ return getKodoClient ( opt ) ;
621620 }
622621 }
623622
@@ -650,18 +649,18 @@ angular.module('web').factory('QiniuClient', [
650649 }
651650
652651 function clearAllCache ( ) {
653- Object . keys ( s3AdaptersCache ) . forEach ( ( key ) => {
654- s3AdaptersCache [ key ] . clearCache ( ) ;
655- delete s3AdaptersCache [ key ] ;
656- } ) ;
657- Object . keys ( kodoAdaptersCache ) . forEach ( ( key ) => {
658- kodoAdaptersCache [ key ] . clearCache ( ) ;
659- delete kodoAdaptersCache [ key ] ;
660- } ) ;
661- Object . keys ( regionServicesCache ) . forEach ( ( key ) => {
662- regionServicesCache [ key ] . clearCache ( ) ;
663- delete regionServicesCache [ key ] ;
664- } ) ;
652+ Object . keys ( s3AdaptersCache ) . forEach ( ( key ) => {
653+ s3AdaptersCache [ key ] . clearCache ( ) ;
654+ delete s3AdaptersCache [ key ] ;
655+ } ) ;
656+ Object . keys ( kodoAdaptersCache ) . forEach ( ( key ) => {
657+ kodoAdaptersCache [ key ] . clearCache ( ) ;
658+ delete kodoAdaptersCache [ key ] ;
659+ } ) ;
660+ Object . keys ( regionServicesCache ) . forEach ( ( key ) => {
661+ regionServicesCache [ key ] . clearCache ( ) ;
662+ delete regionServicesCache [ key ] ;
663+ } ) ;
665664 }
666665
667666 function debugRequest ( mode ) {
@@ -686,21 +685,21 @@ angular.module('web').factory('QiniuClient', [
686685 }
687686
688687 let requestUrl = undefined , requestMethod = undefined , requestHeaders = undefined ,
689- responseStatusCode = undefined , responseHeaders = undefined , responseInterval = undefined , responseData = undefined , responseError = undefined ;
688+ responseStatusCode = undefined , responseHeaders = undefined , responseInterval = undefined , responseData = undefined , responseError = undefined ;
690689 if ( response ) {
691- responseStatusCode = response . statusCode ;
692- responseHeaders = response . headers ;
693- responseInterval = response . interval ;
694- responseData = response . data ;
695- responseError = response . error ;
690+ responseStatusCode = response . statusCode ;
691+ responseHeaders = response . headers ;
692+ responseInterval = response . interval ;
693+ responseData = response . data ;
694+ responseError = response . error ;
696695 if ( response . request ) {
697696 requestUrl = response . request . url ;
698697 requestMethod = response . request . method ;
699698 requestHeaders = response . request . headers ;
700699 }
701700 }
702701 console . info ( '<<' , mode , 'REQ_URL:' , requestUrl , 'REQ_METHOD:' , requestMethod , 'REQ_HEADERS: ' , requestHeaders ,
703- 'RESP_STATUS:' , responseStatusCode , 'RESP_HEADERS:' , responseHeaders , 'RESP_INTERVAL:' , responseInterval , 'ms RESP_DATA:' , responseData , 'RESP_ERROR:' , responseError ) ;
702+ 'RESP_STATUS:' , responseStatusCode , 'RESP_HEADERS:' , responseHeaders , 'RESP_INTERVAL:' , responseInterval , 'ms RESP_DATA:' , responseData , 'RESP_ERROR:' , responseError ) ;
704703 } ;
705704 }
706705
0 commit comments