carboneio / tiny-storage-client Goto Github PK

        function createOutputStream(opts, res) {
                const writer = fs.createWriteStream('5be9a29f97caa8a38e030f0b18ac6fb1.mp4')
                writer.on('error', (e) => { console.log("erreur : " + e) })
                return writer
        }

        s3storage.downloadFile('coachtest', '5be9a29f97caa8a38e030f0b18ac6fb1.mp4', { output: createOutputStream }, (err, resp) => {
                if (err) {
                  return console.log("Error on download: ", err);
                }
                /**
                 * Request reponse:
                 * - resp.headers
                 * - resp.statusCode
                 *
                 * When the callback is called, the stream is closed and the file created,
                 * you don't have to pipe yourself!
                 */
        })

        function createOutputStream(opts, res) {
                const writer = fs.createWriteStream('5be9a29f97caa8a38e030f0b18ac6fb1.mp4')
                writer.on('error', (e) => { console.log("erreur : " + e) })
                return writer
        }

        s3storage.downloadFile('coachtest', '5be9a29f97caa8a38e030f0b18ac6fb1.mp4', { output: createOutputStream }, (err, resp) => {
                if (err) {
                  return console.log("Error on download: ", err);
                }

                const stream = fs.createReadStream('5be9a29f97caa8a38e030f0b18ac6fb1.mp4');
                res.setHeader('Content-Type', 'video/mp4');
                stream.pipe(res);
        })

    const buffer = Buffer.from(fs.readFileSync(path.join(filePath)));

    const res = await storage.uploadFile(containerName, fileName, buffer, (err: any, res: any) => {
        if (err) {
            logError(err);
            return reject(err);
        }
        resolve(res);
    });
    console.log(res);
});