New LWC-based Config Management

dlrs/main/classes/AsyncApexJobsSelector.cls

@@ -31,6 +31,7 @@ public class AsyncApexJobsSelector extends fflib_SObjectSelector {
       AsyncApexJob.Status,
       AsyncApexJob.ExtendedStatus,
       AsyncApexJob.CreatedDate,
+      AsyncApexJob.CronTriggerId,
       AsyncApexJob.CompletedDate,
       AsyncApexJob.JobItemsProcessed,
       AsyncApexJob.TotalJobItems,
@@ -63,11 +64,59 @@ public class AsyncApexJobsSelector extends fflib_SObjectSelector {
     String query = newQueryFactory()
       .setCondition(
         'JobType = :jobType And ' +
-        'ApexClass.Name in :classNames And ' +
-        'Status in :statuses'
+          'ApexClass.Name in :classNames And ' +
+          'Status in :statuses'
       )
       .toSOQL();
     List<AsyncApexJob> jobs = (List<AsyncApexJob>) Database.query(query);
     return jobs.size() > 0;
   }
+
+  /**
+   * Get all scheduled instances of a class
+   **/
+  public List<AsyncApexJob> getScheduledInstancesOfType(Type classType) {
+    String classFullyQualifiedName = classType.getName();
+    List<String> nameParts = classFullyQualifiedName.split('\\.');
+
+    // Probably doesn't work for inner-classes in this format
+    String namespace;
+    if (nameParts.size() > 1) {
+      namespace = nameParts.remove(0);
+    }
+    String className = nameParts.remove(0);
+
+    String query = newQueryFactory()
+      .selectFields(
+        new List<String>{
+          'ApexClass.Name',
+          'CronTrigger.CronJobDetail.Name',
+          'CronTrigger.CronExpression',
+          'CronTrigger.NextFireTime'
+        }
+      )
+      .setCondition(
+        'Status != \'Aborted\' AND ' +
+          'JobType = \'ScheduledApex\' AND ' +
+          'ApexClass.Name = :className AND ' +
+          'ApexClass.NamespacePrefix = :namespace'
+      )
+      .addOrdering(
+        'CronTrigger.NextFireTime',
+        fflib_QueryFactory.SortOrder.ASCENDING
+      )
+      .toSOQL();
+    return Database.query(query);
+  }
+
+  /**
+   * Get all scheduled instances of a class
+   **/
+  public List<AsyncApexJob> getAllScheduledJobs() {
+    String query = newQueryFactory()
+      .selectField('CronTrigger.CronJobDetail.Name')
+      .setCondition('JobType = \'ScheduledApex\' AND Status != \'Aborted\'')
+      .toSOQL();
+    return Database.query(query);
+  }
 }

dlrs/main/classes/CustomMetadataService.cls

@@ -39,6 +39,46 @@ public class CustomMetadataService {
   ) {
   }
 
+  /**
+   * Starts async metadata save using Apex Metadata API
+   */
+  public static Id initiateMetadataSave(List<SObject> records) {
+    Metadata.DeployContainer mdContainer = new Metadata.DeployContainer();
+    for (SObject r : records) {
+      // Setup custom metadata to be created in the subscriber org.
+      Metadata.CustomMetadata customMetadata = new Metadata.CustomMetadata();
+      // Developer name and Label are applied here
+      customMetadata.fullName =
+        r.getSObjectType().getDescribe().getName() +
+        '.' +
+        (String) r.get('DeveloperName');
+      customMetadata.label = (String) r.get('Label');
+      Metadata.CustomMetadata mdt = new Metadata.CustomMetadata();
+      Map<String, Object> populatedFields = r.getPopulatedFieldsAsMap();
+      // We don't want these in values
+      List<String> ignoredKeys = new List<String>{
+        'Id',
+        'DeveloperName',
+        'Label'
+      };
+      for (String key : populatedFields.keySet()) {
+        if (ignoredKeys.contains(key)) {
+          continue;
+        }
+        Metadata.CustomMetadataValue customField = new Metadata.CustomMetadataValue();
+        customField.field = key;
+        customField.value = populatedFields.get(key);
+        customMetadata.values.add(customField);
+      }
+
+      mdContainer.addMetadata(customMetadata);
+    }
+
+    ApexMdApiDeployCallback cb = new ApexMdApiDeployCallback();
+    // Enqueue custom metadata deployment
+    return Metadata.Operations.enqueueDeployment(mdContainer, cb);
+  }
+
   /**
    * Insert the given Custom Metadata records into the orgs config
    **/
