如何在NestJS Interceptor中合并两个Observable对象？

你的代码存在两个核心问题导致无法合并数据并存入数据库：

1. 直接调用subscribe()订阅地理编码流，会导致它与控制器的处理流异步执行，无法保证地理数据合并完成后再存入数据库。
2. 没有将地理编码数据合并到请求体或数据库返回的文档中，导致数据无法被持久化。

根据你“合并后存入数据库”的需求，正确的做法是在请求到达控制器前，将地理编码数据合并到请求体中，这样控制器保存时会直接将完整数据存入数据库。以下是修正后的拦截器代码：

import { Injectable, NestInterceptor, ExecutionContext, CallHandler } from '@nestjs/common';
import { Observable, from, switchMap } from 'rxjs';
import { catchError } from 'rxjs/operators';
import { BadRequestException } from '@nestjs/common';

@Injectable()
export class PointsInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    const request = context.switchToHttp().getRequest();
    const requestBody = request.body;

    // 将地理编码的Promise转为Observable，用RxJS操作符控制流顺序
    return from(geocoder.geocode(requestBody.address)).pipe(
      // 等待地理编码完成后，合并数据并继续执行控制器逻辑
      switchMap((geoResults) => {
        // 取第一个匹配的地理编码结果（通常最准确）
        const geoData = geoResults[0];
        // 合并原请求体与地理数据
        request.body = {
          ...requestBody,
          latitude: geoData.latitude,
          longitude: geoData.longitude,
          city: geoData.city,
          zipcode: geoData.zipcode,
          state: geoData.state
          // 按需添加其他地理字段
        };
        // 继续执行控制器的保存逻辑
        return next.handle();
      }),
      // 处理地理编码失败的情况
      catchError(() => {
        throw new BadRequestException('地址地理编码失败，请检查地址格式');
      })
    );
  }
}

代码说明 #

1. 流顺序控制：使用from()将geocoder.geocode()返回的Promise转为Observable，再通过switchMap()确保地理编码完成后才执行控制器的保存逻辑，避免异步冲突。
2. 数据合并：通过扩展运算符...将原请求体和地理数据合并，覆盖或新增字段到请求体中，控制器保存时会直接将合并后的数据写入数据库。
3. 错误处理：添加catchError()捕获地理编码失败的异常，返回友好的错误提示。

备选方案（仅合并响应数据） #

如果你的需求是数据库只保存原地址数据，仅在响应中返回合并后的结果，可以使用以下代码：

@Injectable()
export class PointsInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    const request = context.switchToHttp().getRequest();
    const address = request.body.address;

    return next.handle().pipe(
      switchMap((dbData) => {
        // 并行获取数据库返回数据与地理编码数据
        return from(geocoder.geocode(address)).pipe(
          map((geoResults) => {
            const geoData = geoResults[0];
            // 合并数据库文档与地理数据
            return { ...dbData, ...geoData };
          })
        );
      })
    );
  }
}

内容的提问来源于stack exchange，提问作者Philippe Corrèges