Brunobkr/llama.cpp_AlgMor24_github

1"use strict";2var __create = Object.create;3var __defProp = Object.defineProperty;4var __getOwnPropDesc = Object.getOwnPropertyDescriptor;5var __getOwnPropNames = Object.getOwnPropertyNames;6var __getProtoOf = Object.getPrototypeOf;7var __hasOwnProp = Object.prototype.hasOwnProperty;8var __export = (target, all) => {9  for (var name in all)10    __defProp(target, name, { get: all[name], enumerable: true });11};12var __copyProps = (to, from, except, desc) => {13  if (from && typeof from === "object" || typeof from === "function") {14    for (let key of __getOwnPropNames(from))15      if (!__hasOwnProp.call(to, key) && key !== except)16        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });17  }18  return to;19};20var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__getProtoOf(mod)) : {}, __copyProps(21  // If the importer is in node compatibility mode or this is not an ESM22  // file that has been converted to a CommonJS file using a Babel-23  // compatible transform (i.e. "__esModule" has not been set), then set24  // "default" to the CommonJS "module.exports" for node compatibility.25  isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target,26  mod27));28var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);29var socksInterceptor_exports = {};30__export(socksInterceptor_exports, {31  SocksInterceptor: () => SocksInterceptor32});33module.exports = __toCommonJS(socksInterceptor_exports);34var import_events = __toESM(require("events"));35var socks = __toESM(require("./utils/socksProxy"));36var import_validator = require("../protocol/validator");37var import_debug = require("./utils/debug");38class SocksInterceptor {39  constructor(transport, pattern, redirectPortForTest) {40    this._ids = /* @__PURE__ */ new Set();41    this._handler = new socks.SocksProxyHandler(pattern, redirectPortForTest);42    let lastId = -1;43    this._channel = new Proxy(new import_events.default(), {44      get: (obj, prop) => {45        if (prop in obj || obj[prop] !== void 0 || typeof prop !== "string")46          return obj[prop];47        return (params) => {48          try {49            const id = --lastId;50            this._ids.add(id);51            const validator = (0, import_validator.findValidator)("SocksSupport", prop, "Params");52            params = validator(params, "", { tChannelImpl: tChannelForSocks, binary: "toBase64", isUnderTest: import_debug.isUnderTest });53            transport.send({ id, guid: this._socksSupportObjectGuid, method: prop, params, metadata: { stack: [], apiName: "", internal: true } });54          } catch (e) {55          }56        };57      }58    });59    this._handler.on(socks.SocksProxyHandler.Events.SocksConnected, (payload) => this._channel.socksConnected(payload));60    this._handler.on(socks.SocksProxyHandler.Events.SocksData, (payload) => this._channel.socksData(payload));61    this._handler.on(socks.SocksProxyHandler.Events.SocksError, (payload) => this._channel.socksError(payload));62    this._handler.on(socks.SocksProxyHandler.Events.SocksFailed, (payload) => this._channel.socksFailed(payload));63    this._handler.on(socks.SocksProxyHandler.Events.SocksEnd, (payload) => this._channel.socksEnd(payload));64    this._channel.on("socksRequested", (payload) => this._handler.socketRequested(payload));65    this._channel.on("socksClosed", (payload) => this._handler.socketClosed(payload));66    this._channel.on("socksData", (payload) => this._handler.sendSocketData(payload));67  }68  cleanup() {69    this._handler.cleanup();70  }71  interceptMessage(message) {72    if (this._ids.has(message.id)) {73      this._ids.delete(message.id);74      return true;75    }76    if (message.method === "__create__" && message.params.type === "SocksSupport") {77      this._socksSupportObjectGuid = message.params.guid;78      return false;79    }80    if (this._socksSupportObjectGuid && message.guid === this._socksSupportObjectGuid) {81      const validator = (0, import_validator.findValidator)("SocksSupport", message.method, "Event");82      const params = validator(message.params, "", { tChannelImpl: tChannelForSocks, binary: "fromBase64", isUnderTest: import_debug.isUnderTest });83      this._channel.emit(message.method, params);84      return true;85    }86    return false;87  }88}89function tChannelForSocks(names, arg, path, context) {90  throw new import_validator.ValidationError(`${path}: channels are not expected in SocksSupport`);91}92// Annotate the CommonJS export names for ESM import in node:930 && (module.exports = {94  SocksInterceptor95});96