feat: service/cache/incr (#73)

* feat: add cache.incr

* test:  improve controller topic unit test cov (#59)

* test: f

* test: f

* chore: fix lint

* test: f

* test: f

Author: forl

app/service/cache.js

@@ -22,6 +22,16 @@ class CacheService extends Service {
     const duration = (Date.now() - t);
     logger.debug('Cache', 'set', key, (duration + 'ms').green);
   }
+
+  async incr(key, seconds) {
+    const { redis, logger } = this.app;
+    const t = Date.now();
+    const result = await redis.multi().incr(key).expire(key, seconds)
+      .exec();
+    const duration = (Date.now() - t);
+    logger.debug('Cache', 'set', key, (duration + 'ms').green);
+    return result[0][1];
+  }
 }
 
 module.exports = CacheService;

test/app/service/cache.test.js

@@ -16,4 +16,23 @@ describe('test/app/service/cache.test.js', () => {
     const result2 = await ctx.service.cache.get('greet123');
     assert(result2 === undefined);
   });
+
+  it('incr should ok', async () => {
+    const ctx = app.mockContext();
+    const key1 = '' + Date.now();
+
+    let initNumber = await ctx.service.cache.incr(key1, 4);
+    assert(initNumber === 1);
+    await new Promise(resolve => setTimeout(resolve, 2000));
+    let secondNumber = await ctx.service.cache.incr(key1, 1);
+    assert(secondNumber === 2);
+
+    // test expire works
+    const key2 = '' + Date.now();
+    initNumber = await ctx.service.cache.incr(key2, 2);
+    assert(initNumber === 1);
+    await new Promise(resolve => setTimeout(resolve, 3000));
+    secondNumber = await ctx.service.cache.incr(key2, 1);
+    assert(secondNumber === 1);
+  });
 });