Adjustments to provide better example of platform event subscription

Author: ImJohnMDaniel

.gitignore

@@ -7,7 +7,7 @@ temp/
 **/dep-dir.txt
 *.prefs
 build.properties
-/sfdx-source/core/main/default
+/sfdx-source/other/main/default
 
 # MavensMate IDE related
 *mm.log

sfdx-source/reference-implementation-common/main/classes/eventpublishers/AccountModsEventPublisher.cls

@@ -0,0 +1,13 @@
+public class AccountModsEventPublisher {
+    public static void publishChangedAccount( Set<Id> accountIdSet ) {
+        // Setup and save the AT4DXMessage__e
+        AT4DXMessage__e platformEventbus = new AT4DXMessage__e();
+        platformEventbus.EventName__c = 'ACCOUNT_RECORD_MODIFICATION';
+        platformEventbus.Category__c = Account.getSObjectType().getDescribe().getName();
+
+        // Serialize the accountIdSet 
+        platformEventbus.Payload__c = JSON.serialize( accountIdSet );
+
+        Database.SaveResult sr = EventBus.publish(platformEventbus);
+    }
+}

sfdx-source/reference-implementation-common/main/classes/eventpublishers/AccountModsEventPublisher.cls-meta.xml

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

sfdx-source/reference-implementation-sales/main/classes/event-consumers/Sales_PlatformEventsConsumer.cls

@@ -26,16 +26,13 @@
 
 public class Sales_PlatformEventsConsumer extends PlatformEventAbstractConsumer {
     public override void runInProcess() {
-        System.debug('<ojs> Sales_PlatformEventsConsumer.runInProcess');
-        System.debug('<ojs> events:\n' + events);
-
-        Set<Id> idSet = new Set<Id>();
+        Set<Id> accountIdSet = new Set<Id>();
 
         for (SObject sobj : events) {
             AT4DXMessage__e evt = (AT4DXMessage__e) sobj;
-            idSet.addAll((Set<Id>) JSON.deserialize(evt.Payload__c, Set<Id>.class));
+            accountIdSet.addAll((Set<Id>) JSON.deserialize(evt.Payload__c, Set<Id>.class));
         }
 
-        System.debug('idSet:\n' + idSet);
+        Sales_AccountsService.proocessAccountChanges(accountIdSet);
     }
 }

sfdx-source/reference-implementation-sales/main/classes/services/Sales_AccountsService.cls

@@ -0,0 +1,38 @@
+/**
+ * Copyright (c) 2020, John M. Daniel, John Storey
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without modification, 
+ *   are permitted provided that the following conditions are met:
+ *
+ * - Redistributions of source code must retain the above copyright notice, 
+ *      this list of conditions and the following disclaimer.
+ * - Redistributions in binary form must reproduce the above copyright notice, 
+ *      this list of conditions and the following disclaimer in the documentation 
+ *      and/or other materials provided with the distribution.
+ * - Neither the name of the John M. Daniel, nor the names of its contributors 
+ *      may be used to endorse or promote products derived from this software without 
+ *      specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND 
+ *  ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 
+ *  OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL 
+ *  THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 
+ *  EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ *  OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
+ *  OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
+ *  ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+**/
+
+public class Sales_AccountsService 
+{
+    // private static IAccountsService service()
+    // {
+    //     return (IAccountsService) Application.Service.newInstance( IAccountsService.class );
+    // }
+
+    public static void proocessAccountChanges( Set<Id> accountIdSet )
+    {
+        
+    }
+}

sfdx-source/reference-implementation-sales/main/classes/services/Sales_AccountsService.cls-meta.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<ApexClass xmlns="urn:metadata.tooling.soap.sforce.com" fqn="AccountsService">
+    <apiVersion>55.0</apiVersion>
+    <status>Active</status>
+</ApexClass>

sfdx-source/reference-implementation-sales/main/schema/customMetadata/PlatformEvents_Subscription.Sales_PlatformEventsConsumer.md-meta.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <CustomMetadata xmlns="http://soap.sforce.com/2006/04/metadata" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema">
-    <label>Sales - Platform Events Consumer</label>
+    <label>Sales_PlatformEventsConsumer</label>
     <protected>false</protected>
     <values>
         <field>Consumer__c</field>
@@ -16,14 +16,18 @@
     </values>
     <values>
         <field>Event__c</field>
-        <value xsi:nil="true"/>
+        <value xsi:type="xsd:string">ACCOUNT_RECORD_MODIFICATION</value>
+    </values>
+    <values>
+        <field>Execute_Synchronous__c</field>
+        <value xsi:type="xsd:boolean">false</value>
     </values>
     <values>
         <field>IsActive__c</field>
         <value xsi:type="xsd:boolean">true</value>
     </values>
     <values>
         <field>MatcherRule__c</field>
-        <value xsi:type="xsd:string">MatchEventBusAndCategory</value>
+        <value xsi:type="xsd:string">MatchEventBusAndCategoryAndEventName</value>
     </values>
 </CustomMetadata>