import {
  GET_STATUS,
  USER_LOADED,
  USER_LOADING,
  AUTH_ERROR,
  LOGIN_SUCCESS,
  LOGIN_FAIL,
  LOGOUT_SUCCESS,
  LOGOUT_FAIL,
  REFRESH_TOKEN_SUCCESS,
} from "../actions/types";

import axios from "axios";
import { returnErrors, returnSuccess } from "./messageActions";
import { setLanguage } from "./generalActions";

// Check token & load user
export const loadUser = () => (dispatch) => {
  // user loading
  dispatch({
    type: USER_LOADING,
  });
  const config = {
    success: (res) => {
      dispatch({
        type: GET_STATUS,
        payload: res.data.user.status,
      });
      dispatch(setLanguage(res.data.user.language));
      dispatch({
        type: USER_LOADED,
        payload: res.data.user,
      });
    },
    error: (err) => {
      if (err.response) {
        dispatch(returnErrors(err.response.data.message, err.response.status));
      }
      var status = [];
      if (window.localStorage.getItem("status")) {
        status = JSON.parse(window.localStorage.getItem("status"));
      }
      dispatch({
        type: GET_STATUS,
        payload: status,
      });
      dispatch({
        type: AUTH_ERROR,
      });
    },
  };
  axios
    .get(
      `${process.env.REACT_APP_BLOCKLY_API}/user`,
      config,
      dispatch(authInterceptor())
    )
    .then((res) => {
      res.config.success(res);
    })
    .catch((err) => {
      err.config.error(err);
    });
};

// Login user
export const login =
  ({ email, password }) =>
    (dispatch) => {
      dispatch({
        type: USER_LOADING,
      });
      // Headers
      const config = {
        headers: {
          "Content-Type": "application/json",
        },
      };
      // Request Body
      const body = JSON.stringify({ email, password });
      axios
        .post(`${process.env.REACT_APP_BLOCKLY_API}/user`, body, config)
        .then((res) => {
          dispatch(setLanguage(res.data.user.language));
          dispatch({
            type: LOGIN_SUCCESS,
            payload: res.data,
          });
          dispatch({
            type: GET_STATUS,
            payload: res.data.user.status,
          });
          dispatch(returnSuccess(res.data.message, res.status, "LOGIN_SUCCESS"));
        })
        .catch((err) => {
          dispatch(
            returnErrors(
              err.response.data.message,
              err.response.status,
              "LOGIN_FAIL"
            )
          );
          dispatch({
            type: LOGIN_FAIL,
          });
          var status = [];
          if (window.localStorage.getItem("status")) {
            status = JSON.parse(window.localStorage.getItem("status"));
          }
          dispatch({
            type: GET_STATUS,
            payload: status,
          });
        });
    };

// Logout User
export const logout = () => (dispatch) => {
  const config = {
    success: (res) => {
      dispatch({
        type: LOGOUT_SUCCESS,
      });
      var status = [];
      if (window.localStorage.getItem("status")) {
        status = JSON.parse(window.localStorage.getItem("status"));
      }
      dispatch({
        type: GET_STATUS,
        payload: status,
      });
      var locale = "en_US";
      if (window.localStorage.getItem("locale")) {
        locale = window.localStorage.getItem("locale");
      } else if (navigator.language === "de-DE") {
        locale = "de_DE";
      }
      dispatch(setLanguage(locale));
      dispatch(returnSuccess(res.data.message, res.status, "LOGOUT_SUCCESS"));
    },
    error: (err) => {
      dispatch(
        returnErrors(
          err.response.data.message,
          err.response.status,
          "LOGOUT_FAIL"
        )
      );
      dispatch({
        type: LOGOUT_FAIL,
      });
      var status = [];
      if (window.localStorage.getItem("status")) {
        status = JSON.parse(window.localStorage.getItem("status"));
      }
      dispatch({
        type: GET_STATUS,
        payload: status,
      });
    },
  };
  axios
    .post("https://api.opensensemap.org/users/sign-out", {}, config)
    .then((res) => {
      res.config.success(res);
    })
    .catch((err) => {
      if (err.response && err.response.status !== 401) {
        err.config.error(err);
      }
    });
};

export const authInterceptor = () => (dispatch, getState) => {
  // Add a request interceptor
  axios.interceptors.request.use(
    (config) => {
      config.headers["Content-Type"] = "application/json";
      const token = getState().auth.token;
      if (token) {
        config.headers["Authorization"] = `Bearer ${token}`;
      }
      return config;
    },
    (error) => {
      Promise.reject(error);
    }
  );

  // Add a response interceptor
  axios.interceptors.response.use(
    (response) => {
      // request was successfull
      return response;
    },
    (error) => {
      const originalRequest = error.config;
      const refreshToken = getState().auth.refreshToken;
      if (refreshToken) {
        // try to refresh the token failed
        if (error.response.status === 401 && originalRequest._retry) {
          // router.push('/login');
          return Promise.reject(error);
        }
        // token was not valid and 1st try to refresh the token
        if (error.response.status === 401 && !originalRequest._retry) {
          originalRequest._retry = true;
          const refreshToken = getState().auth.refreshToken;
          // request to refresh the token, in request-body is the refreshToken
          axios
            .post("https://api.opensensemap.org/users/refresh-auth", {
              token: refreshToken,
            })
            .then((res) => {
              if (res.status === 200) {
                dispatch({
                  type: REFRESH_TOKEN_SUCCESS,
                  payload: res.data,
                });
                axios.defaults.headers.common["Authorization"] =
                  "Bearer " + getState().auth.token;
                // request was successfull, new request with the old parameters and the refreshed token
                return axios(originalRequest)
                  .then((res) => {
                    originalRequest.success(res);
                  })
                  .catch((err) => {
                    originalRequest.error(err);
                  });
              }
              return Promise.reject(error);
            })
            .catch((err) => {
              // request failed, token could not be refreshed
              if (err.response) {
                dispatch(
                  returnErrors(err.response.data.message, err.response.status)
                );
              }
              dispatch({
                type: AUTH_ERROR,
              });
              return Promise.reject(error);
            });
        }
      }
      // request status was unequal to 401, no possibility to refresh the token
      return Promise.reject(error);
    }
  );
};