FM / src

/var/www/p4ela.kz/server/delivery/node_modules/@grpc/grpc-js/src/

/var/www/p4ela.kz/server/delivery/node_modules/@grpc/grpc-js/src

Name	Size	Mode	Actions
generated/	-	0755	rm
admin.ts	1345	0644	edit dl rm
backoff-timeout.ts	4719	0644	edit dl rm
call-credentials-filter.ts	3003	0644	edit dl rm
call-credentials.ts	6412	0644	edit dl rm
call-stream.ts	29012	0644	edit dl rm
call.ts	5444	0644	edit dl rm
channel-credentials.ts	8753	0644	edit dl rm
channel-options.ts	3249	0644	edit dl rm
channel.ts	30310	0644	edit dl rm
channelz.ts	26226	0644	edit dl rm
client-interceptors.ts	18100	0644	edit dl rm
client.ts	24233	0644	edit dl rm
compression-algorithms.ts	682	0644	edit dl rm
compression-filter.ts	10186	0644	edit dl rm
connectivity-state.ts	699	0644	edit dl rm
constants.ts	1651	0644	edit dl rm
deadline-filter.ts	3358	0644	edit dl rm
duration.ts	1096	0644	edit dl rm
events.ts	1108	0755	edit dl rm
experimental.ts	1317	0644	edit dl rm
filter-stack.ts	2687	0644	edit dl rm
filter.ts	1801	0644	edit dl rm
http_proxy.ts	8827	0644	edit dl rm
index.ts	7850	0644	edit dl rm
load-balancer-child-handler.ts	4863	0644	edit dl rm
load-balancer-outlier-detection.ts	22695	0644	edit dl rm
load-balancer-pick-first.ts	15910	0644	edit dl rm
load-balancer-round-robin.ts	7581	0644	edit dl rm
load-balancer.ts	7483	0644	edit dl rm
logging.ts	3407	0644	edit dl rm
make-client.ts	7201	0644	edit dl rm
max-message-size-filter.ts	3155	0644	edit dl rm
metadata.ts	9035	0644	edit dl rm
object-stream.ts	2214	0644	edit dl rm
picker.ts	4685	0644	edit dl rm
resolver-dns.ts	12970	0644	edit dl rm
resolver-ip.ts	3556	0644	edit dl rm
resolver-uds.ts	1611	0644	edit dl rm
resolver.ts	5802	0644	edit dl rm
resolving-load-balancer.ts	11443	0644	edit dl rm
server-call.ts	25825	0644	edit dl rm
server-credentials.ts	2822	0644	edit dl rm
server.ts	32396	0644	edit dl rm
service-config.ts	10544	0644	edit dl rm
status-builder.ts	1780	0755	edit dl rm
stream-decoder.ts	3501	0755	edit dl rm
subchannel-address.ts	2198	0644	edit dl rm
subchannel-interface.ts	2643	0644	edit dl rm
subchannel-pool.ts	5380	0644	edit dl rm
subchannel.ts	35173	0644	edit dl rm
tls-helpers.ts	1088	0644	edit dl rm
uri-parser.ts	2814	0644	edit dl rm

Edit: /var/www/p4ela.kz/server/delivery/node_modules/@grpc/grpc-js/src/stream-decoder.ts (3501B)

/*
 * 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.
 *
 */

enum ReadState {
  NO_DATA,
  READING_SIZE,
  READING_MESSAGE,
}

export class StreamDecoder {
  private readState: ReadState = ReadState.NO_DATA;
  private readCompressFlag: Buffer = Buffer.alloc(1);
  private readPartialSize: Buffer = Buffer.alloc(4);
  private readSizeRemaining = 4;
  private readMessageSize = 0;
  private readPartialMessage: Buffer[] = [];
  private readMessageRemaining = 0;

write(data: Buffer): Buffer[] {
    let readHead = 0;
    let toRead: number;
    const result: Buffer[] = [];

while (readHead < data.length) {
      switch (this.readState) {
        case ReadState.NO_DATA:
          this.readCompressFlag = data.slice(readHead, readHead + 1);
          readHead += 1;
          this.readState = ReadState.READING_SIZE;
          this.readPartialSize.fill(0);
          this.readSizeRemaining = 4;
          this.readMessageSize = 0;
          this.readMessageRemaining = 0;
          this.readPartialMessage = [];
          break;
        case ReadState.READING_SIZE:
          toRead = Math.min(data.length - readHead, this.readSizeRemaining);
          data.copy(
            this.readPartialSize,
            4 - this.readSizeRemaining,
            readHead,
            readHead + toRead
          );
          this.readSizeRemaining -= toRead;
          readHead += toRead;
          // readSizeRemaining >=0 here
          if (this.readSizeRemaining === 0) {
            this.readMessageSize = this.readPartialSize.readUInt32BE(0);
            this.readMessageRemaining = this.readMessageSize;
            if (this.readMessageRemaining > 0) {
              this.readState = ReadState.READING_MESSAGE;
            } else {
              const message = Buffer.concat(
                [this.readCompressFlag, this.readPartialSize],
                5
              );

this.readState = ReadState.NO_DATA;
              result.push(message);
            }
          }
          break;
        case ReadState.READING_MESSAGE:
          toRead = Math.min(data.length - readHead, this.readMessageRemaining);
          this.readPartialMessage.push(data.slice(readHead, readHead + toRead));
          this.readMessageRemaining -= toRead;
          readHead += toRead;
          // readMessageRemaining >=0 here
          if (this.readMessageRemaining === 0) {
            // At this point, we have read a full message
            const framedMessageBuffers = [
              this.readCompressFlag,
              this.readPartialSize,
            ].concat(this.readPartialMessage);
            const framedMessage = Buffer.concat(
              framedMessageBuffers,
              this.readMessageSize + 5
            );

this.readState = ReadState.NO_DATA;
            result.push(framedMessage);
          }
          break;
        default:
          throw new Error('Unexpected read state');
      }
    }

return result;
  }
}

cmd: