@join-com/grpc - npm Package Compare versions

Comparing version 3.1.0 to 3.2.0

dist/Client.d.ts

@@ -5,3 +5,3 @@ import * as grpc from '@grpc/grpc-js';
 import { INoDebugLogger } from './interfaces/ILogger';
-declare type GrpcServiceClient = InstanceType<ReturnType<typeof grpc.makeGenericClientConstructor>>;
+type GrpcServiceClient = InstanceType<ReturnType<typeof grpc.makeGenericClientConstructor>>;
 export declare abstract class Client<ServiceImplementationType = grpc.UntypedServiceImplementation, ServiceNameType extends string = string> implements IClient<ServiceImplementationType, ServiceNameType> {
@@ -8,0 +8,0 @@ /** WARNING: Access this property from outside only for debugging/tracing/profiling purposes */

dist/interfaces/IClient.d.ts

@@ -5,14 +5,14 @@ import * as grpc from '@grpc/grpc-js';
 import { CondCapitalize, UncapitalizedMethodNames } from '../types/CapitalizationAdapters';
-export declare type MethodName<ServiceDefinitionType> = string & keyof grpc.ServiceDefinition<ServiceDefinitionType>;
-export declare type IBidiStreamRequest<RequestType, ResponseType> = {
+export type MethodName<ServiceDefinitionType> = string & keyof grpc.ServiceDefinition<ServiceDefinitionType>;
+export type IBidiStreamRequest<RequestType, ResponseType> = {
     call: grpc.ClientDuplexStream<RequestType, ResponseType>;
 };
-export declare type IClientStreamRequest<RequestType, ResponseType> = {
+export type IClientStreamRequest<RequestType, ResponseType> = {
     call: grpc.ClientWritableStream<RequestType>;
     res: Promise<ResponseType>;
 };
-export declare type IServerStreamRequest<ResponseType> = {
+export type IServerStreamRequest<ResponseType> = {
     call: grpc.ClientReadableStream<ResponseType>;
 };
-export declare type IUnaryRequest<ResponseType> = {
+export type IUnaryRequest<ResponseType> = {
     call: grpc.ClientUnaryCall;
@@ -29,16 +29,16 @@ res: Promise<ResponseType>;
 }
-export declare type UnaryRequestHandler<RequestType, ResponseType> = (argument: RequestType, metadata?: Record<string, string>, options?: grpc.CallOptions) => IUnaryRequest<ResponseType>;
-export declare type ClientStreamRequestHandler<RequestType, ResponseType> = (metadata?: Record<string, string>, options?: grpc.CallOptions) => IClientStreamRequest<RequestType, ResponseType>;
-export declare type ServerStreamRequestHandler<RequestType, ResponseType> = (argument: RequestType, metadata?: Record<string, string>, options?: grpc.CallOptions) => IServerStreamRequest<ResponseType>;
-export declare type BidiStreamRequestHandler<RequestType, ResponseType> = (metadata?: Record<string, string>, options?: grpc.CallOptions) => IBidiStreamRequest<RequestType, ResponseType>;
-export declare type ClientWrappedHandler<RequestType, ResponseType> = UnaryRequestHandler<RequestType, ResponseType> | ClientStreamRequestHandler<RequestType, ResponseType> | ServerStreamRequestHandler<RequestType, ResponseType> | BidiStreamRequestHandler<RequestType, ResponseType>;
-declare type ExtractRequestType<ImplMethod> = ImplMethod extends (call: infer CallType, ...args: any[]) => void ? CallType extends {
+export type UnaryRequestHandler<RequestType, ResponseType> = (argument: RequestType, metadata?: Record<string, string>, options?: grpc.CallOptions) => IUnaryRequest<ResponseType>;
+export type ClientStreamRequestHandler<RequestType, ResponseType> = (metadata?: Record<string, string>, options?: grpc.CallOptions) => IClientStreamRequest<RequestType, ResponseType>;
+export type ServerStreamRequestHandler<RequestType, ResponseType> = (argument: RequestType, metadata?: Record<string, string>, options?: grpc.CallOptions) => IServerStreamRequest<ResponseType>;
+export type BidiStreamRequestHandler<RequestType, ResponseType> = (metadata?: Record<string, string>, options?: grpc.CallOptions) => IBidiStreamRequest<RequestType, ResponseType>;
+export type ClientWrappedHandler<RequestType, ResponseType> = UnaryRequestHandler<RequestType, ResponseType> | ClientStreamRequestHandler<RequestType, ResponseType> | ServerStreamRequestHandler<RequestType, ResponseType> | BidiStreamRequestHandler<RequestType, ResponseType>;
+type ExtractRequestType<ImplMethod> = ImplMethod extends (call: infer CallType, ...args: any[]) => void ? CallType extends {
     request: infer RequestType;
 } ? RequestType : any : never;
-declare type ExtractResponseType<ServiceImplementationType, MethodName extends keyof ServiceImplementationType> = ServiceImplementationType[MethodName] extends (call: infer CallType, ...args: any[]) => void ? CallType extends ServerSurfaceCall & ObjectWritable<infer ResponseType> ? Exclude<ResponseType, grpc.Metadata | undefined> : ServiceImplementationType[MethodName] extends (call: CallType, callback: grpc.sendUnaryData<infer ResponseType>) => void ? ResponseType : unknown : never;
-export declare type IClientMethods<ServiceImplementationType = grpc.UntypedServiceImplementation> = {
+type ExtractResponseType<ServiceImplementationType, MethodName extends keyof ServiceImplementationType> = ServiceImplementationType[MethodName] extends (call: infer CallType, ...args: any[]) => void ? CallType extends ServerSurfaceCall & ObjectWritable<infer ResponseType> ? Exclude<ResponseType, grpc.Metadata | undefined> : ServiceImplementationType[MethodName] extends (call: CallType, callback: grpc.sendUnaryData<infer ResponseType>) => void ? ResponseType : unknown : never;
+export type IClientMethods<ServiceImplementationType = grpc.UntypedServiceImplementation> = {
     [methodName in UncapitalizedMethodNames<ServiceImplementationType>]: CondCapitalize<methodName> extends keyof ServiceImplementationType ? ClientWrappedHandler<ExtractRequestType<ServiceImplementationType[CondCapitalize<methodName>]>, ExtractResponseType<ServiceImplementationType, CondCapitalize<methodName>>> : never;
 };
-export declare type IExtendedClient<ServiceImplementationType = grpc.UntypedServiceImplementation, ServiceNameType extends string = string> = IClient<ServiceImplementationType, ServiceNameType> & IClientMethods<ServiceImplementationType>;
+export type IExtendedClient<ServiceImplementationType = grpc.UntypedServiceImplementation, ServiceNameType extends string = string> = IClient<ServiceImplementationType, ServiceNameType> & IClientMethods<ServiceImplementationType>;
 export {};
 //# sourceMappingURL=IClient.d.ts.map

dist/interfaces/ILogger.d.ts

@@ -10,3 +10,3 @@ export interface IInfoLogger {
 }
-export declare type INoDebugLogger = IInfoLogger & IErrorLogger & IWarnLogger;
+export type INoDebugLogger = IInfoLogger & IErrorLogger & IWarnLogger;
 //# sourceMappingURL=ILogger.d.ts.map

dist/Server.d.ts

@@ -15,4 +15,5 @@ import * as grpc from '@grpc/grpc-js';
     tryShutdown(): Promise<void>;
+    forceShutdown(): void;
 }
 export declare function bindServer(server: grpc.Server, host: string, credentials: grpc.ServerCredentials): Promise<number>;
 //# sourceMappingURL=Server.d.ts.map

dist/Server.js

@@ -57,2 +57,5 @@ "use strict";
     }
+    forceShutdown() {
+        this.server.forceShutdown();
+    }
 }
@@ -59,0 +62,0 @@ exports.Server = Server;

dist/Service.d.ts

@@ -6,8 +6,8 @@ import * as grpc from '@grpc/grpc-js';
 import { CondCapitalize, UncapitalizedMethodNames } from './types/CapitalizationAdapters';
-declare type GrpcCall<RequestType, ResponseType> = grpc.ServerUnaryCall<RequestType, ResponseType> | grpc.ServerReadableStream<RequestType, ResponseType> | grpc.ServerWritableStream<RequestType, ResponseType> | grpc.ServerDuplexStream<RequestType, ResponseType>;
-export declare type JoinGrpcHandler<RequestType = unknown, ResponseType = unknown, Callback extends undefined | grpc.sendUnaryData<ResponseType> = undefined, RequestWrapper extends GrpcCall<RequestType, ResponseType> = GrpcCall<RequestType, ResponseType>> = Callback extends undefined ? RequestWrapper extends grpc.ServerWritableStream<RequestType, ResponseType> | grpc.ServerDuplexStream<RequestType, ResponseType> ? (requestWrapper: RequestWrapper) => void | Promise<void> : (requestWrapper: RequestWrapper) => Promise<ResponseType> : (requestWrapper: RequestWrapper, callback: Callback) => void;
-export declare type JoinServiceImplementation<ServiceImplementationType = grpc.UntypedServiceImplementation> = {
+type GrpcCall<RequestType, ResponseType> = grpc.ServerUnaryCall<RequestType, ResponseType> | grpc.ServerReadableStream<RequestType, ResponseType> | grpc.ServerWritableStream<RequestType, ResponseType> | grpc.ServerDuplexStream<RequestType, ResponseType>;
+export type JoinGrpcHandler<RequestType = unknown, ResponseType = unknown, Callback extends undefined | grpc.sendUnaryData<ResponseType> = undefined, RequestWrapper extends GrpcCall<RequestType, ResponseType> = GrpcCall<RequestType, ResponseType>> = Callback extends undefined ? RequestWrapper extends grpc.ServerWritableStream<RequestType, ResponseType> | grpc.ServerDuplexStream<RequestType, ResponseType> ? (requestWrapper: RequestWrapper) => void | Promise<void> : (requestWrapper: RequestWrapper) => Promise<ResponseType> : (requestWrapper: RequestWrapper, callback: Callback) => void;
+export type JoinServiceImplementation<ServiceImplementationType = grpc.UntypedServiceImplementation> = {
     [methodName in UncapitalizedMethodNames<ServiceImplementationType>]: CondCapitalize<methodName> extends keyof InternalJoinServiceImplementation<ServiceImplementationType> ? InternalJoinServiceImplementation<ServiceImplementationType>[CondCapitalize<methodName>] : never;
 };
-export declare type InternalJoinServiceImplementation<ServiceImplementationType = grpc.UntypedServiceImplementation> = {
+export type InternalJoinServiceImplementation<ServiceImplementationType = grpc.UntypedServiceImplementation> = {
     [Key in keyof ServiceImplementationType]: ServiceImplementationType[Key] extends grpc.handleUnaryCall<infer RequestType, infer ResponseType> ? JoinGrpcHandler<RequestType, ResponseType, undefined, grpc.ServerUnaryCall<RequestType, ResponseType>> : ServiceImplementationType[Key] extends grpc.handleServerStreamingCall<infer RequestType, infer ResponseType> ? JoinGrpcHandler<RequestType, ResponseType, undefined, grpc.ServerWritableStream<RequestType, ResponseType>> : ServiceImplementationType[Key] extends grpc.handleClientStreamingCall<infer RequestType, infer ResponseType> ? JoinGrpcHandler<RequestType, ResponseType, undefined, grpc.ServerReadableStream<RequestType, ResponseType>> : ServiceImplementationType[Key] extends grpc.handleBidiStreamingCall<infer RequestType, infer ResponseType> ? JoinGrpcHandler<RequestType, ResponseType, undefined, grpc.ServerDuplexStream<RequestType, ResponseType>> : JoinGrpcHandler;
@@ -14,0 +14,0 @@ };

dist/types/ApplicationError.d.ts

 import { ApplicationErrorCode } from './ApplicationErrorCode';
-export declare type ApplicationError = Error & {
+export type ApplicationError = Error & {
     type: 'ApplicationError';
@@ -4,0 +4,0 @@ code: ApplicationErrorCode;

dist/types/ApplicationErrorCode.d.ts

@@ -1,2 +0,2 @@
-export declare type ApplicationErrorCode = 'unknown' | 'validation' | 'notFound' | 'conflict' | 'invalidInput';
+export type ApplicationErrorCode = 'unknown' | 'validation' | 'notFound' | 'conflict' | 'invalidInput';
 //# sourceMappingURL=ApplicationErrorCode.d.ts.map

dist/types/BackwardCompatibleCalls.d.ts

 import * as grpc from '@grpc/grpc-js';
-export declare type ServerUnaryCall<T> = grpc.ServerUnaryCall<T, unknown>;
-export declare type ServerWritableStream<T> = grpc.ServerWritableStream<T, unknown>;
+export type ServerUnaryCall<T> = grpc.ServerUnaryCall<T, unknown>;
+export type ServerWritableStream<T> = grpc.ServerWritableStream<T, unknown>;
 //# sourceMappingURL=BackwardCompatibleCalls.d.ts.map

dist/types/CapitalizationAdapters.d.ts

@@ -1,3 +0,3 @@
-export declare type UncapitalizedMethodNames<ServiceImplementationType> = keyof ServiceImplementationType extends string ? Uncapitalize<keyof ServiceImplementationType> : keyof ServiceImplementationType;
-export declare type CondCapitalize<S> = S extends string ? Capitalize<S> : S;
+export type UncapitalizedMethodNames<ServiceImplementationType> = keyof ServiceImplementationType extends string ? Uncapitalize<keyof ServiceImplementationType> : keyof ServiceImplementationType;
+export type CondCapitalize<S> = S extends string ? Capitalize<S> : S;
 //# sourceMappingURL=CapitalizationAdapters.d.ts.map

dist/types/LogSeverity.d.ts

@@ -1,2 +0,2 @@
-export declare type LogSeverity = 'INFO' | 'WARNING' | 'ERROR';
+export type LogSeverity = 'INFO' | 'WARNING' | 'ERROR';
 //# sourceMappingURL=LogSeverity.d.ts.map

package.json

 {
   "name": "@join-com/grpc",
-  "version": "3.1.0",
+  "version": "3.2.0",
   "description": "gRPC library",
@@ -36,19 +36,19 @@ "author": "JOIN Solutions",
     "@coderspirit/nominal": "3.2.2",
-    "@grpc/grpc-js": "^1.8.7",
-    "protobufjs": "^7.2.0"
+    "@grpc/grpc-js": "^1.8.10",
+    "protobufjs": "^7.2.2"
   },
   "devDependencies": {
     "@join-com/jest-matchers": "^1.0.7",
-    "@join-private/eslint-config-backend": "^1.1.3",
+    "@join-private/eslint-config-backend": "^1.2.0",
     "@types/jest": "^29.4.0",
-    "@types/node": "^18.11.18",
-    "eslint": "8.17.0",
-    "jest": "^29.4.1",
-    "jest-extended": "^3.2.3",
-    "jest-mock": "^29.4.1",
+    "@types/node": "^18.14.1",
+    "eslint": "8.34.0",
+    "jest": "^29.4.3",
+    "jest-extended": "^3.2.4",
+    "jest-mock": "^29.4.3",
     "jest-watch-typeahead": "^2.2.2",
-    "prettier": "^2.8.3",
+    "prettier": "^2.8.4",
     "ts-jest": "^29.0.5",
     "ts-node": "^10.9.1",
-    "typescript": "4.7.4"
+    "typescript": "4.9.5"
   },
@@ -55,0 +55,0 @@ "contributors": [

No alert changes

Improved metrics

Total package byte prevSize

72157

increased by0.07%

Lines of code

757

increased by0.53%

Dependency changes

• Updated@grpc/grpc-js@^1.8.10

• Updatedprotobufjs@^7.2.2