import { getApiEndpoint } from '../config/api.uts'
import { request, HttpError } from './http.uts'
import { clearSession, getSession, setSession } from './session.uts'

const consentStorageKey = 'talent-card-agreement-consent'

export const recordAgreementConsent = (version: string) => {
	uni.setStorageSync(consentStorageKey, { version: version, agreedAt: Date.now() })
}

export const loginWithDevelopmentSession = (onSuccess: () => void, onError: (error: HttpError) => void) => {
	request<any>({ path: getApiEndpoint('authDevelopmentSession'), method: 'POST', skipAuth: true }, (data: any) => {
		if (data == null || data.accessToken == null || data.expireAt == null || data.talentId == null) {
			onError({ code: 'INVALID_DEVELOPMENT_SESSION', message: '开发测试会话创建失败', statusCode: 200, traceId: '' })
			return
		}
		setSession({ accessToken: data.accessToken as string, refreshToken: data.refreshToken != null ? data.refreshToken as string : '', expireAt: data.expireAt as number, talentId: '' + data.talentId })
		onSuccess()
	}, onError)
}

export const loginWithPhoneCode = (phoneCode: string, onSuccess: () => void, onError: (error: HttpError) => void) => {
	if (phoneCode.length == 0) {
		onError({ code: 'PHONE_AUTH_REQUIRED', message: '请重新授权手机号', statusCode: 0, traceId: '' })
		return
	}
	const consent: any = uni.getStorageSync(consentStorageKey)
	if (consent == null || consent.agreedAt == null) {
		onError({ code: 'AGREEMENT_REQUIRED', message: '请先阅读并同意相关协议', statusCode: 0, traceId: '' })
		return
	}
	uni.login({
		provider: 'weixin',
		success: (loginResult: any) => {
			const endpoint = getApiEndpoint('authLogin')
			request<any>({
				path: endpoint,
				method: 'POST',
				skipAuth: true,
				data: {
					wechatCode: loginResult.code,
					phoneCode: phoneCode,
					agreementVersion: consent.version,
					agreedAt: consent.agreedAt
				}
			}, (data: any) => {
				if (data == null || data.accessToken == null || data.expireAt == null) {
					onError({ code: 'INVALID_LOGIN_RESPONSE', message: '登录响应缺少会话信息', statusCode: 200, traceId: '' })
					return
				}
				setSession({ accessToken: data.accessToken as string, refreshToken: data.refreshToken != null ? data.refreshToken as string : '', expireAt: data.expireAt as number, talentId: data.talentId != null ? '' + data.talentId : '' })
				onSuccess()
			}, onError)
		},
		fail: () => onError({ code: 'WECHAT_LOGIN_FAILED', message: '微信登录失败，请稍后重试', statusCode: 0, traceId: '' })
	})
}

// 刷新时只接受服务端返回的新会话，不沿用已经过期的 accessToken。
export const refreshSession = (onSuccess: () => void, onError: (error: HttpError) => void) => {
	const current = getSession()
	if (current == null || current.refreshToken.length == 0) {
		clearSession()
		onError({ code: 'REFRESH_TOKEN_MISSING', message: '登录已失效，请重新登录', statusCode: 401, traceId: '' })
		return
	}
	request<any>({ path: getApiEndpoint('authRefresh'), method: 'POST', skipAuth: true, data: { refreshToken: current.refreshToken } }, (data: any) => {
		if (data == null || data.accessToken == null || data.expireAt == null) {
			clearSession()
			onError({ code: 'INVALID_REFRESH_RESPONSE', message: '登录刷新失败，请重新登录', statusCode: 200, traceId: '' })
			return
		}
		setSession({ accessToken: data.accessToken as string, refreshToken: data.refreshToken != null ? data.refreshToken as string : current.refreshToken, expireAt: data.expireAt as number, talentId: data.talentId != null ? '' + data.talentId : current.talentId })
		onSuccess()
	}, (error) => {
		clearSession()
		onError(error)
	})
}

export const logout = (onSuccess: () => void, onError: (error: HttpError) => void) => {
	const endpoint = getApiEndpoint('authLogout')
	if (endpoint.length == 0) {
		clearSession()
		uni.removeStorageSync(consentStorageKey)
		onSuccess()
		return
	}
	request<any>({ path: endpoint, method: 'POST' }, () => { clearSession(); uni.removeStorageSync(consentStorageKey); onSuccess() }, onError)
}