fix(gatsby): 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,
  })