78 lines
2.8 KiB
TypeScript
78 lines
2.8 KiB
TypeScript
|
import { createAlova } from 'alova';
|
||
|
|
import type { AlovaDefaultCacheAdapter, AlovaGenerics, AlovaGlobalCacheAdapter, AlovaRequestAdapter } from 'alova';
|
||
|
|
import VueHook from 'alova/vue';
|
||
|
|
import type { VueHookType } from 'alova/vue';
|
||
|
|
import adapterFetch from 'alova/fetch';
|
||
|
|
import { createServerTokenAuthentication } from 'alova/client';
|
||
|
|
import type { FetchRequestInit } from 'alova/fetch';
|
||
|
|
import { BACKEND_ERROR_CODE } from './constant';
|
||
|
|
import type { CustomAlovaConfig, RequestOptions } from './type';
|
||
|
|
|
||
|
|
export const createAlovaRequest = <
|
||
|
|
RequestConfig = FetchRequestInit,
|
||
|
|
ResponseType = Response,
|
||
|
|
ResponseHeader = Headers,
|
||
|
|
L1Cache extends AlovaGlobalCacheAdapter = AlovaDefaultCacheAdapter,
|
||
|
|
L2Cache extends AlovaGlobalCacheAdapter = AlovaDefaultCacheAdapter
|
||
|
|
>(
|
||
|
|
customConfig: CustomAlovaConfig<
|
||
|
|
AlovaGenerics<any, any, RequestConfig, ResponseType, ResponseHeader, L1Cache, L2Cache, any>
|
||
|
|
>,
|
||
|
|
options: RequestOptions<AlovaGenerics<any, any, RequestConfig, ResponseType, ResponseHeader, L1Cache, L2Cache, any>>
|
||
|
|
) => {
|
||
|
|
const { tokenRefresher } = options;
|
||
|
|
const { onAuthRequired, onResponseRefreshToken } = createServerTokenAuthentication<
|
||
|
|
VueHookType,
|
||
|
|
AlovaRequestAdapter<RequestConfig, ResponseType, ResponseHeader>
|
||
|
|
>({
|
||
|
|
refreshTokenOnSuccess: {
|
||
|
|
isExpired: (response, method) => tokenRefresher?.isExpired(response, method) || false,
|
||
|
|
handler: async (response, method) => tokenRefresher?.handler(response, method)
|
||
|
|
},
|
||
|
|
refreshTokenOnError: {
|
||
|
|
isExpired: (response, method) => tokenRefresher?.isExpired(response, method) || false,
|
||
|
|
handler: async (response, method) => tokenRefresher?.handler(response, method)
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
const instance = createAlova({
|
||
|
|
...customConfig,
|
||
|
|
timeout: customConfig.timeout ?? 10 * 1000,
|
||
|
|
requestAdapter: (customConfig.requestAdapter as any) ?? adapterFetch(),
|
||
|
|
statesHook: VueHook,
|
||
|
|
beforeRequest: onAuthRequired(options.onRequest as any),
|
||
|
|
responded: onResponseRefreshToken({
|
||
|
|
onSuccess: async (response, method) => {
|
||
|
|
// check if http status is success
|
||
|
|
let error: any = null;
|
||
|
|
let transformedData: any = null;
|
||
|
|
try {
|
||
|
|
if (await options.isBackendSuccess(response)) {
|
||
|
|
transformedData = await options.transformBackendResponse(response);
|
||
|
|
} else {
|
||
|
|
error = new Error('the backend request error');
|
||
|
|
error.code = BACKEND_ERROR_CODE;
|
||
|
|
}
|
||
|
|
} catch (err) {
|
||
|
|
error = err;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (error) {
|
||
|
|
await options.onError?.(error, response, method);
|
||
|
|
throw error;
|
||
|
|
}
|
||
|
|
|
||
|
|
return transformedData;
|
||
|
|
},
|
||
|
|
onComplete: options.onComplete,
|
||
|
|
onError: (error, method) => options.onError?.(error, null, method)
|
||
|
|
})
|
||
|
|
});
|
||
|
|
|
||
|
|
return instance;
|
||
|
|
};
|
||
|
|
|
||
|
|
export { BACKEND_ERROR_CODE };
|
||
|
|
export type * from './type';
|
||
|
|
export type * from 'alova';
|