[NAE-1998] Implement transactions for events

.github/workflows/pr-build.yml

@@ -34,10 +34,6 @@ jobs:
     runs-on: ubuntu-latest
     timeout-minutes: 200
     services:
-      mongo:
-        image: mongo:4.4
-        ports:
-          - 27017:27017
 
       redis:
         image: redis
@@ -52,12 +48,45 @@ jobs:
         options: -e="discovery.type=single-node" -e="xpack.security.enabled=false" --health-cmd="curl http://localhost:9200/_cluster/health" --health-interval=10s --health-timeout=5s --health-retries=10
 
     steps:
+      - name: Start MongoDB
+        uses: MongoCamp/mongodb-github-action@1.2.0
+        with:
+          mongodb-version: 4.4
+          mongodb-replica-set: rs0
+
+      - name: Wait for Elasticsearch to be ready
+        run: |
+          echo "Waiting for Elasticsearch to be ready..."
+          for i in {1..30}; do
+            if curl -fsSL http://localhost:9200/_cluster/health | grep '"status":"green"' &>/dev/null; then
+              echo "Elasticsearch is up"
+              break
+            fi
+            echo "Waiting for Elasticsearch..."
+            sleep 2
+          done
+
+      - name: Wait for MongoDB to be ready
+        run: |
+          echo "Waiting for MongoDB to be ready..."
+          for i in {1..30}; do
+            if mongo --eval "printjson(db.serverStatus())" &>/dev/null; then
+              echo "MongoDB is up"
+              break
+            fi
+            echo "Waiting for MongoDB..."
+            sleep 2
+          done
+
       - name: Test Database
         env:
           ELASTIC_SEARCH_URL: http://localhost:${{ job.services.elasticsearch.ports[9200] }}
+          MONGO_URL: http://localhost:27017
         run: |
           echo $ELASTIC_SEARCH_URL
+          echo $MONGO_URL
           curl -fsSL "$ELASTIC_SEARCH_URL/_cat/health?h=status"
+          curl -fsSL "$MONGO_URL"
 
       - uses: actions/checkout@v3
         with:
@@ -86,7 +115,6 @@ jobs:
       - name: Generate certificates
         run: cd src/main/resources/certificates && openssl genrsa -out keypair.pem 4096 && openssl rsa -in keypair.pem -pubout -out public.crt && openssl pkcs8 -topk8 -inform PEM -outform DER -nocrypt -in keypair.pem -out private.der && cd ../../../..
 
-
       - name: Build
         run: mvn clean package install -DskipTests=true
 

docker-compose.yml

@@ -3,8 +3,15 @@ version: "3.3"
 services:
   docker-mongo:
     image: mongo:4.4
+    command: ["--replSet", "rs0", "--bind_ip_all", "--port", "27017"]
+    hostname: 127.0.0.1
     ports:
       - "27017:27017"
+    healthcheck:
+      test: echo "try { rs.status() } catch (err) { rs.initiate({_id:'rs0',members:[{_id:0,host:'host.docker.internal:27017'}]}) }" | mongosh --port 27017 --quiet
+      interval: 5s
+      timeout: 30s
+      retries: 10
     deploy:
       resources:
         limits:

docs/_media/roles/usersRef_functions.groovy

@@ -1,5 +1,5 @@
 Long getDummyUser() {
-   return userService.findByEmail("dummy@netgrif.com", true).id
+   return userService.findByEmail("dummy@netgrif.com").id
 }
 
 void debug() {

src/main/groovy/com/netgrif/application/engine/migration/ActionMigration.groovy

@@ -3,8 +3,9 @@ package com.netgrif.application.engine.migration
 import com.netgrif.application.engine.auth.service.interfaces.IUserService
 import com.netgrif.application.engine.petrinet.domain.PetriNet
 import com.netgrif.application.engine.petrinet.domain.VersionType
+import com.netgrif.application.engine.petrinet.domain.params.ImportPetriNetParams
 import com.netgrif.application.engine.petrinet.service.interfaces.IPetriNetService
-import com.netgrif.application.engine.workflow.domain.eventoutcomes.petrinetoutcomes.ImportPetriNetEventOutcome
+import com.netgrif.application.engine.workflow.domain.outcomes.eventoutcomes.petrinetoutcomes.ImportPetriNetEventOutcome
 import groovy.util.logging.Slf4j
 import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.core.io.ClassPathResource
@@ -20,11 +21,12 @@ class ActionMigration {
     private IPetriNetService petriNetService
 
     @Autowired
-    private IUserService userService;
+    private IUserService userService
 
     void migrateActions(String petriNetPath) {
         InputStream netStream = new ClassPathResource(petriNetPath).inputStream
-        ImportPetriNetEventOutcome newPetriNet = petriNetService.importPetriNet(netStream, VersionType.MAJOR, userService.loggedOrSystem.transformToLoggedUser())
+        ImportPetriNetEventOutcome newPetriNet = petriNetService.importPetriNet(new ImportPetriNetParams(netStream,
+                VersionType.MAJOR, userService.loggedOrSystem.transformToLoggedUser()))
         List<PetriNet> oldPetriNets
 
         if(newPetriNet.getNet() != null) {
@@ -50,15 +52,15 @@ class ActionMigration {
         }
     }
 
-    private void migrateDataSetActions(PetriNet newPetriNet, PetriNet oldPetriNet) {
+    private static void migrateDataSetActions(PetriNet newPetriNet, PetriNet oldPetriNet) {
         newPetriNet.dataSet.each { key, data ->
             if (data.events != null && data.events.size() > 0) {
                 oldPetriNet.dataSet[key].events = data.events
             }
         }
     }
 
-    private void migrateDataRefActions(PetriNet newPetriNet, PetriNet oldPetriNet) {
+    private static void migrateDataRefActions(PetriNet newPetriNet, PetriNet oldPetriNet) {
         newPetriNet.transitions.each { transKey, trans ->
             trans.dataSet.each { dataKey, data ->
                 if (data.events != null && data.events.size() > 0) {