chore(ts): migrate remove-stale-jobs to typescript

packages/gatsby/src/bootstrap/index.js

@@ -21,7 +21,7 @@ const report = require(`gatsby-cli/lib/reporter`)
 import { getConfigFile } from "./get-config-file"
 const tracer = require(`opentracing`).globalTracer()
 const preferDefault = require(`./prefer-default`)
-const removeStaleJobs = require(`./remove-stale-jobs`)
+import { removeStaleJobs } from "./remove-stale-jobs"
 
 // Show stack trace on unhandled promises.
 process.on(`unhandledRejection`, (reason, p) => {

packages/gatsby/src/bootstrap/remove-stale-jobs.ts

@@ -0,0 +1,35 @@
+import {
+  IGatsbyState,
+  IRemoveStaleJobAction,
+  IGatsbyJobV2,
+} from "../redux/types"
+
+import { isJobStale } from "../utils/jobs-manager"
+import { publicActions, internalActions } from "../redux/actions"
+
+export const removeStaleJobs = (
+  state: IGatsbyState
+): IRemoveStaleJobAction[] => {
+  const actions: IRemoveStaleJobAction[] = []
+
+  // If any of our finished jobs are stale we remove them to keep our cache small
+  state.jobsV2.complete.forEach(
+    (job: IGatsbyJobV2, contentDigest: string): void => {
+      if (isJobStale(job)) {
+        actions.push(internalActions.removeStaleJob(contentDigest))
+      }
+    }
+  )
+
+  // If any of our pending jobs do not have an existing inputPath or the inputPath changed
+  // we remove it from the queue as they would fail anyway
+  state.jobsV2.incomplete.forEach(({ job, plugin }: IGatsbyJobV2): void => {
+    if (isJobStale(job)) {
+      actions.push(internalActions.removeStaleJob(job.contentDigest))
+    } else {
+      actions.push(publicActions.createJobV2(job, plugin))
+    }
+  })
+
+  return actions
+}

packages/gatsby/src/redux/actions/internal.ts

@@ -205,7 +205,7 @@ export const pageQueryRun = (
  */
 export const removeStaleJob = (
   contentDigest: string,
-  plugin: IGatsbyPlugin,
+  plugin?: IGatsbyPlugin,
   traceId?: string
 ): IRemoveStaleJobAction => {
   return {

packages/gatsby/src/redux/types.ts

@@ -91,6 +91,17 @@ export interface IGatsbyStaticQueryComponents {
 
 type GatsbyNodes = Map<string, IGatsbyNode>
 
+export interface IGatsbyJobContent {
+  inputPaths: string[]
+  contentDigest: string
+}
+
+export interface IGatsbyJobV2 {
+  job: IGatsbyJobContent
+  plugin: IGatsbyPlugin
+  traceId?: string
+}
+
 export interface IGatsbyState {
   program: IProgram
   nodes: GatsbyNodes
@@ -156,8 +167,8 @@ export interface IGatsbyState {
     done: any[] // TODO
   }
   jobsV2: {
-    incomplete: Map<any, any> // TODO
-    complete: Map<any, any>
+    incomplete: Map<Identifier, IGatsbyJobV2>
+    complete: Map<Identifier, IGatsbyJobV2>
   }
   webpack: any // TODO This should be the output from ./utils/webpack.config.js
   webpackCompilationHash: string