@@ -37,17 +37,6 @@ var __generator = (this && this.__generator) || function (thisArg, body) {
3737} ; 
3838Object . defineProperty ( exports ,  "__esModule" ,  {  value : true  } ) ; 
3939var  endpoint_1  =  require ( "../../components/endpoint" ) ; 
40- var  getErrorFromResponse  =  function  ( response )  { 
41-     return  new  Promise ( function  ( resolve )  { 
42-         var  result  =  '' ; 
43-         response . on ( 'data' ,  function  ( data )  { 
44-             result  +=  data . toString ( 'utf8' ) ; 
45-         } ) ; 
46-         response . on ( 'end' ,  function  ( )  { 
47-             resolve ( result ) ; 
48-         } ) ; 
49-     } ) ; 
50- } ; 
5140var  sendFile  =  function  ( _a )  { 
5241    var  _this  =  this ; 
5342    var  generateUploadUrl  =  _a . generateUploadUrl ,  publishFile  =  _a . publishFile ,  _b  =  _a . modules ,  PubNubFile  =  _b . PubNubFile ,  config  =  _b . config ,  cryptography  =  _b . cryptography ,  networking  =  _b . networking ; 
@@ -84,7 +73,7 @@ var sendFile = function (_a) {
8473                        } 
8574                        _s . label  =  4 ; 
8675                    case  4 :
87-                         _s . trys . push ( [ 4 ,  18 ,  ,  22 ] ) ; 
76+                         _s . trys . push ( [ 4 ,  18 ,  ,  19 ] ) ; 
8877                        if  ( ! ( PubNubFile . supportsFileUri  &&  input . uri ) )  return  [ 3  /*break*/ ,  7 ] ; 
8978                        _f  =  ( _e  =  networking ) . POSTFILE ; 
9079                        _g  =  [ url ,  formFieldsWithMimeType ] ; 
@@ -121,27 +110,28 @@ var sendFile = function (_a) {
121110                        result  =  _s . sent ( ) ; 
122111                        return  [ 3  /*break*/ ,  17 ] ; 
123112                    case  16 : throw  new  Error ( 'Unsupported environment' ) ; 
124-                     case  17 : return  [ 3  /*break*/ ,  22 ] ; 
113+                     case  17 : return  [ 3  /*break*/ ,  19 ] ; 
125114                    case  18 :
126115                        e_1  =  _s . sent ( ) ; 
127-                         if  ( ! e_1 . response )  return  [ 3  /*break*/ ,  20 ] ; 
128-                         return  [ 4  /*yield*/ ,  getErrorFromResponse ( e_1 . response ) ] ; 
116+                         if  ( e_1 . response  &&  typeof  e_1 . response . text  ===  'string' )  { 
117+                             errorBody  =  e_1 . response . text ; 
118+                             reason  =  / < M e s s a g e > ( .* ) < \/ M e s s a g e > / gi. exec ( errorBody ) ; 
119+                             throw  new  endpoint_1 . PubNubError ( reason  ? "Upload to bucket failed: " . concat ( reason [ 1 ] )  : 'Upload to bucket failed.' ,  e_1 ) ; 
120+                         } 
121+                         else  { 
122+                             throw  new  endpoint_1 . PubNubError ( 'Upload to bucket failed.' ,  e_1 ) ; 
123+                         } 
124+                         return  [ 3  /*break*/ ,  19 ] ; 
129125                    case  19 :
130-                         errorBody  =  _s . sent ( ) ; 
131-                         reason  =  / < M e s s a g e > ( .* ) < \/ M e s s a g e > / gi. exec ( errorBody ) ; 
132-                         throw  new  endpoint_1 . PubNubError ( reason  ? "Upload to bucket failed: " . concat ( reason [ 1 ] )  : 'Upload to bucket failed.' ,  e_1 ) ; 
133-                     case  20 : throw  new  endpoint_1 . PubNubError ( 'Upload to bucket failed.' ,  e_1 ) ; 
134-                     case  21 : return  [ 3  /*break*/ ,  22 ] ; 
135-                     case  22 :
136126                        if  ( result . status  !==  204 )  { 
137127                            throw  new  endpoint_1 . PubNubError ( 'Upload to bucket was unsuccessful' ,  result ) ; 
138128                        } 
139129                        retries  =  config . fileUploadPublishRetryLimit ; 
140130                        wasSuccessful  =  false ; 
141131                        publishResult  =  {  timetoken : '0'  } ; 
142-                         _s . label  =  23 ; 
143-                     case  23 :
144-                         _s . trys . push ( [ 23 ,   25 ,  ,  26 ] ) ; 
132+                         _s . label  =  20 ; 
133+                     case  20 :
134+                         _s . trys . push ( [ 20 ,   22 ,  ,  23 ] ) ; 
145135                        return  [ 4  /*yield*/ ,  publishFile ( { 
146136                                channel : channel , 
147137                                message : message , 
@@ -151,19 +141,19 @@ var sendFile = function (_a) {
151141                                storeInHistory : storeInHistory , 
152142                                ttl : ttl , 
153143                            } ) ] ; 
154-                     case  24 :
144+                     case  21 :
155145                        /* eslint-disable-next-line no-await-in-loop */ 
156146                        publishResult  =  _s . sent ( ) ; 
157147                        wasSuccessful  =  true ; 
158-                         return  [ 3  /*break*/ ,  26 ] ; 
159-                     case  25 :
148+                         return  [ 3  /*break*/ ,  23 ] ; 
149+                     case  22 :
160150                        e_2  =  _s . sent ( ) ; 
161151                        retries  -=  1 ; 
162-                         return  [ 3  /*break*/ ,  26 ] ; 
163-                     case  26 :
164-                         if  ( ! wasSuccessful  &&  retries  >  0 )  return  [ 3  /*break*/ ,  23 ] ; 
165-                         _s . label  =  27 ; 
166-                     case  27 :
152+                         return  [ 3  /*break*/ ,  23 ] ; 
153+                     case  23 :
154+                         if  ( ! wasSuccessful  &&  retries  >  0 )  return  [ 3  /*break*/ ,  20 ] ; 
155+                         _s . label  =  24 ; 
156+                     case  24 :
167157                        if  ( ! wasSuccessful )  { 
168158                            throw  new  endpoint_1 . PubNubError ( 'Publish failed. You may want to execute that operation manually using pubnub.publishFile' ,  { 
169159                                channel : channel , 
0 commit comments