refacto refresh token
This commit is contained in:
parent
5723d6d382
commit
d3e7c9e802
@ -4,7 +4,7 @@ import ApiController from "@Common/system/controller-pattern/ApiController";
|
|||||||
import { Service } from "typedi";
|
import { Service } from "typedi";
|
||||||
import Id360Service, { EnrollmentResponse } from "@Services/common/Id360Service/Id360Service";
|
import Id360Service, { EnrollmentResponse } from "@Services/common/Id360Service/Id360Service";
|
||||||
import CustomersService from "@Services/customer/CustomersService/CustomersService";
|
import CustomersService from "@Services/customer/CustomersService/CustomersService";
|
||||||
import AuthService from "@Services/common/AuthService/AuthService";
|
import AuthService, { ICustomerJwtPayload } from "@Services/common/AuthService/AuthService";
|
||||||
import { Customer } from "le-coffre-resources/dist/SuperAdmin";
|
import { Customer } from "le-coffre-resources/dist/SuperAdmin";
|
||||||
|
|
||||||
@Controller()
|
@Controller()
|
||||||
@ -88,4 +88,38 @@ export default class CustomerController extends ApiController {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Post("/api/v1/id360/customers/refresh-token")
|
||||||
|
protected async refreshToken(req: Request, response: Response) {
|
||||||
|
try {
|
||||||
|
const authHeader = req.headers["authorization"];
|
||||||
|
const token = authHeader && authHeader.split(" ")[1];
|
||||||
|
|
||||||
|
if (!token) {
|
||||||
|
this.httpBadRequest(response);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
let accessToken;
|
||||||
|
this.authService.verifyRefreshToken(token, (err, userPayload) => {
|
||||||
|
if (err) {
|
||||||
|
console.log(err);
|
||||||
|
this.httpUnauthorized(response);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const user = userPayload as ICustomerJwtPayload;
|
||||||
|
delete user.iat;
|
||||||
|
delete user.exp;
|
||||||
|
accessToken = this.authService.generateAccessToken(user);
|
||||||
|
});
|
||||||
|
|
||||||
|
//success
|
||||||
|
this.httpSuccess(response, { accessToken });
|
||||||
|
} catch (error) {
|
||||||
|
console.log(error);
|
||||||
|
this.httpInternalError(response);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
@ -70,12 +70,15 @@ export default class UserController extends ApiController {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const user = userPayload as IUserJwtPayload;
|
const user = userPayload as IUserJwtPayload;
|
||||||
|
delete user.iat;
|
||||||
|
delete user.exp;
|
||||||
accessToken = this.authService.generateAccessToken(user);
|
accessToken = this.authService.generateAccessToken(user);
|
||||||
});
|
});
|
||||||
|
|
||||||
//success
|
//success
|
||||||
this.httpSuccess(response, { accessToken });
|
this.httpSuccess(response, { accessToken });
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
console.log(error);
|
||||||
this.httpInternalError(response);
|
this.httpInternalError(response);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
@ -46,7 +46,6 @@ export default class DocumentsService extends BaseService {
|
|||||||
public async refuse(uid: string, document: Partial<Document>, refused_reason: string): Promise<Documents> {
|
public async refuse(uid: string, document: Partial<Document>, refused_reason: string): Promise<Documents> {
|
||||||
if (document.files) {
|
if (document.files) {
|
||||||
for (let i = 0; i < document.files.length; i++) {
|
for (let i = 0; i < document.files.length; i++) {
|
||||||
console.log("archiving file", document.files[i]?.uid);
|
|
||||||
await this.filesRepository.deleteKeyAndArchive(document.files[i]?.uid as string);
|
await this.filesRepository.deleteKeyAndArchive(document.files[i]?.uid as string);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -14,6 +14,8 @@ enum PROVIDER_OPENID {
|
|||||||
export interface ICustomerJwtPayload {
|
export interface ICustomerJwtPayload {
|
||||||
customerId: string;
|
customerId: string;
|
||||||
email: string;
|
email: string;
|
||||||
|
iat?: number;
|
||||||
|
exp?: number;
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface IdNotJwtPayload {
|
export interface IdNotJwtPayload {
|
||||||
@ -31,6 +33,8 @@ export interface IUserJwtPayload {
|
|||||||
office_Id: string;
|
office_Id: string;
|
||||||
role: string;
|
role: string;
|
||||||
rules: string[];
|
rules: string[];
|
||||||
|
iat?: number;
|
||||||
|
exp?: number;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Service()
|
@Service()
|
||||||
|
@ -46,7 +46,6 @@ export default class DocumentsService extends BaseService {
|
|||||||
public async refuse(uid: string, document: Partial<Document>, refused_reason: string): Promise<Documents> {
|
public async refuse(uid: string, document: Partial<Document>, refused_reason: string): Promise<Documents> {
|
||||||
if (document.files) {
|
if (document.files) {
|
||||||
for (let i = 0; i < document.files.length; i++) {
|
for (let i = 0; i < document.files.length; i++) {
|
||||||
console.log("archiving file", document.files[i]?.uid);
|
|
||||||
await this.filesRepository.deleteKeyAndArchive(document.files[i]?.uid as string);
|
await this.filesRepository.deleteKeyAndArchive(document.files[i]?.uid as string);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -46,7 +46,6 @@ export default class DocumentsService extends BaseService {
|
|||||||
public async refuse(uid: string, document: Partial<Document>, refused_reason: string): Promise<Documents> {
|
public async refuse(uid: string, document: Partial<Document>, refused_reason: string): Promise<Documents> {
|
||||||
if (document.files) {
|
if (document.files) {
|
||||||
for (let i = 0; i < document.files.length; i++) {
|
for (let i = 0; i < document.files.length; i++) {
|
||||||
console.log("archiving file", document.files[i]?.uid);
|
|
||||||
await this.filesRepository.deleteKeyAndArchive(document.files[i]?.uid as string);
|
await this.filesRepository.deleteKeyAndArchive(document.files[i]?.uid as string);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user