Nestjs | grpc : How to handle remote error from client side

Question

Remote Server

@Catch(RpcException)
export class RpcExceptionHandler implements RpcExceptionFilter<RpcException> {
    catch(exception: RpcException, host: ArgumentsHost): Observable<any> {
        return throwError(exception.getError());
    }
}

@UseFilters(new RpcExceptionHandler())
@GrpcMethod('AppController', 'Accumulate') 
async accumulate(numberArray: INumberArray, metadata: any): Promise<ISumOfNumberArray> { 

    throw new RpcException({
          code: 5,
          message: 'Data Not Found'
        })
}

Client code

@Get('add')
  async getSumc(@Query('data') data: number[]) {
    try {
      let ata = await this.grpcService.accumulate({ data }); 
      return ata;
    } catch (err) {
      //logic here if error comes
      return err;
    }
  }

Proto defination.

syntax = "proto3";

package app;

// Declare a service for each controller you have
service AppController {
  // Declare an rpc for each method that is called via gRPC
  rpc Accumulate (NumberArray) returns (SumOfNumberArray);
}

// Declare the types used above
message NumberArray {
  repeated double data = 1;
}
message SumOfNumberArray {
  double sum = 1;
}

If error comes it is not going to catch block, just showing the server error. I want to catch the error if remote throwing any error.

No one has dare to answer this. :) – AMit SiNgh Apr 29 '22 at 10:41 — AMit SiNgh, Apr 29 '22 at 10:41
I got the same issue. Did you fix it? – MadTik Sep 09 '22 at 08:03 — MadTik, Sep 09 '22 at 08:03

score 0 · Answer 1 · edited Jul 30 '22 at 08:03

0

Try this one:

@Get('add')
async getSumc(@Query('data') data: number[]) {
  try {
    let ata = await this.grpcService.accumulate({ data }).toPromise(); 
    return ata;
  } catch (e) {
    throw new RpcException(e);
  }
}

Example here

edited Jul 30 '22 at 08:03

Tyler2P

2,324
26
22
31

answered Jul 28 '22 at 05:23

Kirill Moskalew

79
9

Nestjs | grpc : How to handle remote error from client side

1 Answers1