@@ -13,6 +13,7 @@ import type { ConfigGoogleStorage } from '../types';
1313export const noSuchFile : string = 'ENOENT' ;
1414export const fileExist : string = 'EEXISTS' ;
1515export const pkgFileName = 'package.json' ;
16+ export const defaultValidation = 'crc32c' ;
1617
1718declare type StorageType = Package | void ;
1819
@@ -91,7 +92,9 @@ class GoogleCloudStorageHandler implements ILocalPackageManager {
9192 this . logger . debug ( { name : file . name } , 'gcloud: deleting @{name} from storage' ) ;
9293 try {
9394 file
94- . delete ( )
95+ . delete ( {
96+ validation : this . config . validation || defaultValidation
97+ } )
9598 . then ( data => {
9699 const apiResponse = data [ 0 ] ;
97100 this . logger . debug ( { name : file . name } , 'gcloud: @{name} was deleted successfully from storage' ) ;
@@ -111,16 +114,20 @@ class GoogleCloudStorageHandler implements ILocalPackageManager {
111114 // remove all files from storage
112115 const file = this . _getBucket ( ) . file ( `${ this . name } ` ) ;
113116 this . logger . debug ( { name : file . name } , 'gcloud: removing the package @{name} from storage' ) ;
114- file . delete ( ) . then (
115- ( ) => {
116- this . logger . debug ( { name : file . name } , 'gcloud: package @{name} was deleted successfully from storage' ) ;
117- callback ( null ) ;
118- } ,
119- err => {
120- this . logger . error ( { name : file . name , err : err . message } , 'gcloud: delete @{name} package has failed err: @{err}' ) ;
121- callback ( fSError ( err . message , 500 ) ) ;
122- }
123- ) ;
117+ file
118+ . delete ( {
119+ validation : this . config . validation || defaultValidation
120+ } )
121+ . then (
122+ ( ) => {
123+ this . logger . debug ( { name : file . name } , 'gcloud: package @{name} was deleted successfully from storage' ) ;
124+ callback ( null ) ;
125+ } ,
126+ err => {
127+ this . logger . error ( { name : file . name , err : err . message } , 'gcloud: delete @{name} package has failed err: @{err}' ) ;
128+ callback ( fSError ( err . message , 500 ) ) ;
129+ }
130+ ) ;
124131 }
125132
126133 createPackage ( name : string , metadata : Object , cb : Function ) : void {
@@ -159,7 +166,9 @@ class GoogleCloudStorageHandler implements ILocalPackageManager {
159166 return new Promise ( async ( resolve , reject ) => {
160167 const file = this . _buildFilePath ( name , pkgFileName ) ;
161168 try {
162- await file . save ( this . _convertToString ( metadata ) ) ;
169+ await file . save ( this . _convertToString ( metadata ) , {
170+ validation : this . config . validation || defaultValidation
171+ } ) ;
163172 resolve ( null ) ;
164173 } catch ( err ) {
165174 reject ( fSError ( err . message , 500 ) ) ;
@@ -224,7 +233,9 @@ class GoogleCloudStorageHandler implements ILocalPackageManager {
224233 } else {
225234 const file = this . _getBucket ( ) . file ( `${ this . name } /${ name } ` ) ;
226235 this . logger . info ( { url : file . name } , 'gcloud: the @{url} is being uploaded to the storage' ) ;
227- const fileStream = file . createWriteStream ( ) ;
236+ const fileStream = file . createWriteStream ( {
237+ validation : this . config . validation || defaultValidation
238+ } ) ;
228239 uploadStream . done = ( ) => {
229240 uploadStream . on ( 'end' , ( ) => {
230241 fileStream . on ( 'response' , ( ) => {
0 commit comments