* 중복 요청 방지를 위한 atomic, relaese 추가

* preload 로직 오류 수정.

Author: egg-

lib/redmoon.js

@@ -15,9 +15,11 @@ function Redmoon (config) {
     host: '127.0.0.1',
     port: 6379,
     timeout: 5000, // 5 sec
-    buffer: 100
+    buffer: 100,
+    ttl: 5
   }
   this.key = {
+    atomic: [this.config.scope, 'atomic'].join(':'), // hash
     meta: [this.config.scope, 'meta'].join(':'), // hash
     cycle: [this.config.scope, 'cycle'].join(':') // set (sorted)
   }
@@ -94,24 +96,24 @@ Redmoon.prototype.load = function (cb, key, page, limit) {
 
         // migrate meta
         var meta = {}
-        var totalcount = 0
+        var loadedcount = 0
         for (var j = 1, parsed = null; j < metas.length; j += 2) {
           parsed = JSON.parse(metas[j])
           meta[parsed.provider] = parsed
-          totalcount += parseInt(parsed.totalcount, 10)
+          loadedcount += (parsed.page - 1) * (parsed.limit || 0)
         }
 
-        cb(null, items, meta)
-
-        // check data pool
-        if (end + self.config.buffer > totalcount) {
-          // preload data
+        // required collection
+        if (end + self.config.buffer > loadedcount) {
           self._nrp.emit([self.config.name, uuid].join(':'), {
+            uuid: uuid,
             key: key,
             topic: self.toTopic(uuid),
             meta: meta
           })
         }
+
+        cb(null, items, meta)
       })
     } else {
       var timeout = null
@@ -131,6 +133,7 @@ Redmoon.prototype.load = function (cb, key, page, limit) {
         self.load(cb, key, page, limit)
       })
       self._nrp.emit([self.config.name, uuid].join(':'), {
+        uuid: uuid,
         key: key,
         topic: topic
       })
@@ -142,7 +145,6 @@ Redmoon.prototype.load = function (cb, key, page, limit) {
 
 Redmoon.prototype.add = function (cb, moon, meta, items) {
   var uuid = Redmoon.uuid(moon.key)
-
   var multi = this._client.multi()
     .zadd(this.key.cycle, Redmoon.unix(), uuid)
     .hset(this.key.meta, [uuid, meta.provider || shortid.generate()].join(':'), JSON.stringify(meta))
@@ -170,6 +172,34 @@ Redmoon.prototype.trigger = function (topic, data) {
   this._nrp.emit(topic, data || {})
 }
 
+// 중복 이벤트 처리를 방지 목적.
+Redmoon.prototype.atomic = function (cb, uuid) {
+  // atomic
+  var self = this
+  var key = [this.key.atomic, uuid].join(':')
+
+  this._client.get(key, function (err, item) {
+    if (err) {
+      return console.error(err)
+    }
+
+    if (item) {
+      // already requested
+      return true
+    }
+
+    self._client.multi()
+      .set(key, uuid)
+      .expire(key, self.config.ttl)
+      .exec(cb)
+  })
+}
+
+// 중복 이벤트 처리를 방지 목적.
+Redmoon.prototype.release = function (cb, uuid) {
+  this._client.del([this.key.atomic, uuid].join(':'), cb)
+}
+
 Redmoon.prototype.end = function () {
   if (this._client) {
     this._client.end()