request.js 4.58 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 68
export default function request(url, options = {}) {
  console.log(url);
  /**
   * Produce fingerprints based on url and parameters
   * Maybe url has the same parameters
   */
69
  const fingerprint = url + (options.body ? JSON.stringify(options.body) : '');
70 71 72 73 74
  const hashcode = hash
    .sha256()
    .update(fingerprint)
    .digest('hex');

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