/
var
/
www
/
qr4y.com
/
server
/
delivery
/
node_modules
/
@grpc
/
grpc-js
/
build
/
src
/
/var/www/qr4y.com/server/delivery/node_modules/@grpc/grpc-js/build/src
mkdir
upload
Name
Size
Mode
Actions
generated/
-
0755
rm
admin.d.ts
447
0644
edit
dl
rm
admin.js
1277
0644
edit
dl
rm
admin.js.map
471
0644
edit
dl
rm
backoff-timeout.d.ts
2187
0644
edit
dl
rm
backoff-timeout.js
5071
0644
edit
dl
rm
backoff-timeout.js.map
2896
0644
edit
dl
rm
call-credentials-filter.d.ts
684
0644
edit
dl
rm
call-credentials-filter.js
3211
0644
edit
dl
rm
call-credentials-filter.js.map
1685
0644
edit
dl
rm
call-credentials.d.ts
2423
0644
edit
dl
rm
call-credentials.js
4991
0644
edit
dl
rm
call-credentials.js.map
3266
0644
edit
dl
rm
call-stream.d.ts
5788
0644
edit
dl
rm
call-stream.js
30423
0644
edit
dl
rm
call-stream.js.map
18669
0644
edit
dl
rm
call.d.ts
3583
0644
edit
dl
rm
call.js
5073
0644
edit
dl
rm
call.js.map
2779
0644
edit
dl
rm
channel-credentials.d.ts
3836
0644
edit
dl
rm
channel-credentials.js
7306
0644
edit
dl
rm
channel-credentials.js.map
3664
0644
edit
dl
rm
channel-options.d.ts
2215
0644
edit
dl
rm
channel-options.js
2179
0644
edit
dl
rm
channel-options.js.map
1208
0644
edit
dl
rm
channel.d.ts
5808
0644
edit
dl
rm
channel.js
28983
0644
edit
dl
rm
channel.js.map
16058
0644
edit
dl
rm
channelz.d.ts
3908
0644
edit
dl
rm
channelz.js
22955
0644
edit
dl
rm
channelz.js.map
17297
0644
edit
dl
rm
client-interceptors.d.ts
4782
0644
edit
dl
rm
client-interceptors.js
17868
0644
edit
dl
rm
client-interceptors.js.map
10679
0644
edit
dl
rm
client.d.ts
5828
0644
edit
dl
rm
client.js
18328
0644
edit
dl
rm
client.js.map
11909
0644
edit
dl
rm
compression-algorithms.d.ts
94
0644
edit
dl
rm
compression-algorithms.js
1158
0644
edit
dl
rm
compression-algorithms.js.map
311
0644
edit
dl
rm
compression-filter.d.ts
1242
0644
edit
dl
rm
compression-filter.js
10306
0644
edit
dl
rm
compression-filter.js.map
6267
0644
edit
dl
rm
connectivity-state.d.ts
135
0644
edit
dl
rm
connectivity-state.js
1264
0644
edit
dl
rm
connectivity-state.js.map
327
0644
edit
dl
rm
constants.d.ts
944
0644
edit
dl
rm
constants.js
3106
0644
edit
dl
rm
constants.js.map
950
0644
edit
dl
rm
deadline-filter.d.ts
825
0644
edit
dl
rm
deadline-filter.js
3628
0644
edit
dl
rm
deadline-filter.js.map
2574
0644
edit
dl
rm
duration.d.ts
267
0644
edit
dl
rm
duration.js
1253
0644
edit
dl
rm
duration.js.map
606
0644
edit
dl
rm
events.d.ts
521
0644
edit
dl
rm
events.js
711
0644
edit
dl
rm
events.js.map
131
0644
edit
dl
rm
experimental.d.ts
1279
0644
edit
dl
rm
experimental.js
3520
0644
edit
dl
rm
experimental.js.map
741
0644
edit
dl
rm
filter-stack.d.ts
976
0644
edit
dl
rm
filter-stack.js
2589
0644
edit
dl
rm
filter-stack.js.map
2124
0644
edit
dl
rm
filter.d.ts
1106
0644
edit
dl
rm
filter.js
1129
0644
edit
dl
rm
filter.js.map
485
0644
edit
dl
rm
http_proxy.d.ts
696
0644
edit
dl
rm
http_proxy.js
9359
0644
edit
dl
rm
http_proxy.js.map
6009
0644
edit
dl
rm
index.d.ts
5335
0644
edit
dl
rm
index.js
8767
0644
edit
dl
rm
index.js.map
2945
0644
edit
dl
rm
load-balancer-child-handler.d.ts
815
0644
edit
dl
rm
load-balancer-child-handler.js
5226
0644
edit
dl
rm
load-balancer-child-handler.js.map
3231
0644
edit
dl
rm
load-balancer-outlier-detection.d.ts
2663
0644
edit
dl
rm
load-balancer-outlier-detection.js
22763
0644
edit
dl
rm
load-balancer-outlier-detection.js.map
16350
0644
edit
dl
rm
load-balancer-pick-first.d.ts
2828
0644
edit
dl
rm
load-balancer-pick-first.js
17325
0644
edit
dl
rm
load-balancer-pick-first.js.map
9359
0644
edit
dl
rm
load-balancer-round-robin.d.ts
804
0644
edit
dl
rm
load-balancer-round-robin.js
7814
0644
edit
dl
rm
load-balancer-round-robin.js.map
5011
0644
edit
dl
rm
load-balancer.d.ts
4453
0644
edit
dl
rm
load-balancer.js
4845
0644
edit
dl
rm
load-balancer.js.map
2353
0644
edit
dl
rm
logging.d.ts
508
0644
edit
dl
rm
logging.js
3879
0644
edit
dl
rm
logging.js.map
2682
0644
edit
dl
rm
make-client.d.ts
3010
0644
edit
dl
rm
make-client.js
5498
0644
edit
dl
rm
make-client.js.map
3112
0644
edit
dl
rm
max-message-size-filter.d.ts
832
0644
edit
dl
rm
max-message-size-filter.js
3302
0644
edit
dl
rm
max-message-size-filter.js.map
1675
0644
edit
dl
rm
metadata.d.ts
3195
0644
edit
dl
rm
metadata.js
8983
0644
edit
dl
rm
metadata.js.map
5742
0644
edit
dl
rm
object-stream.d.ts
1620
0644
edit
dl
rm
object-stream.js
718
0644
edit
dl
rm
object-stream.js.map
145
0644
edit
dl
rm
picker.d.ts
3309
0644
edit
dl
rm
picker.js
3124
0644
edit
dl
rm
picker.js.map
1256
0644
edit
dl
rm
resolver-dns.d.ts
232
0644
edit
dl
rm
resolver-dns.js
13113
0644
edit
dl
rm
resolver-dns.js.map
7332
0644
edit
dl
rm
resolver-ip.d.ts
39
0644
edit
dl
rm
resolver-ip.js
3803
0644
edit
dl
rm
resolver-ip.js.map
2477
0644
edit
dl
rm
resolver-uds.d.ts
39
0644
edit
dl
rm
resolver-uds.js
1517
0644
edit
dl
rm
resolver-uds.js.map
818
0644
edit
dl
rm
resolver.d.ts
4285
0644
edit
dl
rm
resolver.js
3216
0644
edit
dl
rm
resolver.js.map
1384
0644
edit
dl
rm
resolving-load-balancer.d.ts
2756
0644
edit
dl
rm
resolving-load-balancer.js
11987
0644
edit
dl
rm
resolving-load-balancer.js.map
6237
0644
edit
dl
rm
server-call.d.ts
7941
0644
edit
dl
rm
server-call.js
23244
0644
edit
dl
rm
server-call.js.map
18168
0644
edit
dl
rm
server-credentials.d.ts
480
0644
edit
dl
rm
server-credentials.js
2829
0644
edit
dl
rm
server-credentials.js.map
1782
0644
edit
dl
rm
server.d.ts
1840
0644
edit
dl
rm
server.js
32320
0644
edit
dl
rm
server.js.map
22467
0644
edit
dl
rm
service-config.d.ts
1538
0644
edit
dl
rm
service-config.js
10898
0644
edit
dl
rm
service-config.js.map
6686
0644
edit
dl
rm
status-builder.d.ts
654
0644
edit
dl
rm
status-builder.js
1767
0644
edit
dl
rm
status-builder.js.map
972
0644
edit
dl
rm
stream-decoder.d.ts
313
0644
edit
dl
rm
stream-decoder.js
4267
0644
edit
dl
rm
stream-decoder.js.map
2715
0644
edit
dl
rm
subchannel-address.d.ts
956
0644
edit
dl
rm
subchannel-address.js
2100
0644
edit
dl
rm
subchannel-address.js.map
1056
0644
edit
dl
rm
subchannel-interface.d.ts
1717
0644
edit
dl
rm
subchannel-interface.js
1599
0644
edit
dl
rm
subchannel-interface.js.map
884
0644
edit
dl
rm
subchannel-pool.d.ts
1472
0644
edit
dl
rm
subchannel-pool.js
5555
0644
edit
dl
rm
subchannel-pool.js.map
2426
0644
edit
dl
rm
subchannel.d.ts
7008
0644
edit
dl
rm
subchannel.js
37188
0644
edit
dl
rm
subchannel.js.map
20811
0644
edit
dl
rm
tls-helpers.d.ts
149
0644
edit
dl
rm
tls-helpers.js
1272
0644
edit
dl
rm
tls-helpers.js.map
502
0644
edit
dl
rm
uri-parser.d.ts
357
0644
edit
dl
rm
uri-parser.js
3274
0644
edit
dl
rm
uri-parser.js.map
2010
0644
edit
dl
rm
Edit:
/var/www/qr4y.com/server/delivery/node_modules/@grpc/grpc-js/build/src/call-stream.js
(30423B)
"use strict"; /* * Copyright 2019 gRPC authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * */ Object.defineProperty(exports, "__esModule", { value: true }); exports.Http2CallStream = exports.InterceptingListenerImpl = exports.isInterceptingListener = void 0; const http2 = require("http2"); const os = require("os"); const constants_1 = require("./constants"); const metadata_1 = require("./metadata"); const stream_decoder_1 = require("./stream-decoder"); const logging = require("./logging"); const constants_2 = require("./constants"); const TRACER_NAME = 'call_stream'; const { HTTP2_HEADER_STATUS, HTTP2_HEADER_CONTENT_TYPE, NGHTTP2_CANCEL, } = http2.constants; /** * Should do approximately the same thing as util.getSystemErrorName but the * TypeScript types don't have that function for some reason so I just made my * own. * @param errno */ function getSystemErrorName(errno) { for (const [name, num] of Object.entries(os.constants.errno)) { if (num === errno) { return name; } } return 'Unknown system error ' + errno; } function getMinDeadline(deadlineList) { let minValue = Infinity; for (const deadline of deadlineList) { const deadlineMsecs = deadline instanceof Date ? deadline.getTime() : deadline; if (deadlineMsecs < minValue) { minValue = deadlineMsecs; } } return minValue; } function isInterceptingListener(listener) { return (listener.onReceiveMetadata !== undefined && listener.onReceiveMetadata.length === 1); } exports.isInterceptingListener = isInterceptingListener; class InterceptingListenerImpl { constructor(listener, nextListener) { this.listener = listener; this.nextListener = nextListener; this.processingMetadata = false; this.hasPendingMessage = false; this.processingMessage = false; this.pendingStatus = null; } processPendingMessage() { if (this.hasPendingMessage) { this.nextListener.onReceiveMessage(this.pendingMessage); this.pendingMessage = null; this.hasPendingMessage = false; } } processPendingStatus() { if (this.pendingStatus) { this.nextListener.onReceiveStatus(this.pendingStatus); } } onReceiveMetadata(metadata) { this.processingMetadata = true; this.listener.onReceiveMetadata(metadata, (metadata) => { this.processingMetadata = false; this.nextListener.onReceiveMetadata(metadata); this.processPendingMessage(); this.processPendingStatus(); }); } // eslint-disable-next-line @typescript-eslint/no-explicit-any onReceiveMessage(message) { /* If this listener processes messages asynchronously, the last message may * be reordered with respect to the status */ this.processingMessage = true; this.listener.onReceiveMessage(message, (msg) => { this.processingMessage = false; if (this.processingMetadata) { this.pendingMessage = msg; this.hasPendingMessage = true; } else { this.nextListener.onReceiveMessage(msg); this.processPendingStatus(); } }); } onReceiveStatus(status) { this.listener.onReceiveStatus(status, (processedStatus) => { if (this.processingMetadata || this.processingMessage) { this.pendingStatus = processedStatus; } else { this.nextListener.onReceiveStatus(processedStatus); } }); } } exports.InterceptingListenerImpl = InterceptingListenerImpl; class Http2CallStream { constructor(methodName, channel, options, filterStackFactory, channelCallCredentials, callNumber) { this.methodName = methodName; this.channel = channel; this.options = options; this.channelCallCredentials = channelCallCredentials; this.callNumber = callNumber; this.http2Stream = null; this.pendingRead = false; this.isWriteFilterPending = false; this.pendingWrite = null; this.pendingWriteCallback = null; this.writesClosed = false; this.decoder = new stream_decoder_1.StreamDecoder(); this.isReadFilterPending = false; this.canPush = false; /** * Indicates that an 'end' event has come from the http2 stream, so there * will be no more data events. */ this.readsClosed = false; this.statusOutput = false; this.unpushedReadMessages = []; this.unfilteredReadMessages = []; // Status code mapped from :status. To be used if grpc-status is not received this.mappedStatusCode = constants_1.Status.UNKNOWN; // This is populated (non-null) if and only if the call has ended this.finalStatus = null; this.subchannel = null; this.listener = null; this.internalError = null; this.configDeadline = Infinity; this.statusWatchers = []; this.streamEndWatchers = []; this.callStatsTracker = null; this.filterStack = filterStackFactory.createFilter(this); this.credentials = channelCallCredentials; this.disconnectListener = () => { this.endCall({ code: constants_1.Status.UNAVAILABLE, details: 'Connection dropped', metadata: new metadata_1.Metadata(), }); }; if (this.options.parentCall && this.options.flags & constants_1.Propagate.CANCELLATION) { this.options.parentCall.on('cancelled', () => { this.cancelWithStatus(constants_1.Status.CANCELLED, 'Cancelled by parent call'); }); } } outputStatus() { /* Precondition: this.finalStatus !== null */ if (this.listener && !this.statusOutput) { this.statusOutput = true; const filteredStatus = this.filterStack.receiveTrailers(this.finalStatus); this.trace('ended with status: code=' + filteredStatus.code + ' details="' + filteredStatus.details + '"'); this.statusWatchers.forEach(watcher => watcher(filteredStatus)); /* We delay the actual action of bubbling up the status to insulate the * cleanup code in this class from any errors that may be thrown in the * upper layers as a result of bubbling up the status. In particular, * if the status is not OK, the "error" event may be emitted * synchronously at the top level, which will result in a thrown error if * the user does not handle that event. */ process.nextTick(() => { var _a; (_a = this.listener) === null || _a === void 0 ? void 0 : _a.onReceiveStatus(filteredStatus); }); if (this.subchannel) { this.subchannel.callUnref(); this.subchannel.removeDisconnectListener(this.disconnectListener); } } } trace(text) { logging.trace(constants_2.LogVerbosity.DEBUG, TRACER_NAME, '[' + this.callNumber + '] ' + text); } /** * On first call, emits a 'status' event with the given StatusObject. * Subsequent calls are no-ops. * @param status The status of the call. */ endCall(status) { /* If the status is OK and a new status comes in (e.g. from a * deserialization failure), that new status takes priority */ if (this.finalStatus === null || this.finalStatus.code === constants_1.Status.OK) { this.finalStatus = status; this.maybeOutputStatus(); } this.destroyHttp2Stream(); } maybeOutputStatus() { if (this.finalStatus !== null) { /* The combination check of readsClosed and that the two message buffer * arrays are empty checks that there all incoming data has been fully * processed */ if (this.finalStatus.code !== constants_1.Status.OK || (this.readsClosed && this.unpushedReadMessages.length === 0 && this.unfilteredReadMessages.length === 0 && !this.isReadFilterPending)) { this.outputStatus(); } } } push(message) { this.trace('pushing to reader message of length ' + (message instanceof Buffer ? message.length : null)); this.canPush = false; process.nextTick(() => { var _a; /* If we have already output the status any later messages should be * ignored, and can cause out-of-order operation errors higher up in the * stack. Checking as late as possible here to avoid any race conditions. */ if (this.statusOutput) { return; } (_a = this.listener) === null || _a === void 0 ? void 0 : _a.onReceiveMessage(message); this.maybeOutputStatus(); }); } handleFilterError(error) { this.cancelWithStatus(constants_1.Status.INTERNAL, error.message); } handleFilteredRead(message) { /* If we the call has already ended with an error, we don't want to do * anything with this message. Dropping it on the floor is correct * behavior */ if (this.finalStatus !== null && this.finalStatus.code !== constants_1.Status.OK) { this.maybeOutputStatus(); return; } this.isReadFilterPending = false; if (this.canPush) { this.http2Stream.pause(); this.push(message); } else { this.trace('unpushedReadMessages.push message of length ' + message.length); this.unpushedReadMessages.push(message); } if (this.unfilteredReadMessages.length > 0) { /* nextMessage is guaranteed not to be undefined because unfilteredReadMessages is non-empty */ const nextMessage = this.unfilteredReadMessages.shift(); this.filterReceivedMessage(nextMessage); } } filterReceivedMessage(framedMessage) { /* If we the call has already ended with an error, we don't want to do * anything with this message. Dropping it on the floor is correct * behavior */ if (this.finalStatus !== null && this.finalStatus.code !== constants_1.Status.OK) { this.maybeOutputStatus(); return; } this.trace('filterReceivedMessage of length ' + framedMessage.length); this.isReadFilterPending = true; this.filterStack .receiveMessage(Promise.resolve(framedMessage)) .then(this.handleFilteredRead.bind(this), this.handleFilterError.bind(this)); } tryPush(messageBytes) { if (this.isReadFilterPending) { this.trace('unfilteredReadMessages.push message of length ' + (messageBytes && messageBytes.length)); this.unfilteredReadMessages.push(messageBytes); } else { this.filterReceivedMessage(messageBytes); } } handleTrailers(headers) { this.streamEndWatchers.forEach(watcher => watcher(true)); let headersString = ''; for (const header of Object.keys(headers)) { headersString += '\t\t' + header + ': ' + headers[header] + '\n'; } this.trace('Received server trailers:\n' + headersString); let metadata; try { metadata = metadata_1.Metadata.fromHttp2Headers(headers); } catch (e) { metadata = new metadata_1.Metadata(); } const metadataMap = metadata.getMap(); let code = this.mappedStatusCode; if (code === constants_1.Status.UNKNOWN && typeof metadataMap['grpc-status'] === 'string') { const receivedStatus = Number(metadataMap['grpc-status']); if (receivedStatus in constants_1.Status) { code = receivedStatus; this.trace('received status code ' + receivedStatus + ' from server'); } metadata.remove('grpc-status'); } let details = ''; if (typeof metadataMap['grpc-message'] === 'string') { details = decodeURI(metadataMap['grpc-message']); metadata.remove('grpc-message'); this.trace('received status details string "' + details + '" from server'); } const status = { code, details, metadata }; // This is a no-op if the call was already ended when handling headers. this.endCall(status); } writeMessageToStream(message, callback) { var _a; (_a = this.callStatsTracker) === null || _a === void 0 ? void 0 : _a.addMessageSent(); this.http2Stream.write(message, callback); } attachHttp2Stream(stream, subchannel, extraFilters, callStatsTracker) { this.filterStack.push(extraFilters); if (this.finalStatus !== null) { stream.close(NGHTTP2_CANCEL); } else { this.trace('attachHttp2Stream from subchannel ' + subchannel.getAddress()); this.http2Stream = stream; this.subchannel = subchannel; this.callStatsTracker = callStatsTracker; subchannel.addDisconnectListener(this.disconnectListener); subchannel.callRef(); stream.on('response', (headers, flags) => { var _a; let headersString = ''; for (const header of Object.keys(headers)) { headersString += '\t\t' + header + ': ' + headers[header] + '\n'; } this.trace('Received server headers:\n' + headersString); switch (headers[':status']) { // TODO(murgatroid99): handle 100 and 101 case 400: this.mappedStatusCode = constants_1.Status.INTERNAL; break; case 401: this.mappedStatusCode = constants_1.Status.UNAUTHENTICATED; break; case 403: this.mappedStatusCode = constants_1.Status.PERMISSION_DENIED; break; case 404: this.mappedStatusCode = constants_1.Status.UNIMPLEMENTED; break; case 429: case 502: case 503: case 504: this.mappedStatusCode = constants_1.Status.UNAVAILABLE; break; default: this.mappedStatusCode = constants_1.Status.UNKNOWN; } if (flags & http2.constants.NGHTTP2_FLAG_END_STREAM) { this.handleTrailers(headers); } else { let metadata; try { metadata = metadata_1.Metadata.fromHttp2Headers(headers); } catch (error) { this.endCall({ code: constants_1.Status.UNKNOWN, details: error.message, metadata: new metadata_1.Metadata(), }); return; } try { const finalMetadata = this.filterStack.receiveMetadata(metadata); (_a = this.listener) === null || _a === void 0 ? void 0 : _a.onReceiveMetadata(finalMetadata); } catch (error) { this.endCall({ code: constants_1.Status.UNKNOWN, details: error.message, metadata: new metadata_1.Metadata(), }); } } }); stream.on('trailers', this.handleTrailers.bind(this)); stream.on('data', (data) => { this.trace('receive HTTP/2 data frame of length ' + data.length); const messages = this.decoder.write(data); for (const message of messages) { this.trace('parsed message of length ' + message.length); this.callStatsTracker.addMessageReceived(); this.tryPush(message); } }); stream.on('end', () => { this.readsClosed = true; this.maybeOutputStatus(); }); stream.on('close', () => { /* Use process.next tick to ensure that this code happens after any * "error" event that may be emitted at about the same time, so that * we can bubble up the error message from that event. */ process.nextTick(() => { var _a; this.trace('HTTP/2 stream closed with code ' + stream.rstCode); /* If we have a final status with an OK status code, that means that * we have received all of the messages and we have processed the * trailers and the call completed successfully, so it doesn't matter * how the stream ends after that */ if (((_a = this.finalStatus) === null || _a === void 0 ? void 0 : _a.code) === constants_1.Status.OK) { return; } let code; let details = ''; switch (stream.rstCode) { case http2.constants.NGHTTP2_NO_ERROR: /* If we get a NO_ERROR code and we already have a status, the * stream completed properly and we just haven't fully processed * it yet */ if (this.finalStatus !== null) { return; } code = constants_1.Status.INTERNAL; details = `Received RST_STREAM with code ${stream.rstCode}`; break; case http2.constants.NGHTTP2_REFUSED_STREAM: code = constants_1.Status.UNAVAILABLE; details = 'Stream refused by server'; break; case http2.constants.NGHTTP2_CANCEL: code = constants_1.Status.CANCELLED; details = 'Call cancelled'; break; case http2.constants.NGHTTP2_ENHANCE_YOUR_CALM: code = constants_1.Status.RESOURCE_EXHAUSTED; details = 'Bandwidth exhausted or memory limit exceeded'; break; case http2.constants.NGHTTP2_INADEQUATE_SECURITY: code = constants_1.Status.PERMISSION_DENIED; details = 'Protocol not secure enough'; break; case http2.constants.NGHTTP2_INTERNAL_ERROR: code = constants_1.Status.INTERNAL; if (this.internalError === null) { /* This error code was previously handled in the default case, and * there are several instances of it online, so I wanted to * preserve the original error message so that people find existing * information in searches, but also include the more recognizable * "Internal server error" message. */ details = `Received RST_STREAM with code ${stream.rstCode} (Internal server error)`; } else { if (this.internalError.code === 'ECONNRESET' || this.internalError.code === 'ETIMEDOUT') { code = constants_1.Status.UNAVAILABLE; details = this.internalError.message; } else { /* The "Received RST_STREAM with code ..." error is preserved * here for continuity with errors reported online, but the * error message at the end will probably be more relevant in * most cases. */ details = `Received RST_STREAM with code ${stream.rstCode} triggered by internal client error: ${this.internalError.message}`; } } break; default: code = constants_1.Status.INTERNAL; details = `Received RST_STREAM with code ${stream.rstCode}`; } // This is a no-op if trailers were received at all. // This is OK, because status codes emitted here correspond to more // catastrophic issues that prevent us from receiving trailers in the // first place. this.endCall({ code, details, metadata: new metadata_1.Metadata() }); }); }); stream.on('error', (err) => { /* We need an error handler here to stop "Uncaught Error" exceptions * from bubbling up. However, errors here should all correspond to * "close" events, where we will handle the error more granularly */ /* Specifically looking for stream errors that were *not* constructed * from a RST_STREAM response here: * https://github.com/nodejs/node/blob/8b8620d580314050175983402dfddf2674e8e22a/lib/internal/http2/core.js#L2267 */ if (err.code !== 'ERR_HTTP2_STREAM_ERROR') { this.trace('Node error event: message=' + err.message + ' code=' + err.code + ' errno=' + getSystemErrorName(err.errno) + ' syscall=' + err.syscall); this.internalError = err; } this.streamEndWatchers.forEach(watcher => watcher(false)); }); if (!this.pendingRead) { stream.pause(); } if (this.pendingWrite) { if (!this.pendingWriteCallback) { throw new Error('Invalid state in write handling code'); } this.trace('sending data chunk of length ' + this.pendingWrite.length + ' (deferred)'); try { this.writeMessageToStream(this.pendingWrite, this.pendingWriteCallback); } catch (error) { this.endCall({ code: constants_1.Status.UNAVAILABLE, details: `Write failed with error ${error.message}`, metadata: new metadata_1.Metadata() }); } } this.maybeCloseWrites(); } } start(metadata, listener) { this.trace('Sending metadata'); this.listener = listener; this.channel._startCallStream(this, metadata); this.maybeOutputStatus(); } destroyHttp2Stream() { var _a; // The http2 stream could already have been destroyed if cancelWithStatus // is called in response to an internal http2 error. if (this.http2Stream !== null && !this.http2Stream.destroyed) { /* If the call has ended with an OK status, communicate that when closing * the stream, partly to avoid a situation in which we detect an error * RST_STREAM as a result after we have the status */ let code; if (((_a = this.finalStatus) === null || _a === void 0 ? void 0 : _a.code) === constants_1.Status.OK) { code = http2.constants.NGHTTP2_NO_ERROR; } else { code = http2.constants.NGHTTP2_CANCEL; } this.trace('close http2 stream with code ' + code); this.http2Stream.close(code); } } cancelWithStatus(status, details) { this.trace('cancelWithStatus code: ' + status + ' details: "' + details + '"'); this.endCall({ code: status, details, metadata: new metadata_1.Metadata() }); } getDeadline() { const deadlineList = [this.options.deadline]; if (this.options.parentCall && this.options.flags & constants_1.Propagate.DEADLINE) { deadlineList.push(this.options.parentCall.getDeadline()); } if (this.configDeadline) { deadlineList.push(this.configDeadline); } return getMinDeadline(deadlineList); } getCredentials() { return this.credentials; } setCredentials(credentials) { this.credentials = this.channelCallCredentials.compose(credentials); } getStatus() { return this.finalStatus; } getPeer() { var _a, _b; return (_b = (_a = this.subchannel) === null || _a === void 0 ? void 0 : _a.getAddress()) !== null && _b !== void 0 ? _b : this.channel.getTarget(); } getMethod() { return this.methodName; } getHost() { return this.options.host; } setConfigDeadline(configDeadline) { this.configDeadline = configDeadline; } addStatusWatcher(watcher) { this.statusWatchers.push(watcher); } addStreamEndWatcher(watcher) { this.streamEndWatchers.push(watcher); } addFilters(extraFilters) { this.filterStack.push(extraFilters); } getCallNumber() { return this.callNumber; } startRead() { /* If the stream has ended with an error, we should not emit any more * messages and we should communicate that the stream has ended */ if (this.finalStatus !== null && this.finalStatus.code !== constants_1.Status.OK) { this.readsClosed = true; this.maybeOutputStatus(); return; } this.canPush = true; if (this.http2Stream === null) { this.pendingRead = true; } else { if (this.unpushedReadMessages.length > 0) { const nextMessage = this.unpushedReadMessages.shift(); this.push(nextMessage); return; } /* Only resume reading from the http2Stream if we don't have any pending * messages to emit */ this.http2Stream.resume(); } } maybeCloseWrites() { if (this.writesClosed && !this.isWriteFilterPending && this.http2Stream !== null) { this.trace('calling end() on HTTP/2 stream'); this.http2Stream.end(); } } sendMessageWithContext(context, message) { this.trace('write() called with message of length ' + message.length); const writeObj = { message, flags: context.flags, }; const cb = (error) => { var _a, _b; let code = constants_1.Status.UNAVAILABLE; if (((_a = error) === null || _a === void 0 ? void 0 : _a.code) === 'ERR_STREAM_WRITE_AFTER_END') { code = constants_1.Status.INTERNAL; } if (error) { this.cancelWithStatus(code, `Write error: ${error.message}`); } (_b = context.callback) === null || _b === void 0 ? void 0 : _b.call(context); }; this.isWriteFilterPending = true; this.filterStack.sendMessage(Promise.resolve(writeObj)).then((message) => { this.isWriteFilterPending = false; if (this.http2Stream === null) { this.trace('deferring writing data chunk of length ' + message.message.length); this.pendingWrite = message.message; this.pendingWriteCallback = cb; } else { this.trace('sending data chunk of length ' + message.message.length); try { this.writeMessageToStream(message.message, cb); } catch (error) { this.endCall({ code: constants_1.Status.UNAVAILABLE, details: `Write failed with error ${error.message}`, metadata: new metadata_1.Metadata() }); } this.maybeCloseWrites(); } }, this.handleFilterError.bind(this)); } halfClose() { this.trace('end() called'); this.writesClosed = true; this.maybeCloseWrites(); } } exports.Http2CallStream = Http2CallStream; //# sourceMappingURL=call-stream.js.map
Save
cmd:
run