如何使用nestjs websocket 监听区块链数据

要在 NestJS 中监听区块链数据，可以使用 Web3.js 库与 WebSocket 协议进行交互。具体步骤如下：

1. 安装 `web3` 和 `@types/web3` 库：

npm install web3 @types/web3

2. 在 `app.module.ts` 中导入 `Web3Module`：

import { Module } from '@nestjs/common';
import { Web3Module } from './web3/web3.module';

@Module({
  imports: [Web3Module],
})
export class AppModule {}

3. 创建 `web3.module.ts` 文件，定义 `Web3Service` 类：

import { Module } from '@nestjs/common';
import Web3 from 'web3';
import { ConfigService } from '@nestjs/config';

@Module({
  providers: [
    {
      provide: 'WEB3',
      useFactory: (configService: ConfigService) => {
        const url = configService.get<string>('web3.url');
        return new Web3(url);
      },
      inject: [ConfigService],
    },
  ],
  exports: ['WEB3'],
})
export class Web3Module {}

在上面的代码中，我们使用 `useFactory` 方法来创建一个 `Web3` 实例，并将其提供给其他模块使用。我们还需要在 `app.module.ts` 中导入 `ConfigModule`，并在 `Web3Module` 中注入 `ConfigService`，以便从配置文件中获取 WebSocket 地址。

4. 在需要监听区块链数据的模块中，注入 `Web3Service` 并创建 WebSocket 连接：

import { Controller } from '@nestjs/common';
import { InjectWeb3 } from '../web3/web3.decorators';
import Web3 from 'web3';

@Controller()
export class MyController {
  constructor(@InjectWeb3() private readonly web3: Web3) {
    const subscription = this.web3.eth.subscribe('newBlockHeaders', (error, blockHeader) => {
      if (error) {
        console.error(error);
      } else {
        console.log(blockHeader);
      }
    });
  }
}

在上面的代码中，我们使用 `InjectWeb3` 装饰器来注入 `Web3Service`，然后调用 `eth.subscribe` 方法来订阅区块链数据。在这个示例中，我们订阅了 `newBlockHeaders` 事件，当新的区块生成时，就会触发回调函数并打印区块头信息。

这只是一个简单的示例，你可以根据自己的实际需求来订阅其他类型的区块链事件或执行其他类型的 Web3 操作。