1
1
const { Readable } = require('stream');
2
2
const fs = require('fs');
3
- const { promisify } = require('util');
4
3
5
4
class InputFile {
6
5
stream; // Content of file, readable stream
@@ -14,16 +13,15 @@ class InputFile {
14
13
};
15
14
16
15
static fromBuffer = (buffer, filename) => {
17
- const stream = Readable.from(buffer.toString() );
16
+ const stream = Readable.from(buffer);
18
17
const size = Buffer.byteLength(buffer);
19
18
return new InputFile(stream, filename, size);
20
19
};
21
20
22
- static fromBlob = (blob, filename) => {
23
- const buffer = blob.arrayBuffer();
24
- const stream = Readable.from(buffer.toString());
25
- const size = Buffer.byteLength(buffer);
26
- return new InputFile(stream, filename);
21
+ static fromBlob = async (blob, filename) => {
22
+ const arrayBuffer = await blob.arrayBuffer();
23
+ const buffer = Buffer.from(arrayBuffer);
24
+ return InputFile.fromBuffer(buffer, filename);
27
25
};
28
26
29
27
static fromStream = (stream, filename, size) => {
@@ -32,7 +30,7 @@ class InputFile {
32
30
33
31
static fromPlainText = (content, filename) => {
34
32
const buffer = Buffer.from(content, "utf-8");
35
- const stream = Readable.from(buffer.toString() );
33
+ const stream = Readable.from(buffer);
36
34
const size = Buffer.byteLength(buffer);
37
35
return new InputFile(stream, filename, size);
38
36
};
0 commit comments