Function recoveryStreamInterceptor

server/middleware.go:125–150

recoveryStreamInterceptor recovers from panics in stream RPCs. Security (H11): Stack traces only logged in debug mode.

(logger *zap.Logger)

// recoveryStreamInterceptor recovers from panics in stream RPCs.
// Security (H11): Stack traces only logged in debug mode.
func recoveryStreamInterceptor(logger *zap.Logger) grpc.StreamServerInterceptor {
	return func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error) {
		requestID := uuid.New().String()

		defer func() {
			if r := recover(); r != nil {
				if isDebugMode() {
					logger.Error(i18n.T("server.middleware.panic_stream"),
						zap.String("request_id", requestID),
						zap.Any("panic", r),
						zap.String("method", info.FullMethod),
						zap.String("stack", string(debug.Stack())),
					)
				} else {
					logger.Error("panic recovered (stream)",
						zap.String("request_id", requestID),
						zap.String("method", info.FullMethod),
						zap.String("error", sanitizePanicValue(r)),
					)
				}
				err = status.Errorf(codes.Internal, "internal error (request_id: %s)", requestID)
			}
		}()
		return handler(srv, ss)
	}
}