File size: 3,988 Bytes
a2b2aac |
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 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 |
import * as fs from 'fs'
import * as path from 'path'
import ffmpeg from 'fluent-ffmpeg'
import { exec } from 'child_process'
import { addExif } from './sticker.js'
function convert(file, ext1, ext2, options = []) {
return new Promise(async (resolve, reject) => {
let temp = path.join(__dirname(import.meta.url), '../tmp', Date.now() + '.' + ext1),
out = temp + '.' + ext2;
await fs.promises.writeFile(temp, file);
ffmpeg(temp)
.on('start', (cmd) => {
console.log(cmd);
})
.on('error', (e) => {
fs.unlinkSync(temp);
reject(e);
})
.on('end', () => {
console.log("Finish");
setTimeout(() => {
fs.unlinkSync(temp);
fs.unlinkSync(out);
}, 2000)
resolve(fs.readFileSync(out));
})
.addOutputOptions(options)
.toFormat(ext2)
.save(out);
});
}
function convert2(file, ext1, ext2, options = []) {
return new Promise(async (resolve, reject) => {
let temp = path.join(__dirname(import.meta.url), '../tmp', Date.now() + '.' + ext1),
out = temp + '.' + ext2;
await fs.promises.writeFile(temp, file);
ffmpeg(temp)
.on('start', (cmd) => {
console.log(cmd);
})
.on('error', (e) => {
fs.unlinkSync(temp);
reject(e);
})
.on('end', () => {
console.log("Finish");
setTimeout(() => {
fs.unlinkSync(temp);
fs.unlinkSync(out);
}, 2000)
resolve(fs.readFileSync(out));
})
.addOutputOptions(options)
.seekInput("00:00")
.setDuration("00:05")
.toFormat(ext2)
.save(out);
});
}
async function sticker(file, opts) {
if (typeof opts.cmdType === "undefined") opts.cmdType = "1"
const cmd = {
1: ["-fs 1M", "-vcodec", "libwebp", "-vf", `scale=512:512:flags=lanczos:force_original_aspect_ratio=decrease,format=rgba,pad=512:512:(ow-iw)/2:(oh-ih)/2:color=#00000000,setsar=1`],
2: ["-fs 1M", "-vcodec", "libwebp"]
}
/*
if (opts.withPackInfo) {
if (!opts.packInfo) throw Error("'packInfo' must be filled when using 'withPackInfo'");
let ext = opts.isImage !== undefined || false ? "jpg" : opts.isVideo !== undefined || false ? "mp4" : null;
return stickerWithExif(file, ext, opts.packInfo, cmd[parseInt(opts.cmdType)]);
}
*/
if (opts.isImage) {
return convert(file, "jpg", "webp", cmd[parseInt(opts.cmdType)]);
}
if (opts.isVideo) {
return convert2(file, "mp4", "webp", cmd[parseInt(opts.cmdType)]);
}
}
/*
function stickerWithExif(file, ext, packInfo, cmd) {
return new Bluebird(async (res, rej) => {
let { packname, author } = packInfo;
const filename = Date.now();
const stickerBuffer = ext === "jpg" ? (await convert(file, ext, "webp", cmd)) : (await convert2(file, ext, "webp", cmd));
ex.create(packname !== undefined || '' ? packname : "Original", author !== undefined || '' ? author : "SMH-BOT", filename);
await fs.promises.writeFile(`./temp/${filename}.webp`, stickerBuffer);
run(`webpmux -set exif ./temp/${filename}.exif ./temp/${filename}.webp -o ./temp/${filename}.webp`, async (err) => {
if (err) rej(err) && await Promise.all([
fs.unlink(`./temp/${filename}.webp`),
fs.unlink(`./temp/${filename}.exif`)
]);
setTimeout(() => {
fs.unlinkSync(`./temp/${filename}.exif`); fs.unlinkSync(`./temp/${filename}.webp`);
}, 2000);
res(fs.readFileSync(`./temp/${filename}.webp`));
})
});
}
*/
export {
sticker
} |