request.js 4.65 KB
Newer Older
1
import fetch from 'dva/fetch';
2
import { notification } from 'antd';
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
3
import router from 'umi/router';
4
import hash from 'hash.js';
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
5
const codeMessage = {
6
  200: 'ๆœๅŠกๅ™จๆˆๅŠŸ่ฟ”ๅ›ž่ฏทๆฑ‚็š„ๆ•ฐๆฎใ€‚',
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
7
  201: 'ๆ–ฐๅปบๆˆ–ไฟฎๆ”นๆ•ฐๆฎๆˆๅŠŸใ€‚',
8
  202: 'ไธ€ไธช่ฏทๆฑ‚ๅทฒ็ป่ฟ›ๅ…ฅๅŽๅฐๆŽ’้˜Ÿ๏ผˆๅผ‚ๆญฅไปปๅŠก๏ผ‰ใ€‚',
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
9
  204: 'ๅˆ ้™คๆ•ฐๆฎๆˆๅŠŸใ€‚',
10
  400: 'ๅ‘ๅ‡บ็š„่ฏทๆฑ‚ๆœ‰้”™่ฏฏ๏ผŒๆœๅŠกๅ™จๆฒกๆœ‰่ฟ›่กŒๆ–ฐๅปบๆˆ–ไฟฎๆ”นๆ•ฐๆฎ็š„ๆ“ไฝœใ€‚',
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
11 12
  401: '็”จๆˆทๆฒกๆœ‰ๆƒ้™๏ผˆไปค็‰Œใ€็”จๆˆทๅใ€ๅฏ†็ ้”™่ฏฏ๏ผ‰ใ€‚',
  403: '็”จๆˆทๅพ—ๅˆฐๆŽˆๆƒ๏ผŒไฝ†ๆ˜ฏ่ฎฟ้—ฎๆ˜ฏ่ขซ็ฆๆญข็š„ใ€‚',
13
  404: 'ๅ‘ๅ‡บ็š„่ฏทๆฑ‚้’ˆๅฏน็š„ๆ˜ฏไธๅญ˜ๅœจ็š„่ฎฐๅฝ•๏ผŒๆœๅŠกๅ™จๆฒกๆœ‰่ฟ›่กŒๆ“ไฝœใ€‚',
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
14 15 16
  406: '่ฏทๆฑ‚็š„ๆ ผๅผไธๅฏๅพ—ใ€‚',
  410: '่ฏทๆฑ‚็š„่ต„ๆบ่ขซๆฐธไน…ๅˆ ้™ค๏ผŒไธ”ไธไผšๅ†ๅพ—ๅˆฐ็š„ใ€‚',
  422: 'ๅฝ“ๅˆ›ๅปบไธ€ไธชๅฏน่ฑกๆ—ถ๏ผŒๅ‘็”Ÿไธ€ไธช้ชŒ่ฏ้”™่ฏฏใ€‚',
17 18 19 20
  500: 'ๆœๅŠกๅ™จๅ‘็”Ÿ้”™่ฏฏ๏ผŒ่ฏทๆฃ€ๆŸฅๆœๅŠกๅ™จใ€‚',
  502: '็ฝ‘ๅ…ณ้”™่ฏฏใ€‚',
  503: 'ๆœๅŠกไธๅฏ็”จ๏ผŒๆœๅŠกๅ™จๆš‚ๆ—ถ่ฟ‡่ฝฝๆˆ–็ปดๆŠคใ€‚',
  504: '็ฝ‘ๅ…ณ่ถ…ๆ—ถใ€‚',
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
21
};
22
const checkStatus = response => {
23 24 25
  if (response.status >= 200 && response.status < 300) {
    return response;
  }
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
26
  const errortext = codeMessage[response.status] || response.statusText;
afc163's avatar
afc163 committed
27 28
  notification.error({
    message: `่ฏทๆฑ‚้”™่ฏฏ ${response.status}: ${response.url}`,
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
29
    description: errortext,
afc163's avatar
afc163 committed
30
  });
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
31
  const error = new Error(errortext);
32
  error.name = response.status;
afc163's avatar
afc163 committed
33 34
  error.response = response;
  throw error;
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54
};

