sascha
/
Notes
mirror of https://github.com/TriliumNext/Notes
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove express from deps, move out fCP in separate file.

pull/1829/head
SukantGujar 2019-03-11 17:34:44 +07:00
parent 33a4b1aea4
commit ca0b97b471
3 changed files with 37 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
package.json
Unescape Escape View File

@ -1,8 +1,8 @@
{
"name": "node-partial-stream",
"name": "express-partial-content",
"version": "0.1.0",
"main": "dist/index.js",
"repository": "ssh://git@github.com-sukantgujar/SukantGujar/node-partial-stream",
"repository": "ssh://git@github.com-sukantgujar/SukantGujar/express-partial-content",
"author": "sukantgujar <sukantgujar@yahoo.com>",
"license": "MIT",
"scripts": {
@ -19,7 +19,5 @@
"peerDependencies": {
"express": "^4.16.4"
},
"dependencies": {
"express": "^4.16.4"
}
"dependencies": {}
}

28
src/examples/express-file-server/fileContentProvider.ts
Unescape Escape View File

@ -0,0 +1,28 @@
import { Request } from "express";
import fs from "fs";
import { Range, ContentDoesNotExistError, ContentProvider } from "../../index";
import { existsAsync, statAsync, logger } from "./index";
export const fileContentProvider: ContentProvider = async (req: Request) => {
const fileName = req.params.name;
const file = `${__dirname}/files/${fileName}`;
if (!(await existsAsync(file))) {
throw new ContentDoesNotExistError(`File doesn't exists: ${file}`);
}
const stats = await statAsync(file);
const totalSize = stats.size;
const mimeType = "application/octet-stream";
const getStream = (range?: Range) => {
if (!range) {
return fs.createReadStream(file);
}
const { start, end } = range;
logger.debug(`start: ${start}, end: ${end}`);
return fs.createReadStream(file, { start, end });
};
return {
fileName,
totalSize,
mimeType,
getStream
};
};

39
src/examples/express-file-server/index.ts
Unescape Escape View File

@ -1,40 +1,13 @@
import express, { Request } from "express";
import express from "express";
import { promisify } from "util";
import fs from "fs";
import { Range, createPartialStreamHandler, ContentDoesNotExistError, ContentProvider } from "../../index";
import { createPartialStreamHandler } from "../../index";
import { fileContentProvider } from "./fileContentProvider";
const statAsync = promisify(fs.stat);
const existsAsync = promisify(fs.exists);
export const statAsync = promisify(fs.stat);
export const existsAsync = promisify(fs.exists);
const fileContentProvider: ContentProvider = async (req: Request) => {
const fileName = req.params.name;
const file = `${__dirname}/files/${fileName}`;
if (!(await existsAsync(file))) {
throw new ContentDoesNotExistError(`File doesn't exists: ${file}`);
}
const stats = await statAsync(file);
const totalSize = stats.size;
const mimeType = "application/octet-stream";
const getStream = (range?: Range) => {
if (!range) {
return fs.createReadStream(file);
}
const { start, end } = range;
logger.debug(`start: ${start}, end: ${end}`);
return fs.createReadStream(file, { start, end });
};
return {
fileName,
totalSize,
mimeType,
getStream
};
};
const logger = {
export const logger = {
debug(message: string, extra?: any) {
if (extra) {
console.log(`[debug]: ${message}`, extra);