Check workspace event

lib/logger.ts

@@ -0,0 +1,20 @@
+import { createLogger as createWinstonLogger, format, transports, Logger } from 'winston';
+
+/**
+ * Creates new logger instance
+ */
+export default function createLogger(): Logger {
+  return createWinstonLogger({
+    level: process.env.LOG_LEVEL || 'info',
+    transports: [
+      new transports.Console({
+        format: format.combine(
+          format.timestamp(),
+          format.colorize(),
+          format.simple(),
+          format.printf((msg) => `${msg.timestamp} - ${msg.level}: ${msg.message}`)
+        ),
+      }),
+    ],
+  });
+}

lib/worker.ts

@@ -1,11 +1,11 @@
 import * as amqp from 'amqplib';
 import * as client from 'prom-client';
-import { createLogger, format, transports, Logger } from 'winston';
 import { WorkerTask } from './types/worker-task';
 import { CriticalError, NonCriticalError, ParsingError } from './workerErrors';
 import { MongoError } from 'mongodb';
 import HawkCatcher from '@hawk.so/nodejs';
 import CacheController from '../lib/cache/controller';
+import createLogger from './logger';
 
 /**
  * Base worker class for processing tasks
@@ -46,19 +46,7 @@ export abstract class Worker {
    * Logger module
    * (default level='info')
    */
-  protected logger: Logger = createLogger({
-    level: process.env.LOG_LEVEL || 'info',
-    transports: [
-      new transports.Console({
-        format: format.combine(
-          format.timestamp(),
-          format.colorize(),
-          format.simple(),
-          format.printf((msg) => `${msg.timestamp} - ${msg.level}: ${msg.message}`)
-        ),
-      }),
-    ],
-  });
+  protected logger = createLogger();
 
   /**
    * Cache module.

workers/limiter/README.md

@@ -10,4 +10,29 @@ If so, the Limiter puts information to Redis about the workspace's projects for
 3. `yarn install`
 4. `yarn run-limiter`
 
+## Event types
 
+### Regular check
+
+Serves to check current total events count in workspaces and blocks events receiving if workspace exceed the limit.
+
+Event shape:
+
+```json
+{
+  "type":"regular-workspaces-check"
+}
+```
+
+### Single workspace check
+
+Serves to check single workspace by id. Blocks workspace if the event limit is exceeded and unblocks if not.
+
+Event shape:
+
+```json
+{
+  "type": "check-single-workspace",
+  "workspaceId":"5e4ff30a628a6c73a415f4d5"
+}
+```