rsnext/packages/next/build/webpack/plugins/middleware-plugin.ts

import { webpack, sources, webpack5 } from 'next/dist/compiled/webpack/webpack'
import { getMiddlewareRegex } from '../../../shared/lib/router/utils'
import { getSortedRoutes } from '../../../shared/lib/router/utils'
import {
  MIDDLEWARE_MANIFEST,
  MIDDLEWARE_FLIGHT_MANIFEST,
  MIDDLEWARE_BUILD_MANIFEST,
  MIDDLEWARE_REACT_LOADABLE_MANIFEST,
  MIDDLEWARE_RUNTIME_WEBPACK,
  MIDDLEWARE_SSR_RUNTIME_WEBPACK,
} from '../../../shared/lib/constants'
import { nonNullable } from '../../../lib/non-nullable'
import type { WasmBinding } from '../loaders/next-middleware-wasm-loader'

const PLUGIN_NAME = 'MiddlewarePlugin'
const MIDDLEWARE_FULL_ROUTE_REGEX = /^pages[/\\]?(.*)\/_middleware$/

export const ssrEntries = new Map<string, { requireFlightManifest: boolean }>()

export interface MiddlewareManifest {
  version: 1
  sortedMiddleware: string[]
  clientInfo: [location: string, isSSR: boolean][]
  middleware: {
    [page: string]: {
      env: string[]
      files: string[]
      name: string
      page: string
      regexp: string
      wasm?: WasmBinding[]
    }
  }
}

const middlewareManifest: MiddlewareManifest = {
  sortedMiddleware: [],
  clientInfo: [],
  middleware: {},
  version: 1,
}

function getPageFromEntrypointName(pagePath: string) {
  const ssrEntryInfo = ssrEntries.get(pagePath)
  const result = MIDDLEWARE_FULL_ROUTE_REGEX.exec(pagePath)
  const page = result
    ? `/${result[1]}`
    : ssrEntryInfo
    ? pagePath.slice('pages'.length).replace(/\/index$/, '') || '/'
    : null
  return page
}

export type PerRoute = {
  envPerRoute: Map<string, string[]>
  wasmPerRoute: Map<string, WasmBinding[]>
}

export function getEntrypointInfo(
  compilation: webpack5.Compilation,
  { envPerRoute, wasmPerRoute }: PerRoute,
  isEdgeRuntime: boolean
) {
  const entrypoints = compilation.entrypoints
  const infos = []
  for (const entrypoint of entrypoints.values()) {
    if (!entrypoint.name) continue

    const ssrEntryInfo = ssrEntries.get(entrypoint.name)

    if (ssrEntryInfo && !isEdgeRuntime) continue
    if (!ssrEntryInfo && isEdgeRuntime) continue

    const page = getPageFromEntrypointName(entrypoint.name)

    if (!page) {
      continue
    }

    const entryFiles = entrypoint
      .getFiles()
      .filter((file: string) => !file.endsWith('.hot-update.js'))

    const files = ssrEntryInfo
      ? [
          ssrEntryInfo.requireFlightManifest
            ? `server/${MIDDLEWARE_FLIGHT_MANIFEST}.js`
            : null,
          `server/${MIDDLEWARE_BUILD_MANIFEST}.js`,
          `server/${MIDDLEWARE_REACT_LOADABLE_MANIFEST}.js`,
          ...entryFiles.map((file) => 'server/' + file),
        ].filter(nonNullable)
      : entryFiles.map((file: string) => file)

    infos.push({
      env: envPerRoute.get(entrypoint.name) || [],
      wasm: wasmPerRoute.get(entrypoint.name) || [],
      files,
      name: entrypoint.name,
      page,
      regexp: getMiddlewareRegex(page, !ssrEntryInfo).namedRegex!,
    })
  }
  return infos
}

export default class MiddlewarePlugin {
  dev: boolean
  isEdgeRuntime: boolean

  constructor({
    dev,
    isEdgeRuntime,
  }: {
    dev: boolean
    isEdgeRuntime: boolean
  }) {
    this.dev = dev
    this.isEdgeRuntime = isEdgeRuntime
  }

  createAssets(
    compilation: webpack5.Compilation,
    assets: any,
    { envPerRoute, wasmPerRoute }: PerRoute,
    isEdgeRuntime: boolean
  ) {
    const infos = getEntrypointInfo(
      compilation,
      { envPerRoute, wasmPerRoute },
      isEdgeRuntime
    )
    infos.forEach((info) => {
      middlewareManifest.middleware[info.page] = info
    })

    middlewareManifest.sortedMiddleware = getSortedRoutes(
      Object.keys(middlewareManifest.middleware)
    )
    middlewareManifest.clientInfo = middlewareManifest.sortedMiddleware.map(
      (key) => {
        const middleware = middlewareManifest.middleware[key]
        const ssrEntryInfo = ssrEntries.get(middleware.name)
        return [key, !!ssrEntryInfo]
      }
    )

    assets[
      this.isEdgeRuntime ? MIDDLEWARE_MANIFEST : `server/${MIDDLEWARE_MANIFEST}`
    ] = new sources.RawSource(JSON.stringify(middlewareManifest, null, 2))
  }

