v4.1.1

changelog.md

@@ -1,5 +1,26 @@
 # Changelog
 
+## 2026-02-10 - 4.1.1 - fix(smartproxy)
+upgrade @push.rocks/smartproxy to ^23.1.0 and adapt code/tests for its async getStatistics() API
+
+- Bumped dependency @push.rocks/smartproxy 22.4.2 → 23.1.0 in package.json
+- Changed ts/monitoring/classes.metricsmanager.ts to await smartProxy.getStatistics() (was synchronous)
+- Updated multiple tests to set cacheConfig: { enabled: false } and added socketTimeouts where appropriate
+- Improved SMTP test servers: handle multi-line input, drop data for packet-loss simulation, and ignore socket errors to make tests more robust
+- Added migration notes to readme.hints.md documenting SmartProxy v23.1.0 changes (async getStatistics, Rust proxy behavior)
+
+## 2026-02-10 - 4.1.0 - feat(cache)
+add persistent smartdata-backed cache with LocalTsmDb, cache cleaner, and DcRouter integration
+
+- Introduce CacheDb and CacheCleaner using @push.rocks/smartdata and @push.rocks/smartmongo (LocalTsmDb) for persistent caching
+- Integrate cache initialization, console summary, and graceful shutdown into DcRouter (options.cacheConfig and setupCacheDb())
+- Require svDb() decorators on concrete cache document classes; remove decorators from the abstract CachedDocument base class
+- Switch CacheCleaner to smartdata getInstances() + per-document delete() instead of deleteMany
+- Adapt to LocalTsmDb API changes (folderPath option and start() returning connectionUri) and initialize SmartdataDb with mongoDbUrl/mongoDbName
+- Remove experimentalDecorators and emitDecoratorMetadata from tsconfig to use TC39 Stage 3 decorators (smartdata v7+ compatibility)
+- Add package.json exports mapping (remove main/typings entries) to expose dist entry points
+- Add README documentation for the Smartdata Cache System and configuration/usage examples
+
 ## 2026-02-03 - 4.0.0 - BREAKING CHANGE(config)
 convert configuration management to read-only; remove updateConfiguration endpoint and client-side editing
 

package.json

