diff --git a/consumer/.gitignore b/consumer/.gitignore index e2a45ec..313de31 100644 --- a/consumer/.gitignore +++ b/consumer/.gitignore @@ -5,5 +5,6 @@ ecosystem.config.cjs ecosystem.config.js scripts/start_dev.js +scripts/start_dev_prod.js dist src/shared \ No newline at end of file diff --git a/consumer/package.json b/consumer/package.json index 88d7cf6..563a010 100644 --- a/consumer/package.json +++ b/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", diff --git a/consumer/src/index.ts b/consumer/src/index.ts index 24bdd63..6c1e33a 100644 --- a/consumer/src/index.ts +++ b/consumer/src/index.ts @@ -52,10 +52,10 @@ async function processStreamEntry(data: Record) { 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);