@@ -75,8 +115,8 @@ public class CustomMetadataService {
     for (String customMetadataFullName : customMetadataFullNames)
       qualifiedFullNames.add(
         qualifiedMetadataType.getDescribe().getName() +
-        '.' +
-        customMetadataFullName
+          '.' +
+          customMetadataFullName
       );
     List<MetadataService.DeleteResult> results = service.deleteMetadata(
       'CustomMetadata',
@@ -85,6 +125,21 @@ public class CustomMetadataService {
     handleDeleteResults(results[0]);
   }
 
+  /**
+   * Delete the given Custom Metadata records from the org using Async action
+   **/
+  public static Id deleteMetadataAsync(
+    SObjectType qualifiedMetadataType,
+    List<String> customMetadataFullNames
+  ) {
+    return System.enqueueJob(
+      new DeleteMetadataQueueable(
+        qualifiedMetadataType,
+        customMetadataFullNames
+      )
+    );
+  }
+
   public class CustomMetadataServiceException extends Exception {
   }
 
@@ -156,20 +211,20 @@ public class CustomMetadataService {
       List<String> messages = new List<String>();
       messages.add(
         (saveResult.errors.size() == 1 ? 'Error ' : 'Errors ') +
-        'occured processing component ' +
-        saveResult.fullName +
-        '.'
+          'occured processing component ' +
+          saveResult.fullName +
+          '.'
       );
       for (MetadataService.Error error : saveResult.errors)
         messages.add(
           error.message +
-          ' (' +
-          error.statusCode +
-          ').' +
-          (error.fields != null &&
-            error.fields.size() > 0
-            ? ' Fields ' + String.join(error.fields, ',') + '.'
-            : '')
+            ' (' +
+            error.statusCode +
+            ').' +
+            (error.fields != null &&
+              error.fields.size() > 0
+              ? ' Fields ' + String.join(error.fields, ',') + '.'
+              : '')
         );
       if (messages.size() > 0)
         throw new CustomMetadataServiceException(String.join(messages, ' '));
@@ -194,20 +249,20 @@ public class CustomMetadataService {
       List<String> messages = new List<String>();
       messages.add(
         (deleteResult.errors.size() == 1 ? 'Error ' : 'Errors ') +
-        'occured processing component ' +
-        deleteResult.fullName +
-        '.'
+          'occured processing component ' +
+          deleteResult.fullName +
+          '.'
       );
       for (MetadataService.Error error : deleteResult.errors)
         messages.add(
           error.message +
-          ' (' +
-          error.statusCode +
-          ').' +
-          (error.fields != null &&
-            error.fields.size() > 0
-            ? ' Fields ' + String.join(error.fields, ',') + '.'
-            : '')
+            ' (' +
+            error.statusCode +
+            ').' +
+            (error.fields != null &&
+              error.fields.size() > 0
+              ? ' Fields ' + String.join(error.fields, ',') + '.'
+              : '')
         );
       if (messages.size() > 0)
         throw new CustomMetadataServiceException(String.join(messages, ' '));
@@ -217,4 +272,60 @@ public class CustomMetadataService {
         'Request failed with no specified error.'
       );
   }
+
+  class ApexMdApiDeployCallback implements Metadata.DeployCallback {
+    public void handleResult(
+      Metadata.DeployResult result,
+      Metadata.DeployCallbackContext context
+    ) {
+      UserNotification__e updateEvent = new UserNotification__e(
+        Type__c = 'DeploymentResult',
+        Payload__c = JSON.serialize(result)
+      );
+      EventBus.publish(updateEvent);
+    }
+  }
+
+  class DeleteMetadataQueueable implements Queueable, Database.AllowsCallouts {
+    SObjectType qualifiedMetadataType;
+    List<String> customMetadataFullNames;
+    public DeleteMetadataQueueable(
+      SObjectType qualifiedMetadataType,
+      List<String> customMetadataFullNames
+    ) {
+      this.qualifiedMetadataType = qualifiedMetadataType;
+      this.customMetadataFullNames = customMetadataFullNames;
+    }
+
+    public void execute(QueueableContext ctx) {
+      try {
+        CustomMetadataService.deleteMetadata(
+          qualifiedMetadataType,
+          customMetadataFullNames
+        );
+        UserNotification__e updateEvent = new UserNotification__e(
+          Type__c = 'DeleteRequestResult',
+          Payload__c = JSON.serialize(
+            new Map<String, Object>{
+              'success' => true,
+              'metadataNames' => customMetadataFullNames
+            }
+          )
+        );
+        EventBus.publish(updateEvent);
+      } catch (CustomMetadataService.CustomMetadataServiceException e) {
+        UserNotification__e updateEvent = new UserNotification__e(
+          Type__c = 'DeleteRequestResult',
+          Payload__c = JSON.serialize(
+            new Map<String, Object>{
+              'success' => false,
+              'metadataNames' => customMetadataFullNames,
+              'error' => e.getMessage()
+            }
+          )
+        );
+        EventBus.publish(updateEvent);
+      }
+    }
+  }
 }

dlrs/main/classes/LookupRollupStatusCheckController.cls

@@ -0,0 +1,79 @@
+public with sharing class LookupRollupStatusCheckController {
+  /**
+   * Get count of scheduled items older than yesterday
+   * The assumption is that normal processing should have handled these
+   */
+  @AuraEnabled(Cacheable=true)
+  public static Integer getOutstandingScheduledItemsForLookup(String lookupID) {
+    return [
+      SELECT COUNT()
+      FROM LookupRollupSummaryScheduleItems__c
+      WHERE LookupRollupSummary2__c = :lookupID AND LastModifiedDate < YESTERDAY
+    ];
+  }
+
+  /**
+   * Check if the rollup has a Full Calculate schedule
+   */
+  @AuraEnabled
+  public static Datetime getScheduledFullCalculates(String lookupID) {
+    try {
+      LookupRollupSummary2__mdt LookupRollupSummary = (LookupRollupSummary2__mdt) new RollupSummariesSelector.CustomMetadataSelector(
+            false,
+            true
+          )
+          .selectById(new Set<String>{ lookupID })[0]
+        .Record;
+
+      if (LookupRollupSummary != null) {
+        String id = (LookupRollupSummary.id).to15();
+        List<CronTrigger> ct = new CronTriggersSelector()
+          .selectScheduledApexById(id);
+
+        if (!ct.isEmpty()) {
+          return ct[0].NextFireTime;
+        }
+      }
+    } catch (Exception e) {
+    }
+    return null;
+  }
+
+  /**
+   * Check if the rollup has a child/parent trigger
+   */
+  @AuraEnabled
+  public static Boolean hasChildTriggerDeployed(String lookupID) {
+    try {
+      LookupRollupSummary2__mdt LookupRollupSummary = (LookupRollupSummary2__mdt) new RollupSummariesSelector.CustomMetadataSelector(
+            false,
+            true
+          )
+          .selectById(new Set<String>{ lookupID })[0]
+        .Record;
+
+      if (LookupRollupSummary != null) {
+        RollupSummary rs = new RollupSummary(LookupRollupSummary);
+        String childTrigger = RollupSummaries.makeTriggerName(rs);
+        ApexTriggersSelector selector = new ApexTriggersSelector();
+        Map<String, ApexTrigger> loadTriggers = selector.selectByName(
+          new Set<String>{ ChildTrigger }
+        );
+
+        return loadTriggers.containsKey(ChildTrigger);
+      }
+    } catch (Exception e) {
+    }
+    return false;
+  }
+
+  /**
+   * Check if cron job is running for DLRS
+   */
+  @AuraEnabled
+  public static Integer getScheduledJobs() {
+    return new AsyncApexJobsSelector()
+      .getScheduledInstancesOfType(RollupJob.class)
+      .size();
+  }
+}

dlrs/main/classes/LookupRollupStatusCheckController.cls-meta.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<ApexClass xmlns="http://soap.sforce.com/2006/04/metadata">
+    <apiVersion>60.0</apiVersion>
+    <status>Active</status>
+</ApexClass>

dlrs/main/classes/ManageLookupRollupSummariesController.cls

@@ -334,7 +334,9 @@ public with sharing class ManageLookupRollupSummariesController {
 
   public PageReference newWizard() {
     try {
-      PageReference newPage = Page.managelookuprollupsummaries_New;
+      PageReference newPage = new PageReference(
+        '/lightning/n/ManageLookupRollupSummaries2'
+      );
       newPage.setRedirect(true);
       return newPage;
     } catch (Exception e) {

dlrs/main/classes/ObjectSelectorController.cls

@@ -0,0 +1,26 @@
+public with sharing class ObjectSelectorController {
+  @AuraEnabled(cacheable=true)
+  public static List<SObjectInfo> getParentObjList() {
+    Map<String, Schema.SObjectType> objectDescription = Schema.getGlobalDescribe();
+    List<SObjectInfo> objects = new List<SObjectInfo>();
+    for (Schema.SObjectType obj : objectDescription.values()) {
+      objects.add(new SObjectInfo(obj));
+    }
+    return objects;
+  }
+
+  class SObjectInfo {
+    @AuraEnabled
+    public String fullName;
+    @AuraEnabled
+    public String label;
+
+    public SObjectInfo(Schema.SObjectType obj) {
+      Schema.DescribeSObjectResult description = obj.getDescribe(
+        SObjectDescribeOptions.DEFERRED
+      );
+      this.fullName = description.getName();
+      this.label = description.getLabel();
+    }
+  }
+}