Skip to content

T
tiny-image
Commit c5ec144a authored by rockyl's avatar rockyl
Browse files
Options

init

parent dfdb6f5d
Show whitespace changes
Inline Side-by-side
Showing with 134 additions and 6143 deletions
Dockerfile deleted 100644 → 0
View file @ dfdb6f5d
# node
# Version v10.8
FROM harbor.dui88.com/library/node10:cat
LABEL MAINTAINER op@duiba.com.cn
ARG appname
ARG NODE_ENV
RUN echo "export LANG=en_US.UTF-8" && echo "Asia/Shanghai" > /etc/timezone
# RUN npm install pm2 -g --register=https://registry.npm.taobao.org/
ENV LANG='en_US.UTF-8'
RUN mkdir /root/duiba-deploy/
ADD ./duiba-deploy /root/duiba-deploy/
WORKDIR /root/duiba-deploy/
#define entry point which will be run first when the container starts up
ENTRYPOINT npm start
dist/index.js
View file @ c5ec144a
'use strict'; 'use strict';
function _interopDefault (ex) { return (ex && (typeof ex === 'object') && 'default' in ex) ? ex['default'] : ex; } Object.defineProperty(exports, '__esModule', { value: true });
var restify = _interopDefault(require('restify'));
var Eurekaclient = _interopDefault(require('eureka-client-ts'));
var log4js = require('log4js');
var path = _interopDefault(require('path'));
var fs = _interopDefault(require('fs-extra'));
var imagemin = _interopDefault(require('imagemin'));
var imageminJpegtran = _interopDefault(require('imagemin-jpegtran'));
var imageminPngquant = _interopDefault(require('imagemin-pngquant'));
/**
* Created by rockyl on 2020-02-13.
*/
const logPath = path.join(process.env.HOME || process.env.USERPROFILE, 'logs', 'tiny-image');
fs.ensureDir(logPath);
log4js.configure({
appenders: {
out: {type: 'console'},
allLog: {
type: 'dateFile',
filename: path.join(logPath, 'log.log'),
},
},
categories: {
default: {appenders: ['out', 'allLog'], level: 'debug'},
}
});
const logger = log4js.getLogger();
const eurekaConfig = { function _interopDefault (ex) { return (ex && (typeof ex === 'object') && 'default' in ex) ? ex['default'] : ex; }
appName: 'tiny-image',
services: ['tiny-image'],
};
async function getEurekaClient(port) {
eurekaConfig.port = port;
let eureka;
try {
eureka = new Eurekaclient(eurekaConfig);
await eureka.start();
} catch (e) {
logger.error(e);
}
return eureka; var FormData = _interopDefault(require('form-data'));
} require('fs');
/** /**
* Created by rockyl on 2020-02-13. * Created by rockyl on 2020-02-13.
*/ */
const acceptTypes = ['image/png', 'image/jpeg']; const tinifyUrl = 'http://localhost:8090/tinify';
function applyApi(server){
server.get('/echo/:name', function (req, res, next) {
res.send(req.params);
return next();
});
server.get('/monitor/check', function (req, res, next) { async function compressBuffer(buffer) {
res.sendRaw('ok'); return new Promise((resolve, reject) => {
return next(); if (buffer && buffer.length > 0) {
let form = new FormData();
form.append('file', buffer, {
filename: 'image.png',
contentType: 'image/png',
}); });
server.post('/tinify', async function (req, res, next) { form.submit(tinifyUrl, function (err, res) {
logger.info('/tinify'); if (err) {
reject(err);
let file = req.files.file; } else {
res.resume();
if(acceptTypes.includes(file.type)){ let resBuffer = Buffer.alloc(0);
try { res.on('data', (d) => {
const buffer = await imagemin([file.path], { resBuffer = Buffer.concat([resBuffer, d], resBuffer.length + d.length);
plugins: [
imageminJpegtran(),
imageminPngquant({
quality: [0.6, 0.8]
})
]
}); });
res.on('end', () => {
res.sendRaw(buffer[0].data, { if (resBuffer.length > 50) {
'Content-Type': file.type, resolve(resBuffer);
} else {
let str = resBuffer.toString();
let json = JSON.parse(str);
reject(json.msg);
}
}); });
}catch (e) { res.on('abort', () => {
logger.error('/tinify', 'compress failed'); reject('abort');
res.send({
code: 2,
msg: 'compress failed'
}); });
} }
}else{
logger.error('/tinify', 'type error');
res.send({
code: 1,
msg: 'type error'
}); });
} else {
reject('empty buffer');
} }
})
return next();
});
} }
/** exports.compressBuffer = compressBuffer;
* Created by rockyl on 2020-02-12.
*/
let [_, __, port = '8090'] = process.argv;
let eureka;
port = parseInt(port);
const server = restify.createServer({
name: 'tiny-image',
version: '1.0.0'
});
server.use(restify.plugins.acceptParser(server.acceptable));
server.use(restify.plugins.queryParser());
server.use(restify.plugins.bodyParser());
applyApi(server);
process.on('uncaughtException', (err) => {
logger.error(err);
});
process.on("SIGTERM", () => {
eureka.stop();
setTimeout(() => {
process.exit(1);
}, 6000);
});
server.listen(port, async function () {
try {
eureka = await getEurekaClient(port);
logger.info('eureka register success');
} catch (e) {
logger.error(e.name);
}
logger.info('%s listening at %s', server.name, server.url);
});
//# sourceMappingURL=index.js.map //# sourceMappingURL=index.js.map
dist/index.js.map
View file @ c5ec144a
{"version":3,"file":"index.js","sources":["../src/logger.js","../src/eureka.js","../src/api.js","../src/index.js"],"sourcesContent":["/**\n * Created by rockyl on 2020-02-13.\n */\n\nimport {configure, getLogger} from 'log4js';\nimport path from \"path\";\nimport fs from \"fs-extra\";\n\nconst logPath = path.join(process.env.HOME || process.env.USERPROFILE, 'logs', 'tiny-image');\n\nfs.ensureDir(logPath);\n\nconfigure({\n\tappenders: {\n\t\tout: {type: 'console'},\n\t\tallLog: {\n\t\t\ttype: 'dateFile',\n\t\t\tfilename: path.join(logPath, 'log.log'),\n\t\t},\n\t},\n\tcategories: {\n\t\tdefault: {appenders: ['out', 'allLog'], level: 'debug'},\n\t}\n\n});\n\nconst logger = getLogger();\n\nexport default logger;","import Eurekaclient from 'eureka-client-ts';\nimport logger from './logger';\n\nconst eurekaConfig = {\n appName: 'tiny-image',\n services: ['tiny-image'],\n};\n\nexport async function getEurekaClient(port) {\n eurekaConfig.port = port;\n let eureka;\n try {\n eureka = new Eurekaclient(eurekaConfig);\n await eureka.start();\n } catch (e) {\n logger.error(e);\n }\n\n return eureka;\n}\n","/**\n * Created by rockyl on 2020-02-13.\n */\n\nimport logger from \"./logger\";\nimport imagemin from \"imagemin\";\nimport imageminJpegtran from \"imagemin-jpegtran\";\nimport imageminPngquant from \"imagemin-pngquant\";\n\nconst acceptTypes = ['image/png', 'image/jpeg'];\n\nexport default function applyApi(server){\n\tserver.get('/echo/:name', function (req, res, next) {\n\t\tres.send(req.params);\n\t\treturn next();\n\t});\n\n\tserver.get('/monitor/check', function (req, res, next) {\n\t\tres.sendRaw('ok');\n\t\treturn next();\n\t});\n\n\tserver.post('/tinify', async function (req, res, next) {\n\t\tlogger.info('/tinify');\n\n\t\tlet file = req.files.file;\n\n\t\tif(acceptTypes.includes(file.type)){\n\t\t\ttry {\n\t\t\t\tconst buffer = await imagemin([file.path], {\n\t\t\t\t\tplugins: [\n\t\t\t\t\t\timageminJpegtran(),\n\t\t\t\t\t\timageminPngquant({\n\t\t\t\t\t\t\tquality: [0.6, 0.8]\n\t\t\t\t\t\t})\n\t\t\t\t\t]\n\t\t\t\t});\n\n\t\t\t\tres.sendRaw(buffer[0].data, {\n\t\t\t\t\t'Content-Type': file.type,\n\t\t\t\t});\n\t\t\t}catch (e) {\n\t\t\t\tlogger.error('/tinify', 'compress failed');\n\t\t\t\tres.send({\n\t\t\t\t\tcode: 2,\n\t\t\t\t\tmsg: 'compress failed'\n\t\t\t\t});\n\t\t\t}\n\t\t}else{\n\t\t\tlogger.error('/tinify', 'type error');\n\t\t\tres.send({\n\t\t\t\tcode: 1,\n\t\t\t\tmsg: 'type error'\n\t\t\t});\n\t\t}\n\n\t\treturn next();\n\t});\n}","/**\n * Created by rockyl on 2020-02-12.\n */\n\nimport restify from 'restify';\nimport {getEurekaClient} from \"./eureka\";\nimport logger from \"./logger\";\nimport applyApi from \"./api\";\n\nlet [_, __, port = '8090'] = process.argv;\nlet eureka;\nport = parseInt(port);\n\nconst server = restify.createServer({\n\tname: 'tiny-image',\n\tversion: '1.0.0'\n});\n\nserver.use(restify.plugins.acceptParser(server.acceptable));\nserver.use(restify.plugins.queryParser());\nserver.use(restify.plugins.bodyParser());\n\napplyApi(server);\n\nprocess.on('uncaughtException', (err) => {\n\tlogger.error(err);\n});\n\nprocess.on(\"SIGTERM\", () => {\n\teureka.stop();\n\tsetTimeout(() => {\n\t\tprocess.exit(1)\n\t}, 6000);\n});\n\nserver.listen(port, async function () {\n\ttry {\n\t\teureka = await getEurekaClient(port);\n\t\tlogger.info('eureka register success');\n\t} catch (e) {\n\t\tlogger.error(e.name);\n\t}\n\tlogger.info('%s listening at %s', server.name, server.url);\n});\n"],"names":["configure","getLogger"],"mappings":";;;;;;;;;;;;;AAAA;;;AAGA,AAIA;AACA,MAAM,OAAO,GAAG,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,OAAO,CAAC,GAAG,CAAC,WAAW,EAAE,MAAM,EAAE,YAAY,CAAC,CAAC;;AAE7F,EAAE,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC;;AAEtBA,gBAAS,CAAC;CACT,SAAS,EAAE;EACV,GAAG,EAAE,CAAC,IAAI,EAAE,SAAS,CAAC;EACtB,MAAM,EAAE;GACP,IAAI,EAAE,UAAU;GAChB,QAAQ,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,SAAS,CAAC;GACvC;EACD;CACD,UAAU,EAAE;EACX,OAAO,EAAE,CAAC,SAAS,EAAE,CAAC,KAAK,EAAE,QAAQ,CAAC,EAAE,KAAK,EAAE,OAAO,CAAC;EACvD;;CAED,CAAC,CAAC;;AAEH,MAAM,MAAM,GAAGC,gBAAS,EAAE,CAAC;;ACvB3B,MAAM,YAAY,GAAG;EACnB,OAAO,EAAE,YAAY;EACrB,QAAQ,EAAE,CAAC,YAAY,CAAC;CACzB,CAAC;;AAEF,AAAO,eAAe,eAAe,CAAC,IAAI,EAAE;EAC1C,YAAY,CAAC,IAAI,GAAG,IAAI,CAAC;EACzB,IAAI,MAAM,CAAC;EACX,IAAI;IACF,MAAM,GAAG,IAAI,YAAY,CAAC,YAAY,CAAC,CAAC;IACxC,MAAM,MAAM,CAAC,KAAK,EAAE,CAAC;GACtB,CAAC,OAAO,CAAC,EAAE;IACV,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;GACjB;;EAED,OAAO,MAAM,CAAC;CACf;;ACnBD;;;AAGA,AAKA;AACA,MAAM,WAAW,GAAG,CAAC,WAAW,EAAE,YAAY,CAAC,CAAC;;AAEhD,AAAe,SAAS,QAAQ,CAAC,MAAM,CAAC;CACvC,MAAM,CAAC,GAAG,CAAC,aAAa,EAAE,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI,EAAE;EACnD,GAAG,CAAC,IAAI,CAAC,GAAG,CAAC,MAAM,CAAC,CAAC;EACrB,OAAO,IAAI,EAAE,CAAC;EACd,CAAC,CAAC;;CAEH,MAAM,CAAC,GAAG,CAAC,gBAAgB,EAAE,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI,EAAE;EACtD,GAAG,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;EAClB,OAAO,IAAI,EAAE,CAAC;EACd,CAAC,CAAC;;CAEH,MAAM,CAAC,IAAI,CAAC,SAAS,EAAE,iBAAiB,GAAG,EAAE,GAAG,EAAE,IAAI,EAAE;EACvD,MAAM,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;;EAEvB,IAAI,IAAI,GAAG,GAAG,CAAC,KAAK,CAAC,IAAI,CAAC;;EAE1B,GAAG,WAAW,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;GAClC,IAAI;IACH,MAAM,MAAM,GAAG,MAAM,QAAQ,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;KAC1C,OAAO,EAAE;MACR,gBAAgB,EAAE;MAClB,gBAAgB,CAAC;OAChB,OAAO,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC;OACnB,CAAC;MACF;KACD,CAAC,CAAC;;IAEH,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,EAAE;KAC3B,cAAc,EAAE,IAAI,CAAC,IAAI;KACzB,CAAC,CAAC;IACH,OAAO,CAAC,EAAE;IACV,MAAM,CAAC,KAAK,CAAC,SAAS,EAAE,iBAAiB,CAAC,CAAC;IAC3C,GAAG,CAAC,IAAI,CAAC;KACR,IAAI,EAAE,CAAC;KACP,GAAG,EAAE,iBAAiB;KACtB,CAAC,CAAC;IACH;GACD,IAAI;GACJ,MAAM,CAAC,KAAK,CAAC,SAAS,EAAE,YAAY,CAAC,CAAC;GACtC,GAAG,CAAC,IAAI,CAAC;IACR,IAAI,EAAE,CAAC;IACP,GAAG,EAAE,YAAY;IACjB,CAAC,CAAC;GACH;;EAED,OAAO,IAAI,EAAE,CAAC;EACd,CAAC,CAAC;;;ACzDJ;;;AAGA,AAKA;AACA,IAAI,CAAC,CAAC,EAAE,EAAE,EAAE,IAAI,GAAG,MAAM,CAAC,GAAG,OAAO,CAAC,IAAI,CAAC;AAC1C,IAAI,MAAM,CAAC;AACX,IAAI,GAAG,QAAQ,CAAC,IAAI,CAAC,CAAC;;AAEtB,MAAM,MAAM,GAAG,OAAO,CAAC,YAAY,CAAC;CACnC,IAAI,EAAE,YAAY;CAClB,OAAO,EAAE,OAAO;CAChB,CAAC,CAAC;;AAEH,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,YAAY,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC,CAAC;AAC5D,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,WAAW,EAAE,CAAC,CAAC;AAC1C,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,EAAE,CAAC,CAAC;;AAEzC,QAAQ,CAAC,MAAM,CAAC,CAAC;;AAEjB,OAAO,CAAC,EAAE,CAAC,mBAAmB,EAAE,CAAC,GAAG,KAAK;CACxC,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;CAClB,CAAC,CAAC;;AAEH,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,MAAM;CAC3B,MAAM,CAAC,IAAI,EAAE,CAAC;CACd,UAAU,CAAC,MAAM;EAChB,OAAO,CAAC,IAAI,CAAC,CAAC,EAAC;EACf,EAAE,IAAI,CAAC,CAAC;CACT,CAAC,CAAC;;AAEH,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,kBAAkB;CACrC,IAAI;EACH,MAAM,GAAG,MAAM,eAAe,CAAC,IAAI,CAAC,CAAC;EACrC,MAAM,CAAC,IAAI,CAAC,yBAAyB,CAAC,CAAC;EACvC,CAAC,OAAO,CAAC,EAAE;EACX,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC;EACrB;CACD,MAAM,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,IAAI,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;CAC3D,CAAC,CAAC"} {"version":3,"file":"index.js","sources":["../src/index.js"],"sourcesContent":["/**\n * Created by rockyl on 2020-02-13.\n */\n\nimport FormData from 'form-data';\nimport fs from 'fs';\n\nconst tinifyUrl = 'http://localhost:8090/tinify';\n\nexport async function compressBuffer(buffer) {\n\treturn new Promise((resolve, reject) => {\n\t\tif (buffer && buffer.length > 0) {\n\t\t\tlet form = new FormData();\n\t\t\tform.append('file', buffer, {\n\t\t\t\tfilename: 'image.png',\n\t\t\t\tcontentType: 'image/png',\n\t\t\t});\n\n\t\t\tform.submit(tinifyUrl, function (err, res) {\n\t\t\t\tif (err) {\n\t\t\t\t\treject(err);\n\t\t\t\t} else {\n\t\t\t\t\tres.resume();\n\t\t\t\t\tlet resBuffer = Buffer.alloc(0);\n\t\t\t\t\tres.on('data', (d) => {\n\t\t\t\t\t\tresBuffer = Buffer.concat([resBuffer, d], resBuffer.length + d.length);\n\t\t\t\t\t});\n\t\t\t\t\tres.on('end', () => {\n\t\t\t\t\t\tif (resBuffer.length > 50) {\n\t\t\t\t\t\t\tresolve(resBuffer);\n\t\t\t\t\t\t} else {\n\t\t\t\t\t\t\tlet str = resBuffer.toString();\n\t\t\t\t\t\t\tlet json = JSON.parse(str);\n\t\t\t\t\t\t\treject(json.msg);\n\t\t\t\t\t\t}\n\t\t\t\t\t});\n\t\t\t\t\tres.on('abort', () => {\n\t\t\t\t\t\treject('abort')\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t});\n\t\t} else {\n\t\t\treject('empty buffer')\n\t\t}\n\t})\n}\n"],"names":[],"mappings":";;;;;;;;;AAAA;;;AAGA,AAGA;AACA,MAAM,SAAS,GAAG,8BAA8B,CAAC;;AAEjD,AAAO,eAAe,cAAc,CAAC,MAAM,EAAE;CAC5C,OAAO,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,KAAK;EACvC,IAAI,MAAM,IAAI,MAAM,CAAC,MAAM,GAAG,CAAC,EAAE;GAChC,IAAI,IAAI,GAAG,IAAI,QAAQ,EAAE,CAAC;GAC1B,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,MAAM,EAAE;IAC3B,QAAQ,EAAE,WAAW;IACrB,WAAW,EAAE,WAAW;IACxB,CAAC,CAAC;;GAEH,IAAI,CAAC,MAAM,CAAC,SAAS,EAAE,UAAU,GAAG,EAAE,GAAG,EAAE;IAC1C,IAAI,GAAG,EAAE;KACR,MAAM,CAAC,GAAG,CAAC,CAAC;KACZ,MAAM;KACN,GAAG,CAAC,MAAM,EAAE,CAAC;KACb,IAAI,SAAS,GAAG,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;KAChC,GAAG,CAAC,EAAE,CAAC,MAAM,EAAE,CAAC,CAAC,KAAK;MACrB,SAAS,GAAG,MAAM,CAAC,MAAM,CAAC,CAAC,SAAS,EAAE,CAAC,CAAC,EAAE,SAAS,CAAC,MAAM,GAAG,CAAC,CAAC,MAAM,CAAC,CAAC;MACvE,CAAC,CAAC;KACH,GAAG,CAAC,EAAE,CAAC,KAAK,EAAE,MAAM;MACnB,IAAI,SAAS,CAAC,MAAM,GAAG,EAAE,EAAE;OAC1B,OAAO,CAAC,SAAS,CAAC,CAAC;OACnB,MAAM;OACN,IAAI,GAAG,GAAG,SAAS,CAAC,QAAQ,EAAE,CAAC;OAC/B,IAAI,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;OAC3B,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;OACjB;MACD,CAAC,CAAC;KACH,GAAG,CAAC,EAAE,CAAC,OAAO,EAAE,MAAM;MACrB,MAAM,CAAC,OAAO,EAAC;MACf,CAAC,CAAC;KACH;IACD,CAAC,CAAC;GACH,MAAM;GACN,MAAM,CAAC,cAAc,EAAC;GACtB;EACD,CAAC;CACF;;;;"}
\ No newline at end of file \ No newline at end of file
package-lock.json deleted 100644 → 0
View file @ dfdb6f5d
This source diff could not be displayed because it is too large. You can view the blob instead.
package.json
View file @ c5ec144a
{ {
"name": "duiba-tiny-image-node", "name": "tiny-image",
"version": "1.0.0", "version": "1.0.0",
"main": "index.js", "main": "index.js",
"license": "MIT", "license": "MIT",
"dependencies": { "dependencies": {
"eureka-client-ts": "^0.2.10", "form-data": "^3.0.0",
"fs-extra": "^8.1.0", "node-fetch": "^2.6.0"
"imagemin": "^7.0.1",
"imagemin-jpegtran": "^6.0.0",
"imagemin-pngquant": "^8.0.0",
"jpegtran-bin": "^4.0.0",
"log4js": "^6.1.2",
"restify": "^8.5.1"
}, },
"scripts": { "scripts": {
"dev": "rollup -c -w", "dev": "rollup -c -w",
......
src/api.js deleted 100644 → 0
View file @ dfdb6f5d
/**
* Created by rockyl on 2020-02-13.
*/
import logger from "./logger";
import imagemin from "imagemin";
import imageminJpegtran from "imagemin-jpegtran";
import imageminPngquant from "imagemin-pngquant";
const acceptTypes = ['image/png', 'image/jpeg'];
export default function applyApi(server){
server.get('/echo/:name', function (req, res, next) {
res.send(req.params);
return next();
});
server.get('/monitor/check', function (req, res, next) {
res.sendRaw('ok');
return next();
});
server.post('/tinify', async function (req, res, next) {
logger.info('/tinify');
let file = req.files.file;
if(acceptTypes.includes(file.type)){
try {
const buffer = await imagemin([file.path], {
plugins: [
imageminJpegtran(),
imageminPngquant({
quality: [0.6, 0.8]
})
]
});
res.sendRaw(buffer[0].data, {
'Content-Type': file.type,
});
}catch (e) {
logger.error('/tinify', 'compress failed');
res.send({
code: 2,
msg: 'compress failed'
});
}
}else{
logger.error('/tinify', 'type error');
res.send({
code: 1,
msg: 'type error'
});
}
return next();
});
}
\ No newline at end of file
src/eureka.js deleted 100644 → 0
View file @ dfdb6f5d
import Eurekaclient from 'eureka-client-ts';
import logger from './logger';
const eurekaConfig = {
appName: 'tiny-image',
services: ['tiny-image'],
};
export async function getEurekaClient(port) {
eurekaConfig.port = port;
let eureka;
try {
eureka = new Eurekaclient(eurekaConfig);
await eureka.start();
} catch (e) {
logger.error(e);
}
return eureka;
}
src/index.js
View file @ c5ec144a
/** /**
* Created by rockyl on 2020-02-12. * Created by rockyl on 2020-02-13.
*/ */
import restify from 'restify'; import FormData from 'form-data';
import {getEurekaClient} from "./eureka"; import fs from 'fs';
import logger from "./logger";
import applyApi from "./api"; const tinifyUrl = 'http://localhost:8090/tinify';
let [_, __, port = '8090'] = process.argv; export async function compressBuffer(buffer) {
let eureka; return new Promise((resolve, reject) => {
port = parseInt(port); if (buffer && buffer.length > 0) {
let form = new FormData();
const server = restify.createServer({ form.append('file', buffer, {
name: 'tiny-image', filename: 'image.png',
version: '1.0.0' contentType: 'image/png',
}); });
server.use(restify.plugins.acceptParser(server.acceptable)); form.submit(tinifyUrl, function (err, res) {
server.use(restify.plugins.queryParser()); if (err) {
server.use(restify.plugins.bodyParser()); reject(err);
} else {
applyApi(server); res.resume();
let resBuffer = Buffer.alloc(0);
process.on('uncaughtException', (err) => { res.on('data', (d) => {
logger.error(err); resBuffer = Buffer.concat([resBuffer, d], resBuffer.length + d.length);
}); });
res.on('end', () => {
process.on("SIGTERM", () => { if (resBuffer.length > 50) {
eureka.stop(); resolve(resBuffer);
setTimeout(() => { } else {
process.exit(1) let str = resBuffer.toString();
}, 6000); let json = JSON.parse(str);
}); reject(json.msg);
}
server.listen(port, async function () { });
try { res.on('abort', () => {
eureka = await getEurekaClient(port); reject('abort')
logger.info('eureka register success'); });
} catch (e) { }
logger.error(e.name); });
} else {
reject('empty buffer')
} }
logger.info('%s listening at %s', server.name, server.url); })
}); }
src/logger.js deleted 100644 → 0
View file @ dfdb6f5d
/**
* Created by rockyl on 2020-02-13.
*/
import {configure, getLogger} from 'log4js';
import path from "path";
import fs from "fs-extra";
const logPath = path.join(process.env.HOME || process.env.USERPROFILE, 'logs', 'tiny-image');
fs.ensureDir(logPath);
configure({
appenders: {
out: {type: 'console'},
allLog: {
type: 'dateFile',
filename: path.join(logPath, 'log.log'),
},
},
categories: {
default: {appenders: ['out', 'allLog'], level: 'debug'},
}
});
const logger = getLogger();
export default logger;
\ No newline at end of file
duiba-tiny-image-node.iml → tiny-image.iml
View file @ c5ec144a
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
<module type="WEB_MODULE" version="4"> <module type="WEB_MODULE" version="4">
<component name="NewModuleRootManager" inherit-compiler-output="true"> <component name="NewModuleRootManager" inherit-compiler-output="true">
<exclude-output /> <exclude-output />
<content url="file://$MODULE_DIR$/../duiba-tiny-image-node" /> <content url="file://$MODULE_DIR$" />
<orderEntry type="sourceFolder" forTests="false" /> <orderEntry type="sourceFolder" forTests="false" />
</component> </component>
</module> </module>
\ No newline at end of file
yarn.lock
View file @ c5ec144a
This source diff could not be displayed because it is too large. You can view the blob instead.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment