@@ -192,7 +192,7 @@ export async function importActorProfile(
192
192
onError ?: ( error : Error , context : { fileName ?: string } ) => void
193
193
} = { }
194
194
) : Promise < Record < string , any > > {
195
- const { console = undefined , onError = undefined } = options
195
+ const { console = undefined } = options
196
196
const extract = tar . extract ( )
197
197
const result : Record < string , any > = { }
198
198
@@ -242,13 +242,8 @@ export async function importActorProfile(
242
242
} )
243
243
244
244
stream . on ( 'error' , ( error : any ) => {
245
- const errorMessage = `Stream error on file ${ fileName } : ${ error . message } `
246
- if ( onError ) {
247
- onError ( new Error ( errorMessage ) , { fileName } )
248
- } else {
249
- reject ( new Error ( errorMessage ) )
250
- }
251
- next ( ) // Continue even on stream error
245
+ console ?. error ( `Stream error on file ${ fileName } :` , error . message )
246
+ next ( error ) // Continue even on stream error
252
247
} )
253
248
} )
254
249
@@ -258,21 +253,13 @@ export async function importActorProfile(
258
253
} )
259
254
260
255
extract . on ( 'error' , ( error ) => {
261
- const errorMessage = `Error during tar extraction: ${ error . message } `
262
- if ( onError ) {
263
- onError ( new Error ( errorMessage ) , { } )
264
- } else {
265
- reject ( new Error ( errorMessage ) )
266
- }
256
+ console ?. error ( 'Error during tar extraction:' , error . message )
257
+ reject ( new Error ( 'Failed to extract tar file.' ) )
267
258
} )
268
259
269
260
tarStream . on ( 'error' , ( error ) => {
270
- const errorMessage = `Error in tar stream: ${ error . message } `
271
- if ( onError ) {
272
- onError ( new Error ( errorMessage ) , { } )
273
- } else {
274
- reject ( new Error ( errorMessage ) )
275
- }
261
+ console ?. error ( 'Error in tar stream:' , error . message )
262
+ reject ( new Error ( 'Failed to process tar stream.' ) )
276
263
} )
277
264
278
265
tarStream . pipe ( extract )
0 commit comments