update

consumer/.gitignore

@@ -5,5 +5,6 @@ ecosystem.config.cjs
 ecosystem.config.js
 
 scripts/start_dev.js
+scripts/start_dev_prod.js
 dist
 src/shared

consumer/package.json

@@ -18,6 +18,7 @@
   "main": "dist/index.js",
   "scripts": {
     "dev": "node scripts/start_dev.js",
+    "dev_prod": "node scripts/start_dev_prod.js",
     "compile": "tsc",
     "build": "npm run compile && npm run create_db",
     "create_db": "cd scripts && ts-node create_database.ts",

consumer/src/index.ts

@@ -52,10 +52,10 @@ async function processStreamEntry(data: Record<string, string>) {
         const { pid, sessionHash } = data;
 
         const project = await ProjectModel.exists({ _id: pid });
-        if (!project) return console.log('No project');
+        if (!project) return;
 
         const canLog = await checkLimits(pid);
-        if (!canLog) return console.log('No limits');
+        if (!canLog) return;
 
         if (eventType === 'event') {
             await process_event(data, sessionHash);