add: npm part

Author: backrunner

Diff for: README.md

@@ -30,6 +30,24 @@
 
 参数二选一，GET方法只支持提交图片的URL。
 
+## npm
+
+提供查询npm包信息和下载量的服务。
+
+### API
+
+/npm/registry
+
+支持方法：GET
+
+提交参数：package:string
+
+/npm/downloads
+
+支持方法：GET
+
+提交参数：start:string(YYYY-MM-DD), end:string(YYYY-MM-DD), package:string
+
 ## 部署说明
 
 参考egg.js服务器通用的部署方法，在克隆本仓库代码后，使用npm install安装依赖，并安装egg-scripts，即可使用npm run start启动服务器。
@@ -46,4 +64,4 @@
 
 cookie: 用于加密Cookie的密钥
 
-redis：redis访问密钥，请确保你的redis是有访问密码的。
+redis：redis访问密钥，请确保你的redis是有访问密码的。

Diff for: app/controller/v1/npm.js

@@ -0,0 +1,29 @@
+'use strict';
+
+const Controller = require('egg').Controller;
+const R = require('../../utils/common/response');
+
+class NpmController extends Controller {
+    async registry() {
+        const { ctx } = this;
+        ctx.validate({ package: 'string' }, ctx.query);
+        const res = await this.service.npm.getRegistry(ctx.query.package);
+        if (res) {
+            R.success(ctx, res, null);
+            return;
+        }
+        R.error(ctx, 500, '无法获取数据');
+    }
+    async downloads() {
+        const { ctx } = this;
+        ctx.validate({ package: 'string', start: 'date', end: 'date' }, ctx.query);
+        const res = await this.service.npm.getDownloads(ctx.query.start, ctx.query.end, ctx.query.package);
+        if (res) {
+            R.success(ctx, res, null);
+            return;
+        }
+        R.error(ctx, 500, '无法获取数据');
+    }
+}
+
+module.exports = NpmController;

Diff for: app/service/npm.js

@@ -0,0 +1,44 @@
+'use strict';
+
+const Service = require('egg').Service;
+const axios = require('../utils/common/axios');
+
+const REGISTRY_URL = 'https://registry.npmjs.org';
+const API_URL = 'https://api.npmjs.org';
+
+class NpmService extends Service {
+    async getRegistry(name) {
+        const cached = this.service.redis.get(`npm_registry_${name}`);
+        if (cached) {
+            return cached;
+        }
+        try {
+            const res = await axios.get(`${REGISTRY_URL}/${name}`);
+            if (res.data) {
+                this.service.redis.set(`npm_registry_${name}`, res.data, 1800);
+                return res.data;
+            }
+            return null;
+        } catch (err) {
+            throw err.message;
+        }
+    }
+    async getDownloads(start, end, name) {
+        const cached = this.service.redis.get(`npm_downloads_${start}_${end}_${name}`);
+        if (cached) {
+            return cached;
+        }
+        try {
+            const res = await axios.get(`${API_URL}/downloads/point/${start}:${end}/${name}`);
+            if (res.data) {
+                this.service.redis.set(`npm_downloads_${start}_${end}_${name}`, res.data, 1800);
+                return res.data;
+            }
+            return null;
+        } catch (err) {
+            throw err.message;
+        }
+    }
+}
+
+module.exports = NpmService;

Diff for: app/utils/common/axios.js

@@ -0,0 +1,17 @@
+'use strict';
+
+const axios = require('axios');
+const qs = require('qs');
+
+axios.defaults.timeout = 5000;
+axios.defaults.headers.post['Content-Type'] = 'application/x-www-form-urlencoded';
+axios.defaults.headers.get['Content-Type'] = 'application/x-www-form-urlencoded';
+axios.defaults.transformRequest = [
+    function(data) {
+        return qs.stringify(data, {
+            arrayFormat: 'brackets',
+        });
+    },
+];
+
+module.exports = axios;

Diff for: app/utils/common/error_response.js

@@ -0,0 +1,21 @@
+'use strict';
+
+module.exports = {
+    success(ctx, data, message) {
+        ctx.status = 200;
+        ctx.body = {
+            code: 200,
+            status: 'success',
+            message,
+            data,
+        };
+    },
+    error(ctx, code, message) {
+        ctx.status = 200;
+        ctx.body = {
+            code,
+            status: 'error',
+            message,
+        };
+    },
+};

Diff for: app/utils/common/response.js

@@ -26,10 +26,10 @@ module.exports = () => {
         csrf: {
             enable: false,
         },
+        domainWhiteList: ['http://localhost:8080', 'http://packages.pwp.app'],
     };
 
     config.cors = {
-        origin: '*',
         allowMethods: 'GET,POST',
     };
 

Diff for: config/config.default.js

@@ -1,12 +1,13 @@
 {
   "name": "tools-server",
-  "version": "1.0.1",
+  "version": "1.1.0",
   "description": "",
   "private": true,
   "egg": {
     "declarations": true
   },
   "dependencies": {
+    "axios": "^0.19.2",
     "egg": "^2.26.1",
     "egg-cors": "^2.2.3",
     "egg-onerror": "^2.1.0",
@@ -16,7 +17,8 @@
     "egg-validate": "^2.0.2",
     "jimp": "^0.10.1",
     "jsqr": "^1.3.1",
-    "qrcode": "^1.4.4"
+    "qrcode": "^1.4.4",
+    "qs": "^6.9.4"
   },
   "devDependencies": {
     "autod": "^3.0.1",