const cachedSave = (response, hashcode) => {
  /**
   * Clone a response data and store it in sessionStorage
   * Does not support data other than json, Cache only json
   */
  let contentType = response.headers.get('Content-Type');
  if (contentType && contentType.match(/application\/json/i)) {
    // All data is saved as text
    response
      .clone()
      .text()
      .then(content => {
        sessionStorage.setItem(hashcode, content);
        sessionStorage.setItem(hashcode + ':timestamp', Date.now());
      });
  }
  return response;
};
55 56 57 58 59 60 61 62

/**
 * Requests a URL, returning a promise.
 *
 * @param  {string} url       The URL we want to request
 * @param  {object} [options] The options we want to pass to "fetch"
 * @return {object}           An object containing either "data" or "err"
 */
63 64 65 66 67
export default function request(url, options = {}) {
  /**
   * Produce fingerprints based on url and parameters
   * Maybe url has the same parameters
   */
68
  const fingerprint = url + (options.body ? JSON.stringify(options.body) : '');
69 70 71 72 73
  const hashcode = hash
    .sha256()
    .update(fingerprint)
    .digest('hex');

74 75 76 77
  const defaultOptions = {
    credentials: 'include',
  };
  const newOptions = { ...defaultOptions, ...options };
78 79 80 81 82
  if (
    newOptions.method === 'POST' ||
    newOptions.method === 'PUT' ||
    newOptions.method === 'DELETE'
  ) {
83 84 85 86 87 88 89 90 91 92 93 94 95 96
    if (!(newOptions.body instanceof FormData)) {
      newOptions.headers = {
        Accept: 'application/json',
        'Content-Type': 'application/json; charset=utf-8',
        ...newOptions.headers,
      };
      newOptions.body = JSON.stringify(newOptions.body);
    } else {
      // newOptions.body is FormData
      newOptions.headers = {
        Accept: 'application/json',
        ...newOptions.headers,
      };
    }
97
  }
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
98

99
  const expirys = options.expirys || 60;
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
100 101 102 103 104 105 106 107 108 109 110 111 112
  // options.expirys !== false, return the cache,
  if (options.expirys !== false) {
    let cached = sessionStorage.getItem(hashcode);
    let whenCached = sessionStorage.getItem(hashcode + ':timestamp');
    if (cached !== null && whenCached !== null) {
      let age = (Date.now() - whenCached) / 1000;
      if (age < expirys) {
        let response = new Response(new Blob([cached]));
        return response.json();
      } else {
        sessionStorage.removeItem(hashcode);
        sessionStorage.removeItem(hashcode + ':timestamp');
      }
113 114
    }
  }
115 116
  return fetch(url, newOptions)
    .then(checkStatus)
117
    .then(cachedSave)
118 119 120
    .then(response => {
      // DELETE and 204 do not return data by default
      // using .json will report an error.
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
121 122
      if (newOptions.method === 'DELETE' || response.status === 204) {
        return response.text();
afc163's avatar
afc163 committed
123
      }
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
124
      return response.json();
125
    })
jim's avatar
jim committed
126
    .catch(e => {
127 128
      const status = e.name;
      if (status === 401) {
129
        // @HACK
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
130 131
        /* eslint-disable no-underscore-dangle */
        window.g_app._store.dispatch({
132 133 134 135
          type: 'login/logout',
        });
        return;
      }
136
      // environment should not be used
137
      if (status === 403) {
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
138
        router.push('/exception/403');
139 140
        return;
      }
141
      if (status <= 504 && status >= 500) {
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
142
        router.push('/exception/500');
143 144
        return;
      }
145
      if (status >= 404 && status < 422) {
้™ˆๅธ…'s avatar
้™ˆๅธ… committed
146
        router.push('/exception/404');
147
      }
afc163's avatar
afc163 committed
148
    });
149
}