From e03c1159ea650cc4bb931ae7be2ef22188bd635e Mon Sep 17 00:00:00 2001 From: Robert Date: Tue, 26 Oct 2021 14:01:37 -0700 Subject: [PATCH] log a warning when invalid value for grpc.default_compression_algorithm option is provided --- packages/grpc-js/src/compression-filter.ts | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/packages/grpc-js/src/compression-filter.ts b/packages/grpc-js/src/compression-filter.ts index 69fcf48d..26b2836b 100644 --- a/packages/grpc-js/src/compression-filter.ts +++ b/packages/grpc-js/src/compression-filter.ts @@ -19,10 +19,12 @@ import * as zlib from 'zlib'; import { Call, WriteObject, WriteFlags } from './call-stream'; import { Channel } from './channel'; -import { CompressionAlgorithms } from './compression-algorithms'; -import { BaseFilter, Filter, FilterFactory } from './filter'; -import { Metadata, MetadataValue } from './metadata'; import { ChannelOptions } from './channel-options'; +import { CompressionAlgorithms } from './compression-algorithms'; +import { LogVerbosity } from './constants'; +import { BaseFilter, Filter, FilterFactory } from './filter'; +import * as logging from './logging'; +import { Metadata, MetadataValue } from './metadata'; const CompressionAlgorithKeys = new Set(Object.keys(CompressionAlgorithms)); @@ -186,6 +188,8 @@ export class CompressionFilter extends BaseFilter implements Filter { if (isCompressionAlgorithmKey(compressionAlgorithmKey)) { this.defaultCompressionAlgorithm = CompressionAlgorithms[compressionAlgorithmKey]; this.sendCompression = getCompressionHandler(this.defaultCompressionAlgorithm); + } else { + logging.log(LogVerbosity.ERROR, 'Invalid value provided for grpc.default_compression_algorithm option'); } }