first commit
This commit is contained in:
54
server/conf.js
Normal file
54
server/conf.js
Normal file
@@ -0,0 +1,54 @@
|
||||
const pandocPath = process.env.PANDOC_PATH || 'pandoc';
|
||||
const wkhtmltopdfPath = process.env.WKHTMLTOPDF_PATH || 'wkhtmltopdf';
|
||||
const paypalReceiverEmail = process.env.PAYPAL_RECEIVER_EMAIL;
|
||||
|
||||
const dropboxAppKey = process.env.DROPBOX_APP_KEY;
|
||||
const dropboxAppKeyFull = process.env.DROPBOX_APP_KEY_FULL;
|
||||
const githubClientId = process.env.GITHUB_CLIENT_ID;
|
||||
const githubClientSecret = process.env.GITHUB_CLIENT_SECRET;
|
||||
const giteeClientId = process.env.GITEE_CLIENT_ID;
|
||||
const giteeClientSecret = process.env.GITEE_CLIENT_SECRET;
|
||||
const googleClientId = process.env.GOOGLE_CLIENT_ID;
|
||||
const googleApiKey = process.env.GOOGLE_API_KEY;
|
||||
const wordpressClientId = process.env.WORDPRESS_CLIENT_ID;
|
||||
const giteaClientId = process.env.GITEA_CLIENT_ID;
|
||||
const giteaClientSecret = process.env.GITEA_CLIENT_SECRET;
|
||||
const giteaUrl = process.env.GITEA_URL;
|
||||
const gitlabClientId = process.env.GITLAB_CLIENT_ID;
|
||||
const gitlabClientSecret = process.env.GITLAB_CLIENT_SECRET;
|
||||
const gitlabUrl = process.env.GITLAB_URL;
|
||||
|
||||
exports.values = {
|
||||
pandocPath,
|
||||
wkhtmltopdfPath,
|
||||
paypalReceiverEmail,
|
||||
dropboxAppKey,
|
||||
dropboxAppKeyFull,
|
||||
githubClientId,
|
||||
githubClientSecret,
|
||||
giteeClientId,
|
||||
giteeClientSecret,
|
||||
googleClientId,
|
||||
googleApiKey,
|
||||
wordpressClientId,
|
||||
giteaClientId,
|
||||
giteaClientSecret,
|
||||
giteaUrl,
|
||||
gitlabClientId,
|
||||
gitlabClientSecret,
|
||||
gitlabUrl,
|
||||
};
|
||||
|
||||
exports.publicValues = {
|
||||
dropboxAppKey,
|
||||
dropboxAppKeyFull,
|
||||
githubClientId,
|
||||
googleClientId,
|
||||
googleApiKey,
|
||||
wordpressClientId,
|
||||
allowSponsorship: !!paypalReceiverEmail,
|
||||
giteaClientId,
|
||||
giteaUrl,
|
||||
gitlabClientId,
|
||||
gitlabUrl,
|
||||
};
|
||||
40
server/gitea.js
Normal file
40
server/gitea.js
Normal file
@@ -0,0 +1,40 @@
|
||||
const request = require('request');
|
||||
const conf = require('./conf');
|
||||
|
||||
function giteaToken(queryParam) {
|
||||
return new Promise((resolve, reject) => {
|
||||
request({
|
||||
method: 'POST',
|
||||
url: `${conf.values.giteaUrl}/login/oauth/access_token`,
|
||||
headers: {
|
||||
'content-type': 'application/json',
|
||||
},
|
||||
json: true,
|
||||
body: {
|
||||
...queryParam,
|
||||
client_id: conf.values.giteaClientId,
|
||||
client_secret: conf.values.giteaClientSecret,
|
||||
},
|
||||
}, (err, res, body) => {
|
||||
if (err) {
|
||||
reject(err);
|
||||
}
|
||||
const token = body.access_token;
|
||||
if (token) {
|
||||
resolve(body);
|
||||
} else {
|
||||
reject(res.statusCode + ',body:' + JSON.stringify(body));
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
exports.giteaToken = (req, res) => {
|
||||
giteaToken(req.query)
|
||||
.then(
|
||||
tokenBody => res.send(tokenBody),
|
||||
err => res
|
||||
.status(400)
|
||||
.send(err ? err.message || err.toString() : 'bad_code'),
|
||||
);
|
||||
};
|
||||
42
server/gitee.js
Normal file
42
server/gitee.js
Normal file
@@ -0,0 +1,42 @@
|
||||
const qs = require('qs'); // eslint-disable-line import/no-extraneous-dependencies
|
||||
const request = require('request');
|
||||
const conf = require('./conf');
|
||||
|
||||
function giteeToken(clientId, code, oauth2RedirectUri) {
|
||||
const clientIndex = conf.values.giteeClientId.split(',').indexOf(clientId);
|
||||
const clientSecret = conf.values.giteeClientSecret.split(',')[clientIndex];
|
||||
return new Promise((resolve, reject) => {
|
||||
request({
|
||||
method: 'POST',
|
||||
url: 'https://gitee.com/oauth/token',
|
||||
form: {
|
||||
client_id: clientId,
|
||||
client_secret: clientSecret,
|
||||
code,
|
||||
grant_type: 'authorization_code',
|
||||
redirect_uri: oauth2RedirectUri,
|
||||
},
|
||||
json: true
|
||||
}, (err, res, body) => {
|
||||
if (err) {
|
||||
reject(err);
|
||||
}
|
||||
const token = body.access_token;
|
||||
if (token) {
|
||||
resolve(body);
|
||||
} else {
|
||||
reject(res.statusCode + ',body:' + JSON.stringify(body));
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
exports.giteeToken = (req, res) => {
|
||||
giteeToken(req.query.clientId, req.query.code, req.query.oauth2RedirectUri)
|
||||
.then(
|
||||
tokenBody => res.send(tokenBody),
|
||||
err => res
|
||||
.status(400)
|
||||
.send(err ? err.message || err.toString() : 'bad_code'),
|
||||
);
|
||||
};
|
||||
37
server/github.js
Normal file
37
server/github.js
Normal file
@@ -0,0 +1,37 @@
|
||||
const qs = require('qs'); // eslint-disable-line import/no-extraneous-dependencies
|
||||
const request = require('request');
|
||||
const conf = require('./conf');
|
||||
|
||||
function githubToken(clientId, code) {
|
||||
return new Promise((resolve, reject) => {
|
||||
request({
|
||||
method: 'POST',
|
||||
url: 'https://github.com/login/oauth/access_token',
|
||||
qs: {
|
||||
client_id: clientId,
|
||||
client_secret: conf.values.githubClientSecret,
|
||||
code,
|
||||
},
|
||||
}, (err, res, body) => {
|
||||
if (err) {
|
||||
reject(err);
|
||||
}
|
||||
const token = qs.parse(body).access_token;
|
||||
if (token) {
|
||||
resolve(token);
|
||||
} else {
|
||||
reject(res.statusCode);
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
exports.githubToken = (req, res) => {
|
||||
githubToken(req.query.clientId, req.query.code)
|
||||
.then(
|
||||
token => res.send(token),
|
||||
err => res
|
||||
.status(400)
|
||||
.send(err ? err.message || err.toString() : 'bad_code'),
|
||||
);
|
||||
};
|
||||
40
server/gitlab.js
Normal file
40
server/gitlab.js
Normal file
@@ -0,0 +1,40 @@
|
||||
const request = require('request');
|
||||
const conf = require('./conf');
|
||||
|
||||
function gitlabToken(queryParam) {
|
||||
return new Promise((resolve, reject) => {
|
||||
request({
|
||||
method: 'POST',
|
||||
url: `${conf.values.gitlabUrl}/oauth/token`,
|
||||
headers: {
|
||||
'content-type': 'application/json',
|
||||
},
|
||||
json: true,
|
||||
qs: {
|
||||
...queryParam,
|
||||
client_id: conf.values.gitlabClientId,
|
||||
client_secret: conf.values.gitlabClientSecret,
|
||||
},
|
||||
}, (err, res, body) => {
|
||||
if (err) {
|
||||
reject(err);
|
||||
}
|
||||
const token = body.access_token;
|
||||
if (token) {
|
||||
resolve(body);
|
||||
} else {
|
||||
reject(res.statusCode + ',body:' + JSON.stringify(body));
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
exports.gitlabToken = (req, res) => {
|
||||
gitlabToken(req.query)
|
||||
.then(
|
||||
tokenBody => res.send(tokenBody),
|
||||
err => res
|
||||
.status(400)
|
||||
.send(err ? err.message || err.toString() : 'bad_code'),
|
||||
);
|
||||
};
|
||||
89
server/index.js
Normal file
89
server/index.js
Normal file
@@ -0,0 +1,89 @@
|
||||
const compression = require('compression');
|
||||
const serveStatic = require('serve-static');
|
||||
const bodyParser = require('body-parser');
|
||||
const path = require('path');
|
||||
const github = require('./github');
|
||||
const gitee = require('./gitee');
|
||||
const gitea = require('./gitea');
|
||||
const gitlab = require('./gitlab');
|
||||
const pdf = require('./pdf');
|
||||
const pandoc = require('./pandoc');
|
||||
const conf = require('./conf');
|
||||
|
||||
const resolvePath = pathToResolve => path.join(__dirname, '..', pathToResolve);
|
||||
|
||||
module.exports = (app) => {
|
||||
if (process.env.NODE_ENV === 'production') {
|
||||
// Enable CORS for fonts
|
||||
app.all('*', (req, res, next) => {
|
||||
if (/\.(eot|ttf|woff2?|svg)$/.test(req.url)) {
|
||||
res.header('Access-Control-Allow-Origin', '*');
|
||||
}
|
||||
next();
|
||||
});
|
||||
|
||||
// Use gzip compression
|
||||
app.use(compression());
|
||||
}
|
||||
|
||||
app.get('/oauth2/githubToken', github.githubToken);
|
||||
app.get('/oauth2/giteeToken', gitee.giteeToken);
|
||||
app.get('/oauth2/giteaToken', gitea.giteaToken);
|
||||
app.get('/oauth2/gitlabToken', gitlab.gitlabToken);
|
||||
app.get('/conf', (req, res) => res.send(conf.publicValues));
|
||||
app.post('/pdfExport', pdf.generate);
|
||||
app.post('/pandocExport', pandoc.generate);
|
||||
app.get('/giteeClientId', (req, res) => {
|
||||
const giteeClientIds = conf.values.giteeClientId.split(',');
|
||||
// 仅一个 则直接返回
|
||||
if (giteeClientIds.length === 1) {
|
||||
res.send(giteeClientIds[0]);
|
||||
return;
|
||||
}
|
||||
// 是否随机一个clientId 默认第一个 如果random 为1 则使用随机 避免单个应用接口次数用满无法自动切换其他应用
|
||||
const random = req.query.random;
|
||||
if (!random) {
|
||||
res.send(giteeClientIds[0]);
|
||||
return;
|
||||
}
|
||||
// 随机一个 排除第一个 因为第一个应用接口次数用完了
|
||||
const clientId = giteeClientIds[Math.floor(((giteeClientIds.length - 1) * Math.random())) + 1];
|
||||
res.send(clientId);
|
||||
});
|
||||
// Serve landing.html
|
||||
app.get('/', (req, res) => res.sendFile(resolvePath('static/landing/index.html')));
|
||||
// Serve privacy_policy.html
|
||||
app.get('/privacy_policy.html', (req, res) => res.sendFile(resolvePath('static/landing/privacy_policy.html')));
|
||||
// Serve sitemap.xml
|
||||
app.get('/sitemap.xml', (req, res) => res.sendFile(resolvePath('static/sitemap.xml')));
|
||||
// Serve callback.html
|
||||
app.get('/oauth2/callback', (req, res) => res.sendFile(resolvePath('static/oauth2/callback.html')));
|
||||
// Google Drive action receiver
|
||||
app.get('/googleDriveAction', (req, res) =>
|
||||
res.redirect(`./app#providerId=googleDrive&state=${encodeURIComponent(req.query.state)}`));
|
||||
// Serve the static folder with 30 day max-age
|
||||
app.use('/themes', serveStatic(resolvePath('static/themes'), {
|
||||
maxAge: '5d',
|
||||
}));
|
||||
|
||||
// Serve style.css with 1 day max-age
|
||||
app.get('/style.css', (req, res) => res.sendFile(resolvePath('dist/style.css'), {
|
||||
maxAge: '1d',
|
||||
}));
|
||||
// Serve share.html
|
||||
app.get('/share.html', (req, res) => res.sendFile(resolvePath('static/landing/share.html')));
|
||||
app.get('/gistshare.html', (req, res) => res.sendFile(resolvePath('static/landing/gistshare.html')));
|
||||
|
||||
// Serve static resources
|
||||
if (process.env.NODE_ENV === 'production') {
|
||||
// Serve index.html in /app
|
||||
app.get('/app', (req, res) => res.sendFile(resolvePath('dist/index.html')));
|
||||
|
||||
// Serve the static folder with 1 year max-age
|
||||
app.use('/static', serveStatic(resolvePath('dist/static'), {
|
||||
maxAge: '1y',
|
||||
}));
|
||||
|
||||
app.use(serveStatic(resolvePath('dist')));
|
||||
}
|
||||
};
|
||||
141
server/pandoc.js
Normal file
141
server/pandoc.js
Normal file
@@ -0,0 +1,141 @@
|
||||
/* global window */
|
||||
const { spawn } = require('child_process');
|
||||
const fs = require('fs');
|
||||
const tmp = require('tmp');
|
||||
const conf = require('./conf');
|
||||
|
||||
const outputFormats = {
|
||||
asciidoc: 'text/plain',
|
||||
context: 'application/x-latex',
|
||||
epub: 'application/epub+zip',
|
||||
epub3: 'application/epub+zip',
|
||||
latex: 'application/x-latex',
|
||||
odt: 'application/vnd.oasis.opendocument.text',
|
||||
pdf: 'application/pdf',
|
||||
rst: 'text/plain',
|
||||
rtf: 'application/rtf',
|
||||
textile: 'text/plain',
|
||||
docx: 'application/vnd.openxmlformats-officedocument.wordprocessingml.document',
|
||||
};
|
||||
|
||||
const highlightStyles = [
|
||||
'pygments',
|
||||
'kate',
|
||||
'monochrome',
|
||||
'espresso',
|
||||
'zenburn',
|
||||
'haddock',
|
||||
'tango',
|
||||
];
|
||||
|
||||
const readJson = (str) => {
|
||||
try {
|
||||
return JSON.parse(str);
|
||||
} catch (e) {
|
||||
return {};
|
||||
}
|
||||
};
|
||||
|
||||
exports.generate = (req, res) => {
|
||||
let pandocError = '';
|
||||
const outputFormat = Object.prototype.hasOwnProperty.call(outputFormats, req.query.format)
|
||||
? req.query.format
|
||||
: 'pdf';
|
||||
new Promise((resolve, reject) => {
|
||||
tmp.file({
|
||||
postfix: `.${outputFormat}`,
|
||||
}, (err, filePath, fd, cleanupCallback) => {
|
||||
if (err) {
|
||||
reject(err);
|
||||
} else {
|
||||
resolve({
|
||||
filePath,
|
||||
cleanupCallback,
|
||||
});
|
||||
}
|
||||
});
|
||||
}).then(({ filePath, cleanupCallback }) => new Promise((resolve, reject) => {
|
||||
const options = readJson(req.query.options);
|
||||
const metadata = readJson(req.query.metadata);
|
||||
const params = [];
|
||||
|
||||
params.push('--pdf-engine=xelatex');
|
||||
params.push('--webtex=http://chart.apis.google.com/chart?cht=tx&chf=bg,s,FFFFFF00&chco=000000&chl=');
|
||||
if (options.toc) {
|
||||
params.push('--toc');
|
||||
}
|
||||
options.tocDepth = parseInt(options.tocDepth, 10);
|
||||
if (!Number.isNaN(options.tocDepth)) {
|
||||
params.push('--toc-depth', options.tocDepth);
|
||||
}
|
||||
options.highlightStyle = highlightStyles.includes(options.highlightStyle) ? options.highlightStyle : 'kate';
|
||||
params.push('--highlight-style', options.highlightStyle);
|
||||
Object.keys(metadata).forEach((key) => {
|
||||
params.push('-M', `${key}=${metadata[key]}`);
|
||||
});
|
||||
|
||||
let finished = false;
|
||||
|
||||
function onError(error) {
|
||||
finished = true;
|
||||
cleanupCallback();
|
||||
reject(error);
|
||||
}
|
||||
|
||||
const format = outputFormat === 'pdf' ? 'latex' : outputFormat;
|
||||
params.push('-f', 'json', '-t', format, '-o', filePath);
|
||||
const pandoc = spawn(conf.values.pandocPath, params, {
|
||||
stdio: [
|
||||
'pipe',
|
||||
'ignore',
|
||||
'pipe',
|
||||
],
|
||||
});
|
||||
let timeoutId = setTimeout(() => {
|
||||
timeoutId = null;
|
||||
pandoc.kill();
|
||||
}, 50000);
|
||||
pandoc.on('error', onError);
|
||||
pandoc.stdin.on('error', onError);
|
||||
pandoc.stderr.on('data', (data) => {
|
||||
pandocError += `${data}`;
|
||||
});
|
||||
pandoc.on('close', (code) => {
|
||||
if (!finished) {
|
||||
clearTimeout(timeoutId);
|
||||
if (!timeoutId) {
|
||||
res.statusCode = 408;
|
||||
cleanupCallback();
|
||||
reject(new Error('timeout'));
|
||||
} else if (code) {
|
||||
cleanupCallback();
|
||||
reject();
|
||||
} else {
|
||||
res.set('Content-Type', outputFormats[outputFormat]);
|
||||
const readStream = fs.createReadStream(filePath);
|
||||
readStream.on('open', () => readStream.pipe(res));
|
||||
readStream.on('close', () => cleanupCallback());
|
||||
readStream.on('error', () => {
|
||||
cleanupCallback();
|
||||
reject();
|
||||
});
|
||||
}
|
||||
}
|
||||
});
|
||||
req.pipe(pandoc.stdin);
|
||||
}))
|
||||
.catch((err) => {
|
||||
console.error(err);
|
||||
const message = err && err.message;
|
||||
if (message === 'unauthorized') {
|
||||
res.statusCode = 401;
|
||||
res.end('Unauthorized.');
|
||||
} else if (message === 'timeout') {
|
||||
res.statusCode = 408;
|
||||
res.end('Request timeout.');
|
||||
} else {
|
||||
res.statusCode = 400;
|
||||
res.end(pandocError || 'Unknown error.');
|
||||
}
|
||||
});
|
||||
};
|
||||
178
server/pdf.js
Normal file
178
server/pdf.js
Normal file
@@ -0,0 +1,178 @@
|
||||
/* global window,MathJax */
|
||||
const { spawn } = require('child_process');
|
||||
const fs = require('fs');
|
||||
const tmp = require('tmp');
|
||||
const conf = require('./conf');
|
||||
|
||||
/* eslint-disable no-var, prefer-arrow-callback, func-names */
|
||||
function waitForJavaScript() {
|
||||
if (window.MathJax) {
|
||||
// Amazon EC2: fix TeX font detection
|
||||
MathJax.Hub.Register.StartupHook('HTML-CSS Jax Startup', function () {
|
||||
var htmlCss = MathJax.OutputJax['HTML-CSS'];
|
||||
htmlCss.Font.checkWebFont = function (check, font, callback) {
|
||||
if (check.time(callback)) {
|
||||
return;
|
||||
}
|
||||
if (check.total === 0) {
|
||||
htmlCss.Font.testFont(font);
|
||||
setTimeout(check, 200);
|
||||
} else {
|
||||
callback(check.STATUS.OK);
|
||||
}
|
||||
};
|
||||
});
|
||||
MathJax.Hub.Queue(function () {
|
||||
window.status = 'done';
|
||||
});
|
||||
} else {
|
||||
setTimeout(function () {
|
||||
window.status = 'done';
|
||||
}, 2000);
|
||||
}
|
||||
}
|
||||
/* eslint-disable no-var, prefer-arrow-callback, func-names */
|
||||
|
||||
const authorizedPageSizes = [
|
||||
'A3',
|
||||
'A4',
|
||||
'Legal',
|
||||
'Letter',
|
||||
];
|
||||
|
||||
const readJson = (str) => {
|
||||
try {
|
||||
return JSON.parse(str);
|
||||
} catch (e) {
|
||||
return {};
|
||||
}
|
||||
};
|
||||
|
||||
exports.generate = (req, res) => {
|
||||
let wkhtmltopdfError = '';
|
||||
new Promise((resolve, reject) => {
|
||||
tmp.file((err, filePath, fd, cleanupCallback) => {
|
||||
if (err) {
|
||||
reject(err);
|
||||
} else {
|
||||
resolve({
|
||||
filePath,
|
||||
cleanupCallback,
|
||||
});
|
||||
}
|
||||
});
|
||||
}).then(({ filePath, cleanupCallback }) => new Promise((resolve, reject) => {
|
||||
let finished = false;
|
||||
|
||||
function onError(err) {
|
||||
finished = true;
|
||||
cleanupCallback();
|
||||
reject(err);
|
||||
}
|
||||
const options = readJson(req.query.options);
|
||||
const params = [];
|
||||
|
||||
// Margins
|
||||
const marginTop = parseInt(`${options.marginTop}`, 10);
|
||||
params.push('-T', Number.isNaN(marginTop) ? 25 : marginTop);
|
||||
const marginRight = parseInt(`${options.marginRight}`, 10);
|
||||
params.push('-R', Number.isNaN(marginRight) ? 25 : marginRight);
|
||||
const marginBottom = parseInt(`${options.marginBottom}`, 10);
|
||||
params.push('-B', Number.isNaN(marginBottom) ? 25 : marginBottom);
|
||||
const marginLeft = parseInt(`${options.marginLeft}`, 10);
|
||||
params.push('-L', Number.isNaN(marginLeft) ? 25 : marginLeft);
|
||||
|
||||
// Header
|
||||
if (options.headerCenter) {
|
||||
params.push('--header-center', `${options.headerCenter}`);
|
||||
}
|
||||
if (options.headerLeft) {
|
||||
params.push('--header-left', `${options.headerLeft}`);
|
||||
}
|
||||
if (options.headerRight) {
|
||||
params.push('--header-right', `${options.headerRight}`);
|
||||
}
|
||||
if (options.headerFontName) {
|
||||
params.push('--header-font-name', `${options.headerFontName}`);
|
||||
}
|
||||
if (options.headerFontSize) {
|
||||
params.push('--header-font-size', `${options.headerFontSize}`);
|
||||
}
|
||||
|
||||
// Footer
|
||||
if (options.footerCenter) {
|
||||
params.push('--footer-center', `${options.footerCenter}`);
|
||||
}
|
||||
if (options.footerLeft) {
|
||||
params.push('--footer-left', `${options.footerLeft}`);
|
||||
}
|
||||
if (options.footerRight) {
|
||||
params.push('--footer-right', `${options.footerRight}`);
|
||||
}
|
||||
if (options.footerFontName) {
|
||||
params.push('--footer-font-name', `${options.footerFontName}`);
|
||||
}
|
||||
if (options.footerFontSize) {
|
||||
params.push('--footer-font-size', `${options.footerFontSize}`);
|
||||
}
|
||||
|
||||
// Page size
|
||||
params.push('--page-size', !authorizedPageSizes.includes(options.pageSize) ? 'A4' : options.pageSize);
|
||||
|
||||
// Use a temp file as wkhtmltopdf can't access /dev/stdout on Amazon EC2 for some reason
|
||||
params.push('--run-script', `${waitForJavaScript.toString()}waitForJavaScript()`);
|
||||
params.push('--window-status', 'done');
|
||||
const wkhtmltopdf = spawn(conf.values.wkhtmltopdfPath, params.concat('-', filePath), {
|
||||
stdio: [
|
||||
'pipe',
|
||||
'ignore',
|
||||
'pipe',
|
||||
],
|
||||
});
|
||||
let timeoutId = setTimeout(function () {
|
||||
timeoutId = null;
|
||||
wkhtmltopdf.kill();
|
||||
}, 50000);
|
||||
wkhtmltopdf.on('error', onError);
|
||||
wkhtmltopdf.stdin.on('error', onError);
|
||||
wkhtmltopdf.stderr.on('data', (data) => {
|
||||
wkhtmltopdfError += `${data}`;
|
||||
});
|
||||
wkhtmltopdf.on('close', (code) => {
|
||||
if (!finished) {
|
||||
clearTimeout(timeoutId);
|
||||
if (!timeoutId) {
|
||||
cleanupCallback();
|
||||
reject(new Error('timeout'));
|
||||
} else if (code) {
|
||||
cleanupCallback();
|
||||
reject();
|
||||
} else {
|
||||
res.set('Content-Type', 'application/pdf');
|
||||
const readStream = fs.createReadStream(filePath);
|
||||
readStream.on('open', () => readStream.pipe(res));
|
||||
readStream.on('close', () => cleanupCallback());
|
||||
readStream.on('error', () => {
|
||||
cleanupCallback();
|
||||
reject();
|
||||
});
|
||||
}
|
||||
}
|
||||
});
|
||||
req.pipe(wkhtmltopdf.stdin);
|
||||
}))
|
||||
.catch((err) => {
|
||||
console.error(err);
|
||||
const message = err && err.message;
|
||||
if (message === 'unauthorized') {
|
||||
res.statusCode = 401;
|
||||
res.end('Unauthorized.');
|
||||
} else if (message === 'timeout') {
|
||||
res.statusCode = 408;
|
||||
res.end('Request timeout.');
|
||||
} else {
|
||||
res.statusCode = 400;
|
||||
res.end(wkhtmltopdfError || 'Unknown error.');
|
||||
}
|
||||
});
|
||||
};
|
||||
Reference in New Issue
Block a user