Inngest SDK: Using middleware to access search params from request

inngest-client.ts

import { type NextRequest } from 'next/server';
import { Inngest, InngestMiddleware } from 'inngest';
import { schemas } from './types';

export const searchParamsMiddleware = new InngestMiddleware({
  name: 'query-params-pass-through',
  init({}) {
    return {
      onFunctionRun() {
        return {
          transformInput({ reqArgs }) {
            // The second arg in the array is the request itself
            const req = reqArgs[1] as NextRequest;
            const url = new URL(req.url);
            return {
              ctx: {
                // Adding fields to "ctx" adds them to your function handler's args (see function below)
                searchParams: url.searchParams,
              },
            };
          },
        };
      },
    };
  },
});

export const inngest = new Inngest({
  id: 'my-nextjs-app',
  schemas,
  middleware: [searchParamsMiddleware],
});

inngest-function.ts

import { inngest, searchParamsMiddleware } from './client';

export default inngest.createFunction(
  { id: 'hello-world' },
  { event: 'demo/event.sent' },
  // The new field added to "ctx" in the middleware is now available in your function args:
  async ({ event, step, searchParams }) => {
    console.log('searchParams', searchParams);
    return {
      message: `Hello ${event.name}!`,
    };
  }
);