fix: typo

toeverything · Mar 4, 2024 · 256a053 · 256a053
1 parent f82726b
commit 256a053
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/packages/backend/server/src/fundamentals/mutex/index.ts b/packages/backend/server/src/fundamentals/mutex/index.ts
@@ -13,14 +13,14 @@ export class MutexService {
  private readonly logger = new Logger(MutexService.name);
  private readonly bucket = new Map<string, string>();
 
- constructor(private readonly als: ClsService) {}
+ constructor(private readonly cls: ClsService) {}
 
  private getId() {
- let id = this.als.get('asyncId');
+ let id = this.cls.get('asyncId');
 
  if (!id) {
  id = randomUUID();
- this.als.set('asyncId', id);
+ this.cls.set('asyncId', id);
  }
 
  return id;

diff --git a/packages/backend/server/src/plugins/redis/mutex.ts b/packages/backend/server/src/plugins/redis/mutex.ts
@@ -44,11 +44,11 @@ export class MutexRedisService {
  return id;
  }
 
- async lock(key: string, timeout: number = 100): Promise<boolean> {
+ async lock(key: string, releaseTimeInMS: number = 200): Promise<boolean> {
  const clientId = this.getId();
  console.error('lock', key, clientId);
  this.logger.debug(`Client ID is ${clientId}`);
- const timeoutStr = timeout.toString();
+ const releaseTime = releaseTimeInMS.toString();
 
  const fetchLock = async (retry: number): Promise<boolean> => {
  if (retry === 0) {
@@ -59,7 +59,7 @@ export class MutexRedisService {
  }
  try {
  const success = await this.redis.sendCommand(
- new Command('EVAL', [lockScript, '1', key, clientId, timeoutStr])
+ new Command('EVAL', [lockScript, '1', key, clientId, releaseTime])
  );
  if (success === 1) {
  console.error('success lock', key);