+ Add graceful stop to sinergy with process managers (i.e. PM2)

+ Add npm start script

memoryStore.js

@@ -1,14 +1,17 @@
 const MemoryStore = {
   games: new Map(),
-  set: async function (gameId, gameState) {
+  async set(gameId, gameState) {
     this.games.set(gameId, gameState);
     return Promise.resolve(gameState.id);
   },
-  get: async function (gameId) {
+  async get(gameId) {
     return Promise.resolve(this.games.get(gameId));
   },
-  del: async function (gameId) {
+  async del(gameId) {
     return Promise.resolve(this.games.delete(gameId));
+  },
+  async quit() {
+    return Promise.resolve('OK');
   }
 };
 

moonBot.js

@@ -8,7 +8,9 @@ const { concatMap, map } = require('rxjs/operators');
 const { partition } = require('rxjs');
 const keyBoards = require('./telegramKeyboard');
 const { Rules, GameEventType } = require('./gameRules');
-const Store = require('./memoryStore');
+const Store = require('./memoryStore'); //memory store for testing and develop
+//const Store = require('./redisStore'); //redis store recommended for production
+
 const showStateEvent = Symbol.for("SHOW_GAME_STATE");
 
 const token = process.env.MOON_BOT_TOKEN;
@@ -368,4 +370,12 @@ Operation  Target  Cost
 
 All 2 register operations store the result in the first register.
 "or A B" will modify register A.
-"mov A B" will copy register B value into register A.\`\`\``;
+"mov A B" will copy register B value into register A.\`\`\``;
+
+process.on('SIGINT', function () {
+
+  eventStream.complete();
+  eventStream.unsubscribe();
+  Game.Quit();
+
+});

moonGame.js

@@ -154,6 +154,10 @@ function Game(store) {
       gameState = StateManager.fixError({ gameState, playerId, error }).gameState;
 
       return gameState;
+    },
+
+    async Quit() {
+      return store.quit();
     }
   };
 

package.json

@@ -4,6 +4,7 @@
   "description": "tabletop moon game on telegram",
   "main": "moonBot.js",
   "scripts": {
+    "start": "node moonBot.js",
     "test": "mocha"
   },
   "repository": {