v1.0.3

pom.xml

@@ -5,7 +5,7 @@
 	
 	<groupId>com.inteligr8.alfresco.activiti</groupId>
 	<artifactId>model-share-activiti-app-ext</artifactId>
-	<version>1.0-SNAPSHOT</version>
+	<version>1.0.3</version>
 	<packaging>jar</packaging>
 	
 	<name>Model Share APS Extension</name>
@@ -39,11 +39,11 @@
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-		<maven.compiler.source>17</maven.compiler.source>
-		<maven.compiler.target>17</maven.compiler.target>
-		<maven.compiler.release>17</maven.compiler.release>
+		<maven.compiler.source>11</maven.compiler.source>
+		<maven.compiler.target>11</maven.compiler.target>
+		<maven.compiler.release>11</maven.compiler.release>
 		
-		<aps.version>24.3.0</aps.version>
+		<aps.version>2.4.1</aps.version>
 	</properties>
 
 	<dependencies>
@@ -154,7 +154,7 @@
 					<plugin>
 						<groupId>org.sonatype.plugins</groupId>
 						<artifactId>nexus-staging-maven-plugin</artifactId>
-						<version>1.7.0</version>
+						<version>1.6.13</version>
 						<configuration>
 							<serverId>ossrh</serverId>
 							<nexusUrl>https://s01.oss.sonatype.org/</nexusUrl>

src/main/java/com/inteligr8/alfresco/activiti/share/ModelShareExtension.java

