all files / modules/utils/ saveToDisk.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
1×
1×
1×
1×
1×
 
1×
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1×
 
const fs = require("fs");
const File = require("./File");
const Promise = require("./Promise");
const makeTemporaryPath = require("./makeTemporaryPath");
const R = require("ramda");
 
function saveToDisk(message, filePrefix) {
    return new Promise(function (resolve, reject) {
        const content = message.content;
        const path = makeTemporaryPath(filePrefix);
        const stream = fs.createWriteStream(path);
        let size = 0;
 
        content.on("error", reject);
 
        content.on("data", function (chunk) {
            size += chunk.length;
            stream.write(chunk);
        });
 
        content.on("end", function () {
            stream.end(function () {
                resolve(
          new File({
              path,
              name: message.filename,
              type: message.mediaType,
              size
          })
        );
            });
        });
 
        if (R.is(Function, content.resume)) {
            content.resume();
        }
    });
}
 
module.exports = saveToDisk;