external/hydra
1
0
Fork 0
mirror of https://github.com/hydralauncher/hydra.git synced 2025-03-09 15:40:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

feat: handling 401 status code

Browse source
This commit is contained in:
Zamitto 2024-06-28 12:24:12 -03:00
parent c27182c618
commit 4bd2174bf3
1 changed files with 32 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

55
src/main/services/hydra-api.ts
View file

@ -160,24 +160,7 @@ export class HydraApi {
["id"] ["id"]
); );
} catch (err) { } catch (err) {
if ( this.handleUnauthorizedError(err);
err instanceof AxiosError &&
(err?.response?.status === 401 || err?.response?.status === 403)
) {
this.userAuth = {
authToken: "",
expirationTimestamp: 0,
refreshToken: "",
};
userAuthRepository.delete({ id: 1 });
this.sendSignOutEvent();
logger.log("user refresh token expired");
}
throw err;
} }
} }
} }
@ -190,28 +173,54 @@ export class HydraApi {
}; };
} }
private static handleUnauthorizedError = (err) => {
if (err instanceof AxiosError && err.response?.status === 401) {
this.userAuth = {
authToken: "",
expirationTimestamp: 0,
refreshToken: "",
};
userAuthRepository.delete({ id: 1 });
this.sendSignOutEvent();
}
throw err;
};
static async get(url: string) { static async get(url: string) {
await this.revalidateAccessTokenIfExpired(); await this.revalidateAccessTokenIfExpired();
return this.instance.get(url, this.getAxiosConfig()); return this.instance
.get(url, this.getAxiosConfig())
.catch(this.handleUnauthorizedError);
} }
static async post(url: string, data?: any) { static async post(url: string, data?: any) {
await this.revalidateAccessTokenIfExpired(); await this.revalidateAccessTokenIfExpired();
return this.instance.post(url, data, this.getAxiosConfig()); return this.instance
.post(url, data, this.getAxiosConfig())
.catch(this.handleUnauthorizedError);
} }
static async put(url: string, data?: any) { static async put(url: string, data?: any) {
await this.revalidateAccessTokenIfExpired(); await this.revalidateAccessTokenIfExpired();
return this.instance.put(url, data, this.getAxiosConfig()); return this.instance
.put(url, data, this.getAxiosConfig())
.catch(this.handleUnauthorizedError);
} }
static async patch(url: string, data?: any) { static async patch(url: string, data?: any) {
await this.revalidateAccessTokenIfExpired(); await this.revalidateAccessTokenIfExpired();
return this.instance.patch(url, data, this.getAxiosConfig()); return this.instance
.patch(url, data, this.getAxiosConfig())
.catch(this.handleUnauthorizedError);
} }
static async delete(url: string) { static async delete(url: string) {
await this.revalidateAccessTokenIfExpired(); await this.revalidateAccessTokenIfExpired();
return this.instance.delete(url, this.getAxiosConfig()); return this.instance
.delete(url, this.getAxiosConfig())
.catch(this.handleUnauthorizedError);
} }
} }