🐛 events, test w/ split organizations

bot-github-core/src/main/java/org/commonhaus/automation/github/discovery/PostInitialDiscoveryEvent.java

@@ -0,0 +1,11 @@
+package org.commonhaus.automation.github.discovery;
+
+import org.kohsuke.github.GitHub;
+
+import io.smallrye.graphql.client.dynamic.api.DynamicGraphQLClient;
+
+public record PostInitialDiscoveryEvent(
+        long installationId,
+        GitHub github,
+        DynamicGraphQLClient graphQLClient) {
+}

bot-github-core/src/main/java/org/commonhaus/automation/github/discovery/RepositoryDiscovery.java

@@ -43,6 +43,9 @@ public class RepositoryDiscovery {
     @Inject
     Event<RepositoryDiscoveryEvent> repositoryDiscoveryEvent;
 
+    @Inject
+    Event<PostInitialDiscoveryEvent> postDiscoveryEvent;
+
     private ContextService ctx;
 
     // discoverRepositories is/was being called twice. Avoid double discovery
@@ -67,11 +70,14 @@ void discoverRepositories(@Observes StartupEvent ev) {
                 DynamicGraphQLClient graphQLClient = gitHubService.getInstallationGraphQLClient(ghiId);
                 GHAuthenticatedAppInstallation ghai = github.getInstallation();
 
+                Log.debugf("[%s] Fire initial discovery events", ghiId);
                 for (GHRepository repo : ghai.listRepositories()) {
                     repositoryDiscoveryEvent.fire(new RepositoryDiscoveryEvent(
                             DiscoveryAction.ADDED, github, graphQLClient, ghiId,
-                            repo, fetchConfigFile(repo)));
+                            repo, fetchConfigFile(repo), true));
                 }
+                Log.debugf("[%s] PostInitialDiscoveryEvent", ghiId);
+                postDiscoveryEvent.fire(new PostInitialDiscoveryEvent(ghiId, github, graphQLClient));
             }
         } catch (GHIOException e) {
             ctx.logAndSendEmail("discoverRepositories", "Error making GH Request", e, null);
@@ -114,14 +120,14 @@ void onInstallationChange(@RawEvent(event = "installation") GitHubEvent gitHubEv
                 for (GHRepository repo : repositories) {
                     repositoryDiscoveryEvent.fire(new RepositoryDiscoveryEvent(
                             DiscoveryAction.INSTALL_ADDED, github, graphQLClient, installationId,
-                            repo, fetchConfigFile(repo)));
+                            repo, fetchConfigFile(repo), false));
                 }
             }
             case "deleted", "suspend" -> {
                 for (GHRepository repo : repositories) {
                     repositoryDiscoveryEvent.fire(new RepositoryDiscoveryEvent(
                             DiscoveryAction.INSTALL_REMOVED, github, graphQLClient, installationId,
-                            repo, null));
+                            repo, null, false));
                 }
             }
             default -> {
@@ -155,13 +161,13 @@ protected void handleRepositoryChanges(GitHub github, DynamicGraphQLClient graph
         for (GHRepository repo : added) {
             repositoryDiscoveryEvent.fire(new RepositoryDiscoveryEvent(
                     DiscoveryAction.ADDED, github, graphQLClient, installationId,
-                    repo, fetchConfigFile(repo)));
+                    repo, fetchConfigFile(repo), false));
         }
 
         for (GHRepository repo : removed) {
             repositoryDiscoveryEvent.fire(new RepositoryDiscoveryEvent(
                     DiscoveryAction.REMOVED, github, graphQLClient, installationId,
-                    repo, null));
+                    repo, null, false));
         }
     }
 

bot-github-core/src/main/java/org/commonhaus/automation/github/discovery/RepositoryDiscoveryEvent.java

@@ -13,7 +13,8 @@ public record RepositoryDiscoveryEvent(
         DynamicGraphQLClient graphQLClient,
         long installationId,
         GHRepository repository,
-        Optional<?> repoConfig) {
+        Optional<?> repoConfig,
+        boolean bootstrap) {
 
     public boolean added() {
         return action.added();