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 bidiNetworkManager_exports = {};30__export(bidiNetworkManager_exports, {31  BidiNetworkManager: () => BidiNetworkManager,32  bidiBytesValueToString: () => bidiBytesValueToString33});34module.exports = __toCommonJS(bidiNetworkManager_exports);35var import_eventsHelper = require("../utils/eventsHelper");36var import_cookieStore = require("../cookieStore");37var network = __toESM(require("../network"));38var bidi = __toESM(require("./third_party/bidiProtocol"));39class BidiNetworkManager {40  constructor(bidiSession, page) {41    this._userRequestInterceptionEnabled = false;42    this._protocolRequestInterceptionEnabled = false;43    this._attemptedAuthentications = /* @__PURE__ */ new Set();44    this._session = bidiSession;45    this._requests = /* @__PURE__ */ new Map();46    this._page = page;47    this._eventListeners = [48      import_eventsHelper.eventsHelper.addEventListener(bidiSession, "network.beforeRequestSent", this._onBeforeRequestSent.bind(this)),49      import_eventsHelper.eventsHelper.addEventListener(bidiSession, "network.responseStarted", this._onResponseStarted.bind(this)),50      import_eventsHelper.eventsHelper.addEventListener(bidiSession, "network.responseCompleted", this._onResponseCompleted.bind(this)),51      import_eventsHelper.eventsHelper.addEventListener(bidiSession, "network.fetchError", this._onFetchError.bind(this)),52      import_eventsHelper.eventsHelper.addEventListener(bidiSession, "network.authRequired", this._onAuthRequired.bind(this))53    ];54  }55  dispose() {56    import_eventsHelper.eventsHelper.removeEventListeners(this._eventListeners);57  }58  _onBeforeRequestSent(param) {59    if (param.request.url.startsWith("data:"))60      return;61    const redirectedFrom = param.redirectCount ? this._requests.get(param.request.request) || null : null;62    const frame = redirectedFrom ? redirectedFrom.request.frame() : param.context ? this._page.frameManager.frame(param.context) : null;63    if (!frame)64      return;65    if (redirectedFrom)66      this._deleteRequest(redirectedFrom._id);67    let route;68    if (param.intercepts) {69      if (redirectedFrom) {70        let params = {};71        if (redirectedFrom._originalRequestRoute?._alreadyContinuedHeaders)72          params = toBidiRequestHeaders(redirectedFrom._originalRequestRoute._alreadyContinuedHeaders ?? []);73        this._session.sendMayFail("network.continueRequest", {74          request: param.request.request,75          ...params76        });77      } else {78        route = new BidiRouteImpl(this._session, param.request.request);79      }80    }81    const request = new BidiRequest(frame, redirectedFrom, param, route);82    this._requests.set(request._id, request);83    this._page.frameManager.requestStarted(request.request, route);84  }85  _onResponseStarted(params) {86    const request = this._requests.get(params.request.request);87    if (!request)88      return;89    const getResponseBody = async () => {90      const { bytes } = await this._session.send("network.getData", { request: params.request.request, dataType: bidi.Network.DataType.Response });91      const encoding = bytes.type === "base64" ? "base64" : "utf8";92      return Buffer.from(bytes.value, encoding);93    };94    const timings = params.request.timings;95    const startTime = timings.requestTime;96    function relativeToStart(time) {97      if (!time)98        return -1;99      return time - startTime;100    }101    const timing = {102      startTime,103      requestStart: relativeToStart(timings.requestStart),104      responseStart: relativeToStart(timings.responseStart),105      domainLookupStart: relativeToStart(timings.dnsStart),106      domainLookupEnd: relativeToStart(timings.dnsEnd),107      connectStart: relativeToStart(timings.connectStart),108      secureConnectionStart: relativeToStart(timings.tlsStart),109      connectEnd: relativeToStart(timings.connectEnd)110    };111    const response = new network.Response(request.request, params.response.status, params.response.statusText, fromBidiHeaders(params.response.headers), timing, getResponseBody, false);112    response._serverAddrFinished();113    response._securityDetailsFinished();114    response.setRawResponseHeaders(null);115    response.setResponseHeadersSize(params.response.headersSize);116    this._page.frameManager.requestReceivedResponse(response);117  }118  _onResponseCompleted(params) {119    const request = this._requests.get(params.request.request);120    if (!request)121      return;122    const response = request.request._existingResponse();123    response.setTransferSize(params.response.bodySize);124    response.setEncodedBodySize(params.response.bodySize);125    const isRedirected = response.status() >= 300 && response.status() <= 399;126    const responseEndTime = params.request.timings.responseEnd - response.timing().startTime;127    if (isRedirected) {128      response._requestFinished(responseEndTime);129    } else {130      this._deleteRequest(request._id);131      response._requestFinished(responseEndTime);132    }133    response._setHttpVersion(params.response.protocol);134    this._page.frameManager.reportRequestFinished(request.request, response);135  }136  _onFetchError(params) {137    const request = this._requests.get(params.request.request);138    if (!request)139      return;140    this._deleteRequest(request._id);141    const response = request.request._existingResponse();142    if (response) {143      response.setTransferSize(null);144      response.setEncodedBodySize(null);145      response._requestFinished(-1);146    }147    request.request._setFailureText(params.errorText);148    this._page.frameManager.requestFailed(request.request, params.errorText === "NS_BINDING_ABORTED");149  }150  _onAuthRequired(params) {151    const isBasic = params.response.authChallenges?.some((challenge) => challenge.scheme.startsWith("Basic"));152    const credentials = this._page.browserContext._options.httpCredentials;153    if (isBasic && credentials && (!credentials.origin || new URL(params.request.url).origin.toLowerCase() === credentials.origin.toLowerCase())) {154      if (this._attemptedAuthentications.has(params.request.request)) {155        this._session.sendMayFail("network.continueWithAuth", {156          request: params.request.request,157          action: "cancel"158        });159      } else {160        this._attemptedAuthentications.add(params.request.request);161        this._session.sendMayFail("network.continueWithAuth", {162          request: params.request.request,163          action: "provideCredentials",164          credentials: {165            type: "password",166            username: credentials.username,167            password: credentials.password168          }169        });170      }171    } else {172      this._session.sendMayFail("network.continueWithAuth", {173        request: params.request.request,174        action: "cancel"175      });176    }177  }178  _deleteRequest(requestId) {179    this._requests.delete(requestId);180    this._attemptedAuthentications.delete(requestId);181  }182  async setRequestInterception(value) {183    this._userRequestInterceptionEnabled = value;184    await this._updateProtocolRequestInterception();185  }186  async setCredentials(credentials) {187    this._credentials = credentials;188    await this._updateProtocolRequestInterception();189  }190  async _updateProtocolRequestInterception(initial) {191    const enabled = this._userRequestInterceptionEnabled || !!this._credentials;192    if (enabled === this._protocolRequestInterceptionEnabled)193      return;194    this._protocolRequestInterceptionEnabled = enabled;195    if (initial && !enabled)196      return;197    const cachePromise = this._session.send("network.setCacheBehavior", { cacheBehavior: enabled ? "bypass" : "default" });198    let interceptPromise = Promise.resolve(void 0);199    if (enabled) {200      interceptPromise = this._session.send("network.addIntercept", {201        phases: [bidi.Network.InterceptPhase.AuthRequired, bidi.Network.InterceptPhase.BeforeRequestSent],202        urlPatterns: [{ type: "pattern" }]203        // urlPatterns: [{ type: 'string', pattern: '*' }],204      }).then((r) => {205        this._intercepId = r.intercept;206      });207    } else if (this._intercepId) {208      interceptPromise = this._session.send("network.removeIntercept", { intercept: this._intercepId });209      this._intercepId = void 0;210    }211    await Promise.all([cachePromise, interceptPromise]);212  }213}214class BidiRequest {215  constructor(frame, redirectedFrom, payload, route) {216    this._id = payload.request.request;217    if (redirectedFrom)218      redirectedFrom._redirectedTo = this;219    const postDataBuffer = null;220    this.request = new network.Request(221      frame._page.browserContext,222      frame,223      null,224      redirectedFrom ? redirectedFrom.request : null,225      payload.navigation ?? void 0,226      payload.request.url,227      resourceTypeFromBidi(payload.request.destination, payload.request.initiatorType, payload.initiator?.type),228      payload.request.method,229      postDataBuffer,230      fromBidiHeaders(payload.request.headers)231    );232    this.request.setRawRequestHeaders(null);233    this.request._setBodySize(payload.request.bodySize || 0);234    this._originalRequestRoute = route ?? redirectedFrom?._originalRequestRoute;235    route?._setRequest(this.request);236  }237  _finalRequest() {238    let request = this;239    while (request._redirectedTo)240      request = request._redirectedTo;241    return request;242  }243}244class BidiRouteImpl {245  constructor(session, requestId) {246    this._session = session;247    this._requestId = requestId;248  }249  _setRequest(request) {250    this._request = request;251  }252  async continue(overrides) {253    let headers = overrides.headers || this._request.headers();254    if (overrides.postData && headers) {255      headers = headers.map((header) => {256        if (header.name.toLowerCase() === "content-length")257          return { name: header.name, value: overrides.postData.byteLength.toString() };258        return header;259      });260    }261    this._alreadyContinuedHeaders = headers;262    await this._session.sendMayFail("network.continueRequest", {263      request: this._requestId,264      url: overrides.url,265      method: overrides.method,266      ...toBidiRequestHeaders(this._alreadyContinuedHeaders),267      body: overrides.postData ? { type: "base64", value: Buffer.from(overrides.postData).toString("base64") } : void 0268    });269  }270  async fulfill(response) {271    const base64body = response.isBase64 ? response.body : Buffer.from(response.body).toString("base64");272    await this._session.sendMayFail("network.provideResponse", {273      request: this._requestId,274      statusCode: response.status,275      reasonPhrase: network.statusText(response.status),276      ...toBidiResponseHeaders(response.headers),277      body: { type: "base64", value: base64body }278    });279  }280  async abort(errorCode) {281    await this._session.sendMayFail("network.failRequest", {282      request: this._requestId283    });284  }285}286function fromBidiHeaders(bidiHeaders) {287  const result = [];288  for (const { name, value } of bidiHeaders)289    result.push({ name, value: bidiBytesValueToString(value) });290  return result;291}292function toBidiRequestHeaders(allHeaders) {293  const bidiHeaders = toBidiHeaders(allHeaders);294  return { headers: bidiHeaders };295}296function toBidiResponseHeaders(headers) {297  const setCookieHeaders = headers.filter((h) => h.name.toLowerCase() === "set-cookie");298  const otherHeaders = headers.filter((h) => h.name.toLowerCase() !== "set-cookie");299  const rawCookies = setCookieHeaders.map((h) => (0, import_cookieStore.parseRawCookie)(h.value));300  const cookies = rawCookies.filter(Boolean).map((c) => {301    return {302      ...c,303      value: { type: "string", value: c.value },304      sameSite: toBidiSameSite(c.sameSite)305    };306  });307  return { cookies, headers: toBidiHeaders(otherHeaders) };308}309function toBidiHeaders(headers) {310  return headers.map(({ name, value }) => ({ name, value: { type: "string", value } }));311}312function bidiBytesValueToString(value) {313  if (value.type === "string")314    return value.value;315  if (value.type === "base64")316    return Buffer.from(value.type, "base64").toString("binary");317  return "unknown value type: " + value.type;318}319function toBidiSameSite(sameSite) {320  if (!sameSite)321    return void 0;322  if (sameSite === "Strict")323    return bidi.Network.SameSite.Strict;324  if (sameSite === "Lax")325    return bidi.Network.SameSite.Lax;326  return bidi.Network.SameSite.None;327}328function resourceTypeFromBidi(requestDestination, requestInitiatorType, eventInitiatorType) {329  switch (requestDestination) {330    case "audio":331      return "media";332    case "audioworklet":333      return "script";334    case "document":335      return "document";336    case "font":337      return "font";338    case "frame":339      return "document";340    case "iframe":341      return "document";342    case "image":343      return "image";344    case "object":345      return "object";346    case "paintworklet":347      return "script";348    case "script":349      return "script";350    case "serviceworker":351      return "script";352    case "sharedworker":353      return "script";354    case "style":355      return "stylesheet";356    case "track":357      return "texttrack";358    case "video":359      return "media";360    case "worker":361      return "script";362    case "":363      switch (requestInitiatorType) {364        case "fetch":365          return "fetch";366        case "font":367          return "font";368        case "xmlhttprequest":369          return "xhr";370        case null:371          return eventInitiatorType === "script" ? "xhr" : "document";372        default:373          return "other";374      }375    default:376      return "other";377  }378}379// Annotate the CommonJS export names for ESM import in node:3800 && (module.exports = {381  BidiNetworkManager,382  bidiBytesValueToString383});384