fix(gatsby): refactor sourceNodes api and add I&C/CFLOW as a codeowner (

#36244)

refactor sourceNodes api and add I&C/CFLOW as a codeowner

CODEOWNERS

@@ -0,0 +1 @@
+packages/gatsby/src/utils/source-nodes-api-runner.ts @gatsbyjs/integrations-collaboration

packages/gatsby/src/utils/source-nodes-api-runner.ts

@@ -0,0 +1,25 @@
+import { Span } from "opentracing"
+import apiRunner from "./api-runner-node"
+
+export function sourceNodesApiRunner({
+  traceId,
+  deferNodeMutation,
+  parentSpan,
+  webhookBody,
+  pluginName,
+}: {
+  traceId: string
+  webhookBody: unknown
+  pluginName?: string
+  parentSpan?: Span
+  deferNodeMutation?: boolean
+}): Promise<void> {
+  return apiRunner(`sourceNodes`, {
+    traceId,
+    waitForCascadingActions: true,
+    deferNodeMutation,
+    parentSpan,
+    webhookBody: webhookBody || {},
+    pluginName,
+  })
+}

packages/gatsby/src/utils/source-nodes.ts

@@ -1,6 +1,6 @@
 import report from "gatsby-cli/lib/reporter"
 import { Span } from "opentracing"
-import apiRunner from "./api-runner-node"
+import { sourceNodesApiRunner } from "./source-nodes-api-runner"
 import { store } from "../redux"
 import { getDataStore, getNode } from "../datastore"
 import { actions } from "../redux/actions"
@@ -106,12 +106,11 @@ export default async ({
   const traceId = isInitialSourcing
     ? `initial-sourceNodes`
     : `sourceNodes #${sourcingCount}`
-  await apiRunner(`sourceNodes`, {
+  await sourceNodesApiRunner({
     traceId,
-    waitForCascadingActions: true,
     deferNodeMutation,
     parentSpan,
-    webhookBody: webhookBody || {},
+    webhookBody,
     pluginName,
   })