create-api-server.js 1.67 KB
const api = global.yoho.API;
const service = global.yoho.ServiceAPI;
const checkParams = require('../../utils/check-params');
const apiMaps = require('../../config/api-map');

const NOT_FOUND_API_MAP = {
  code: 400,
  message: '未找到对应的接口'
};
const checkApiMap = url => {
  return apiMaps[url] ? apiMaps[url] : void 0;
};
const request = async({url, method, reqParams, context}) => {
  const apiInfo = checkApiMap(url);
  const {env, user} = context;

  if (!apiInfo) {
    return Promise.reject(NOT_FOUND_API_MAP);
  }
  if (!apiInfo.service) {
    Object.assign(reqParams, {
      uid: (user && user.uid) ? {
        toString: () => {
          return user.uid;
        },
        sessionKey: user.sessionKey,
        appSessionType: user.appSessionType
      } : 1,
      method: apiInfo.api,
    });
  }

  const params = checkParams.getParams(reqParams, apiInfo);
  const cache = method.toLowerCase() !== 'get' ? false : apiInfo.cache;

  if (apiInfo.service) {
    return await service.get(apiInfo.api, params, {
      cache: cache,
      code: 200,
      headers: {
        'X-YOHO-IP': env.clientIp,
        'X-Forwarded-For': env.clientIp,
        'User-Agent': 'yoho/nodejs'
      }
    });
  } else {
    return await api[method]('', params, {
      code: 200,
      cache: cache,
      headers: {
        'X-YOHO-IP': env.clientIp,
        'X-Forwarded-For': env.clientIp,
        'User-Agent': 'yoho/nodejs'
      }
    });
  }
};

export const createApi = context => {
  return {
    get(url, reqParams) {
      return request({url, method: 'get', reqParams, context});
    },
    post(url, reqParams) {
      return request({url, method: 'post', reqParams, context});
    }
  };
};