test and CMake line for atomic acls

Author: d-w-moore

indexing.cmake

@@ -66,6 +66,7 @@ install(
   FILES
   ${CMAKE_SOURCE_DIR}/packaging/test_plugin_indexing.py
   ${CMAKE_SOURCE_DIR}/packaging/atomic_metadata_ops.py
+  ${CMAKE_SOURCE_DIR}/packaging/atomic_acl_ops.py
   DESTINATION ${IRODS_HOME_DIRECTORY}/scripts/irods/test
   PERMISSIONS OWNER_READ OWNER_WRITE GROUP_READ WORLD_READ
   COMPONENT ${IRODS_PACKAGE_COMPONENT_POLICY_NAME}

packaging/test_plugin_indexing.py

@@ -11,7 +11,7 @@
 
 import zipfile
 import subprocess
-from time import sleep
+from time import sleep, time
 from textwrap import dedent
 from datetime import datetime as _datetime
 
@@ -932,6 +932,29 @@ def logical_filesystem_for_indexing(self,objects,session):
             for p in collections_to_delete:
                 session.assert_icommand(['irm', '-rf', p],'STDOUT','')
 
+    def test_indexing_with_atomic_acl_ops__81(self):
+        with indexing_plugin__installed():
+            test_coll = self.test_coll_name()
+            INDEX = DEFAULT_METADATA_INDEX + "__81_{:%s.%f}".format(_datetime.now())
+            create_metadata_index (INDEX)
+            try:
+                with session.make_session_for_existing_admin() as admin_session:
+                    admin_session.assert_icommand("""imeta set -C {0} irods::indexing::index {1}::metadata elasticsearch""".format(test_coll, INDEX))
+                    admin_session.assert_icommand("itouch {0}/testobj".format(test_coll))
+                    sleep(5)
+                    # hit the apply_atomic_acl api
+                    self.assertIsNotNone (repeat_until (operator.eq, True) (self.delay_queue_is_empty) (admin_session))
+                    admin_session.assert_icommand("""cd ${{HOME}} ;  python3 ~/scripts/irods/test/atomic_acl_ops.py -v {self.venv_dir} """
+                                                  """ '/{0.zone_name}/home/{0.username}'/{test_coll}/testobj {self.user0.username} write """
+                                                  """ {self.user1.username} read """.format(admin_session, **locals()), use_unsafe_shell=True)
+                    # Check new permissions are reflected in the index
+                    self.assertIsNotNone( repeat_until(operator.eq, 1, transform=number_of_hits,
+                                                      ) (search_index_for_userPermissions_user_name) (INDEX, self.user0.username))
+                    self.assertEqual(1, number_of_hits(search_index_for_userPermissions_user_name (INDEX, self.user1.username)))
+            finally:
+                delete_metadata_index (INDEX)
+                admin_session.assert_icommand("irm -fr {0}".format(test_coll))
+
     def test_indexing_with_atomic_metadata_ops_66(self):
         with indexing_plugin__installed():
             test_coll = 'testcoll_66'