chore(telemetry): Flush more often with gatsby develop (#32015)

packages/gatsby-telemetry/src/index.ts

@@ -11,7 +11,7 @@ import time, { TimeUnit } from "@turist/time"
 
 const instance = new AnalyticsTracker()
 
-const flush = createFlush(instance.isTrackingEnabled())
+export const flush = createFlush(instance.isTrackingEnabled())
 
 process.on(`exit`, flush)
 
@@ -124,19 +124,20 @@ export {
 }
 
 module.exports = {
-  trackFeatureIsUsed,
-  trackCli,
+  addSiteMeasurement,
+  aggregateStats,
   captureEvent,
-  trackError,
-  trackBuildError,
-  setDefaultTags,
   decorateEvent,
-  setTelemetryEnabled,
-  startBackgroundUpdate,
-  isTrackingEnabled,
-  aggregateStats,
-  addSiteMeasurement,
   expressMiddleware,
+  flush,
+  isTrackingEnabled,
   setDefaultComponentId,
+  setDefaultTags,
   setGatsbyCliVersion,
+  setTelemetryEnabled,
+  startBackgroundUpdate,
+  trackBuildError,
+  trackCli,
+  trackError,
+  trackFeatureIsUsed,
 }

packages/gatsby/src/commands/develop.ts

@@ -23,6 +23,7 @@ import reporter from "gatsby-cli/lib/reporter"
 import { getSslCert } from "../utils/get-ssl-cert"
 import { IProxyControls, startDevelopProxy } from "../utils/develop-proxy"
 import { IProgram, IDebugInfo } from "./types"
+import { flush as telemetryFlush } from "gatsby-telemetry"
 
 // Adapted from https://stackoverflow.com/a/16060619
 const requireUncached = (file: string): any => {
@@ -392,6 +393,11 @@ module.exports = async (program: IProgram): Promise<void> => {
   // This needs to be propagated back to the parent process
   developProcess.onExit(
     (code: number | null, signal: NodeJS.Signals | null) => {
+      try {
+        telemetryFlush()
+      } catch (e) {
+        // nop
+      }
       if (isRestarting) return
       if (signal !== null) {
         process.kill(process.pid, signal)
@@ -519,6 +525,11 @@ function shutdownServices(
   }: IShutdownServicesOptions,
   signal: NodeJS.Signals
 ): Promise<void> {
+  try {
+    telemetryFlush()
+  } catch (e) {
+    // nop
+  }
   const services = [
     developProcess.stop(signal),
     telemetryServerProcess.stop(),