Skip to content

Commit 0dcaff4

Browse files
committed
🐛 fixed if-range bug
1 parent cda8fc0 commit 0dcaff4

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/server/serve.ts

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ function createServe(root: string) {
5050
// cache hit
5151
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats.size}`)
5252
res.statusCode = 206;
53-
res.end();
53+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(compress).pipe(res);
5454
} else {
5555
// file update
5656
res.statusCode = 200;
@@ -86,7 +86,7 @@ function createServe(root: string) {
8686
// cache hit
8787
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats.size}`)
8888
res.statusCode = 206;
89-
res.end();
89+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(compress).pipe(res);
9090
} else {
9191
// file update
9292
res.statusCode = 200;
@@ -122,7 +122,7 @@ function createServe(root: string) {
122122
// cache hit
123123
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats.size}`)
124124
res.statusCode = 206;
125-
res.end();
125+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(compress).pipe(res);
126126
} else {
127127
// file update
128128
res.statusCode = 200;
@@ -156,7 +156,7 @@ function createServe(root: string) {
156156
// cache hit
157157
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats.size}`)
158158
res.statusCode = 206;
159-
res.end();
159+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(res);
160160
}else{
161161
// file update
162162
res.statusCode = 200;
@@ -269,7 +269,7 @@ function createServe(root: string) {
269269
// cache hit
270270
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats!.size}`)
271271
res.statusCode = 206;
272-
res.end();
272+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(compress).pipe(res);
273273
} else {
274274
// file update
275275
res.statusCode = 200;
@@ -305,7 +305,7 @@ function createServe(root: string) {
305305
// cache hit
306306
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats!.size}`)
307307
res.statusCode = 206;
308-
res.end();
308+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(compress).pipe(res);
309309
} else {
310310
// file update
311311
res.statusCode = 200;
@@ -341,7 +341,7 @@ function createServe(root: string) {
341341
// cache hit
342342
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats!.size}`)
343343
res.statusCode = 206;
344-
res.end();
344+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(compress).pipe(res);
345345
} else {
346346
// file update
347347
res.statusCode = 200;
@@ -375,7 +375,7 @@ function createServe(root: string) {
375375
// cache hit
376376
res.setHeader('Content-Range', `bytes ${range[0].start}-${range[0].end}/${stats!.size}`)
377377
res.statusCode = 206;
378-
res.end();
378+
fs.createReadStream(realPath, { start: range[0].start, end: range[0].end }).pipe(res);
379379
}else{
380380
// file update
381381
res.statusCode = 200;

0 commit comments

Comments
 (0)