  apply(compiler: webpack5.Compiler) {
    collectAssets(compiler, this.createAssets.bind(this), {
      dev: this.dev,
      pluginName: PLUGIN_NAME,
      isEdgeRuntime: this.isEdgeRuntime,
    })
  }
}

export function collectAssets(
  compiler: webpack5.Compiler,
  createAssets: (
    compilation: webpack5.Compilation,
    assets: any,
    { envPerRoute, wasmPerRoute }: PerRoute,
    isEdgeRuntime: boolean
  ) => void,
  options: {
    dev: boolean
    pluginName: string
    isEdgeRuntime: boolean
  }
) {
  const wp = compiler.webpack
  compiler.hooks.compilation.tap(
    options.pluginName,
    (compilation, { normalModuleFactory }) => {
      compilation.hooks.afterChunks.tap(options.pluginName, () => {
        const middlewareRuntimeChunk = compilation.namedChunks.get(
          MIDDLEWARE_RUNTIME_WEBPACK
        )
        if (middlewareRuntimeChunk) {
          middlewareRuntimeChunk.filenameTemplate = 'server/[name].js'
        }
      })

      const envPerRoute = new Map<string, string[]>()
      const wasmPerRoute = new Map<string, WasmBinding[]>()

      compilation.hooks.afterOptimizeModules.tap(PLUGIN_NAME, () => {
        const { moduleGraph } = compilation as any
        envPerRoute.clear()

        for (const [name, info] of compilation.entries) {
          if (
            info.options.runtime === MIDDLEWARE_SSR_RUNTIME_WEBPACK ||
            info.options.runtime === MIDDLEWARE_RUNTIME_WEBPACK
          ) {
            const middlewareEntries = new Set<webpack5.Module>()
            const env = new Set<string>()
            const wasm = new Set<WasmBinding>()

            const addEntriesFromDependency = (dep: any) => {
              const module = moduleGraph.getModule(dep)
              if (module) {
                middlewareEntries.add(module)
              }
            }

            const runtime = wp.util.runtime.getEntryRuntime(compilation, name)

            info.dependencies.forEach(addEntriesFromDependency)
            info.includeDependencies.forEach(addEntriesFromDependency)

            const queue = new Set(middlewareEntries)
            for (const module of queue) {
              const { buildInfo } = module
              if (buildInfo.nextWasmMiddlewareBinding) {
                wasm.add(buildInfo.nextWasmMiddlewareBinding)
              }
              if (
                !options.dev &&
                buildInfo &&
                isUsedByExports({
                  module,
                  moduleGraph,
                  runtime,
                  usedByExports: buildInfo.usingIndirectEval,
                })
              ) {
                if (
                  /node_modules[\\/]regenerator-runtime[\\/]runtime\.js/.test(
                    module.identifier()
                  )
                )
                  continue
                const error = new wp.WebpackError(
                  `Dynamic Code Evaluation (e. g. 'eval', 'new Function') not allowed in Middleware ${name}${
                    typeof buildInfo.usingIndirectEval !== 'boolean'
                      ? `\nUsed by ${Array.from(
                          buildInfo.usingIndirectEval
                        ).join(', ')}`
                      : ''
                  }`
                )
                error.module = module
                compilation.errors.push(error)
              }

              if (buildInfo?.nextUsedEnvVars !== undefined) {
                for (const envName of buildInfo.nextUsedEnvVars) {
                  env.add(envName)
                }
              }

              const connections = moduleGraph.getOutgoingConnections(module)
              for (const connection of connections) {
                if (connection.module) {
                  queue.add(connection.module)
                }
              }
            }

            envPerRoute.set(name, Array.from(env))
            wasmPerRoute.set(name, Array.from(wasm))
          }
        }
      })

      const handler = (parser: webpack5.javascript.JavascriptParser) => {
        const isMiddlewareModule = () =>
          parser.state.module && parser.state.module.layer === 'middleware'

        const wrapExpression = (expr: any) => {
          if (!isMiddlewareModule()) return

          if (options.dev) {
            const dep1 = new wp.dependencies.ConstDependency(
              '__next_eval__(function() { return ',
              expr.range[0]
            )
            dep1.loc = expr.loc
            parser.state.module.addPresentationalDependency(dep1)
            const dep2 = new wp.dependencies.ConstDependency(
              '})',
              expr.range[1]
            )
            dep2.loc = expr.loc
            parser.state.module.addPresentationalDependency(dep2)
          }
          expressionHandler()
          return true
        }

        const flagModule = (
          usedByExports: boolean | Set<string> | undefined
        ) => {
          if (usedByExports === undefined) usedByExports = true
          const old = parser.state.module.buildInfo.usingIndirectEval
          if (old === true || usedByExports === false) return
          if (!old || usedByExports === true) {
            parser.state.module.buildInfo.usingIndirectEval = usedByExports
            return
          }
          const set = new Set(old)
          for (const item of usedByExports) {
            set.add(item)
          }
          parser.state.module.buildInfo.usingIndirectEval = set
        }

        const expressionHandler = () => {
          if (!isMiddlewareModule()) return

          wp.optimize.InnerGraph.onUsage(parser.state, flagModule)
        }

        const ignore = () => {
          if (!isMiddlewareModule()) return

          return true
        }

        // wrapping
        parser.hooks.call.for('eval').tap(PLUGIN_NAME, wrapExpression)
        parser.hooks.call.for('global.eval').tap(PLUGIN_NAME, wrapExpression)
        parser.hooks.call.for('Function').tap(PLUGIN_NAME, wrapExpression)
        parser.hooks.call
          .for('global.Function')
          .tap(PLUGIN_NAME, wrapExpression)
        parser.hooks.new.for('Function').tap(PLUGIN_NAME, wrapExpression)
        parser.hooks.new.for('global.Function').tap(PLUGIN_NAME, wrapExpression)

        // fallbacks
        parser.hooks.expression.for('eval').tap(PLUGIN_NAME, expressionHandler)
        parser.hooks.expression
          .for('Function')
          .tap(PLUGIN_NAME, expressionHandler)
        parser.hooks.expression
          .for('Function.prototype')
          .tap(PLUGIN_NAME, ignore)
        parser.hooks.expression
          .for('global.eval')
          .tap(PLUGIN_NAME, expressionHandler)
        parser.hooks.expression
          .for('global.Function')
          .tap(PLUGIN_NAME, expressionHandler)
        parser.hooks.expression
          .for('global.Function.prototype')
          .tap(PLUGIN_NAME, ignore)

        const memberChainHandler = (_expr: any, members: string[]) => {
          if (members.length >= 2 && members[0] === 'env') {
            const envName = members[1]
            const { buildInfo } = parser.state.module
            if (buildInfo.nextUsedEnvVars === undefined) {
              buildInfo.nextUsedEnvVars = new Set()
            }

            buildInfo.nextUsedEnvVars.add(envName)
            if (isMiddlewareModule()) return true
          }
        }

        parser.hooks.callMemberChain
          .for('process')
          .tap(PLUGIN_NAME, memberChainHandler)

        parser.hooks.expressionMemberChain
          .for('process')
          .tap(PLUGIN_NAME, memberChainHandler)
      }

      normalModuleFactory.hooks.parser
        .for('javascript/auto')
        .tap(PLUGIN_NAME, handler)

      normalModuleFactory.hooks.parser
        .for('javascript/dynamic')
        .tap(PLUGIN_NAME, handler)

      normalModuleFactory.hooks.parser
        .for('javascript/esm')
        .tap(PLUGIN_NAME, handler)

      // @ts-ignore TODO: Remove ignore when webpack 5 is stable
      compilation.hooks.processAssets.tap(
        {
          name: 'NextJsMiddlewareManifest',
          // @ts-ignore TODO: Remove ignore when webpack 5 is stable
          stage: webpack.Compilation.PROCESS_ASSETS_STAGE_ADDITIONS,
        },
        (assets: any) => {
          createAssets(
            compilation,
            assets,
            { envPerRoute, wasmPerRoute },
            options.isEdgeRuntime
          )
        }
      )
    }
  )
}

function isUsedByExports(args: {
  module: webpack5.Module
  moduleGraph: webpack5.ModuleGraph
  runtime: any
  usedByExports: boolean | Set<string> | undefined
}): boolean {
  const { moduleGraph, runtime, module, usedByExports } = args
  if (usedByExports === undefined) return false
  if (typeof usedByExports === 'boolean') return usedByExports
  const exportsInfo = moduleGraph.getExportsInfo(module)
  const wp = webpack as unknown as typeof webpack5
  for (const exportName of usedByExports) {
    if (exportsInfo.getUsed(exportName, runtime) !== wp.UsageState.Unused)
      return true
  }
  return false
}