refactor: code directory

intentjs · Jan 23, 2025 · e74fe53 · e74fe53
1 parent 5d3c1fe
commit e74fe53
Show file tree

Hide file tree

Showing 16 changed files with 8 additions and 59 deletions.
diff --git a/lib/limiter/explorer.ts b/lib/limiter/explorer.ts
diff --git a/packages/core/lib/explorer.ts b/packages/core/lib/explorer.ts
@@ -7,6 +7,9 @@ import { GenericFunction } from './interfaces';
 import { JOB_NAME, JOB_OPTIONS } from './queue/constants';
 import { QueueMetadata } from './queue/metadata';
 import { Injectable } from './foundation';
+import { REFILL_INTERVAL, TOKEN_COUNT } from './limiter/constants';
+import { ulid } from 'ulid';
+import { Limiter } from './limiter';
 
 @Injectable()
 export class IntentExplorer {

diff --git a/lib/limiter/constants.ts → packages/core/lib/limiter/constants.ts b/lib/limiter/constants.ts → packages/core/lib/limiter/constants.ts
diff --git a/lib/limiter/decorator.ts → packages/core/lib/limiter/decorator.ts b/lib/limiter/decorator.ts → packages/core/lib/limiter/decorator.ts
diff --git a/lib/limiter/drivers/index.ts → packages/core/lib/limiter/drivers/index.ts b/lib/limiter/drivers/index.ts → packages/core/lib/limiter/drivers/index.ts
diff --git a/lib/limiter/drivers/memory.ts → packages/core/lib/limiter/drivers/memory.ts b/lib/limiter/drivers/memory.ts → packages/core/lib/limiter/drivers/memory.ts
@@ -1,4 +1,4 @@
-import { LimiterDriver } from '../interfaces/LimiterDriver';
+import { LimiterDriver } from '../interfaces/limiterDriver';
 
 export class MemoryDriver implements LimiterDriver {
   private static keyCounts = {};

diff --git a/lib/limiter/drivers/redis.ts → packages/core/lib/limiter/drivers/redis.ts b/lib/limiter/drivers/redis.ts → packages/core/lib/limiter/drivers/redis.ts
diff --git a/lib/limiter/index.ts → packages/core/lib/limiter/index.ts b/lib/limiter/index.ts → packages/core/lib/limiter/index.ts
diff --git a/lib/limiter/interfaces/limiterDriver.ts → ...e/lib/limiter/interfaces/limiterDriver.ts b/lib/limiter/interfaces/limiterDriver.ts → ...e/lib/limiter/interfaces/limiterDriver.ts
diff --git a/lib/limiter/interfaces/options.ts → ...es/core/lib/limiter/interfaces/options.ts b/lib/limiter/interfaces/options.ts → ...es/core/lib/limiter/interfaces/options.ts
diff --git a/lib/limiter/rateLimiter.ts → packages/core/lib/limiter/rateLimiter.ts b/lib/limiter/rateLimiter.ts → packages/core/lib/limiter/rateLimiter.ts
@@ -1,20 +1,19 @@
 import { LimiterDriver } from './interfaces/limiterDriver';
 import { BaseStrategy } from './strategies/baseStrategy';
 import { Injectable } from '@nestjs/common';
-import { RedisDriver } from './drivers/redis';
-import { IntentConfig } from '../config/service';
+import { ConfigService } from '../config/service';
 import {
   DriversMap,
   LimiterDriverType,
-  LimiterOptions,
 } from './interfaces/options';
 
 @Injectable()
 export class Limiter {
   private static driver: LimiterDriver;
   private static strategy: BaseStrategy;
-  constructor(private config: IntentConfig) {
-    const options = this.config.get<LimiterOptions>('queue');
+  constructor(private config: ConfigService) {
+    const options = this.config.get('limiter');
+    if(!options) return
     switch (options.driver) {
       case LimiterDriverType.REDIS: {
         Limiter.driver = new DriversMap[LimiterDriverType.REDIS](

diff --git a/lib/limiter/strategies/baseStrategy.ts → ...re/lib/limiter/strategies/baseStrategy.ts b/lib/limiter/strategies/baseStrategy.ts → ...re/lib/limiter/strategies/baseStrategy.ts
diff --git a/lib/limiter/strategies/index.ts → ...ages/core/lib/limiter/strategies/index.ts b/lib/limiter/strategies/index.ts → ...ages/core/lib/limiter/strategies/index.ts
diff --git a/...imiter/strategies/slidingWindowCounter.ts → ...imiter/strategies/slidingWindowCounter.ts b/...imiter/strategies/slidingWindowCounter.ts → ...imiter/strategies/slidingWindowCounter.ts
diff --git a/lib/limiter/strategies/tokenBucket.ts → ...ore/lib/limiter/strategies/tokenBucket.ts b/lib/limiter/strategies/tokenBucket.ts → ...ore/lib/limiter/strategies/tokenBucket.ts
diff --git a/lib/limiter/strategies/windowCounter.ts → ...e/lib/limiter/strategies/windowCounter.ts b/lib/limiter/strategies/windowCounter.ts → ...e/lib/limiter/strategies/windowCounter.ts