Fix demo/complex2s

common.bash

@@ -1,3 +1,3 @@
 maintainer="tier"
 imagename="midpoint"
-tag="latest"
+tag="laboratory"

demo/complex2s/add-ref-groups.sh

@@ -1,3 +1,3 @@
 source ../../library.bash
 
-execute_gsh complex2_grouper_daemon_1 add-ref-groups.gsh
+execute_gsh complex2s_grouper_daemon_1 add-ref-groups.gsh

demo/complex2s/create-ref-loaders.sh

@@ -1,3 +1,3 @@
 source ../../library.bash
 
-execute_gsh complex2_grouper_daemon_1 create-ref-loaders.gsh
+execute_gsh complex2s_grouper_daemon_1 create-ref-loaders.gsh

demo/complex2s/midpoint-objects/resources/resource-grouper.xml

@@ -38,7 +38,7 @@
     </connectorRef>
     <connectorConfiguration>
         <icfc:configurationProperties>
-            <rest:baseUrl>https://192.168.56.101:9443</rest:baseUrl>
+            <rest:baseUrl>https://grouper-ws:443</rest:baseUrl>
             <rest:username>banderson</rest:username>
             <rest:password>password</rest:password>
             <rest:superGroup>etc:midpointGroups</rest:superGroup>
@@ -66,7 +66,7 @@
         <connectorConfiguration>
             <conf:sources>
                 <amqp091>
-                    <uri>amqp://192.168.56.101:5672</uri>
+                    <uri>amqp://mq:5672</uri>
                     <username>guest</username>
                     <password>guest</password>
                     <queue>sampleQueue</queue>

demo/complex2s/midpoint-objects/systemConfigurations/SystemConfiguration.xml

@@ -24,6 +24,72 @@
          <channel>http://midpoint.evolveum.com/xml/ns/public/gui/channels-3#init</channel>
       </operationExecution>
       <globalSecurityPolicyRef xmlns:tns="http://midpoint.evolveum.com/xml/ns/public/common/common-3" oid="00000000-0000-0000-0000-000000000120" relation="org:default" type="tns:SecurityPolicyType"/>
+      <modelHooks>
+         <change>
+            <hook>
+               <name>Recompute affected users</name>
+               <state>final</state>
+               <focusType>OrgType</focusType>
+               <script>
+                  <code>
+                      import com.evolveum.midpoint.prism.delta.*
+                      import com.evolveum.midpoint.xml.ns._public.common.common_3.*
+                      import com.evolveum.midpoint.prism.path.*
+
+                      log.info('Starting Org change hook execution')
+
+                      affectedUsers = new HashSet()
+
+                      MEMBER_PATH = ItemPath.create(ObjectType.F_EXTENSION, 'member')
+
+                      for (delta in modelContext.allChanges) {
+                         if (delta.objectTypeClass == OrgType.class) {
+                            log.info('Found Org delta: {}', delta)
+                            if (delta.isDelete()) {
+                               addFromObject(affectedUsers, modelContext.focusContext.objectOld)
+                            } else {
+                               memberDelta = delta.findPropertyDelta(MEMBER_PATH)
+                               if (memberDelta != null) {
+                                  log.info('Found member delta: {}', memberDelta)
+                                  if (memberDelta.isReplace()) {
+                                     addFromObject(affectedUsers, modelContext.focusContext.objectOld)
+                                     addFromValues(affectedUsers, memberDelta.valuesToReplace)
+                                  } else {
+                                     addFromValues(affectedUsers, memberDelta.valuesToAdd)
+                                     addFromValues(affectedUsers, memberDelta.valuesToDelete)
+                                  }
+                               }
+                            }
+                         }
+                      }
+                      log.info('Affected users = {}', affectedUsers)
+                      for (userName in affectedUsers) {
+                         user = midpoint.searchObjectByName(UserType.class, userName)
+                         if (user != null) {
+                            midpoint.addRecomputeTrigger(user, null)
+                            log.info('Recompute trigger added to {}', user)
+                         } else {
+                            log.warn('User {} couldn\'t be found', userName)
+                         }
+                      }
+                      log.info('Finishing Org change hook execution')
+
+                      def addFromObject(users, object) {
+                         addFromValues(users, object?.findExtensionItem('member')?.values)
+                      }
+                      def addFromValues(users, values) {
+                         if (values != null) {
+                            for (value in values) {
+                               users.add(value.realValue)
+                            }
+                         }
+                      }
+                  </code>
+               </script>
+            </hook>
+         </change>
+      </modelHooks>
+
       <logging>
          <classLogger id="1">
             <level>ERROR</level>

demo/complex2s/show-queue-size.sh

@@ -1 +1 @@
-docker exec complex2_mq_1 rabbitmqctl list_queues
+docker exec complex2s_mq_1 rabbitmqctl list_queues

demo/complex2s/update-bgasper-in-grouper.sh

@@ -2,4 +2,4 @@
 
 source ../../library.bash
 
-execute_gsh complex2_grouper_daemon_1 update-bgasper-in-grouper.gsh
+execute_gsh complex2s_grouper_daemon_1 update-bgasper-in-grouper.gsh