grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

try catch promise rejection and sendError

This commit is contained in:
Cedric Kassen 2023-07-12 13:41:30 +02:00
parent 14b18a4bba
commit 555643dcc8
1 changed files with 41 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
packages/grpc-js/src/server.ts
View File

@ -1183,29 +1183,33 @@ async function handleUnary<RequestType, ResponseType>(
metadata: Metadata,
encoding: string
): Promise<void> {
const request = await call.receiveUnaryMessage(encoding);
try {
const request = await call.receiveUnaryMessage(encoding);
if (request === undefined || call.cancelled) {
return;
}
const emitter = new ServerUnaryCallImpl<RequestType, ResponseType>(
call,
metadata,
request
);
handler.func(
emitter,
(
err: ServerErrorResponse | ServerStatusResponse | null,
value?: ResponseType | null,
trailer?: Metadata,
flags?: number
) => {
call.sendUnaryMessage(err, value, trailer, flags);
if (request === undefined || call.cancelled) {
return;
}
);
const emitter = new ServerUnaryCallImpl<RequestType, ResponseType>(
call,
metadata,
request
);
handler.func(
emitter,
(
err: ServerErrorResponse | ServerStatusResponse | null,
value?: ResponseType | null,
trailer?: Metadata,
flags?: number
) => {
call.sendUnaryMessage(err, value, trailer, flags);
}
);
} catch (err) {
call.sendError(err as ServerErrorResponse)
}
}
function handleClientStreaming<RequestType, ResponseType>(
@ -1245,20 +1249,24 @@ async function handleServerStreaming<RequestType, ResponseType>(
metadata: Metadata,
encoding: string
): Promise<void> {
const request = await call.receiveUnaryMessage(encoding);
try {
const request = await call.receiveUnaryMessage(encoding);
if (request === undefined || call.cancelled) {
return;
if (request === undefined || call.cancelled) {
return;
}
const stream = new ServerWritableStreamImpl<RequestType, ResponseType>(
call,
metadata,
handler.serialize,
request
);
handler.func(stream);
} catch (err) {
call.sendError(err as ServerErrorResponse)
}
const stream = new ServerWritableStreamImpl<RequestType, ResponseType>(
call,
metadata,
handler.serialize,
request
);
handler.func(stream);
}
function handleBidiStreaming<RequestType, ResponseType>(