taihu/app/containers/App/sagas.ts

/*
 * <<
 * Davinci
 * ==
 * Copyright (C) 2016 - 2017 EDP
 * ==
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * >>
 */

import {
  call,
  put,
  all,
  takeLatest,
  throttle,
  takeEvery
} from 'redux-saga/effects'
import { message } from 'antd'
import {
  LOGIN,
  LOGOUT,
  CHECK_NAME,
  ACTIVE,
  GET_SERVER_CONFIGURATIONS,
  UPDATE_PROFILE,
  CHANGE_USER_PASSWORD,
  JOIN_ORGANIZATION,
  LOAD_DOWNLOAD_LIST,
  DOWNLOAD_FILE,
  GET_EXTERNAL_AUTH_PROVIDERS,
  TRY_EXTERNAL_AUTH,
  GET_CAPTCHA_FOR_RESET_PASSWORD,
  RESET_PASSWORD_UNLOGGED,
  GET_USER_BY_TOKEN
} from './constants'
import {
  loginError,
  activeSuccess,
  activeError,
  joinOrganizationSuccess,
  joinOrganizationError,
  updateProfileSuccess,
  updateProfileError,
  userPasswordChanged,
  changeUserPasswordFail,
  downloadListLoaded,
  loadDownloadListFail,
  fileDownloaded,
  downloadFileFail,
  gotExternalAuthProviders,
  getCaptchaforResetPasswordSuccess,
  getCaptchaforResetPasswordError,
  resetPasswordUnloggedSuccess,
  resetPasswordUnloggedFail,
  serverConfigurationsGetted,
  getServerConfigurationsFail,
  getUserByTokenFail,
  getUserByTokenSuccess
} from './actions'
import request, {
  removeToken,
  getToken,
  setTokenExpired,
  IDavinciResponse
} from 'utils/request'
import { errorHandler } from 'utils/util'
import api from 'utils/api'

import { IReduxActionStruct } from 'utils/types'
import {
  IResetPasswordParams,
  IGetgetCaptchaParams
} from '../FindPassword/types'
import { IServerConfigurations } from './types'

export function* getExternalAuthProviders() {
  try {
    const asyncData = yield call(request, {
      method: 'get',
      url: api.externalAuthProviders
    })
    const providers = asyncData.payload
    yield put(gotExternalAuthProviders(providers))
    return providers
  } catch (err) {
    errorHandler(err)
  }
}

export function* getServerConfigurations(action) {
  try {
    const result: IDavinciResponse<IServerConfigurations> = yield call(
      request,
      {
        method: 'get',
        url: api.configurations
      }
    )
    const configurations = result.payload
    setTokenExpired(configurations.jwtToken.timeout)
    yield put(serverConfigurationsGetted(configurations))
  } catch (err) {
    yield put(getServerConfigurationsFail(err))
    errorHandler(err)
  }
}

export function* tryExternalAuth(action) {
  const { resolve } = action.payload
  try {
    const asyncData = yield call(request, {
      method: 'post',
      url: api.tryExternalAuth
    })
    const loginUser = asyncData.payload
    localStorage.setItem('loginUser', JSON.stringify(loginUser))
    resolve()
  } catch (err) {
    console.error(err)
  }
}

export function* login(action) {
  const { username, password, resolve } = action.payload

  try {
    const asyncData = yield call(request, {
      method: 'post',
      url: api.login,
      data: {
        username,
        password
      }
    })

    const loginUser = asyncData.payload
    localStorage.setItem('loginUser', JSON.stringify(loginUser))
    resolve()
  } catch (err) {
    yield put(loginError())
    errorHandler(err)
  }
}

export function* logout() {
  try {
    removeToken()
    localStorage.removeItem('loginUser')
  } catch (err) {
    errorHandler(err)
  }
}

export function* activeUser(action) {
  const { token, resolve } = action.payload
  try {
    const asyncData = yield call(request, {
      method: 'post',
      url: `${api.signup}/active/${token}`
    })
    switch (asyncData.header.code) {
      case 200:
        const loginUser = asyncData.payload
        yield put(activeSuccess(loginUser))
        localStorage.setItem('loginUser', JSON.stringify(loginUser))
        resolve()
        return loginUser
      case 302:
        message.error(asyncData.header.msg)
        setTimeout(() => location.replace('/'), 500)
        return
      default:
        yield put(activeError())
        message.error(asyncData.header.msg)
        return null
    }
  } catch (err) {
    yield put(activeError())
    errorHandler(err)
  }
}

export function* checkName(action) {
  const { id, name, type, params, resolve, reject } = action.payload
  try {
    const asyncData = yield call(request, `${api.checkName}/${type}`, {
      method: 'get',
      params: {
        ...params,
        id,
        name
      }
    })
    const msg =
      asyncData && asyncData.header && asyncData.header.msg
        ? asyncData.header.msg
        : ''
    const code =
      asyncData && asyncData.header && asyncData.header.code
        ? asyncData.header.code
        : ''
    resolve(msg)
  } catch (err) {
    errorHandler(err)
  }
}

export function* checkNameUnique(action) {
  const { pathname, data, resolve, reject } = action.payload
  try {
    if (!data.name) {
      return
    }
    const asyncData = yield call(request, {
      method: 'get',
      url: `${api.checkNameUnique}/${pathname}`,
      params: data
    })
    const msg =
      asyncData && asyncData.header && asyncData.header.msg
        ? asyncData.header.msg
        : ''
    const code =
      asyncData && asyncData.header && asyncData.header.code
        ? asyncData.header.code
        : ''
    resolve(msg)
  } catch (err) {
    errorHandler(err)
  }
}

