Method init

packages/pino/src/handler-plugin.ts:65–196

(options: StandardHandlerOptions<T>)

  }

  init(options: StandardHandlerOptions<T>): void {
    options.rootInterceptors ??= []
    options.interceptors ??= []
    options.clientInterceptors ??= []

    options.rootInterceptors.unshift(async (interceptorOptions) => {
      const logger = (
        (interceptorOptions.context as LoggerContext)[CONTEXT_LOGGER_SYMBOL] ?? this.logger
      ).child({
        rpc: { id: this.generateId(interceptorOptions), system: ORPC_NAME },
      })

      /**
       * pino-http might have already set req info in bindings
       */
      if (!logger.bindings().req) {
        logger.setBindings({
          req: {
            url: interceptorOptions.request.url,
            method: interceptorOptions.request.method,
            headers: {
              'content-type': interceptorOptions.request.headers['content-type'],
              'content-length': interceptorOptions.request.headers['content-length'],
              'content-disposition': interceptorOptions.request.headers['content-disposition'],
            },
          },
        })
      }

      if (this.logRequestAbort) {
        const signal = interceptorOptions.request.signal

        if (signal?.aborted) {
          logger?.info(`request was aborted before handling (${String(signal.reason)})`)
        }
        else {
          signal?.addEventListener('abort', () => {
            logger?.info(`request is aborted (${String(signal.reason)})`)
          }, { once: true })
        }
      }

      try {
        if (this.logRequestResponse) {
          logger?.info('request received')
        }

        const result = await interceptorOptions.next({
          ...interceptorOptions,
          context: {
            ...interceptorOptions.context,
            [CONTEXT_LOGGER_SYMBOL]: logger,
          },
        })

        if (this.logRequestResponse) {
          if (result.matched) {
            logger?.info({