Inngest transport for NestJS | nestjs-inngest-transport

A transport like any other

@EventPattern, @Payload(), @Ctx() and the whole Nest pipeline. Moving a service to Inngest changes its bootstrap and nothing else.

Durable steps

step.run, step.sleep and step.waitForEvent from a Nest handler: each step runs once, its result memoized across retries.

Configured where it is declared

Concurrency, throttling, debouncing, timeouts and retries on the decorator, type-checked against Inngest's own types.

Errors Inngest understands

InngestExceptionFilter keeps NonRetriableError and RetryAfterError intact through Nest's exception layer.

Express or Fastify

Mounted on the application's own HTTP server with Inngest's official handlers — the adapter is detected, the body is read when Nest has not yet.

Tested against the real thing

A fake client for unit tests, in-process runs with @inngest/test, and the dev server in Docker — the package's own suite runs all three.

The Nest you already write

Controllers, @Payload(), @Ctx(), guards, pipes, interceptors and filters work the way Nest documents them for every transport. What changes is what runs the handler: an Inngest function, invoked over HTTP, with durable steps underneath.

orders.handler.ts
@Controller()
@UseFilters(InngestExceptionFilter)
export class OrdersHandler {
  @InngestEventPattern('orders.placed', { concurrency: { limit: 5 } })
  async place(@Payload() order: Order, @Ctx() context: InngestContext) {
    const step = context.getStep();
    await step.run('reserve-stock', () => this.stock.reserve(order));
    await step.sleep('cool-off', '1h');
    await step.run('confirm', () => this.mailer.confirm(order));
  }
}

main.ts
const app = await NestFactory.create(AppModule);
app.connectMicroservice({
  strategy: new InngestStrategy({ inngest, httpAdapter: app.getHttpAdapter() }),
});
await app.startAllMicroservices();
await app.listen(3000);

// anywhere else
await lastValueFrom(events.emit('orders.placed', order));

Start here, or read why Nest's default exception filter needs replacing before going to production.