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
|
import { fileTypeFromStream } from "file-type";
import pump from "pump";
import Clone from "readable-stream-clone";
import fs from "fs";
import path from "path";
import sharp from "sharp";
import { pipeline } from "stream";
import { g, s, db } from "$lib/db";
import { bail, fail } from "$lib/utils";
import crypto from "crypto";
import { err } from "$lib/logging";
async function getSha256Hash(stream) {
return new Promise((resolve, reject) => {
const hash = crypto.createHash("sha256");
stream.pipe(hash);
let hashValue;
hash.on("data", (data) => {
hashValue = data.toString("hex");
});
hash.on("end", () => {
resolve(hashValue);
});
hash.on("error", reject);
});
}
export default async (req, res) => {
try {
let {
params: { type },
} = req;
let width = type === "banner" ? 1920 : 240;
let data = await req.file();
let s1 = new Clone(data.file);
let s2 = new Clone(data.file);
let [format, ext] = (await fileTypeFromStream(s1)).mime.split("/");
if (format !== "image" && !["jpg", "jpeg", "png"].includes(ext))
fail("unsupported file type");
let t = sharp().rotate().resize(width).webp();
let processedBuffer = await streamToBuffer(s2.pipe(t));
let hash = crypto
.createHash("sha256")
.update(processedBuffer)
.digest("hex");
let filePath = `/app/data/uploads/${hash}.webp`;
fs.writeFileSync(filePath, processedBuffer);
res.send({ hash });
} catch (e) {
err("problem uploading", e.message);
bail(res, e.message);
}
};
function streamToBuffer(stream) {
return new Promise((resolve, reject) => {
const chunks = [];
stream.on("data", (chunk) => chunks.push(chunk));
stream.on("end", () => resolve(Buffer.concat(chunks)));
stream.on("error", reject);
});
}
|
