chayen - npm Package Compare versions

Comparing version 0.1.4 to 0.2.0

dist/Server.d.ts

@@ -8,8 +8,10 @@ /// <reference types="node" />
 }
+export interface CacheOption {
+    ttl: number;
+    limit?: number;
+}
 export interface Endpoint {
     schema: Joi.Schema;
     timeout?: number;
-    cache?: {
-        ttl: number;
-    };
+    cacheOption?: CacheOption | false;
     handler(payload: any, delegator: Delegator): any;
@@ -36,3 +38,4 @@ }
     terminate(): Promise<void>;
+    private shouldReturnCache(cacheOption, cacheKey);
     private executeEndpoint(topic, payload);
 }

dist/Server.js

@@ -78,3 +78,2 @@ "use strict";
                 return;
-            this.server.close();
             if (this.redis) {
@@ -88,5 +87,25 @@ try {
             }
+            this.server.close();
             delete this.server;
         });
     }
+    shouldReturnCache(cacheOption, cacheKey) {
+        return __awaiter(this, void 0, void 0, function* () {
+            if (!this.redis || !cacheOption)
+                return false;
+            if (!cacheOption.limit)
+                return true;
+            try {
+                const cacheCount = yield this.redis.incr(`${cacheKey}::count`);
+                if (cacheCount === 1) {
+                    yield this.redis.expire(`${cacheKey}::count`, cacheOption.ttl);
+                }
+                return cacheCount > cacheOption.limit;
+            }
+            catch (err) {
+                console.error(err);
+            }
+            return false;
+        });
+    }
     executeEndpoint(topic, payload) {
@@ -103,5 +122,6 @@ return __awaiter(this, void 0, void 0, function* () {
             }
-            if (this.redis && endpoint.cache) {
+            const cacheKey = _getCacheKey(topic, payload);
+            if (yield this.shouldReturnCache(endpoint.cacheOption, cacheKey)) {
                 try {
-                    const cache = yield this.redis.get(_getCacheKey(topic, payload));
+                    const cache = yield this.redis.get(cacheKey);
                     if (cache)
@@ -130,7 +150,6 @@ return JSON.parse(cache).v;
             }
-            if (this.redis && endpoint.cache) {
+            if (this.redis && endpoint.cacheOption) {
                 try {
-                    const key = _getCacheKey(topic, payload);
                     const value = JSON.stringify({ v: result });
-                    yield this.redis.set([key, value, 'EX', endpoint.cache.ttl]);
+                    yield this.redis.set([cacheKey, value, 'EX', endpoint.cacheOption.ttl]);
                 }
@@ -137,0 +156,0 @@ catch (err) {

package.json

 {
   "name": "chayen",
-  "version": "0.1.4",
+  "version": "0.2.0",
   "description": "An RPC framework with so much hype going on. such wow.",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Lines of code

239

increased by10.14%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

126345

decreased by-2.72%

No dependency changes