PHP WebShell

Текущая директория: /opt/BitGoJS/node_modules/@hashgraph/sdk/lib/channel
Просмотр файла: NodeChannel.cjs

"use strict";

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports.default = void 0;
var _grpcJs = require("@grpc/grpc-js");
var _Channel = _interopRequireDefault(require("./Channel.cjs"));
var _GrpcServiceError = _interopRequireDefault(require("../grpc/GrpcServiceError.cjs"));
var _GrpcStatus = _interopRequireDefault(require("../grpc/GrpcStatus.cjs"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
/*-
 * ‌
 * Hedera JavaScript SDK
 * 
 * Copyright (C) 2020 - 2022 Hedera Hashgraph, LLC
 * 
 * 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.
 * ‍
 */

/**
 * @property {?HashgraphProto.proto.CryptoService} _crypto
 * @property {?HashgraphProto.proto.SmartContractService} _smartContract
 * @property {?HashgraphProto.proto.FileService} _file
 * @property {?HashgraphProto.proto.FreezeService} _freeze
 * @property {?HashgraphProto.proto.ConsensusService} _consensus
 * @property {?HashgraphProto.proto.NetworkService} _network
 */
class NodeChannel extends _Channel.default {
  /**
   * @internal
   * @param {string} address
   * @param {string=} cert
   * @param {number=} maxExecutionTime
   */
  constructor(address, cert, maxExecutionTime) {
    super();
    this.cert = cert;
    this.maxExecutionTime = maxExecutionTime;
    let security;
    let options;
    if (this.cert != null) {
      security = _grpcJs.credentials.createSsl(Buffer.from(this.cert));
      options = {
        "grpc.ssl_target_name_override": "127.0.0.1",
        "grpc.default_authority": "127.0.0.1",
        "grpc.http_connect_creds": "0",
        // https://github.com/grpc/grpc-node/issues/1593
        // https://github.com/grpc/grpc-node/issues/1545
        // https://github.com/grpc/grpc/issues/13163
        "grpc.keepalive_timeout_ms": 10000,
        "grpc.keepalive_permit_without_calls": 1,
        "grpc.enable_retries": 0
      };
    } else {
      security = _grpcJs.credentials.createInsecure();
      options = {
        "grpc.keepalive_timeout_ms": 10000,
        "grpc.keepalive_permit_without_calls": 1,
        "grpc.enable_retries": 0
      };
    }

    /**
     * @type {Client}
     * @private
     */
    this._client = new _grpcJs.Client(address, security, options);
  }

  /**
   * @override
   * @returns {void}
   */
  close() {
    this._client.close();
  }

  /**
   * @override
   * @protected
   * @param {string} serviceName
   * @returns {import("protobufjs").RPCImpl}
   */
  _createUnaryClient(serviceName) {
    return (method, requestData, callback) => {
      const deadline = new Date();
      const milliseconds = this.maxExecutionTime ? this.maxExecutionTime : 10000;
      deadline.setMilliseconds(deadline.getMilliseconds() + milliseconds);
      this._client.waitForReady(deadline, err => {
        if (err) {
          callback(new _GrpcServiceError.default(_GrpcStatus.default.Timeout));
        } else {
          this._client.makeUnaryRequest(`/proto.${serviceName}/${method.name}`, value => value, value => {
            return value;
          }, Buffer.from(requestData), (e, r) => {
            callback(e, r);
          });
        }
      });
    };
  }
}
exports.default = NodeChannel;
Выполнить команду

Для локальной разработки. Не используйте в интернете!