Skip to content

D
duiba-tiny-image-node
Commit d14f5027 authored by rockyl's avatar rockyl
Browse files
Options

使用tinypng开设tinify2接口

parent 65cecd20
Hide whitespace changes
Inline Side-by-side
Showing with 207 additions and 136 deletions
dist/api.js
View file @ d14f5027
...@@ -5,9 +5,9 @@ ...@@ -5,9 +5,9 @@
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
const logger_1 = require("./logger"); const logger_1 = require("./logger");
const imagemin = require("imagemin"); const imagemin = require("imagemin");
const imageminJpegtran = require("imagemin-jpegtran"); const imageminJpegtran = require("imagemin-mozjpeg");
const imageminPngquant = require("imagemin-pngquant2"); const imageminPngquant = require("imagemin-pngquant2");
const fs = require('fs-extra'); const node_tinify_1 = require("node-tinify");
const acceptTypes = ['image/png', 'image/jpeg']; const acceptTypes = ['image/png', 'image/jpeg'];
function applyApi(server) { function applyApi(server) {
server.get('/info', function (req, res, next) { server.get('/info', function (req, res, next) {
...@@ -18,50 +18,83 @@ function applyApi(server) { ...@@ -18,50 +18,83 @@ function applyApi(server) {
res.sendRaw('ok'); res.sendRaw('ok');
return next(); return next();
}); });
server.post('/tinify', async function (req, res, next) { server.post('/tinify', tinify);
let file = req.files.file; server.post('/tinify2', tinify2);
if (file) { }
if (acceptTypes.includes(file.type)) { exports.default = applyApi;
try { async function tinify(req, res, next) {
console.log(`start compress!`); let file = req.files.file;
const buffer = await imagemin([file.path], { if (file) {
plugins: [ if (acceptTypes.includes(file.type)) {
imageminJpegtran(), try {
imageminPngquant({ const buffer = await imagemin([file.path], {
quality: [0.6, 0.8] plugins: [
}) imageminJpegtran(),
] imageminPngquant({
}); quality: [0.6, 0.8]
console.log(`compress success!`); })
res.sendRaw(buffer[0].data, { ]
'Content-Type': file.type, });
}); res.sendRaw(buffer[0].data, {
console.log('send row success!'); 'Content-Type': file.type,
} });
catch (e) {
logger_1.default.error('/tinify', 'compress failed', e.message);
res.send({
code: 3,
msg: 'compress failed'
});
}
} }
else { catch (e) {
logger_1.default.error('/tinify', 'type error'); logger_1.default.error('/tinify', 'compress failed', e.message);
res.send({ res.send({
code: 2, code: 3,
msg: 'type error' msg: 'compress failed'
}); });
} }
} }
else { else {
logger_1.default.error('/tinify', 'type error');
res.send({ res.send({
code: 1, code: 2,
msg: 'file not exists' msg: 'type error'
}); });
} }
return next(); }
}); else {
res.send({
code: 1,
msg: 'file not exists'
});
}
return next();
}
async function tinify2(req, res, next) {
let file = req.files.file;
if (file) {
if (acceptTypes.includes(file.type)) {
try {
const buffer = await node_tinify_1.compress(file.path, { returnType: 'buffer' });
res.sendRaw(buffer, {
'Content-Type': file.type,
});
}
catch (e) {
logger_1.default.error('/tinify2', 'compress failed', e.message);
res.send({
code: 3,
msg: 'compress failed'
});
}
}
else {
logger_1.default.error('/tinify2', 'type error');
res.send({
code: 2,
msg: 'type error'
});
}
}
else {
res.send({
code: 1,
msg: 'file not exists'
});
}
return next();
} }
exports.default = applyApi;
//# sourceMappingURL=api.js.map //# sourceMappingURL=api.js.map
\ No newline at end of file
dist/api.js.map
View file @ d14f5027
{"version":3,"file":"api.js","sourceRoot":"","sources":["../src/api.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,qCAA8B;AAC9B,MAAM,QAAQ,GAAG,OAAO,CAAC,UAAU,CAAC,CAAC;AACrC,MAAM,gBAAgB,GAAG,OAAO,CAAC,mBAAmB,CAAC,CAAC;AACtD,MAAM,gBAAgB,GAAG,OAAO,CAAC,oBAAoB,CAAC,CAAC;AACvD,MAAM,EAAE,GAAG,OAAO,CAAC,UAAU,CAAC,CAAC;AAE/B,MAAM,WAAW,GAAG,CAAC,WAAW,EAAE,YAAY,CAAC,CAAC;AAEhD,SAAwB,QAAQ,CAAC,MAAM;IACtC,MAAM,CAAC,GAAG,CAAC,OAAO,EAAE,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;QAC3C,GAAG,CAAC,OAAO,CAAC,8BAA8B,CAAC,CAAC;QAC5C,OAAO,IAAI,EAAE,CAAC;IACf,CAAC,CAAC,CAAC;IAEH,MAAM,CAAC,GAAG,CAAC,gBAAgB,EAAE,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;QACpD,GAAG,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;QAClB,OAAO,IAAI,EAAE,CAAC;IACf,CAAC,CAAC,CAAC;IAEH,MAAM,CAAC,IAAI,CAAC,SAAS,EAAE,KAAK,WAAY,GAAG,EAAE,GAAG,EAAE,IAAI;QACrD,IAAI,IAAI,GAAG,GAAG,CAAC,KAAK,CAAC,IAAI,CAAC;QAE1B,IAAG,IAAI,EAAC;YACP,IAAG,WAAW,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,EAAC;gBAClC,IAAI;oBACH,OAAO,CAAC,GAAG,CAAC,iBAAiB,CAAC,CAAC;oBAC/B,MAAM,MAAM,GAAG,MAAM,QAAQ,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;wBAC1C,OAAO,EAAE;4BACR,gBAAgB,EAAE;4BAClB,gBAAgB,CAAC;gCAChB,OAAO,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC;6BACnB,CAAC;yBACF;qBACD,CAAC,CAAC;oBAEH,OAAO,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;oBACjC,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,EAAE;wBAC3B,cAAc,EAAE,IAAI,CAAC,IAAI;qBACzB,CAAC,CAAC;oBACH,OAAO,CAAC,GAAG,CAAC,mBAAmB,CAAC,CAAC;iBACjC;gBAAA,OAAO,CAAC,EAAE;oBACV,gBAAM,CAAC,KAAK,CAAC,SAAS,EAAE,iBAAiB,EAAE,CAAC,CAAC,OAAO,CAAC,CAAC;oBACtD,GAAG,CAAC,IAAI,CAAC;wBACR,IAAI,EAAE,CAAC;wBACP,GAAG,EAAE,iBAAiB;qBACtB,CAAC,CAAC;iBACH;aACD;iBAAI;gBACJ,gBAAM,CAAC,KAAK,CAAC,SAAS,EAAE,YAAY,CAAC,CAAC;gBACtC,GAAG,CAAC,IAAI,CAAC;oBACR,IAAI,EAAE,CAAC;oBACP,GAAG,EAAE,YAAY;iBACjB,CAAC,CAAC;aACH;SACD;aAAI;YACJ,GAAG,CAAC,IAAI,CAAC;gBACR,IAAI,EAAE,CAAC;gBACP,GAAG,EAAE,iBAAiB;aACtB,CAAC,CAAC;SACH;QAED,OAAO,IAAI,EAAE,CAAC;IACf,CAAC,CAAC,CAAC;AACJ,CAAC;AAvDD,2BAuDC"} {"version":3,"file":"api.js","sourceRoot":"","sources":["../src/api.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,qCAA6B;AAE7B,MAAM,QAAQ,GAAG,OAAO,CAAC,UAAU,CAAC,CAAA;AACpC,MAAM,gBAAgB,GAAG,OAAO,CAAC,kBAAkB,CAAC,CAAA;AACpD,MAAM,gBAAgB,GAAG,OAAO,CAAC,oBAAoB,CAAC,CAAA;AACtD,6CAAoC;AAEpC,MAAM,WAAW,GAAG,CAAC,WAAW,EAAE,YAAY,CAAC,CAAA;AAE/C,SAAwB,QAAQ,CAAC,MAAM;IACtC,MAAM,CAAC,GAAG,CAAC,OAAO,EAAE,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;QAC3C,GAAG,CAAC,OAAO,CAAC,8BAA8B,CAAC,CAAA;QAC3C,OAAO,IAAI,EAAE,CAAA;IACd,CAAC,CAAC,CAAA;IAEF,MAAM,CAAC,GAAG,CAAC,gBAAgB,EAAE,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;QACpD,GAAG,CAAC,OAAO,CAAC,IAAI,CAAC,CAAA;QACjB,OAAO,IAAI,EAAE,CAAA;IACd,CAAC,CAAC,CAAA;IAEF,MAAM,CAAC,IAAI,CAAC,SAAS,EAAE,MAAM,CAAC,CAAA;IAC9B,MAAM,CAAC,IAAI,CAAC,UAAU,EAAE,OAAO,CAAC,CAAA;AACjC,CAAC;AAbD,2BAaC;AAED,KAAK,UAAU,MAAM,CAAC,GAAG,EAAE,GAAG,EAAE,IAAI;IACnC,IAAI,IAAI,GAAG,GAAG,CAAC,KAAK,CAAC,IAAI,CAAA;IAEzB,IAAI,IAAI,EAAE;QACT,IAAI,WAAW,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;YACpC,IAAI;gBACH,MAAM,MAAM,GAAG,MAAM,QAAQ,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;oBAC1C,OAAO,EAAE;wBACR,gBAAgB,EAAE;wBAClB,gBAAgB,CAAC;4BAChB,OAAO,EAAE,CAAC,GAAG,EAAE,GAAG,CAAC;yBACnB,CAAC;qBACF;iBACD,CAAC,CAAA;gBAEF,GAAG,CAAC,OAAO,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,IAAI,EAAE;oBAC3B,cAAc,EAAE,IAAI,CAAC,IAAI;iBACzB,CAAC,CAAA;aACF;YAAC,OAAO,CAAC,EAAE;gBACX,gBAAM,CAAC,KAAK,CAAC,SAAS,EAAE,iBAAiB,EAAE,CAAC,CAAC,OAAO,CAAC,CAAA;gBACrD,GAAG,CAAC,IAAI,CAAC;oBACR,IAAI,EAAE,CAAC;oBACP,GAAG,EAAE,iBAAiB;iBACtB,CAAC,CAAA;aACF;SACD;aAAM;YACN,gBAAM,CAAC,KAAK,CAAC,SAAS,EAAE,YAAY,CAAC,CAAA;YACrC,GAAG,CAAC,IAAI,CAAC;gBACR,IAAI,EAAE,CAAC;gBACP,GAAG,EAAE,YAAY;aACjB,CAAC,CAAA;SACF;KACD;SAAM;QACN,GAAG,CAAC,IAAI,CAAC;YACR,IAAI,EAAE,CAAC;YACP,GAAG,EAAE,iBAAiB;SACtB,CAAC,CAAA;KACF;IACD,OAAO,IAAI,EAAE,CAAA;AACd,CAAC;AAED,KAAK,UAAU,OAAO,CAAC,GAAG,EAAE,GAAG,EAAE,IAAI;IACpC,IAAI,IAAI,GAAG,GAAG,CAAC,KAAK,CAAC,IAAI,CAAA;IAEzB,IAAI,IAAI,EAAE;QACT,IAAI,WAAW,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE;YACpC,IAAI;gBACH,MAAM,MAAM,GAAG,MAAM,sBAAQ,CAAC,IAAI,CAAC,IAAI,EAAE,EAAC,UAAU,EAAE,QAAQ,EAAC,CAAC,CAAA;gBAChE,GAAG,CAAC,OAAO,CAAC,MAAM,EAAE;oBACnB,cAAc,EAAE,IAAI,CAAC,IAAI;iBACzB,CAAC,CAAA;aACF;YAAC,OAAO,CAAC,EAAE;gBACX,gBAAM,CAAC,KAAK,CAAC,UAAU,EAAE,iBAAiB,EAAE,CAAC,CAAC,OAAO,CAAC,CAAA;gBACtD,GAAG,CAAC,IAAI,CAAC;oBACR,IAAI,EAAE,CAAC;oBACP,GAAG,EAAE,iBAAiB;iBACtB,CAAC,CAAA;aACF;SACD;aAAM;YACN,gBAAM,CAAC,KAAK,CAAC,UAAU,EAAE,YAAY,CAAC,CAAA;YACtC,GAAG,CAAC,IAAI,CAAC;gBACR,IAAI,EAAE,CAAC;gBACP,GAAG,EAAE,YAAY;aACjB,CAAC,CAAA;SACF;KACD;SAAM;QACN,GAAG,CAAC,IAAI,CAAC;YACR,IAAI,EAAE,CAAC;YACP,GAAG,EAAE,iBAAiB;SACtB,CAAC,CAAA;KACF;IACD,OAAO,IAAI,EAAE,CAAA;AACd,CAAC"}
\ No newline at end of file \ No newline at end of file
dist/eureka.js
View file @ d14f5027
"use strict"; "use strict";
Object.defineProperty(exports, "__esModule", { value: true }); Object.defineProperty(exports, "__esModule", { value: true });
exports.getEurekaClient = void 0;
const eureka_client_ts_1 = require("eureka-client-ts"); const eureka_client_ts_1 = require("eureka-client-ts");
const logger_1 = require("./logger"); const logger_1 = require("./logger");
const eurekaConfig = { const eurekaConfig = {
......
dist/eureka.js.map
View file @ d14f5027
{"version":3,"file":"eureka.js","sourceRoot":"","sources":["../src/eureka.ts"],"names":[],"mappings":";;;AAAA,uDAA4C;AAC5C,qCAA8B;AAE9B,MAAM,YAAY,GAAO;IACvB,OAAO,EAAE,uBAAuB;IAChC,QAAQ,EAAE,CAAC,uBAAuB,CAAC;CACpC,CAAC;AAEK,KAAK,UAAU,eAAe,CAAC,IAAI;IACxC,YAAY,CAAC,IAAI,GAAG,IAAI,CAAC;IACzB,IAAI,MAAM,CAAC;IACX,IAAI;QACF,MAAM,GAAG,IAAI,0BAAY,CAAC,YAAY,CAAC,CAAC;QACxC,MAAM,MAAM,CAAC,KAAK,EAAE,CAAC;KACtB;IAAC,OAAO,CAAC,EAAE;QACV,gBAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;KACjB;IAED,OAAO,MAAM,CAAC;AAChB,CAAC;AAXD,0CAWC"} {"version":3,"file":"eureka.js","sourceRoot":"","sources":["../src/eureka.ts"],"names":[],"mappings":";;AAAA,uDAA2C;AAC3C,qCAA6B;AAE7B,MAAM,YAAY,GAAO;IACvB,OAAO,EAAE,uBAAuB;IAChC,QAAQ,EAAE,CAAC,uBAAuB,CAAC;CACpC,CAAA;AAEM,KAAK,UAAU,eAAe,CAAC,IAAI;IACxC,YAAY,CAAC,IAAI,GAAG,IAAI,CAAA;IACxB,IAAI,MAAM,CAAA;IACV,IAAI;QACF,MAAM,GAAG,IAAI,0BAAY,CAAC,YAAY,CAAC,CAAA;QACvC,MAAM,MAAM,CAAC,KAAK,EAAE,CAAA;KACrB;IAAC,OAAO,CAAC,EAAE;QACV,gBAAM,CAAC,KAAK,CAAC,CAAC,CAAC,CAAA;KAChB;IAED,OAAO,MAAM,CAAA;AACf,CAAC;AAXD,0CAWC"}
\ No newline at end of file \ No newline at end of file
dist/index.js.map
View file @ d14f5027
{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,MAAM,OAAO,GAAG,OAAO,CAAC,SAAS,CAAC,CAAC;AACnC,qCAAyC;AACzC,qCAA8B;AAC9B,+BAA6B;AAE7B,IAAI,CAAC,CAAC,EAAE,EAAE,EAAE,OAAO,GAAG,MAAM,CAAC,GAAG,OAAO,CAAC,IAAI,CAAC;AAC7C,IAAI,MAAM,CAAC;AACX,IAAI,IAAI,GAAG,QAAQ,CAAC,OAAO,CAAC,CAAC;AAE7B,MAAM,MAAM,GAAG,OAAO,CAAC,YAAY,CAAC;IACnC,IAAI,EAAE,YAAY;IAClB,OAAO,EAAE,OAAO;CAChB,CAAC,CAAC;AAEH,MAAM,eAAe,GAAG,CAAC,gBAAgB,CAAC,CAAC;AAE3C,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;AACzC,MAAM,CAAC,GAAG,CAAC,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;IAClC,IAAI,CAAC,eAAe,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAa,CAAC,EAAE;QACjD,gBAAM,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,CAAC;KACrB;IACD,OAAO,IAAI,EAAE,CAAC;AACf,CAAC,CAAC,CAAC;AAEH,aAAQ,CAAC,MAAM,CAAC,CAAC;AAEjB,OAAO,CAAC,EAAE,CAAC,mBAAmB,EAAE,CAAC,GAAG,EAAE,EAAE;IACvC,gBAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;AACnB,CAAC,CAAC,CAAC;AAEH,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,GAAG,EAAE;IAC1B,MAAM,CAAC,IAAI,EAAE,CAAC;IACd,UAAU,CAAC,GAAG,EAAE;QACf,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAA;IAChB,CAAC,EAAE,IAAI,CAAC,CAAC;AACV,CAAC,CAAC,CAAC;AAEH,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK;IACxB,IAAI;QACH,MAAM,GAAG,MAAM,wBAAe,CAAC,IAAI,CAAC,CAAC;QACrC,gBAAM,CAAC,IAAI,CAAC,yBAAyB,CAAC,CAAC;KACvC;IAAC,OAAO,CAAC,EAAE;QACX,gBAAM,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC;KACrB;IACD,gBAAM,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,IAAI,EAAE,MAAM,CAAC,GAAG,CAAC,CAAC;AAC5D,CAAC,CAAC,CAAC"} {"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,MAAM,OAAO,GAAG,OAAO,CAAC,SAAS,CAAC,CAAA;AAClC,qCAAwC;AACxC,qCAA6B;AAC7B,+BAA4B;AAE5B,IAAI,CAAC,CAAC,EAAE,EAAE,EAAE,OAAO,GAAG,MAAM,CAAC,GAAG,OAAO,CAAC,IAAI,CAAA;AAC5C,IAAI,MAAM,CAAA;AACV,IAAI,IAAI,GAAG,QAAQ,CAAC,OAAO,CAAC,CAAA;AAE5B,MAAM,MAAM,GAAG,OAAO,CAAC,YAAY,CAAC;IACnC,IAAI,EAAE,YAAY;IAClB,OAAO,EAAE,OAAO;CAChB,CAAC,CAAA;AAEF,MAAM,eAAe,GAAG,CAAC,gBAAgB,CAAC,CAAA;AAE1C,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,YAAY,CAAC,MAAM,CAAC,UAAU,CAAC,CAAC,CAAA;AAC3D,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,WAAW,EAAE,CAAC,CAAA;AACzC,MAAM,CAAC,GAAG,CAAC,OAAO,CAAC,OAAO,CAAC,UAAU,EAAE,CAAC,CAAA;AACxC,MAAM,CAAC,GAAG,CAAC,UAAU,GAAG,EAAE,GAAG,EAAE,IAAI;IAClC,IAAI,CAAC,eAAe,CAAC,QAAQ,CAAC,GAAG,CAAC,GAAa,CAAC,EAAE;QACjD,gBAAM,CAAC,IAAI,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;KACpB;IACD,OAAO,IAAI,EAAE,CAAA;AACd,CAAC,CAAC,CAAA;AAEF,aAAQ,CAAC,MAAM,CAAC,CAAA;AAEhB,OAAO,CAAC,EAAE,CAAC,mBAAmB,EAAE,CAAC,GAAG,EAAE,EAAE;IACvC,gBAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;AAClB,CAAC,CAAC,CAAA;AAEF,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,GAAG,EAAE;IAC1B,MAAM,CAAC,IAAI,EAAE,CAAA;IACb,UAAU,CAAC,GAAG,EAAE;QACf,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAA;IAChB,CAAC,EAAE,IAAI,CAAC,CAAA;AACT,CAAC,CAAC,CAAA;AAEF,MAAM,CAAC,MAAM,CAAC,IAAI,EAAE,KAAK;IACxB,IAAI;QACH,MAAM,GAAG,MAAM,wBAAe,CAAC,IAAI,CAAC,CAAA;QACpC,gBAAM,CAAC,IAAI,CAAC,yBAAyB,CAAC,CAAA;KACtC;IAAC,OAAO,CAAC,EAAE;QACX,gBAAM,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAAC,CAAA;KACpB;IACD,gBAAM,CAAC,IAAI,CAAC,oBAAoB,EAAE,MAAM,CAAC,IAAI,EAAE,MAAM,CAAC,GAAG,CAAC,CAAA;AAC3D,CAAC,CAAC,CAAA"}
\ No newline at end of file \ No newline at end of file
dist/logger.js.map
View file @ d14f5027
{"version":3,"file":"logger.js","sourceRoot":"","sources":["../src/logger.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,mCAA4C;AAC5C,MAAM,IAAI,GAAG,OAAO,CAAC,MAAM,CAAC,CAAC;AAC7B,MAAM,EAAE,GAAG,OAAO,CAAC,UAAU,CAAC,CAAC;AAE/B,MAAM,OAAO,GAAG,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,OAAO,CAAC,GAAG,CAAC,WAAqB,EAAE,MAAM,EAAE,YAAY,CAAC,CAAC;AAEvG,EAAE,CAAC,SAAS,CAAC,OAAO,CAAC,CAAC;AAEtB,kBAAS,CAAC;IACT,SAAS,EAAE;QACV,GAAG,EAAE,EAAC,IAAI,EAAE,SAAS,EAAC;QACtB,MAAM,EAAE;YACP,IAAI,EAAE,UAAU;YAChB,QAAQ,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,SAAS,CAAC;SACvC;KACD;IACD,UAAU,EAAE;QACX,OAAO,EAAE,EAAC,SAAS,EAAE,CAAC,KAAK,EAAE,QAAQ,CAAC,EAAE,KAAK,EAAE,OAAO,EAAC;KACvD;CAED,CAAC,CAAC;AAEH,MAAM,MAAM,GAAG,kBAAS,EAAE,CAAC;AAE3B,kBAAe,MAAM,CAAC"} {"version":3,"file":"logger.js","sourceRoot":"","sources":["../src/logger.ts"],"names":[],"mappings":";AAAA;;GAEG;;AAEH,mCAA2C;AAC3C,MAAM,IAAI,GAAG,OAAO,CAAC,MAAM,CAAC,CAAA;AAC5B,MAAM,EAAE,GAAG,OAAO,CAAC,UAAU,CAAC,CAAA;AAE9B,MAAM,OAAO,GAAG,IAAI,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,IAAI,IAAI,OAAO,CAAC,GAAG,CAAC,WAAqB,EAAE,MAAM,EAAE,YAAY,CAAC,CAAA;AAEtG,EAAE,CAAC,SAAS,CAAC,OAAO,CAAC,CAAA;AAErB,kBAAS,CAAC;IACT,SAAS,EAAE;QACV,GAAG,EAAE,EAAC,IAAI,EAAE,SAAS,EAAC;QACtB,MAAM,EAAE;YACP,IAAI,EAAE,UAAU;YAChB,QAAQ,EAAE,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,SAAS,CAAC;SACvC;KACD;IACD,UAAU,EAAE;QACX,OAAO,EAAE,EAAC,SAAS,EAAE,CAAC,KAAK,EAAE,QAAQ,CAAC,EAAE,KAAK,EAAE,OAAO,EAAC;KACvD;CAED,CAAC,CAAA;AAEF,MAAM,MAAM,GAAG,kBAAS,EAAE,CAAA;AAE1B,kBAAe,MAAM,CAAA"}
\ No newline at end of file \ No newline at end of file
package.json
View file @ d14f5027
...@@ -12,6 +12,7 @@ ...@@ -12,6 +12,7 @@
"imagemin-jpegtran": "^6.0.0", "imagemin-jpegtran": "^6.0.0",
"imagemin-pngquant2": "^9.0.1", "imagemin-pngquant2": "^9.0.1",
"log4js": "^6.1.2", "log4js": "^6.1.2",
"node-tinify": "^1.0.4",
"restify": "^8.5.1" "restify": "^8.5.1"
}, },
"scripts": { "scripts": {
......
src/api.ts
View file @ d14f5027
...@@ -2,67 +2,100 @@ ...@@ -2,67 +2,100 @@
* Created by rockyl on 2020-02-13. * Created by rockyl on 2020-02-13.
*/ */
import logger from "./logger"; import logger from "./logger"
const imagemin = require("imagemin");
const imageminJpegtran = require("imagemin-jpegtran");
const imageminPngquant = require("imagemin-pngquant2");
const fs = require('fs-extra');
const acceptTypes = ['image/png', 'image/jpeg']; const imagemin = require("imagemin")
const imageminJpegtran = require("imagemin-mozjpeg")
const imageminPngquant = require("imagemin-pngquant2")
import {compress} from 'node-tinify'
export default function applyApi(server){ const acceptTypes = ['image/png', 'image/jpeg']
export default function applyApi(server) {
server.get('/info', function (req, res, next) { server.get('/info', function (req, res, next) {
res.sendRaw('Tiny image serve is running.'); res.sendRaw('Tiny image serve is running.')
return next(); return next()
}); })
server.get('/monitor/check', function (req, res, next) { server.get('/monitor/check', function (req, res, next) {
res.sendRaw('ok'); res.sendRaw('ok')
return next(); return next()
}); })
server.post('/tinify', tinify)
server.post('/tinify2', tinify2)
}
server.post('/tinify', async function (req, res, next) { async function tinify(req, res, next) {
let file = req.files.file; let file = req.files.file
if(file){ if (file) {
if(acceptTypes.includes(file.type)){ if (acceptTypes.includes(file.type)) {
try { try {
console.log(`start compress!`); const buffer = await imagemin([file.path], {
const buffer = await imagemin([file.path], { plugins: [
plugins: [ imageminJpegtran(),
imageminJpegtran(), imageminPngquant({
imageminPngquant({ quality: [0.6, 0.8]
quality: [0.6, 0.8] })
}) ]
] })
});
console.log(`compress success!`); res.sendRaw(buffer[0].data, {
res.sendRaw(buffer[0].data, { 'Content-Type': file.type,
'Content-Type': file.type, })
}); } catch (e) {
console.log('send row success!'); logger.error('/tinify', 'compress failed', e.message)
}catch (e) {
logger.error('/tinify', 'compress failed', e.message);
res.send({
code: 3,
msg: 'compress failed'
});
}
}else{
logger.error('/tinify', 'type error');
res.send({ res.send({
code: 2, code: 3,
msg: 'type error' msg: 'compress failed'
}); })
} }
}else{ } else {
logger.error('/tinify', 'type error')
res.send({ res.send({
code: 1, code: 2,
msg: 'file not exists' msg: 'type error'
}); })
} }
} else {
res.send({
code: 1,
msg: 'file not exists'
})
}
return next()
}
async function tinify2(req, res, next) {
let file = req.files.file
return next(); if (file) {
}); if (acceptTypes.includes(file.type)) {
try {
const buffer = await compress(file.path, {returnType: 'buffer'})
res.sendRaw(buffer, {
'Content-Type': file.type,
})
} catch (e) {
logger.error('/tinify2', 'compress failed', e.message)
res.send({
code: 3,
msg: 'compress failed'
})
}
} else {
logger.error('/tinify2', 'type error')
res.send({
code: 2,
msg: 'type error'
})
}
} else {
res.send({
code: 1,
msg: 'file not exists'
})
}
return next()
} }
src/eureka.ts
View file @ d14f5027
import Eurekaclient from 'eureka-client-ts'; import Eurekaclient from 'eureka-client-ts'
import logger from './logger'; import logger from './logger'
const eurekaConfig:any = { const eurekaConfig:any = {
appName: 'duiba-tiny-image-node', appName: 'duiba-tiny-image-node',
services: ['duiba-tiny-image-node'], services: ['duiba-tiny-image-node'],
}; }
export async function getEurekaClient(port) { export async function getEurekaClient(port) {
eurekaConfig.port = port; eurekaConfig.port = port
let eureka; let eureka
try { try {
eureka = new Eurekaclient(eurekaConfig); eureka = new Eurekaclient(eurekaConfig)
await eureka.start(); await eureka.start()
} catch (e) { } catch (e) {
logger.error(e); logger.error(e)
} }
return eureka; return eureka
} }
src/index.ts
View file @ d14f5027
...@@ -2,53 +2,53 @@ ...@@ -2,53 +2,53 @@
* Created by rockyl on 2020-02-12. * Created by rockyl on 2020-02-12.
*/ */
const restify = require('restify'); const restify = require('restify')
import {getEurekaClient} from "./eureka"; import {getEurekaClient} from "./eureka"
import logger from "./logger"; import logger from "./logger"
import applyApi from "./api"; import applyApi from "./api"
let [_, __, portStr = '8090'] = process.argv; let [_, __, portStr = '8090'] = process.argv
let eureka; let eureka
let port = parseInt(portStr); let port = parseInt(portStr)
const server = restify.createServer({ const server = restify.createServer({
name: 'tiny-image', name: 'tiny-image',
version: '1.0.0' version: '1.0.0'
}); })
const ignoreUrlLogger = ['/monitor/check']; const ignoreUrlLogger = ['/monitor/check']
server.use(restify.plugins.acceptParser(server.acceptable)); server.use(restify.plugins.acceptParser(server.acceptable))
server.use(restify.plugins.queryParser()); server.use(restify.plugins.queryParser())
server.use(restify.plugins.bodyParser()); server.use(restify.plugins.bodyParser())
server.use(function (req, res, next) { server.use(function (req, res, next) {
if (!ignoreUrlLogger.includes(req.url as string)) { if (!ignoreUrlLogger.includes(req.url as string)) {
logger.info(req.url); logger.info(req.url)
} }
return next(); return next()
}); })
applyApi(server); applyApi(server)
process.on('uncaughtException', (err) => { process.on('uncaughtException', (err) => {
logger.error(err); logger.error(err)
}); })
process.on("SIGTERM", () => { process.on("SIGTERM", () => {
eureka.stop(); eureka.stop()
setTimeout(() => { setTimeout(() => {
process.exit(1) process.exit(1)
}, 6000); }, 6000)
}); })
server.listen(port, async function () { server.listen(port, async function () {
try { try {
eureka = await getEurekaClient(port); eureka = await getEurekaClient(port)
logger.info('eureka register success'); logger.info('eureka register success')
} catch (e) { } catch (e) {
logger.error(e.name); logger.error(e.name)
} }
logger.info('%s listening at %s', server.name, server.url); logger.info('%s listening at %s', server.name, server.url)
}); })
src/logger.ts
View file @ d14f5027
...@@ -2,13 +2,13 @@ ...@@ -2,13 +2,13 @@
* Created by rockyl on 2020-02-13. * Created by rockyl on 2020-02-13.
*/ */
import {configure, getLogger} from 'log4js'; import {configure, getLogger} from 'log4js'
const path = require("path"); const path = require("path")
const fs = require("fs-extra"); const fs = require("fs-extra")
const logPath = path.join(process.env.HOME || process.env.USERPROFILE as string, 'logs', 'tiny-image'); const logPath = path.join(process.env.HOME || process.env.USERPROFILE as string, 'logs', 'tiny-image')
fs.ensureDir(logPath); fs.ensureDir(logPath)
configure({ configure({
appenders: { appenders: {
...@@ -22,8 +22,8 @@ configure({ ...@@ -22,8 +22,8 @@ configure({
default: {appenders: ['out', 'allLog'], level: 'debug'}, default: {appenders: ['out', 'allLog'], level: 'debug'},
} }
}); })
const logger = getLogger(); const logger = getLogger()
export default logger; export default logger
yarn.lock
View file @ d14f5027
...@@ -1849,6 +1849,11 @@ nice-try@^1.0.4: ...@@ -1849,6 +1849,11 @@ nice-try@^1.0.4:
resolved "https://registry.yarnpkg.com/nice-try/-/nice-try-1.0.5.tgz#a3378a7696ce7d223e88fc9b764bd7ef1089e366" resolved "https://registry.yarnpkg.com/nice-try/-/nice-try-1.0.5.tgz#a3378a7696ce7d223e88fc9b764bd7ef1089e366"
integrity sha512-1nh45deeb5olNY7eX82BkPO7SSxR5SSYJiPTrTdFUVYwAl8CKMA5N9PjTYkHiRjisVcxcQ1HXdLhx2qxxJzLNQ== integrity sha512-1nh45deeb5olNY7eX82BkPO7SSxR5SSYJiPTrTdFUVYwAl8CKMA5N9PjTYkHiRjisVcxcQ1HXdLhx2qxxJzLNQ==
node-tinify@^1.0.4:
version "1.0.4"
resolved "http://npm.dui88.com:80/node-tinify/-/node-tinify-1.0.4.tgz#6f225449872a72ec49e3e1f24ec4abf212870135"
integrity sha1-byJUSYcqcuxJ4+HyTsSr8hKHATU=
normalize-package-data@^2.3.2, normalize-package-data@^2.3.4: normalize-package-data@^2.3.2, normalize-package-data@^2.3.4:
version "2.5.0" version "2.5.0"
resolved "https://registry.yarnpkg.com/normalize-package-data/-/normalize-package-data-2.5.0.tgz#e66db1838b200c1dfc233225d12cb36520e234a8" resolved "https://registry.yarnpkg.com/normalize-package-data/-/normalize-package-data-2.5.0.tgz#e66db1838b200c1dfc233225d12cb36520e234a8"
......
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