Typescript GRPC客户端拦截器

import { Client, ClientUnaryCall, ClientReadableStream } from '@grpc/grpc-js';
import { Request, Response } from './your-grpc-service'; // 替换为你的gRPC服务定义

// UnaryInterceptor 示例
function unaryInterceptor(
  error: grpc.ServiceError | null,
  req: Request,
  metadata: grpc.Metadata,
  client: Client,
  method: grpc.UnaryMethodDefinition<Request, Response>
): Response {
  console.log('UnaryInterceptor - Before request');
  if (error) {
    console.error('UnaryInterceptor - Error:', error);
  }
  return method(req, metadata, client);
}

// StreamInterceptor 示例
function streamInterceptor(
  err: grpc.ServiceError | null,
  reqs: Request[],
  metadata: grpc.Metadata,
  client: Client,
  method: grpc.ClientStreamingMethodDefinition<Request, Response>
): ClientReadableStream<Response> {
  console.log('StreamInterceptor - Before request');
  if (err) {
    console.error('StreamInterceptor - Error:', err);
  }
  return method(reqs, metadata, client);
}

// 创建gRPC客户端并应用拦截器
const client = new YourGrpcServiceClient('localhost:50051', grpc.credentials.createInsecure());
client.yourMethod = unaryInterceptor.bind(null, client.yourMethod);
client.yourStreamingMethod = streamInterceptor.bind(null, client.yourStreamingMethod);