Server: keep exec history in-memory up-to MAX_EVENT_LIMIT

ropelive · Nov 21, 2017 · 026b62b · 026b62b
1 parent f93f1a2
commit 026b62b
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/src/api.js b/src/api.js
@@ -1,4 +1,4 @@
-import { MAX_QUERY_LIMIT, LOG_LEVEL } from './constants'
+import { TYPES, MAX_EVENT_LIMIT, MAX_QUERY_LIMIT, LOG_LEVEL } from './constants'
 import readline from 'readline'
 
 function __share(target, name, method, as) {
@@ -76,7 +76,11 @@ export default class RopeApi {
       return callback({ message: 'No kite available' })
     }
 
-    this.notifyNodes('node.exec', { from: requester, to: kiteId, method })
+    this.addToExecHistory({
+      from: requester,
+      to: kiteId,
+      method,
+    })
 
     this.ctx.connections
       .get(kiteId)

diff --git a/src/constants.js b/src/constants.js
@@ -1,5 +1,6 @@
 export const AUTH_SERVER = process.env.AUTH_SERVER || 'https://rope.live'
 export const MAX_QUERY_LIMIT = 200
+export const MAX_EVENT_LIMIT = 200
 export const BLACKLIST_LIMIT = 10
 export const LOG_LEVEL = process.env.ROPE_DEBUG || 0
 export const PORT = 3210

diff --git a/src/context.js b/src/context.js
@@ -6,7 +6,7 @@ export default class RopeContext {
       ['node.added', new Set()],
       ['node.removed', new Set()],
     ])
-
+    this.execHistory = new Array()
     this.blackListCandidates = new Object()
     this.blackList = new Set()
   }