hrms-bangkok/hrms-api-org
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

fix: handle error
All checks were successful
Build & Deploy on Dev / build (push) Successful in 2m0s
Details

Browse source
This commit is contained in:
Warunee Tamkoo 2026-02-26 21:47:10 +07:00
parent 1b3806c6f7
commit 26bcfd728e
1 changed files with 84 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

105
src/controllers/PermissionController.ts
View file

@ -34,10 +34,18 @@ export class PermissionController extends Controller {
@Get("") @Get("")
public async getPermission(@Request() request: RequestWithUser) { public async getPermission(@Request() request: RequestWithUser) {
const redisClient = await this.redis.createClient({ const redisClient = this.redis.createClient({
host: REDIS_HOST, socket: {
port: REDIS_PORT, host: REDIS_HOST,
port: parseInt(REDIS_PORT as string) || 6379,
},
}); });
redisClient.on("error", (err: any) => {
console.error("[REDIS] Connection error:", err.message);
});
await redisClient.connect();
const getAsync = promisify(redisClient.get).bind(redisClient); const getAsync = promisify(redisClient.get).bind(redisClient);
let profile: any = await this.profileRepo.findOne({ let profile: any = await this.profileRepo.findOne({
@ -113,6 +121,7 @@ export class PermissionController extends Controller {
roles: roleAttrData, roles: roleAttrData,
}; };
redisClient.setex("role_" + profile.id, 86400, JSON.stringify(reply)); redisClient.setex("role_" + profile.id, 86400, JSON.stringify(reply));
await redisClient.quit();
} }
return new HttpSuccess(reply); return new HttpSuccess(reply);
} }
@ -126,10 +135,18 @@ export class PermissionController extends Controller {
orgRevisionIsCurrent: true, orgRevisionIsCurrent: true,
}, },
}); });
const redisClient = await this.redis.createClient({ const redisClient = this.redis.createClient({
host: REDIS_HOST, socket: {
port: REDIS_PORT, host: REDIS_HOST,
port: parseInt(REDIS_PORT as string) || 6379,
},
}); });
redisClient.on("error", (err: any) => {
console.error("[REDIS] Connection error:", err.message);
});
await redisClient.connect();
const getAsync = promisify(redisClient.get).bind(redisClient); const getAsync = promisify(redisClient.get).bind(redisClient);
let profileType = "OFFICER"; let profileType = "OFFICER";
@ -229,6 +246,7 @@ export class PermissionController extends Controller {
}); });
redisClient.setex("menu_" + profile.id, 86400, JSON.stringify(reply)); redisClient.setex("menu_" + profile.id, 86400, JSON.stringify(reply));
await redisClient.quit();
} }
return new HttpSuccess(reply); return new HttpSuccess(reply);
@ -307,10 +325,18 @@ export class PermissionController extends Controller {
@Path() system: string, @Path() system: string,
@Path() action: string, @Path() action: string,
) { ) {
const redisClient = await this.redis.createClient({ const redisClient = this.redis.createClient({
host: REDIS_HOST, socket: {
port: REDIS_PORT, host: REDIS_HOST,
port: parseInt(REDIS_PORT as string) || 6379,
},
}); });
redisClient.on("error", (err: any) => {
console.error("[REDIS] Connection error:", err.message);
});
await redisClient.connect();
const getAsync = promisify(redisClient.get).bind(redisClient); const getAsync = promisify(redisClient.get).bind(redisClient);
let profileType = "OFFICER"; let profileType = "OFFICER";
@ -398,6 +424,7 @@ export class PermissionController extends Controller {
redisClient.setex("posMaster_" + profile.id, 86400, JSON.stringify(reply)); redisClient.setex("posMaster_" + profile.id, 86400, JSON.stringify(reply));
} }
} }
await redisClient.quit();
return new HttpSuccess(reply); return new HttpSuccess(reply);
} }
@ -416,10 +443,18 @@ export class PermissionController extends Controller {
orgRevisionIsCurrent: true, orgRevisionIsCurrent: true,
}, },
}); });
const redisClient = await this.redis.createClient({ const redisClient = this.redis.createClient({
host: REDIS_HOST, socket: {
port: REDIS_PORT, host: REDIS_HOST,
port: parseInt(REDIS_PORT as string) || 6379,
},
}); });
redisClient.on("error", (err: any) => {
console.error("[REDIS] Connection error:", err.message);
});
await redisClient.connect();
const getAsync = promisify(redisClient.get).bind(redisClient); const getAsync = promisify(redisClient.get).bind(redisClient);
let org = this.PermissionOrg(request, system, action); let org = this.PermissionOrg(request, system, action);
@ -499,15 +534,24 @@ export class PermissionController extends Controller {
redisClient.setex("user_" + profile.id, 86400, JSON.stringify(reply)); redisClient.setex("user_" + profile.id, 86400, JSON.stringify(reply));
} }
} }
await redisClient.quit();
return new HttpSuccess(reply); return new HttpSuccess(reply);
} }
public async getPermissionFunc(@Request() request: RequestWithUser) { public async getPermissionFunc(@Request() request: RequestWithUser) {
const redisClient = await this.redis.createClient({ const redisClient = this.redis.createClient({
host: REDIS_HOST, socket: {
port: REDIS_PORT, host: REDIS_HOST,
port: parseInt(REDIS_PORT as string) || 6379,
},
}); });
redisClient.on("error", (err: any) => {
console.error("[REDIS] Connection error:", err.message);
});
await redisClient.connect();
const getAsync = promisify(redisClient.get).bind(redisClient); const getAsync = promisify(redisClient.get).bind(redisClient);
let profile: any = await this.profileRepo.findOne({ let profile: any = await this.profileRepo.findOne({
@ -583,6 +627,7 @@ export class PermissionController extends Controller {
roles: roleAttrData, roles: roleAttrData,
}; };
redisClient.setex("role_" + profile.id, 86400, JSON.stringify(reply)); redisClient.setex("role_" + profile.id, 86400, JSON.stringify(reply));
await redisClient.quit();
} }
return reply; return reply;
} }
@ -610,10 +655,18 @@ export class PermissionController extends Controller {
} }
public async listAuthSysOrgFunc(request: RequestWithUser, system: string, action: string) { public async listAuthSysOrgFunc(request: RequestWithUser, system: string, action: string) {
const redisClient = await this.redis.createClient({ const redisClient = this.redis.createClient({
host: REDIS_HOST, socket: {
port: REDIS_PORT, host: REDIS_HOST,
port: parseInt(REDIS_PORT as string) || 6379,
},
}); });
redisClient.on("error", (err: any) => {
console.error("[REDIS] Connection error:", err.message);
});
await redisClient.connect();
const getAsync = promisify(redisClient.get).bind(redisClient); const getAsync = promisify(redisClient.get).bind(redisClient);
let profileType = "OFFICER"; let profileType = "OFFICER";
@ -700,6 +753,7 @@ export class PermissionController extends Controller {
redisClient.setex("posMaster_" + profile.id, 86400, JSON.stringify(reply)); redisClient.setex("posMaster_" + profile.id, 86400, JSON.stringify(reply));
} }
} }
await redisClient.quit();
return reply; return reply;
} }
@ -782,10 +836,18 @@ export class PermissionController extends Controller {
@Get("checkOrg/{keycloakId}") @Get("checkOrg/{keycloakId}")
public async checkOrg(@Path() keycloakId: string) { public async checkOrg(@Path() keycloakId: string) {
const redisClient = await this.redis.createClient({ const redisClient = this.redis.createClient({
host: REDIS_HOST, socket: {
port: REDIS_PORT, host: REDIS_HOST,
port: parseInt(REDIS_PORT as string) || 6379,
},
}); });
redisClient.on("error", (err: any) => {
console.error("[REDIS] Connection error:", err.message);
});
await redisClient.connect();
// const getAsync = promisify(redisClient.get).bind(redisClient); // const getAsync = promisify(redisClient.get).bind(redisClient);
// let profileType = "OFFICER"; // let profileType = "OFFICER";
@ -836,6 +898,7 @@ export class PermissionController extends Controller {
}; };
} }
redisClient.setex("org_" + profile.id, 86400, JSON.stringify(reply)); //Create Redis redisClient.setex("org_" + profile.id, 86400, JSON.stringify(reply)); //Create Redis
await redisClient.quit();
// } else { // } else {
// const posMaster = await this.posMasterEmpRepository.findOne({ // const posMaster = await this.posMasterEmpRepository.findOne({
// where: { // where: {