@@ -1,11 +1,13 @@
 {
   "name": "@serve.zone/dcrouter",
   "private": false,
-  "version": "4.0.0",
+  "version": "4.1.1",
   "description": "A multifaceted routing service handling mail and SMS delivery functions.",
-  "main": "dist_ts/index.js",
-  "typings": "dist_ts/index.d.ts",
   "type": "module",
+  "exports": {
+    ".": "./dist_ts/index.js",
+    "./interfaces": "./dist_ts_interfaces/index.js"
+  },
   "author": "Task Venture Capital GmbH",
   "license": "MIT",
   "scripts": {
@@ -48,7 +50,7 @@
     "@push.rocks/smartnetwork": "^4.4.0",
     "@push.rocks/smartpath": "^6.0.0",
     "@push.rocks/smartpromise": "^4.2.3",
-    "@push.rocks/smartproxy": "^22.4.2",
+    "@push.rocks/smartproxy": "^23.1.0",
     "@push.rocks/smartradius": "^1.1.0",
     "@push.rocks/smartrequest": "^5.0.1",
     "@push.rocks/smartrule": "^2.0.1",

pnpm-lock.yaml

@@ -75,8 +75,8 @@ importers:
         specifier: ^4.2.3
         version: 4.2.3
       '@push.rocks/smartproxy':
-        specifier: ^22.4.2
-        version: 22.4.2(socks@2.8.7)
+        specifier: ^23.1.0
+        version: 23.1.0(socks@2.8.7)
       '@push.rocks/smartradius':
         specifier: ^1.1.0
         version: 1.1.0
@@ -677,6 +677,10 @@ packages:
     resolution: {integrity: sha512-ZT55BDLV0yv0RBm2czMiZ+SqCGO7AvmOM3G/w2xhVPH+te0aKgFjmBvGlL1dH+ql2tgGO3MVrbb3jCKyvpgnxA==}
     engines: {node: 20 || >=22}
 
+  '@isaacs/brace-expansion@5.0.1':
+    resolution: {integrity: sha512-WMz71T1JS624nWj2n2fnYAuPovhv7EUhk69R6i9dsVyzxt5eM3bjwvgk9L+APE1TRscGysAVMANkB0jh0LQZrQ==}
+    engines: {node: 20 || >=22}
+
   '@isaacs/cliui@8.0.2':
     resolution: {integrity: sha512-O8jcjabXaleOG9DQ0+ARXWZBTfnP4WNAqzuiJK7ll44AmxGKv/J2M4TPjxjY3znBCfvBXFzucm1twdyFybFqEA==}
     engines: {node: '>=12'}
@@ -1075,8 +1079,8 @@ packages:
   '@push.rocks/smartpromise@4.2.3':
     resolution: {integrity: sha512-Ycg/TJR+tMt+S3wSFurOpEoW6nXv12QBtKXgBcjMZ4RsdO28geN46U09osPn9N9WuwQy1PkmTV5J/V4F9U8qEw==}
 
-  '@push.rocks/smartproxy@22.4.2':
-    resolution: {integrity: sha512-JdDa1VxGOnWfF5HuJRvkX3/zHuIKz+IV9n/XOsNZQA9zMZdLVlWPqjGio9GLWsPOWA2l1YZKymjMH4ybPbGQtA==}
+  '@push.rocks/smartproxy@23.1.0':
+    resolution: {integrity: sha512-2EhMFeQytDwnqooK9BNkLw9oz8M1LUFuMEg6271xRnwf8gUkDq5WT0brrmLdOmpqkU/3h/wDeZUrn65zq3VAcA==}
 
   '@push.rocks/smartpuppeteer@2.0.5':
     resolution: {integrity: sha512-yK/qSeWVHIGWRp3c8S5tfdGP6WCKllZC4DR8d8CQlEjszOSBmHtlTdyyqOMBZ/BA4kd+eU5f3A1r4K2tGYty1g==}
@@ -1099,6 +1103,9 @@ packages:
   '@push.rocks/smartrule@2.0.1':
     resolution: {integrity: sha512-8oYEnS9z+NgCAcUtXPMguYyZpHqA/ROp0bxVQwUaHDwa3YzzA8jHIXvA94hk3sxvkk0xmIpp4UhBEelzIwwJow==}
 
+  '@push.rocks/smartrust@1.1.1':
+    resolution: {integrity: sha512-NtfTOrVpw0K+z/jW24OmunvZBqkJHfe1tJhTMPFYUb4a5Yt5mtTc3oUvlX+bHarn94Jq0oh0HCLh8xcPQ2Sd7w==}
+
   '@push.rocks/smartrx@3.0.10':
     resolution: {integrity: sha512-USjIYcsSfzn14cwOsxgq/bBmWDTTzy3ouWAnW5NdMyRRzEbmeNrvmy6TRqNeDlJ2PsYNTt1rr/zGUqvIy72ITg==}
 
@@ -1160,6 +1167,9 @@ packages:
   '@push.rocks/taskbuffer@3.5.0':
     resolution: {integrity: sha512-Y9WwIEIyp6oVFdj06j84tfrZIvjhbMb3DF52rYxlTeYLk3W7RPhSg1bGPCbtkXWeKdBrSe37V90BkOG7Qq8Pqg==}
 
+  '@push.rocks/taskbuffer@4.2.0':
+    resolution: {integrity: sha512-ttoBe5y/WXkAo5/wSMcC/Y4Zbyw4XG8kwAsEaqnAPCxa3M9MI1oV/yM1e9gU1IH97HVPidzbTxRU5/PcHDdUsg==}
+
   '@push.rocks/webrequest@3.0.37':
     resolution: {integrity: sha512-fLN7kP6GeHFxE4UH4r9C9pjcQb0QkJxHeAMwXvbOqB9hh0MFNKhtGU7GoaTn8SVRGRMPc9UqZVNwo6u5l8Wn0A==}
 
@@ -3336,6 +3346,10 @@ packages:
     resolution: {integrity: sha512-enIvLvRAFZYXJzkCYG5RKmPfrFArdLv+R+lbQ53BmIMLIry74bjKzX6iHAm8WYamJkhSSEabrWN5D97XnKObjQ==}
     engines: {node: 20 || >=22}
 
+  minimatch@10.1.2:
+    resolution: {integrity: sha512-fu656aJ0n2kcXwsnwnv9g24tkU5uSmOlTjd6WyyaKm2Z+h1qmY6bAjrcaIxF/BslFqbZ8UBtbJi7KgQOZD2PTw==}
+    engines: {node: 20 || >=22}
+
   minimatch@3.1.2:
     resolution: {integrity: sha512-J7p63hRiAjw1NDEww1W7i37+ByIrOWO5XQQAzZ3VOcL0PNybwpfmV/N05zFAzwQ9USyEcX6t3UO+K5aqBQOIHw==}
 
@@ -5551,6 +5565,10 @@ snapshots:
     dependencies:
       '@isaacs/balanced-match': 4.0.1
 
+  '@isaacs/brace-expansion@5.0.1':
+    dependencies:
+      '@isaacs/balanced-match': 4.0.1
+
   '@isaacs/cliui@8.0.2':
     dependencies:
       string-width: 5.1.2
@@ -6513,7 +6531,7 @@ snapshots:
 
   '@push.rocks/smartpromise@4.2.3': {}
 
-  '@push.rocks/smartproxy@22.4.2(socks@2.8.7)':
+  '@push.rocks/smartproxy@23.1.0(socks@2.8.7)':
     dependencies:
       '@push.rocks/lik': 6.2.2
       '@push.rocks/smartacme': 8.0.0(socks@2.8.7)
@@ -6524,13 +6542,14 @@ snapshots:
       '@push.rocks/smartnetwork': 4.4.0
       '@push.rocks/smartpromise': 4.2.3
       '@push.rocks/smartrequest': 5.0.1
+      '@push.rocks/smartrust': 1.1.1
       '@push.rocks/smartrx': 3.0.10
       '@push.rocks/smartstring': 4.1.0
-      '@push.rocks/taskbuffer': 3.5.0
+      '@push.rocks/taskbuffer': 4.2.0
       '@tsclass/tsclass': 9.3.0
       '@types/minimatch': 6.0.0
       '@types/ws': 8.18.1
-      minimatch: 10.1.1
+      minimatch: 10.1.2
       pretty-ms: 9.3.0
       ws: 8.19.0
     transitivePeerDependencies:
@@ -6604,6 +6623,10 @@ snapshots:
 
   '@push.rocks/smartrule@2.0.1': {}
 
+  '@push.rocks/smartrust@1.1.1':
+    dependencies:
+      '@push.rocks/smartpath': 6.0.0
+
   '@push.rocks/smartrx@3.0.10':
     dependencies:
       '@push.rocks/smartpromise': 4.2.3
@@ -6775,6 +6798,22 @@ snapshots:
       - supports-color
       - vue
 
+  '@push.rocks/taskbuffer@4.2.0':
+    dependencies:
+      '@design.estate/dees-element': 2.1.6
+      '@push.rocks/lik': 6.2.2
+      '@push.rocks/smartdelay': 3.0.5
+      '@push.rocks/smartlog': 3.1.10
+      '@push.rocks/smartpromise': 4.2.3
+      '@push.rocks/smartrx': 3.0.10
+      '@push.rocks/smarttime': 4.1.1
+      '@push.rocks/smartunique': 3.0.9
+    transitivePeerDependencies:
+      - '@nuxt/kit'
+      - react
+      - supports-color
+      - vue
+
   '@push.rocks/webrequest@3.0.37':
     dependencies:
       '@push.rocks/smartdelay': 3.0.5
@@ -7631,7 +7670,7 @@ snapshots:
 
   '@types/minimatch@6.0.0':
     dependencies:
-      minimatch: 10.1.1
+      minimatch: 10.1.2
 
   '@types/ms@2.1.0': {}
 
@@ -9397,6 +9436,10 @@ snapshots:
     dependencies:
       '@isaacs/brace-expansion': 5.0.0
 
+  minimatch@10.1.2:
+    dependencies:
+      '@isaacs/brace-expansion': 5.0.1
+
   minimatch@3.1.2:
     dependencies:
       brace-expansion: 1.1.12

readme.hints.md

@@ -1,5 +1,28 @@
 # Implementation Hints and Learnings
 
+## Dependency Upgrade (2026-02-10)
+
+### SmartProxy v23.1.0 Upgrade
+- `@push.rocks/smartproxy`: 22.4.2 → 23.1.0
+
+**Key Changes:**
+- Rust-based proxy components for improved performance
+- Rust binary runs as separate process via IPC
+- `getStatistics()` now returns `Promise<any>` (was synchronous)
+- nftables-proxy removed (not used by dcrouter)
+
+**Code Changes Required:**
+```typescript
+// Old (synchronous)
+const proxyStats = this.dcRouter.smartProxy.getStatistics();
+
+// New (async)
+const proxyStats = await this.dcRouter.smartProxy.getStatistics();
+```
+
+**Files Modified:**
+- `ts/monitoring/classes.metricsmanager.ts` - Added `await` to `getStatistics()` call
+
 ## Dependency Upgrade (2026-02-01)
 
 ### Major Upgrades Completed
@@ -1316,4 +1339,87 @@ The configuration UI has been converted from an editable interface to a read-onl
 - Numbers formatted with locale separators
 - Byte sizes auto-formatted (B, KB, MB, GB)
 - Time values shown with "seconds" suffix
-- Nested objects with visual indentation
+- Nested objects with visual indentation
+
+## Smartdata Cache System (2026-02-03)
+
+### Overview
+DcRouter now uses smartdata + LocalTsmDb for persistent caching. Data is stored at `/etc/dcrouter/tsmdb`.
+
+### Technology Stack
+| Layer | Package | Purpose |
+|-------|---------|---------|
+| ORM | `@push.rocks/smartdata` | Document classes, decorators, queries |
+| Database | `@push.rocks/smartmongo` (LocalTsmDb) | Embedded TsmDB via Unix socket |
+
+### TC39 Decorators
+The project uses TC39 Stage 3 decorators (not experimental decorators). The tsconfig was updated:
+- Removed `experimentalDecorators: true`
+- Removed `emitDecoratorMetadata: true`
+
+This is required for smartdata v7+ compatibility.
+
+### Cache Document Classes
+Located in `ts/cache/documents/`:
+
+| Class | Purpose | Default TTL |
+|-------|---------|-------------|
+| `CachedEmail` | Email queue items | 30 days |
+| `CachedIPReputation` | IP reputation lookups | 24 hours |
+| `CachedBounce` | Bounce records | 30 days |
+| `CachedSuppression` | Suppression list | 30 days / permanent |
+| `CachedDKIMKey` | DKIM key pairs | 90 days |
+
+### Usage Pattern
+```typescript
+// Document classes use smartdata decorators
+@plugins.smartdata.Collection(() => getDb())
+export class CachedEmail extends CachedDocument<CachedEmail> {
+  @plugins.smartdata.svDb()
+  public createdAt: Date = new Date();
+
+  @plugins.smartdata.svDb()
+  public expiresAt: Date = new Date(Date.now() + TTL.DAYS_30);
+
+  @plugins.smartdata.unI()
+  @plugins.smartdata.svDb()
+  public id: string;
+  // ...
+}
+
+// Query examples
+const email = await CachedEmail.getInstance({ id: 'abc123' });
+const pending = await CachedEmail.getInstances({ status: 'pending' });
+await email.save();
+await email.delete();
+```
+
+### Configuration
+```typescript
+const dcRouter = new DcRouter({
+  cacheConfig: {
+    enabled: true,
+    storagePath: '/etc/dcrouter/tsmdb',
+    dbName: 'dcrouter',
+    cleanupIntervalHours: 1,
+    ttlConfig: {
+      emails: 30,       // days
+      ipReputation: 1,  // days
+      bounces: 30,      // days
+      dkimKeys: 90,     // days
+      suppression: 30   // days
+    }
+  }
+});
+```
+
+### Cache Cleaner
+- Runs hourly by default (configurable via `cleanupIntervalHours`)
+- Finds and deletes documents where `expiresAt < now()`
+- Uses smartdata's `getInstances()` + `delete()` pattern
+
+### Key Files
+- `ts/cache/classes.cachedb.ts` - CacheDb singleton wrapper
+- `ts/cache/classes.cached.document.ts` - Base class with TTL support
+- `ts/cache/classes.cache.cleaner.ts` - Periodic cleanup service
+- `ts/cache/documents/*.ts` - Document class definitions

test/suite/smtpclient_error-handling/test.cerr-03.network-failures.ts

@@ -197,65 +197,55 @@ tap.test('CERR-03: Network Failures - should handle EHOSTUNREACH', async () => {
 });
 
 tap.test('CERR-03: Network Failures - should handle packet loss simulation', async () => {
-  // Create a server that randomly drops data
-  let packetCount = 0;
+  // Create a server that sends a greeting but never responds to commands,
+  // simulating complete packet loss after the initial connection.
   const lossyServer = net.createServer((socket) => {
+    socket.on('error', () => {});
     socket.write('220 Lossy server ready\r\n');
-    
-    socket.on('data', (data) => {
-      packetCount++;
-      
-      // Simulate 30% packet loss
-      if (Math.random() > 0.3) {
-        const command = data.toString().trim();
-        if (command.startsWith('EHLO')) {
-          socket.write('250 OK\r\n');
-        } else if (command === 'QUIT') {
-          socket.write('221 Bye\r\n');
-          socket.end();
-        }
-      }
-      // Otherwise, don't respond (simulate packet loss)
+
+    // Never respond to any commands - simulates total packet loss
+    socket.on('data', () => {
+      // Intentionally drop all data to simulate packet loss
     });
   });
-  
+
   await new Promise<void>((resolve) => {
     lossyServer.listen(2558, () => resolve());
   });
-  
+
   const client = createSmtpClient({
     host: 'localhost',
     port: 2558,
     secure: false,
-    connectionTimeout: 1000,
-    socketTimeout: 1000 // Short timeout to detect loss
+    connectionTimeout: 2000,
+    socketTimeout: 2000 // Short timeout to detect loss
   });
-  
+
   let verifyResult = false;
   let errorOccurred = false;
-  
+
   try {
     verifyResult = await client.verify();
     if (verifyResult) {
-      console.log('✅ Connected despite simulated packet loss');
+      console.log('Connection succeeded unexpectedly');
     } else {
       console.log('✅ Connection failed due to packet loss');
     }
   } catch (error) {
     errorOccurred = true;
-    console.log(`✅ Packet loss detected after ${packetCount} packets: ${error.message}`);
+    console.log(`✅ Packet loss detected: ${error.message}`);
   }
-  
-  // Either verification failed or an error occurred - both are expected with packet loss
+
+  // verify() must have returned false or thrown - both indicate packet loss was detected
   expect(!verifyResult || errorOccurred).toBeTrue();
-  
+
   // Clean up client first
   try {
     await client.close();
   } catch (closeError) {
     // Ignore close errors in this test
   }
-  
+
   // Then close server
   await new Promise<void>((resolve) => {
     lossyServer.close(() => resolve());

test/suite/smtpclient_error-handling/test.cerr-04.greylisting-handling.ts

@@ -19,23 +19,31 @@ tap.test('setup - start SMTP server for greylisting tests', async () => {
 tap.test('CERR-04: Basic greylisting response handling', async () => {
   // Create server that simulates greylisting
   const greylistServer = net.createServer((socket) => {
+    socket.on('error', () => {});
     socket.write('220 Greylist Test Server\r\n');
 
     socket.on('data', (data) => {
-      const command = data.toString().trim();
-      
-      if (command.startsWith('EHLO') || command.startsWith('HELO')) {
-        socket.write('250 OK\r\n');
-      } else if (command.startsWith('MAIL FROM')) {
-        socket.write('250 OK\r\n');
-      } else if (command.startsWith('RCPT TO')) {
-        // Simulate greylisting response
-        socket.write('451 4.7.1 Greylisting in effect, please retry later\r\n');
-      } else if (command === 'QUIT') {
-        socket.write('221 Bye\r\n');
-        socket.end();
-      } else {
-        socket.write('250 OK\r\n');
+      const lines = data.toString().split('\r\n').filter((l: string) => l.trim());
+      for (const line of lines) {
+        const command = line.trim();
+
+        if (command.startsWith('EHLO') || command.startsWith('HELO')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('MAIL FROM')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('RCPT TO')) {
+          // Simulate greylisting response
+          socket.write('451 4.7.1 Greylisting in effect, please retry later\r\n');
+        } else if (command.startsWith('RSET')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('DATA')) {
+          socket.write('503 Bad sequence of commands\r\n');
+        } else if (command === 'QUIT') {
+          socket.write('221 Bye\r\n');
+          socket.end();
+        } else if (command.length > 0) {
+          socket.write('250 OK\r\n');
+        }
       }
     });
   });
@@ -48,7 +56,8 @@ tap.test('CERR-04: Basic greylisting response handling', async () => {
     host: '127.0.0.1',
     port: 2560,
     secure: false,
-    connectionTimeout: 5000
+    connectionTimeout: 5000,
+    socketTimeout: 5000
   });
 
   const email = new Email({
@@ -59,7 +68,7 @@ tap.test('CERR-04: Basic greylisting response handling', async () => {
   });
 
   const result = await smtpClient.sendMail(email);
-  
+
   // Should get a failed result due to greylisting
   expect(result.success).toBeFalse();
   console.log('Actual error:', result.error?.message);
@@ -107,20 +116,30 @@ tap.test('CERR-04: Different greylisting response codes', async () => {
 tap.test('CERR-04: Greylisting with temporary failure', async () => {
   // Create server that sends 450 response (temporary failure)
   const tempFailServer = net.createServer((socket) => {
+    socket.on('error', () => {});
     socket.write('220 Temp Fail Server\r\n');
 
     socket.on('data', (data) => {
-      const command = data.toString().trim();
-      
-      if (command.startsWith('EHLO')) {
-        socket.write('250 OK\r\n');
-      } else if (command.startsWith('MAIL FROM')) {
-        socket.write('250 OK\r\n');
-      } else if (command.startsWith('RCPT TO')) {
-        socket.write('450 4.7.1 Mailbox temporarily unavailable\r\n');
-      } else if (command === 'QUIT') {
-        socket.write('221 Bye\r\n');
-        socket.end();
+      const lines = data.toString().split('\r\n').filter((l: string) => l.trim());
+      for (const line of lines) {
+        const command = line.trim();
+
+        if (command.startsWith('EHLO') || command.startsWith('HELO')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('MAIL FROM')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('RCPT TO')) {
+          socket.write('450 4.7.1 Mailbox temporarily unavailable\r\n');
+        } else if (command.startsWith('RSET')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('DATA')) {
+          socket.write('503 Bad sequence of commands\r\n');
+        } else if (command === 'QUIT') {
+          socket.write('221 Bye\r\n');
+          socket.end();
+        } else if (command.length > 0) {
+          socket.write('250 OK\r\n');
+        }
       }
     });
   });
@@ -133,7 +152,8 @@ tap.test('CERR-04: Greylisting with temporary failure', async () => {
     host: '127.0.0.1',
     port: 2561,
     secure: false,
-    connectionTimeout: 5000
+    connectionTimeout: 5000,
+    socketTimeout: 5000
   });
 
   const email = new Email({
@@ -144,7 +164,7 @@ tap.test('CERR-04: Greylisting with temporary failure', async () => {
   });
 
   const result = await smtpClient.sendMail(email);
-  
+
   expect(result.success).toBeFalse();
   console.log('Actual error:', result.error?.message);
   expect(result.error?.message).toMatch(/450|temporary|rejected/i);
@@ -199,20 +219,30 @@ tap.test('CERR-04: Basic connection verification', async () => {
 tap.test('CERR-04: Server with RCPT rejection', async () => {
   // Test server rejecting at RCPT TO stage
   const rejectServer = net.createServer((socket) => {
+    socket.on('error', () => {});
     socket.write('220 Reject Server\r\n');
 
     socket.on('data', (data) => {
-      const command = data.toString().trim();
-      
-      if (command.startsWith('EHLO')) {
-        socket.write('250 OK\r\n');
-      } else if (command.startsWith('MAIL FROM')) {
-        socket.write('250 OK\r\n');
-      } else if (command.startsWith('RCPT TO')) {
-        socket.write('451 4.2.1 Recipient rejected temporarily\r\n');
-      } else if (command === 'QUIT') {
-        socket.write('221 Bye\r\n');
-        socket.end();
+      const lines = data.toString().split('\r\n').filter((l: string) => l.trim());
+      for (const line of lines) {
+        const command = line.trim();
+
+        if (command.startsWith('EHLO') || command.startsWith('HELO')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('MAIL FROM')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('RCPT TO')) {
+          socket.write('451 4.2.1 Recipient rejected temporarily\r\n');
+        } else if (command.startsWith('RSET')) {
+          socket.write('250 OK\r\n');
+        } else if (command.startsWith('DATA')) {
+          socket.write('503 Bad sequence of commands\r\n');
+        } else if (command === 'QUIT') {
+          socket.write('221 Bye\r\n');
+          socket.end();
+        } else if (command.length > 0) {
+          socket.write('250 OK\r\n');
+        }
       }
     });
   });
@@ -225,7 +255,8 @@ tap.test('CERR-04: Server with RCPT rejection', async () => {
     host: '127.0.0.1',
     port: 2562,
     secure: false,
-    connectionTimeout: 5000
+    connectionTimeout: 5000,
+    socketTimeout: 5000
   });
 
   const email = new Email({
@@ -236,7 +267,7 @@ tap.test('CERR-04: Server with RCPT rejection', async () => {
   });
 
   const result = await smtpClient.sendMail(email);
-  
+
   expect(result.success).toBeFalse();
   console.log('Actual error:', result.error?.message);
   expect(result.error?.message).toMatch(/451|reject|recipient/i);

test/test.dns-socket-handler.ts

@@ -8,7 +8,8 @@ tap.test('should NOT instantiate DNS server when dnsNsDomains is not set', async
   dcRouter = new DcRouter({
     smartProxyConfig: {
       routes: []
-    }
+    },
+    cacheConfig: { enabled: false }
   });
 
   await dcRouter.start();

test/test.email-socket-handler.ts

@@ -15,7 +15,8 @@ tap.test('should use traditional port forwarding when useSocketHandler is false'
     },
     smartProxyConfig: {
       routes: []
-    }
+    },
+    cacheConfig: { enabled: false }
   });
   
   await dcRouter.start();
@@ -51,7 +52,8 @@ tap.test('should use socket-handler mode when useSocketHandler is true', async (
     },
     smartProxyConfig: {
       routes: []
-    }
+    },
+    cacheConfig: { enabled: false }
   });
   
   await dcRouter.start();
@@ -85,7 +87,7 @@ tap.test('should generate correct email routes for each port', async () => {
     useSocketHandler: true
   };
 
-  dcRouter = new DcRouter({ emailConfig });
+  dcRouter = new DcRouter({ emailConfig, cacheConfig: { enabled: false } });
 
   // Access the private method to generate routes
   const emailRoutes = (dcRouter as any).generateEmailRoutes(emailConfig);
@@ -119,7 +121,8 @@ tap.test('email socket handler should handle different ports correctly', async (
       domains: ['test.local'],
       routes: [],
       useSocketHandler: true
-    }
+    },
+    cacheConfig: { enabled: false }
   });
 
   await dcRouter.start();
@@ -145,7 +148,8 @@ tap.test('email server handleSocket method should work', async () => {
       domains: ['test.local'],
       routes: [],
       useSocketHandler: true
-    }
+    },
+    cacheConfig: { enabled: false }
   });
 
   await dcRouter.start();
@@ -182,11 +186,12 @@ tap.test('should not create SMTP servers when useSocketHandler is true', async (
       domains: ['test.local'],
       routes: [],
       useSocketHandler: true
-    }
+    },
+    cacheConfig: { enabled: false }
   });
-  
+
   await dcRouter.start();
-  
+
   // The email server should not have any SMTP server instances
   const emailServer = (dcRouter as any).emailServer;
   expect(emailServer).toBeDefined();
@@ -209,7 +214,7 @@ tap.test('TLS handling should differ between ports', async () => {
     useSocketHandler: false // Use traditional mode to check TLS config
   };
 
-  dcRouter = new DcRouter({ emailConfig });
+  dcRouter = new DcRouter({ emailConfig, cacheConfig: { enabled: false } });
 
   const emailRoutes = (dcRouter as any).generateEmailRoutes(emailConfig);
 

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@serve.zone/dcrouter',
-  version: '4.0.0',
+  version: '4.1.1',
   description: 'A multifaceted routing service handling mail and SMS delivery functions.'
 }

ts/cache/classes.cache.cleaner.ts

@@ -98,24 +98,20 @@ export class CacheCleaner {
     const results: { collection: string; deleted: number }[] = [];
 
     try {
-      // Clean CachedEmail documents
-      const emailsDeleted = await this.cleanCollection(CachedEmail, now);
+      // Clean each collection using smartdata's getInstances + delete pattern
+      const emailsDeleted = await this.cleanExpiredDocuments(CachedEmail, now);
       results.push({ collection: 'CachedEmail', deleted: emailsDeleted });
 
-      // Clean CachedIPReputation documents
-      const ipReputationDeleted = await this.cleanCollection(CachedIPReputation, now);
+      const ipReputationDeleted = await this.cleanExpiredDocuments(CachedIPReputation, now);
       results.push({ collection: 'CachedIPReputation', deleted: ipReputationDeleted });
 
-      // Clean CachedBounce documents
-      const bouncesDeleted = await this.cleanCollection(CachedBounce, now);
+      const bouncesDeleted = await this.cleanExpiredDocuments(CachedBounce, now);
       results.push({ collection: 'CachedBounce', deleted: bouncesDeleted });
 
-      // Clean CachedSuppression documents (but not permanent ones)
-      const suppressionDeleted = await this.cleanCollection(CachedSuppression, now);
+      const suppressionDeleted = await this.cleanExpiredDocuments(CachedSuppression, now);
       results.push({ collection: 'CachedSuppression', deleted: suppressionDeleted });
 
-      // Clean CachedDKIMKey documents
-      const dkimDeleted = await this.cleanCollection(CachedDKIMKey, now);
+      const dkimDeleted = await this.cleanExpiredDocuments(CachedDKIMKey, now);
       results.push({ collection: 'CachedDKIMKey', deleted: dkimDeleted });
 
       // Log results
@@ -137,17 +133,30 @@ export class CacheCleaner {
   }
 
   /**
-   * Clean expired documents from a specific collection
+   * Clean expired documents from a specific collection using smartdata API
    */
-  private async cleanCollection<T>(
-    documentClass: { deleteMany: (filter: any) => Promise<any> },
+  private async cleanExpiredDocuments<T extends { delete: () => Promise<void> }>(
+    documentClass: { getInstances: (filter: any) => Promise<T[]> },
     now: Date
   ): Promise<number> {
     try {
-      const result = await documentClass.deleteMany({
+      // Find all expired documents
+      const expiredDocs = await documentClass.getInstances({
         expiresAt: { $lt: now },
       });
-      return result?.deletedCount || 0;
+
+      // Delete each expired document
+      let deletedCount = 0;
+      for (const doc of expiredDocs) {
+        try {
+          await doc.delete();
+          deletedCount++;
+        } catch (deleteError) {
+          logger.log('warn', `Failed to delete expired document: ${deleteError.message}`);
+        }
+      }
+
+      return deletedCount;
     } catch (error) {
       logger.log('error', `Error cleaning collection: ${error.message}`);
       return 0;

ts/cache/classes.cached.document.ts

@@ -7,24 +7,27 @@ import * as plugins from '../plugins.js';
  * - Automatic timestamps (createdAt, lastAccessedAt)
  * - TTL/expiration support (expiresAt)
  * - Helper methods for TTL management
+ *
+ * NOTE: Subclasses MUST add @svDb() decorators to createdAt, expiresAt, and lastAccessedAt
+ * since decorators on abstract classes don't propagate correctly.
  */
 export abstract class CachedDocument<T extends CachedDocument<T>> extends plugins.smartdata.SmartDataDbDoc<T, T> {
   /**
    * Timestamp when the document was created
+   * NOTE: Subclasses must add @svDb() decorator
    */
-  @plugins.smartdata.svDb()
   public createdAt: Date = new Date();
 
   /**
    * Timestamp when the document expires and should be cleaned up
+   * NOTE: Subclasses must add @svDb() decorator
    */
-  @plugins.smartdata.svDb()
   public expiresAt: Date;
 
   /**
    * Timestamp of last access (for LRU-style eviction if needed)
+   * NOTE: Subclasses must add @svDb() decorator
    */
-  @plugins.smartdata.svDb()
   public lastAccessedAt: Date = new Date();
 
   /**

ts/cache/classes.cachedb.ts

@@ -69,19 +69,21 @@ export class CacheDb {
 
       // Create LocalTsmDb instance
       this.localTsmDb = new plugins.smartmongo.LocalTsmDb({
-        dbDir: this.options.storagePath,
+        folderPath: this.options.storagePath,
       });
 
-      // Start LocalTsmDb and get connection URI
-      await this.localTsmDb.start();
-      const mongoDescriptor = this.localTsmDb.mongoDescriptor;
+      // Start LocalTsmDb and get connection info
+      const connectionInfo = await this.localTsmDb.start();
 
       if (this.options.debug) {
-        logger.log('debug', `LocalTsmDb started with descriptor: ${JSON.stringify(mongoDescriptor)}`);
+        logger.log('debug', `LocalTsmDb started with URI: ${connectionInfo.connectionUri}`);
       }
 
-      // Initialize smartdata with the connection
-      this.smartdataDb = new plugins.smartdata.SmartdataDb(mongoDescriptor);
+      // Initialize smartdata with the connection URI
+      this.smartdataDb = new plugins.smartdata.SmartdataDb({
+        mongoDbUrl: connectionInfo.connectionUri,
+        mongoDbName: this.options.dbName,
+      });
       await this.smartdataDb.init();
 
       this.isStarted = true;

ts/cache/documents/classes.cached.bounce.ts

@@ -33,6 +33,16 @@ export type TBounceCategory =
  */
 @plugins.smartdata.Collection(() => getDb())
 export class CachedBounce extends CachedDocument<CachedBounce> {
+  // TTL fields from base class (decorators required on concrete class)
+  @plugins.smartdata.svDb()
+  public createdAt: Date = new Date();
+
+  @plugins.smartdata.svDb()
+  public expiresAt: Date = new Date(Date.now() + TTL.DAYS_30);
+
+  @plugins.smartdata.svDb()
+  public lastAccessedAt: Date = new Date();
+
   /**
    * Unique identifier for this bounce record
    */

ts/cache/documents/classes.cached.dkim.ts

@@ -15,6 +15,16 @@ const getDb = () => CacheDb.getInstance().getDb();
  */
 @plugins.smartdata.Collection(() => getDb())
 export class CachedDKIMKey extends CachedDocument<CachedDKIMKey> {
+  // TTL fields from base class (decorators required on concrete class)
+  @plugins.smartdata.svDb()
+  public createdAt: Date = new Date();
+
+  @plugins.smartdata.svDb()
+  public expiresAt: Date = new Date(Date.now() + TTL.DAYS_90);
+
+  @plugins.smartdata.svDb()
+  public lastAccessedAt: Date = new Date();
+
   /**
    * Composite key: domain:selector
    */

ts/cache/documents/classes.cached.email.ts

@@ -20,6 +20,16 @@ const getDb = () => CacheDb.getInstance().getDb();
  */
 @plugins.smartdata.Collection(() => getDb())
 export class CachedEmail extends CachedDocument<CachedEmail> {
+  // TTL fields from base class (decorators required on concrete class)
+  @plugins.smartdata.svDb()
+  public createdAt: Date = new Date();
+
+  @plugins.smartdata.svDb()
+  public expiresAt: Date = new Date(Date.now() + TTL.DAYS_30);
+
+  @plugins.smartdata.svDb()
+  public lastAccessedAt: Date = new Date();
+
   /**
    * Unique identifier for this email
    */

ts/cache/documents/classes.cached.ip.reputation.ts

@@ -30,6 +30,16 @@ export interface IIPReputationData {
  */
 @plugins.smartdata.Collection(() => getDb())
 export class CachedIPReputation extends CachedDocument<CachedIPReputation> {
+  // TTL fields from base class (decorators required on concrete class)
+  @plugins.smartdata.svDb()
+  public createdAt: Date = new Date();
+
+  @plugins.smartdata.svDb()
+  public expiresAt: Date = new Date(Date.now() + TTL.HOURS_24);
+
+  @plugins.smartdata.svDb()
+  public lastAccessedAt: Date = new Date();
+
   /**
    * IP address (unique identifier)
    */

ts/cache/documents/classes.cached.suppression.ts

@@ -27,6 +27,16 @@ export type TSuppressionReason =
  */
 @plugins.smartdata.Collection(() => getDb())
 export class CachedSuppression extends CachedDocument<CachedSuppression> {
+  // TTL fields from base class (decorators required on concrete class)
+  @plugins.smartdata.svDb()
+  public createdAt: Date = new Date();
+
+  @plugins.smartdata.svDb()
+  public expiresAt: Date = new Date(Date.now() + TTL.DAYS_30);
+
+  @plugins.smartdata.svDb()
+  public lastAccessedAt: Date = new Date();
+
   /**
    * Email address to suppress (unique identifier)
    */

ts/classes.dcrouter.ts

@@ -11,6 +11,8 @@ import { logger } from './logger.js';
 import { configureEmailStorage, configureEmailServer } from './mail/delivery/index.js';
 // Import storage manager
 import { StorageManager, type IStorageConfig } from './storage/index.js';
+// Import cache system
+import { CacheDb, CacheCleaner, type ICacheDbOptions } from './cache/index.js';
 
 import { OpsServer } from './opsserver/index.js';
 import { MetricsManager } from './monitoring/index.js';
@@ -111,6 +113,36 @@ export interface IDcRouterOptions {
   /** Storage configuration */
   storage?: IStorageConfig;
 
+  /**
+   * Cache database configuration using smartdata and LocalTsmDb
+   * Provides persistent caching for emails, IP reputation, bounces, etc.
+   */
+  cacheConfig?: {
+    /** Enable cache database (default: true) */
+    enabled?: boolean;
+    /** Storage path for TsmDB data (default: /etc/dcrouter/tsmdb) */
+    storagePath?: string;
+    /** Database name (default: dcrouter) */
+    dbName?: string;
+    /** Default TTL in days for cached items (default: 30) */
+    defaultTTLDays?: number;
+    /** Cleanup interval in hours (default: 1) */
+    cleanupIntervalHours?: number;
+    /** TTL configuration per data type (in days) */
+    ttlConfig?: {
+      /** Email cache TTL (default: 30 days) */
+      emails?: number;
+      /** IP reputation cache TTL (default: 1 day) */
+      ipReputation?: number;
+      /** Bounce records TTL (default: 30 days) */
+      bounces?: number;
+      /** DKIM keys TTL (default: 90 days) */
+      dkimKeys?: number;
+      /** Suppression list TTL (default: 30 days, can be permanent) */
+      suppression?: number;
+    };
+  };
+
   /**
    * RADIUS server configuration for network authentication
    * Enables MAC Authentication Bypass (MAB) and VLAN assignment
@@ -134,7 +166,7 @@ export interface PortProxyRuleContext {
 
 export class DcRouter {
   public options: IDcRouterOptions;
-  
+
   // Core services
   public smartProxy?: plugins.smartproxy.SmartProxy;
   public dnsServer?: plugins.smartdns.dnsServerMod.DnsServer;
@@ -143,11 +175,15 @@ export class DcRouter {
   public storageManager: StorageManager;
   public opsServer: OpsServer;
   public metricsManager?: MetricsManager;
-  
+
+  // Cache system (smartdata + LocalTsmDb)
+  public cacheDb?: CacheDb;
+  public cacheCleaner?: CacheCleaner;
+
   // TypedRouter for API endpoints
   public typedrouter = new plugins.typedrequest.TypedRouter();
-  
-  // Environment access 
+
+  // Environment access
   private qenv = new plugins.qenv.Qenv('./', '.nogit/');
   
   constructor(optionsArg: IDcRouterOptions) {
@@ -170,6 +206,11 @@ export class DcRouter {
     await this.opsServer.start();
 
     try {
+      // Initialize cache database if enabled (default: enabled)
+      if (this.options.cacheConfig?.enabled !== false) {
+        await this.setupCacheDb();
+      }
+
       // Initialize MetricsManager
       this.metricsManager = new MetricsManager(this);
       await this.metricsManager.start();
@@ -291,9 +332,45 @@ export class DcRouter {
       console.log(`   └─ Path: ${this.options.storage.fsPath || 'default'}`);
     }
 
+    // Cache database summary
+    if (this.cacheDb) {
+      console.log('\n🗄️  Cache Database (smartdata + LocalTsmDb):');
+      console.log(`   ├─ Storage: ${this.cacheDb.getStoragePath()}`);
+      console.log(`   ├─ Database: ${this.cacheDb.getDbName()}`);
+      console.log(`   └─ Cleaner: ${this.cacheCleaner?.isActive() ? 'Active' : 'Inactive'} (${(this.options.cacheConfig?.cleanupIntervalHours || 1)}h interval)`);
+    }
+
     console.log('\n✅ All services are running\n');
   }
   
+  /**
+   * Set up the cache database (smartdata + LocalTsmDb)
+   */
+  private async setupCacheDb(): Promise<void> {
+    logger.log('info', 'Setting up CacheDb...');
+
+    const cacheConfig = this.options.cacheConfig || {};
+
+    // Initialize CacheDb singleton
+    this.cacheDb = CacheDb.getInstance({
+      storagePath: cacheConfig.storagePath || '/etc/dcrouter/tsmdb',
+      dbName: cacheConfig.dbName || 'dcrouter',
+      debug: false,
+    });
+
+    await this.cacheDb.start();
+
+    // Start the cache cleaner
+    const cleanupIntervalMs = (cacheConfig.cleanupIntervalHours || 1) * 60 * 60 * 1000;
+    this.cacheCleaner = new CacheCleaner(this.cacheDb, {
+      intervalMs: cleanupIntervalMs,
+      verbose: false,
+    });
+    this.cacheCleaner.start();
+
+    logger.log('info', `CacheDb initialized at ${this.cacheDb.getStoragePath()}`);
+  }
+
   /**
    * Set up SmartProxy with direct configuration and automatic email routes
    */
@@ -600,10 +677,13 @@ export class DcRouter {
     console.log('Stopping DcRouter services...');
 
     await this.opsServer.stop();
-    
+
     try {
       // Stop all services in parallel for faster shutdown
       await Promise.all([
+        // Stop cache cleaner if running
+        this.cacheCleaner ? Promise.resolve(this.cacheCleaner.stop()) : Promise.resolve(),
+
         // Stop metrics manager if running
         this.metricsManager ? this.metricsManager.stop().catch(err => console.error('Error stopping MetricsManager:', err)) : Promise.resolve(),
 
@@ -623,7 +703,12 @@ export class DcRouter {
           this.radiusServer.stop().catch(err => console.error('Error stopping RADIUS server:', err)) :
           Promise.resolve()
       ]);
-      
+
+      // Stop cache database after other services (they may need it during shutdown)
+      if (this.cacheDb) {
+        await this.cacheDb.stop().catch(err => console.error('Error stopping CacheDb:', err));
+      }
+
       console.log('All DcRouter services stopped');
     } catch (error) {
       console.error('Error during DcRouter shutdown:', error);

ts/monitoring/classes.metricsmanager.ts

@@ -123,8 +123,8 @@ export class MetricsManager {
     return this.metricsCache.get('serverStats', async () => {
       const smartMetricsData = await this.smartMetrics.getMetrics();
       const proxyMetrics = this.dcRouter.smartProxy ? this.dcRouter.smartProxy.getMetrics() : null;
-      const proxyStats = this.dcRouter.smartProxy ? this.dcRouter.smartProxy.getStatistics() : null;
-      
+      const proxyStats = this.dcRouter.smartProxy ? await this.dcRouter.smartProxy.getStatistics() : null;
+
       return {
         uptime: process.uptime(),
         startTime: Date.now() - (process.uptime() * 1000),

ts_web/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@serve.zone/dcrouter',
-  version: '4.0.0',
+  version: '4.1.1',
   description: 'A multifaceted routing service handling mail and SMS delivery functions.'
 }

tsconfig.json

@@ -1,8 +1,5 @@
 {
   "compilerOptions": {
-    "experimentalDecorators": true,
-    "emitDecoratorMetadata": true,
-    "useDefineForClassFields": false,
     "target": "ES2022",
     "module": "NodeNext",
     "moduleResolution": "NodeNext",