|
1 | | -import path from 'path'; |
2 | | -import { createWriteStream, mkdir } from 'fs'; |
3 | | -import { pipeline } from 'stream'; |
4 | | -import { promisify } from 'util'; |
| 1 | +import path from 'node:path'; |
| 2 | +import { createWriteStream } from 'node:fs'; |
| 3 | +import { mkdir } from 'node:fs/promises'; |
| 4 | +import { pipeline } from 'node:stream/promises'; |
5 | 5 | import fetch from 'electron-fetch'; |
6 | | -import { URL } from 'url'; |
| 6 | +import { URL } from 'node:url'; |
7 | 7 | import { read, utils } from 'xlsx'; |
8 | 8 | import isUrl from 'is-url'; |
9 | 9 | import mime from 'mime-types'; |
10 | 10 |
|
11 | 11 | import generateFileName from './generateFileName'; |
12 | 12 |
|
13 | | -const streamPipeline = promisify(pipeline); |
14 | | - |
15 | 13 | let initialItemsLength; |
16 | 14 | let processedItemsCount; |
17 | 15 | let incompatibleItems = []; |
@@ -49,7 +47,7 @@ const processItem = async (item, outputPath) => { |
49 | 47 | const dest = createWriteStream(path.join(outputPath, subFolderName || '', fileName), {flags: 'wx'}); |
50 | 48 |
|
51 | 49 | try { |
52 | | - await streamPipeline(response.body, dest); |
| 50 | + await pipeline(response.body, dest); |
53 | 51 | } catch (error) { |
54 | 52 | throw { |
55 | 53 | statusText: error.message, |
|
0 commit comments