增加对异步操作的支持

Author: kscript

README.md

@@ -1,5 +1,5 @@
 ## ks-mock
-一个模拟服务端api的工具, 支持 https、触发鉴权、模拟接口、模拟请求错误、转发请求 等功能
+一个模拟服务端api的工具, 支持 https、触发鉴权、模拟接口、模拟请求错误、转发请求, 异步操作 等功能
 
 ## npm命令
 ``` npm
@@ -59,8 +59,15 @@ new KsMock({
 module.exports = {
     login: {
         format: (method, params, result, { body }) => {
-            Object.assign(result.data, params);
-            return result
+          Object.assign(result.data, params);
+          // 同步
+          return result
+          // 异步
+          return new Promise((resolve, reject) => {
+            setTimeout(() => {
+              resolve(result)
+            }, 1e4)
+          })
         },
         post: {
           message: "登录成功!"

index.js

@@ -138,7 +138,6 @@ var Auth = /** @class */ (function () {
      * 退出登录
      */
     Auth.prototype.logout = function () {
-        console.log(server);
         user.clear();
         server.set('login', false);
     };
@@ -367,7 +366,22 @@ var Server$1 = function (option, callback) {
                     next();
                     return;
                 }
-                http.writeHead(200, headConfig);
+                if (result instanceof Promise) {
+                    try {
+                        result.then(function (data) {
+                            http.writeHead(200, headConfig);
+                            http.end(data);
+                        }).catch(function (e) {
+                            http.writeHead(500, headConfig);
+                            http.end(e);
+                        });
+                    }
+                    catch (e) { }
+                    return;
+                }
+                else {
+                    http.writeHead(200, headConfig);
+                }
             }
             else {
                 http.writeHead(405, headConfig);

package.json

@@ -1,13 +1,14 @@
 {
   "name": "ks-mock",
-  "version": "1.2.1",
+  "version": "1.2.2",
   "description": "mock server 模拟后端API接口",
   "main": "index.js",
   "scripts": {
     "mock": "node ./public/server.js",
-    "prepublishOnly": "npm run build",
+    "prepublishOnly": "npm run mockData && npm run build",
     "build": "rollup -c -i ./src/index.ts -o index.js",
     "typedoc": "typedoc --options typedoc.ts",
+    "mockData": "tsc src/datas.ts --outdir public",
     "test": "jest"
   },
   "repository": {

public/config.js

@@ -0,0 +1,87 @@
+"use strict";
+var __extends = (this && this.__extends) || (function () {
+    var extendStatics = function (d, b) {
+        extendStatics = Object.setPrototypeOf ||
+            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
+            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
+        return extendStatics(d, b);
+    };
+    return function (d, b) {
+        extendStatics(d, b);
+        function __() { this.constructor = d; }
+        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
+    };
+})();
+exports.__esModule = true;
+var Base = /** @class */ (function () {
+    function Base() {
+        this.data = {};
+    }
+    Base.prototype.get = function (key) {
+        return key ? this.data[key] : this.data;
+    };
+    Base.prototype.set = function (key, val) {
+        this.data[key] = val;
+        return this;
+    };
+    Base.prototype.reset = function (obj) {
+        this.clear();
+        Object.assign(this.data, obj);
+        return this;
+    };
+    Base.prototype.clear = function () {
+        for (var key in this.data) {
+            delete this.data[key];
+        }
+        return this;
+    };
+    return Base;
+}());
+var Server = /** @class */ (function (_super) {
+    __extends(Server, _super);
+    function Server() {
+        var _this = _super !== null && _super.apply(this, arguments) || this;
+        _this.data = {
+            login: false
+        };
+        return _this;
+    }
+    return Server;
+}(Base));
+var User = /** @class */ (function (_super) {
+    __extends(User, _super);
+    function User() {
+        var _this = _super !== null && _super.apply(this, arguments) || this;
+        _this.data = {};
+        return _this;
+    }
+    return User;
+}(Base));
+var Config = /** @class */ (function (_super) {
+    __extends(Config, _super);
+    function Config() {
+        var _this = _super !== null && _super.apply(this, arguments) || this;
+        _this.data = {
+            username: 'admin',
+            password: '123456',
+            retryUrl: 'http://localhost:3030/info'
+        };
+        return _this;
+    }
+    return Config;
+}(Base));
+exports.server = new Server;
+exports.user = new User;
+exports.config = new Config;
+exports.crossDomain = {
+    'Access-Control-Allow-Origin': '*',
+    'Access-Control-Allow-Methods': '*',
+    'Access-Control-Allow-Headers': '*',
+    'Access-Control-Allow-Credentials': true
+};
+exports["default"] = {
+    user: exports.user,
+    server: exports.server,
+    config: exports.config,
+    crossDomain: exports.crossDomain
+};

public/datas.js

@@ -1,11 +1,9 @@
 "use strict";
 exports.__esModule = true;
-var config = {
-    username: 'admin',
-    password: '123456',
-    retryUrl: '/info'
-};
-var defaultConfig = Object.assign({}, config);
+/// <reference path="../types/datas.d.ts" />
+var config_1 = require("./config");
+var defaultConfig = Object.assign({}, config_1.config.data);
+var config = defaultConfig;
 exports.login = {
     // 转发
     relay: '',
@@ -59,8 +57,13 @@ exports.info = {
     },
     format: function (method, params, result) {
         result.message = 'hello ' + (params.username || 'world');
+        return new Promise(function (resolve, reject) {
+            setTimeout(function () {
+                reject(result);
+            }, 1e4);
+        });
         // 不返回, 那么修改无效
-        return result;
+        // return result
     },
     get: {
         code: 200,

src/datas.ts

@@ -1,4 +1,5 @@
 
+/// <reference path="../types/datas.d.ts" />
 import { config as _config } from './config';
 const defaultConfig = Object.assign({}, _config.data);
 const config = defaultConfig;
@@ -53,8 +54,13 @@ export const info: api = {
     },
     format(method, params, result) {
         result.message = 'hello ' + (params.username || 'world')
+        return new Promise((resolve, reject) => {
+            setTimeout(() => {
+                reject(result);
+            }, 1e4);
+        })
         // 不返回, 那么修改无效
-        return result
+        // return result
     },
     get: {
         code: 200,

src/server.ts

@@ -190,7 +190,20 @@ const Server = (option: anyObject, callback?: Function) => {
                     next()
                     return
                 }
-                http.writeHead(200, headConfig)
+                if (result instanceof Promise) {
+                    try {
+                        result.then((data) => {
+                            http.writeHead(200, headConfig)
+                            http.end(data)
+                        }).catch((e) => {
+                            http.writeHead(500, headConfig)
+                            http.end(e)
+                        })
+                    } catch(e) {}
+                    return
+                } else {
+                    http.writeHead(200, headConfig)
+                }
             } else {
                 http.writeHead(405, headConfig)
                 result = {
@@ -216,7 +229,6 @@ const Server = (option: anyObject, callback?: Function) => {
             urlKey,
             params,
         } = getInfo(req, option, config.crossDomain)
-
         mockData = mockData || {}
         let body = {
             code: 201,