import axios from "axios";
import { getItem, setItem } from "@/ui/util/storageHelper";
import Config from "@/config";
import FavItem from "@/wfc/model/favItem";
import { stringValue } from "@/wfc/util/longUtil";
import AppServerError from "./appServerError";
import wfc from "@/wfc/client/wfc";

export class AppServerApi {
  constructor() {}

  requestAuthCode(mobile) {
    return this._post("/send_code", { mobile });
  }

  loinWithPassword(mobile, password) {
    return new Promise((resolve, reject) => {
      let responsePromise = this._post(
        "/login_pwd",
        {
          mobile,
          password,
          platform: Config.getWFCPlatform(),
          clientId: wfc.getClientId(),
        },
        true
      );
      this._interceptLoginResponse(responsePromise, resolve, reject);
    });
  }

  loginWithAuthCode(mobile, authCode) {
    return new Promise((resolve, reject) => {
      let responsePromise = this._post(
        "/login",
        {
          mobile,
          code: authCode,
          platform: Config.getWFCPlatform(),
          clientId: wfc.getClientId(),
        },
        true
      );
      this._interceptLoginResponse(responsePromise, resolve, reject);
    });
  }

  loginWithCurrent(params) {
    return new Promise((resolve, reject) => {
      let responsePromise = this._postB(
        "/identify/api/yehuo/get/token",
        {
          platform: Config.getWFCPlatform(),
          clientId: wfc.getClientId(),
          ...params,
        },
        true
      );
      this._interceptLoginResponse(responsePromise, resolve, reject);
    });
  }

  createPCSession(userId) {
    return this._post("/pc_session", {
      flag: 1,
      device_name: "pc",
      userId: userId,
      clientId: wfc.getClientId(),
      platform: Config.getWFCPlatform(),
    });
  }

  // 扫码登录
  loginWithPCSession(appToken) {
    const _interceptPCSessionLoginResponse = (responsePromise, resolve, reject) => {
      responsePromise
        .then((response) => {
          if (response.data.code === 0) {
            let appAuthToken = response.headers["authtoken"];
            if (!appAuthToken) {
              appAuthToken = response.headers["authToken"];
            }

            if (appAuthToken) {
              setItem("authToken-" + new URL(response.config.url).host, appAuthToken);
            }
            resolve(response.data);
          } else if ([9, 18].indexOf(response.data.code) > -1) {
            resolve(response.data);
          } else {
            reject(new AppServerError(response.data.code, response.data.message));
          }
        })
        .catch((err) => {
          reject(err);
        });
    };

    return new Promise((resolve, reject) => {
      let responsePromise = this._post(`/session_login/${appToken}`, null, true);
      _interceptPCSessionLoginResponse(responsePromise, resolve, reject);
    });
  }

  changePassword(oldPassword, newPassword) {
    return this._post("/change_pwd", {
      oldPassword,
      newPassword,
    });
  }

  requestResetPasswordAuthCode() {
    return this._post("/send_reset_code");
  }

  resetPassword(resetPasswordAuthCode, newPassword) {
    return this._post("/reset_pwd", {
      resetCode: resetPasswordAuthCode,
      newPassword: newPassword,
    });
  }

  getGroupAnnouncement(groupId) {
    return this._post("/get_group_announcement", { groupId: groupId });
  }

  updateGroupAnnouncement(author, groupId, announcement) {
    return this._post("/put_group_announcement", {
      author,
      groupId,
      text: announcement,
    });
  }

  favMessage(message) {
    let favItem = FavItem.fromMessage(message);
    return this._post("/fav/add", {
      messageUid: stringValue(favItem.messageUid),
      type: favItem.favType,
      convType: favItem.conversation.type,
      convTarget: favItem.conversation.target,
      convLine: favItem.conversation.line,
      origin: favItem.origin,
      sender: favItem.sender,
      title: favItem.title,
      url: favItem.url,
      thumbUrl: favItem.thumbUrl,
      data: favItem.data,
    });
  }

  getFavList(startId, count = 20) {
    return this._post("/fav/list", { id: startId, count: count }, false, true);
  }

  delFav(favItemId) {
    return this._post("/fav/del/" + favItemId, "");
  }

  getUserInfo(userId) {
    return this._post("/admin/user/get_info", {
      userId,
    });
  }

  _interceptLoginResponse(responsePromise, resolve, reject) {
    responsePromise
      .then((response) => {
        console.log(response);
        if (response.data.code === 0) {
          let appAuthToken = response.headers["authtoken"];
          if (!appAuthToken) {
            appAuthToken = response.headers["authToken"];
          }

          if (appAuthToken) {
            setItem("authToken-" + new URL(response.config.url).host, appAuthToken);
          }
          resolve(response.data.result);
        } else {
          reject(new AppServerError(response.data.code, response.data.message));
        }
      })
      .catch((err) => {
        reject(err);
      });
  }

  /**
   *
   * @param path
   * @param data
   * @param rawResponse
   * @param rawResponseData
   * @return {Promise<string | AxiosResponse<any>|*|T>}
   * @private
   */
  async _post(path, data = {}, rawResponse = false, rawResponseData = false) {
    let response;
    path = Config.APP_SERVER + path;
    console.log(new URL(path).host);
    response = await axios.post(path, data, {
      transformResponse: rawResponseData ? [(data) => data] : axios.defaults.transformResponse,
      headers: {
        authToken: getItem("authToken-" + new URL(path).host),
      },
      withCredentials: true,
    });
    if (rawResponse) {
      return response;
    }
    if (response.data) {
      if (rawResponseData) {
        return response.data;
      }
      if (response.data.code === 0) {
        return response.data.result;
      } else {
        throw new AppServerError(response.data.code, response.data.message);
      }
    } else {
      throw new Error("request error, status code: " + response.status);
    }
  }

  async _postB(path, data = {}, rawResponse = false, rawResponseData = false) {
    let response;
    path = "http://identify.test.bcxin.com.cn" + path;
    response = await axios.post(path, data, {
      transformResponse: rawResponseData ? [(data) => data] : axios.defaults.transformResponse,
      headers: {
        authToken: getItem("authToken-" + new URL(path).host),
      },
      withCredentials: true,
    });
    if (rawResponse) {
      return response;
    }
    if (response.data) {
      if (rawResponseData) {
        return response.data;
      }
      if (response.data.code === 0) {
        return response.data.result;
      } else {
        throw new AppServerError(response.data.code, response.data.message);
      }
    } else {
      throw new Error("request error, status code: " + response.status);
    }
  }
}

const appServerApi = new AppServerApi();
export default appServerApi;