split/monofile
1
0
Fork 0
mirror of https://github.com/mollersuite/monofile.git synced 2024-11-22 13:56:27 -08:00
Code Issues Actions Packages Projects Releases 1 Wiki Activity

pls

Browse source
This commit is contained in:
May 2023-05-19 15:58:50 +00:00
parent 81bca21a9a
commit 9bb5babd1d
1 changed files with 13 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
src/server/index.ts
View file

@ -190,33 +190,29 @@ let fgRQH = async (req:express.Request,res:express.Response) => {
// todo: make readfilestream just the stream since we already have filepointer // todo: make readfilestream just the stream since we already have filepointer
files.readFileStream(req.params.fileId).then(async f => { files.readFileStream(req.params.fileId).then(async f => {
res.setHeader("Content-Type",f.contentType) res.setHeader("Content-Type",f.contentType)
if (f.byteSize) {
res.setHeader("Content-Length",f.byteSize)
}
if (req.headers.range) { if (f.byteSize && req.range(f.byteSize)) {
// todo: proper implementation of range header // range header implementation
/* // todo : make this better (or actually work if i dont manage to finish it)
let ranges = req.range(f.byteSize)
if (typeof ranges == "number" || !ranges) { res.status(400); res.send(); return }
let fsds = f.dataStream; let fsds = f.dataStream;
res.status(206); res.status(206);
let position = 0 let bytePosition = 0
console.log(ranges.type)
for await(let x of fsds) { for await(let x of fsds) {
}*/ let curRanges = [ bytePosition, bytePosition+x.byteLength()-1 ]
bytePosition+= x.byteLength
let fsds = f.dataStream;
let bf = []
for await(let x of fsds) {
bf.push(x)
} }
res.send(Buffer.concat(bf))
} else { } else {
if (f.byteSize) {
res.setHeader("Content-Length",f.byteSize)
}
res.status(200) res.status(200)
f.dataStream.pipe(res) f.dataStream.pipe(res)
} }