refactor: throw a custom S5Error

This commit is contained in:
Derrick Hammer 2024-03-21 10:47:14 -04:00
parent dfe79e2fc2
commit 4561e06b61
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
2 changed files with 39 additions and 23 deletions

View File

@ -1,31 +1,37 @@
import Axios, { AxiosRequestConfig } from "axios";
import Axios, {AxiosError, AxiosRequestConfig} from "axios";
import {S5Error} from "#client.js";
export const customInstance = <T>(
config: AxiosRequestConfig,
options?: AxiosRequestConfig,
config: AxiosRequestConfig,
options?: AxiosRequestConfig,
): Promise<T> => {
const source = Axios.CancelToken.source();
const source = Axios.CancelToken.source();
/*
Hack to ensure that the data is passed to the request as an option.
*/
if (options?.data) {
config = config || {};
config.data = options.data;
delete config.data;
}
/*
Hack to ensure that the data is passed to the request as an option.
*/
if (options?.data) {
config = config || {};
config.data = options.data;
delete config.data;
}
const instance = Axios.create({ baseURL: options?.baseURL });
const promise = instance({
...config,
...options,
cancelToken: source.token,
}).then(({ data }) => data);
const instance = Axios.create({baseURL: options?.baseURL});
const promise = instance({
...config,
...options,
cancelToken: source.token,
}).then(({data}) => data).catch((error) => {
if (Axios.isCancel(error)) {
return;
}
throw new S5Error((error as AxiosError).message, (error as AxiosError).response?.status as number);
})
// @ts-ignore
promise.cancel = () => {
source.cancel("Query was cancelled");
};
// @ts-ignore
promise.cancel = () => {
source.cancel("Query was cancelled");
};
return promise;
return promise;
};

View File

@ -70,6 +70,16 @@ import { Multihash } from "@lumeweb/libs5/lib/multihash.js";
import { blake3 } from "@noble/hashes/blake3";
import { base64urlDecode, base64urlEncode } from "#utils/encoding.js";
export class S5Error extends Error {
public statusCode: number;
constructor(message: string, statusCode: number) {
super(message);
this.name = "S5Error";
this.statusCode = statusCode;
}
}
/**
* The S5 Client which can be used to access S5-net.
*/