[GitHub Workflow] Add syncOnStartup configuration #8103

Author: tobiu

ai/mcp/server/github-workflow/Server.mjs

@@ -6,6 +6,7 @@ import aiConfig                                        from './config.mjs';
 import logger                                          from './logger.mjs';
 import HealthService                                   from './services/HealthService.mjs';
 import RepositoryService                               from './services/RepositoryService.mjs';
+import SyncService                                     from './services/SyncService.mjs';
 import {listTools, callTool}                           from './services/toolService.mjs';
 
 /**
@@ -87,7 +88,11 @@ class Server extends Base {
             await RepositoryService.fetchAndCacheViewerPermission();
         }
 
-        // 5. Connect Transport
+        // 5. Wait for dependent services
+        // SyncService (singleton) might be performing a startup sync. We wait for it to be ready.
+        await SyncService.ready();
+
+        // 6. Connect Transport
         this.transport = new StdioServerTransport();
         await this.mcpServer.connect(this.transport);
 

ai/mcp/server/github-workflow/config.mjs

@@ -46,6 +46,11 @@ const defaultConfig = {
      * @type {string}
      */
     repo: 'neo',
+    /**
+     * Whether to automatically trigger a full sync when the server starts.
+     * @type {boolean}
+     */
+    syncOnStartup: true,
     /**
      * Configuration for the issue synchronization service.
      */

ai/mcp/server/github-workflow/services/HealthService.mjs

@@ -66,6 +66,14 @@ class HealthService extends Base {
      */
     #lastCheckTime = null;
 
+    /**
+     * Promise of the currently executing health check.
+     * Used for request deduplication to prevent "thundering herd" of gh CLI calls.
+     * @member {Promise<Object>|null} #healthCheckPromise
+     * @private
+     */
+    #healthCheckPromise = null;
+
     /**
      * The status from the previous health check, used to detect state transitions
      * (e.g., recovery from 'unhealthy' to 'healthy') and log meaningful messages.
@@ -238,9 +246,22 @@ class HealthService extends Base {
             }
         }
 
+        // Check for in-flight request (deduplication)
+        if (this.#healthCheckPromise) {
+            logger.debug('[HealthService] Joining in-flight health check...');
+            return this.#healthCheckPromise;
+        }
+
         // Cache is stale, was unhealthy, or doesn't exist - perform a fresh check
         logger.debug('[HealthService] Performing fresh health check');
-        const health = await this.#performHealthCheck();
+
+        // Create the promise and store it
+        this.#healthCheckPromise = this.#performHealthCheck().finally(() => {
+            // Always clear the promise when done, success or fail
+            this.#healthCheckPromise = null;
+        });
+
+        const health = await this.#healthCheckPromise;
 
         // Detect and log meaningful state transitions
         // This helps users understand when their fixes (like running `gh auth login`) succeed

ai/mcp/server/github-workflow/services/SyncService.mjs

@@ -1,6 +1,7 @@
 import aiConfig        from '../config.mjs';
 import Base            from '../../../../../src/core/Base.mjs';
 import logger          from '../logger.mjs';
+import HealthService   from './HealthService.mjs';
 import IssueSyncer     from './sync/IssueSyncer.mjs';
 import MetadataManager from './sync/MetadataManager.mjs';
 import ReleaseSyncer   from './sync/ReleaseSyncer.mjs';
@@ -34,6 +35,33 @@ class SyncService extends Base {
         singleton: true
     }
 
+    /**
+     * @returns {Promise<void>}
+     */
+    async initAsync() {
+        await super.initAsync();
+
+        if (aiConfig.syncOnStartup) {
+            try {
+                // Ensure the system is healthy before attempting a sync.
+                // This call is cached/deduplicated by HealthService, so it's cheap if the server
+                // has already checked it.
+                const health = await HealthService.healthcheck();
+
+                if (health.status === 'healthy') {
+                    logger.info('[SyncService] Starting automatic startup sync...');
+                    await this.runFullSync();
+                } else {
+                    logger.warn('[SyncService] Skipping startup sync: GitHub CLI is unhealthy.');
+                }
+            } catch (error) {
+                // We strictly catch errors here to ensure that a sync failure (network, API, etc.)
+                // does not crash the entire service or prevent the server from starting.
+                logger.error('[SyncService] Startup sync failed:', error.message);
+            }
+        }
+    }
+
     /**
      * The main public entry point for the synchronization process.
      *