export function* updateProfile(action) {
  const { id, name, description, department, resolve } = action.payload

  try {
    const asyncData = yield call(request, {
      method: 'put',
      url: `${api.signup}/${id}`,
      data: {
        name,
        description,
        department
      }
    })
    const updateUserProfile = { id, name, department, description }
    yield put(updateProfileSuccess(updateUserProfile))
    const prevLoginUser = JSON.parse(localStorage.getItem('loginUser'))
    localStorage.setItem(
      'loginUser',
      JSON.stringify({ ...prevLoginUser, ...updateUserProfile })
    )
    resolve(asyncData)
  } catch (err) {
    yield put(updateProfileError())
    errorHandler(err)
  }
}

export function* getCaptchaForResetPassword(
  action: IReduxActionStruct<IGetgetCaptchaParams>
) {
  const { type, ticket, resolve } = action.payload

  try {
    const httpResponse = yield call(request, {
      method: 'post',
      url: `${api.user}/forget/password/${type}`,
      data: {
        ticket
      }
    })

    const { payload } = httpResponse
    yield put(getCaptchaforResetPasswordSuccess(payload))
    resolve(payload)
  } catch (err) {
    yield put(getCaptchaforResetPasswordError(err))
    errorHandler(err)
  }
}

export function* resetPasswordUnlogged(
  action: IReduxActionStruct<IResetPasswordParams>
) {
  const { ticket, type, token, resolve, checkCode, password } = action.payload

  try {
    const httpResponse = yield call(request, {
      method: 'post',
      url: `${api.user}/reset/password/${type}/${token}`,
      data: {
        ticket,
        checkCode,
        password
      }
    })
    const { header } = httpResponse
    yield put(resetPasswordUnloggedSuccess(header))
    resolve(header)
  } catch (err) {
    yield put(resetPasswordUnloggedFail(err))
    errorHandler(err)
  }
}

export function* changeUserPassword({ payload }) {
  const { user } = payload
  try {
    const result = yield call(request, {
      method: 'put',
      url: `${api.user}/${user.id}/changepassword`,
      data: user
    })
    yield put(userPasswordChanged(payload.info))
    payload.resolve()
  } catch (err) {
    yield put(changeUserPasswordFail())
    errorHandler(err)
  }
}

export function* joinOrganization(action) {
  const { token, resolve, reject } = action.payload
  try {
    const asyncData = yield call(request, {
      method: 'post',
      url: `${api.organizations}/confirminvite/${token}`
    })
    switch (asyncData.header.code) {
      case 200:
        const detail = asyncData.payload
        yield put(joinOrganizationSuccess(detail))
        if (resolve) {
          resolve(detail)
        }
        return token
      default:
        yield put(joinOrganizationError())
        message.error(asyncData.header.msg)
        return null
    }
  } catch (error) {
    if (reject) {
      reject(error)
    }
    if (error.response) {
      switch (error.response.status) {
        case 403:
          removeToken()
          break
        case 400:
          message.error(error.response.data.header.msg, 3)
          break
        default:
          break
      }
    }
  }
}

export function* getDownloadList() {
  try {
    const result = yield call(request, `${api.download}/page`)
    yield put(downloadListLoaded(result.payload))
  } catch (err) {
    yield put(loadDownloadListFail(err))
    errorHandler(err)
  }
}

export function* downloadFile(action) {
  const { id } = action.payload
  try {
    location.href = `${api.download}/record/file/${id}/${getToken()}`
    yield put(fileDownloaded(id))
  } catch (err) {
    yield put(downloadFileFail(err))
    errorHandler(err)
  }
}

export function* getUserByToken(action) {
  const { token } = action.payload
  try {
    const result = yield call(request, `${api.user}/check/${token}`)
    const loginUser = result.payload
    yield put(getUserByTokenSuccess(loginUser))
    localStorage.setItem('loginUser', JSON.stringify(loginUser))
  } catch (err) {
    yield put(getUserByTokenFail(err))
    errorHandler(err)
  }
}

export default function* rootGroupSaga() {
  yield all([
    throttle(1000, CHECK_NAME, checkNameUnique),
    takeEvery(ACTIVE, activeUser),
    takeLatest(GET_EXTERNAL_AUTH_PROVIDERS, getExternalAuthProviders),
    takeEvery(TRY_EXTERNAL_AUTH, tryExternalAuth),
    takeEvery(LOGIN, login),
    takeEvery(LOGOUT, logout),
    takeEvery(UPDATE_PROFILE, updateProfile),
    takeEvery(CHANGE_USER_PASSWORD, changeUserPassword as any),
    takeEvery(
      GET_CAPTCHA_FOR_RESET_PASSWORD,
      getCaptchaForResetPassword as any
    ),
    takeEvery(RESET_PASSWORD_UNLOGGED, resetPasswordUnlogged  as any),
    takeEvery(GET_USER_BY_TOKEN, getUserByToken),
    takeEvery(JOIN_ORGANIZATION, joinOrganization),
    takeLatest(LOAD_DOWNLOAD_LIST, getDownloadList),
    takeLatest(DOWNLOAD_FILE, downloadFile),
    takeLatest(GET_SERVER_CONFIGURATIONS, getServerConfigurations)
  ])
}