Add EOR reason in case of LHC user stopping run

Author: graduta

lib/server/kafka/AliEcsSynchronizer.js

@@ -85,12 +85,24 @@ class AliEcsSynchronizer {
             }
 
             if (transition === 'STOP_ACTIVITY' || transition === 'GO_ERROR') {
+                const eorReasons = [];
+                if (userName === 'LHC') {
+                    this._logger.infoMessage(`Run ${runNumber} stopped by LHC user, adding adequate EOR reason`);
+                    eorReasons.push({
+                        category: 'LHC',
+                        title: 'Dump',
+                        description: 'Run stopped due to LHC dump',
+                    });
+                }
                 runService
                     .createOrUpdate(
                         runNumber,
                         environmentId,
                         { timeO2End: timestamp.toNumber() },
-                        { userO2Stop: { userIdentifier: { externalUserId }, name: userName } },
+                        {
+                            userO2Stop: { userIdentifier: { externalUserId }, name: userName },
+                            eorReasons,
+                        },
                     )
                     .catch((error) => this._logger.errorMessage(`Failed to save run end for ${runNumber}: ${error.message}`));
             }

test/lib/server/services/run/RunService.test.js

@@ -359,7 +359,7 @@ module.exports = () => {
 
         const run = await runService.update(
             { runNumber },
-            { relations: { eorReasons: eorReasons } },
+            { relations: { eorReasons } },
         );
 
         expect(run.eorReasons).to.lengthOf(2);
@@ -391,7 +391,7 @@ module.exports = () => {
 
         const run = await runService.update(
             { runNumber },
-            { relations: { eorReasons: eorReasons } },
+            { relations: { eorReasons } },
         );
 
         expect(run.eorReasons).to.lengthOf(2);
@@ -431,7 +431,7 @@ module.exports = () => {
 
         const run = await runService.update(
             { runNumber },
-            { relations: { eorReasons: eorReasons } },
+            { relations: { eorReasons } },
         );
 
         // Should only include the valid ones without throwing for invalid one (is simply excluded)
@@ -453,7 +453,7 @@ module.exports = () => {
 
         const run = await runService.update(
             { runNumber },
-            { relations: { eorReasons: eorReasons } },
+            { relations: { eorReasons } },
         );
 
         expect(run.eorReasons).to.lengthOf(0);
@@ -485,7 +485,7 @@ module.exports = () => {
 
         const run = await runService.update(
             { runNumber },
-            { relations: { eorReasons: eorReasons } },
+            { relations: { eorReasons } },
         );
 
         // EorReasons should only include the one that does not have an id
@@ -733,4 +733,26 @@ module.exports = () => {
         expect(run.userIdO2Stop).to.equal(2);
         expect(run.flpRoles.map(({ name }) => name)).to.deep.equal(['fake-flp1', 'fake-flp2', 'fake-ctp-host']);
     });
+
+    it('should successfully update a run with provided EOR reasons via the createOrUpdate', async () => {
+        const run = await runService.createOrUpdate(
+            1234,
+            'CmCvjNbg',
+            {  },
+            {
+                eorReasons: [
+                    {
+                        category: 'DETECTORS',
+                        title: 'TPC',
+                        description: 'Run stopped due to LHC dump',
+                    },
+                ],
+            },
+        );
+        // console.log(run);
+        expect(run.eorReasons).to.have.lengthOf(1);
+        expect(run.eorReasons[0].category).to.equal('DETECTORS');
+        expect(run.eorReasons[0].title).to.equal('TPC');
+        expect(run.eorReasons[0].description).to.equal('Run stopped due to LHC dump');
+    });
 };