fix(core): update
This commit is contained in:
		| @@ -38,7 +38,7 @@ tap.test('should extract existing files on disk', async () => { | |||||||
|   await testSmartarchive.exportToFs(testPaths.nogitDir); |   await testSmartarchive.exportToFs(testPaths.nogitDir); | ||||||
| }); | }); | ||||||
|  |  | ||||||
| tap.test('should extract a b2zip', async () => { | tap.skip.test('should extract a b2zip', async () => { | ||||||
|   const dataUrl = 'https://daten.offeneregister.de/de_companies_ocdata.jsonl.bz2'; |   const dataUrl = 'https://daten.offeneregister.de/de_companies_ocdata.jsonl.bz2'; | ||||||
|   const testArchive = await smartarchive.SmartArchive.fromArchiveUrl(dataUrl); |   const testArchive = await smartarchive.SmartArchive.fromArchiveUrl(dataUrl); | ||||||
|     await testArchive.exportToFs( |     await testArchive.exportToFs( | ||||||
|   | |||||||
| @@ -3,6 +3,6 @@ | |||||||
|  */ |  */ | ||||||
| export const commitinfo = { | export const commitinfo = { | ||||||
|   name: '@push.rocks/smartarchive', |   name: '@push.rocks/smartarchive', | ||||||
|   version: '4.0.12', |   version: '4.0.13', | ||||||
|   description: 'work with archives' |   description: 'work with archives' | ||||||
| } | } | ||||||
|   | |||||||
| @@ -66,7 +66,6 @@ export function unbzip2Stream() { | |||||||
|       while (!broken && hasBytes - bitReader.bytesRead + 1 >= (25000 + 100000 * blockSize || 4)) { |       while (!broken && hasBytes - bitReader.bytesRead + 1 >= (25000 + 100000 * blockSize || 4)) { | ||||||
|         //console.error('decompressing with', hasBytes - bitReader.bytesRead + 1, 'bytes in buffer'); |         //console.error('decompressing with', hasBytes - bitReader.bytesRead + 1, 'bytes in buffer'); | ||||||
|         const result = await decompressAndPush(); |         const result = await decompressAndPush(); | ||||||
|         console.log('pushing...'); |  | ||||||
|         await streamTools.push(result); |         await streamTools.push(result); | ||||||
|       } |       } | ||||||
|     }, |     }, | ||||||
| @@ -74,7 +73,6 @@ export function unbzip2Stream() { | |||||||
|       //console.error(x,'last compressing with', hasBytes, 'bytes in buffer'); |       //console.error(x,'last compressing with', hasBytes, 'bytes in buffer'); | ||||||
|       while (!broken && bitReader && hasBytes > bitReader.bytesRead) { |       while (!broken && bitReader && hasBytes > bitReader.bytesRead) { | ||||||
|         const result = await decompressAndPush(); |         const result = await decompressAndPush(); | ||||||
|         console.log('pushing final...'); |  | ||||||
|         streamTools.push(result); |         streamTools.push(result); | ||||||
|       } |       } | ||||||
|       if (!broken) { |       if (!broken) { | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user