@@ -21,10 +21,6 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import com.activiti.domain.idm.User;
-import com.activiti.security.SecurityUtils;
-import com.activiti.service.api.UserService;
-
 @Component
 public class ModelShareExtension implements Bootstrappable {
     
@@ -33,12 +29,6 @@ public class ModelShareExtension implements Bootstrappable {
     @Autowired
     private ModelShareWorker worker;
 
-    @Autowired
-    private UserService userService;
-
-    @Value("${inteligr8.modelShareExtension.runAs:admin@app.activiti.com}")
-    private String runAsUser;
-
     @Value("${inteligr8.modelShareExtension.enabled:true}")
     private boolean enabled;
 
@@ -48,7 +38,7 @@ public class ModelShareExtension implements Bootstrappable {
     public void onBootstrap() {
         this.logger.trace("onBootstrap()");
         
-        if (!this.enabled)
+        if (this.enabled)
             return;
         
         this.logger.info("Model Share Extension enabled");
@@ -70,13 +60,7 @@ public class ModelShareExtension implements Bootstrappable {
             return;
         
         this.logger.trace("scheduled()");
-
-        this.logger.debug("Assuming user: {}", this.runAsUser);
-        User runAsUser = this.userService.findUserByEmail(this.runAsUser);
-        SecurityUtils.assumeUser(runAsUser);
-        this.logger.debug("Assumed user: {}", runAsUser.getId());
-        
-        this.worker.shareAllModels();
+        this.worker.share();
     }
 
 }

src/main/java/com/inteligr8/alfresco/activiti/share/ModelShareWorker.java

@@ -25,7 +25,6 @@ import java.util.Map.Entry;
 import java.util.Set;
 
 import org.activiti.engine.ProcessEngine;
-import org.activiti.engine.repository.ModelQuery;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -35,7 +34,6 @@ import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Component;
 
-import com.activiti.domain.editor.AbstractModel;
 import com.activiti.domain.editor.Model;
 import com.activiti.domain.editor.ModelShareInfo;
 import com.activiti.domain.editor.SharePermission;
@@ -208,110 +206,36 @@ public class ModelShareWorker implements Bootstrappable {
             map.put(key, value);
     }
     
-    public void shareAllModels() {
-        this.shareApsFormModels();
-        this.shareApsDataModels();
-        this.shareApsDecisionTableModels();
-        this.shareApsProcessModels();
-        this.shareApsAppModels();
-        
-        if (this.tenantId != null) {
-            this.shareAllActivitiModels(this.tenantId);
-        } else {
-            this.shareAllActivitiModels(null);
-        }
-    }
-    
-    private void shareApsFormModels() {
-        this.logger.trace("Discovering APS form models");
-        List<AbstractModel> models = this.modelService.getModelsByModelTypeAndReferenceId(Model.MODEL_TYPE_FORM, null);
-        for (AbstractModel model : models) {
-            this.logger.debug("Discovered APS form model: {} [{}]", model.getName(), model.getId());
-            this.shareModel((Model) model);
-        }
-    }
-    
-    private void shareApsDataModels() {
-        this.logger.trace("Discovering APS data models");
-        List<AbstractModel> models = this.modelService.getModelsByModelTypeAndReferenceId(Model.MODEL_TYPE_DATA_MODEL, null);
-        for (AbstractModel model : models) {
-            this.logger.debug("Discovered APS data model: {} [{}]", model.getName(), model.getId());
-            this.shareModel((Model) model);
-        }
-    }
-    
-    private void shareApsDecisionTableModels() {
-        this.logger.trace("Discovering APS decision table models");
-        List<AbstractModel> models = this.modelService.getModelsByModelTypeAndReferenceId(Model.MODEL_TYPE_DECISION_TABLE, null);
-        for (AbstractModel model : models) {
-            this.logger.debug("Discovered APS decision table model: {} [{}]", model.getName(), model.getId());
-            this.shareModel((Model) model);
-        }
-    }
-    
-    private void shareApsProcessModels() {
-        this.logger.trace("Discovering APS process models");
-        List<AbstractModel> models = this.modelService.getModelsByModelTypeAndReferenceId(Model.MODEL_TYPE_BPMN, null);
-        for (AbstractModel model : models) {
-            this.logger.debug("Discovered APS process model: {} [{}]", model.getName(), model.getId());
-            this.shareModel((Model) model);
-        }
-    }
-    
-    private void shareApsAppModels() {
-        this.logger.trace("Discovering APS app models");
-        List<AbstractModel> models = this.modelService.getModelsByModelTypeAndReferenceId(Model.MODEL_TYPE_APP, null);
-        for (AbstractModel model : models) {
-            this.logger.debug("Discovered APS app model: {} [{}]", model.getName(), model.getId());
-            this.shareModel((Model) model);
-        }
-    }
-    
-    private void shareAllActivitiModels(Long tenantId) {
-        this.logger.trace("Discovering activiti models in tenant {} ...", tenantId);
+    public void share() {
+        this.logger.trace("Discovering models ...");
         
         long modelCount = 0L;
         int page = 1;
         int perPage = this.modelChunkSize;
         
-        ModelQuery query = this.services.getRepositoryService().createModelQuery()
-        		.latestVersion();
-        if (tenantId != null)
-            query.modelTenantId(String.valueOf(tenantId));
-        else query.modelWithoutTenantId();
-
-        this.logger.trace("Discovering activiti models with page size: {}", perPage);
-        List<org.activiti.engine.repository.Model> models = query.listPage((page-1)*perPage, perPage);
-        if (models.isEmpty()) {
-        	this.logger.debug("No activiti models; procDef count: {}", this.services.getRepositoryService().createProcessDefinitionQuery().latestVersion().count());
-        }
-        
+        List<org.activiti.engine.repository.Model> models = this.services.getRepositoryService().createModelQuery().listPage((page-1)*perPage, perPage);
         while (!models.isEmpty()) {
-            this.logger.trace("Fetched page #{} of {} activiti models in tenant {}", page, models.size(), tenantId);
+            this.logger.trace("Fetched page #{} of {} models", page, models.size());
             
             for (org.activiti.engine.repository.Model model : models) {
                 this.logger.debug("Discovered model: {}: {}: {}", model.getCategory(), model.getId(), model.getName());
-                this.shareModel(model);
+                this.share(model);
             }
             
             modelCount += models.size();
             page++;
-            models = query.listPage((page-1)*perPage, perPage);
+            models = this.services.getRepositoryService().createModelQuery().listPage((page-1)*perPage, perPage);
         }
 
-        this.logger.trace("Discovered {} activiti models in tenant {}", modelCount, tenantId);
+        this.logger.trace("Discovered {} models", modelCount);
     }
     
-    public void shareModel(org.activiti.engine.repository.Model orgModel) {
+    public void share(org.activiti.engine.repository.Model orgModel) {
         Model model = (Model) this.modelService.getModel(Long.valueOf(orgModel.getId()));
-        this.shareModel(model);
-    }
-    
-    public void shareModel(Model model) {
         Map<HashableGroup, SharePermission> shares = this.fetchCurrentModelShares(model);
 
         switch (model.getModelType()) {
-            case Model.MODEL_TYPE_APP:
+            case 3:
                 for (Entry<HashableGroup, SharePermission> group : this.groups.entrySet()) {
                     if (this.appDefsGroups.containsKey(group.getKey())) {
                         this.logger.trace("The default group permission is overridden by the app group permission: {}", group.getKey());
@@ -322,7 +246,7 @@ public class ModelShareWorker implements Bootstrappable {
                 for (Entry<HashableGroup, SharePermission> group : this.appDefsGroups.entrySet())
                     this.share(shares, model, group.getKey(), group.getValue());
                 break;
-            case Model.MODEL_TYPE_BPMN:
+            case 0:
                 for (Entry<HashableGroup, SharePermission> group : this.groups.entrySet()) {
                     if (this.processDefsGroups.containsKey(group.getKey())) {
                         this.logger.trace("The default group permission is overridden by the app group permission: {}", group.getKey());
@@ -333,7 +257,7 @@ public class ModelShareWorker implements Bootstrappable {
                 for (Entry<HashableGroup, SharePermission> group : this.processDefsGroups.entrySet())
                     this.share(shares, model, group.getKey(), group.getValue());
                 break;
-            case Model.MODEL_TYPE_FORM:
+            case 1:
                 for (Entry<HashableGroup, SharePermission> group : this.groups.entrySet()) {
                     if (this.formDefsGroups.containsKey(group.getKey())) {
                         this.logger.trace("The default group permission is overridden by the app group permission: {}", group.getKey());
@@ -360,15 +284,9 @@ public class ModelShareWorker implements Bootstrappable {
             for (ModelShareInfo share : shares)
                 map.put(new HashableGroup(share.getGroup()), share.getPermission());
             
-            pageable = pageable.next();
             shares = this.shareInfoRepo.findByModelIdOrderByShareDateAsc(model.getId(), pageable);
         }
         
-        if (this.logger.isTraceEnabled()) {
-            this.logger.trace("Found existing shares: {}", map);
-        } else {
-            this.logger.debug("Found existing shares: {}", map.size());
-        }
         return map;
     }
     
@@ -424,13 +342,7 @@ public class ModelShareWorker implements Bootstrappable {
         
         @Override
         public boolean equals(Object obj) {
-            if (obj instanceof HashableGroup) {
-                return this.group.getId().equals(((HashableGroup) obj).getGroup().getId());
-            } else if (obj instanceof Group) {
-                return this.group.getId().equals(((Group) obj).getId());
-            } else {
-                return false;
-            }
+            return this.group.getId().equals(((Group) obj).getId());
         }
         
         @Override