link scenarios to backend

backend/app/Db.js

@@ -26,7 +26,7 @@ class Db {
         try {
             dbo = db.db(app.config.db.name);
             this.instance = dbo;
-            for (let c of ['users', 'user_sessions', 'history', 'log', 'assets']){
+            for (let c of ['users', 'user_sessions', 'history', 'log', 'assets', 'scenarios']){
                 try {
                     await dbo.createCollection(c);
                 }catch(err){}
@@ -245,6 +245,24 @@ class Db {
     ObjectId(id){
         return new ObjectId(id);
     }
+
+    /**
+     * Gets last asset Id from database, намира последния пореден идентификатор на обект в базата от данни
+     * @returns {Number} Last Asset Id, последен (най-голям) идентификатор
+     */
+    async getLastId(collection){
+        let ag = await this.aggregate(collection, [
+            {
+                $group:{
+                    _id: null,
+                    max: {
+                        $max: "$id",
+                    },
+                },
+            },
+        ]);
+        return ag.max || 0;
+    }
 }
 
 export { Db };

backend/app/bl/GameObjectsManager.js

@@ -20,31 +20,13 @@ class GameObjectsManager{
     init(app){
         const {db, config} = app;
 
-        /**
-         * Gets last asset Id from database, намира последния пореден идентификатор на обект в базата от данни
-         * @returns {Number} Last Asset Id, последен (най-голям) идентификатор
-         */
-        this.getLastId = async function(){
-            let ag = await db.aggregate(collection, [
-                {
-                    $group:{
-                        _id: null,
-                        max: {
-                            $max: "$id",
-                        },
-                    },
-                },
-            ]);
-            return ag.max || 0;
-        }
-
         /**
          * Creates a game object, създаване на игрови обект
          * @param {Context} ctx Request context, контекст на заявката
          * @param {GameObject} data Asset data, данни за игровия обект
          */
         this.create = async function(ctx, data){
-            data.id = (await this.getLastId()) + 1;
+            data.id = (await db.getLastId(collection)) + 1;
             await db.create(collection, data);
             if (ctx.files?.file){
                 await this.addFile(data, ctx.files.file)
@@ -139,9 +121,9 @@ class GameObjectsManager{
          * @param {Object} query Query to DB, критерии - заявка към базата от данни
          * @returns {GameObject[]} Array of game objects, масив от игрови обекти
          */
-        this.list = async function(query){
+        this.list = async function(query = {}){
             return await db.list(collection, {
-                query: {},
+                query,
                 project: { name:1, id:1, type:1, asset:1}
             });
         }

backend/app/bl/ScenariosManager.js

@@ -1,4 +1,6 @@
 
+const collection = 'scenarios';
+
 /**
  * Scenarios manager class, контролен клас за управление на игрови сценарии
  */
@@ -18,7 +20,9 @@ class ScenariosManager{
          * @param {Scenario} data the scenario, данни за сценария
          */
         this.create = async function(ctx, data){
-
+            data.id = (await db.getLastId(collection)) + 1;
+            await db.create(collection, data);
+            return data;
         }
 
         /**
@@ -27,7 +31,8 @@ class ScenariosManager{
          * @returns {Scenario}
          */
         this.read = async function(id){
-
+            id = parseInt(id);
+            return await db.get(collection, {id});
         }
 
         /**
@@ -36,7 +41,11 @@ class ScenariosManager{
          * @param {Scenario} data the scenario
          */
         this.update = async function(ctx, data){
-
+            data.id = parseInt(data.id);
+            let object = await this.read(data.id);
+            data = Object.assign(object, data);
+            await db.update(collection, {id: data.id}, data);
+            return data;
         }
 
         /**
@@ -44,7 +53,8 @@ class ScenariosManager{
          * @param {Number} id scenario ID, идентификатор на сценарий
          */
         this.remove = async function(id){
-
+            id = parseInt(id);
+            await db.remove(collection, {id});
         }
 
         /**
@@ -52,8 +62,11 @@ class ScenariosManager{
          * @param {Query} query criteria, критерии - заявка към базата от данни
          * @returns {Scenario[]}
          */
-        this.list = async function(query){
-
+        this.list = async function(query = {}){
+            return await db.list(collection, {
+                query,
+                project: { name:1, id:1, sceneThumb: '$scenes.data.environment'}
+            });
         }
         
     }