Add realm limit settings (#151)

Author: baranga

CHANGELOG.md

@@ -9,6 +9,7 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/).
 - Introduce new administrative channel management endpoints `/admin/v1/realms/{realmId}/channels`.
 - Introduce new administrative subscription management endpoints `/admin/v1/realms/{realmId}/subscriptions`.
 - Introduce new administrative endpoint for deleting auth tokens `DELETE /admin/v1/realms/{realmId}/tokens/{tokenId}`
+- Introduce limit settings on realm level ([#151]).
 
 ### Changed
 - Add support for upgraded verneMQ broker. This requires the acceptance of their [EULA](https://vernemq.com/end-user-license-agreement/),
@@ -20,6 +21,7 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/).
 - Hide secret `auth.token` from all responses, except token creation, to avoid access right escalation. ([#138])
 
 [#138]: https://github.com/realmq/realmq-platform/issues/138
+[#151]: https://github.com/realmq/realmq-platform/issues/151
 
 ## [0.2.0] - 2023-03-09
 

src/api/admin/v1/mappers/index.js

@@ -3,6 +3,7 @@ const authList = require('./auth-list');
 const channel = require('./channel');
 const channelList = require('./channel-list');
 const realm = require('./realm');
+const realmDetails = require('./realm-details');
 const realmList = require('./realm-list');
 const subscription = require('./subscription');
 const subscriptionList = require('./subscription-list');
@@ -18,6 +19,7 @@ module.exports = {
   channel,
   channelList,
   realm,
+  realmDetails,
   realmList,
   subscription,
   subscriptionList,

src/api/admin/v1/mappers/realm-details.js

@@ -0,0 +1,30 @@
+const mapRealm = require('./realm');
+const mapGenericEntity = require('../../../../lib/mappers/generic-entity');
+
+/**
+ * @class RealmViewModel
+ * @property {string} id
+ * @property {string} name
+ * @property {Date} createdAt
+ * @property {Date} updatedAt
+ */
+/**
+ * Map a realm to detail response view model
+ * @param {object} args
+ * @param {RealmModel} args.realm The realm entity
+ * @param {RealmLimitsModel} args.realmLimits The realm limits entity
+ * @return {RealmViewModel} The realm view model
+ */
+module.exports = ({realm, realmLimits}) => ({
+  ...mapRealm(realm),
+  limits: mapGenericEntity({
+    entity: realmLimits,
+    propertyMap: {
+      maxConnections: 'maxConnections',
+      sessionMaxMessageRate: 'sessionMaxMessageRate',
+      sessionMaxConnectionLifetime: 'sessionMaxConnectionLifetime',
+      sessionMaxMessageSize: 'sessionMaxMessageSize',
+    }
+  }),
+});
+

src/api/admin/v1/mappers/realm.js

@@ -8,7 +8,7 @@ const mapGenericEntity = require('../../../../lib/mappers/generic-entity');
  * @property {Date} updatedAt
  */
 /**
- * Map an realm to response view model
+ * Map a realm to response view model
  * @param {RealmModel} realm The realm entity
  * @return {RealmViewModel} The realm view model
  */

src/api/admin/v1/openapi/definitions.yaml

@@ -74,13 +74,39 @@ TimestampsTrait:
 Realm:
   allOf:
     - $ref: '#/definitions/BaseEntity'
-    - properties:
+    - type: object
+      properties:
         name:
           type: string
       required:
         - name
     - $ref: '#/definitions/TimestampsTrait'
 
+RealmDetails:
+  allOf:
+    - $ref: '#/definitions/Realm'
+    - type: object
+      properties:
+        limits:
+          $ref: '#/definitions/RealmLimits'
+
+RealmLimits:
+  type: object
+  properties:
+    maxConnections:
+      description: Maximum number of simultaneously online connections
+      type: integer
+    sessionMaxMessageRate:
+      description: Maximum incoming publish rate per session per second
+      type: integer
+    sessionMaxConnectionLifetime:
+      description: Maximum lifetime of a connection in seconds
+      type: integer
+    sessionMaxMessageSize:
+      description: Maximum size of a message payload in bytes
+      type: integer
+  additionalProperties: false
+
 RealmList:
   allOf:
     - $ref: '#/definitions/BaseList'

src/api/admin/v1/routes/realms.js

@@ -16,13 +16,16 @@ module.exports = (tasks, mappers) => ({
   },
 
   async post(request, response) {
-    const {body: {name}} = request;
-    const {ok, result: realm, error} = await tasks.admin.createRealm({name});
+    const {body: {name, limits = {}}} = request;
+    const {ok, result, error} = await tasks.admin.createRealm({name, limits});
 
     if (!ok) {
       throw error;
     }
 
-    return response.status(201).json(mappers.realm(realm));
+    return response.status(201).json(mappers.realm({
+      realm: result.realm,
+      realmLimits: result.realmLimits
+    }));
   },
 });

src/api/admin/v1/routes/realms.yaml

@@ -40,11 +40,13 @@
             name:
               description: The name of the real, eg. project/org name
               type: string
+            limits:
+              $ref: '#/definitions/RealmLimits'
     responses:
       201:
         description: Realm was successfully created.
         schema:
-          $ref: '#/definitions/Realm'
+          $ref: '#/definitions/RealmDetails'
       400:
         description: Request validation failed.
       401:

src/bootstrap/repositories.js

@@ -12,6 +12,7 @@ module.exports = async ({db}) => {
     channelCollection,
     messageCollection,
     realmCollection,
+    realmLimitsCollection,
     realtimeConnectionCollection,
     subscriptionCollection,
     userCollection,
@@ -20,6 +21,7 @@ module.exports = async ({db}) => {
     db.collection('channels'),
     db.collection('messages'),
     db.collection('realms'),
+    db.collection('realm-limits'),
     db.collection('realtime-connections'),
     db.collection('subscriptions'),
     db.collection('users'),
@@ -29,6 +31,7 @@ module.exports = async ({db}) => {
     channelCollection,
     messageCollection,
     realmCollection,
+    realmLimitsCollection,
     realtimeConnectionCollection,
     subscriptionCollection,
     userCollection,

src/bootstrap/tasks.js

@@ -26,6 +26,7 @@ module.exports = ({
     channel: channelRepository,
     message: messageRepository,
     realm: realmRepository,
+    realmLimits: realmLimitsRepository,
     realtimeConnection: realtimeConnectionRepository,
     subscription: subscriptionRepository,
     user: userRepository,
@@ -44,6 +45,7 @@ module.exports = ({
       authRepository,
       channelRepository,
       realmRepository,
+      realmLimitsRepository,
       subscriptionRepository,
       userRepository,
       sendSubscriptionSyncMessage,
@@ -54,6 +56,7 @@ module.exports = ({
       authRepository,
       channelRepository,
       subscriptionRepository,
+      realmLimitsRepository,
       realtimeConnectionRepository,
       messageRepository,
       userRepository,

src/index.js

@@ -34,3 +34,4 @@ const createLogger = require('./lib/logger');
     process.exit(1);
   }
 })();
+