MCPcopy
hub / github.com/di-sukharev/opencommit / dispatch

Function dispatch

out/cli.cjs:60673–60805  ·  view source on GitHub ↗
({ body })

Source from the content-addressed store, hash-verified

60671 fetchParams.controller.controller.error(new TypeError("terminated", {
60672 cause: isErrorLike(reason) ? reason : void 0
60673 }));
60674 }
60675 }
60676 fetchParams.controller.connection.destroy();
60677 }
60678 return response;
60679 async function dispatch({ body }) {
60680 const url2 = requestCurrentURL(request3);
60681 const agent = fetchParams.controller.dispatcher;
60682 return new Promise((resolve, reject) => agent.dispatch(
60683 {
60684 path: url2.pathname + url2.search,
60685 origin: url2.origin,
60686 method: request3.method,
60687 body: fetchParams.controller.dispatcher.isMockActive ? request3.body && (request3.body.source || request3.body.stream) : body,
60688 headers: request3.headersList.entries,
60689 maxRedirections: 0,
60690 upgrade: request3.mode === "websocket" ? "websocket" : void 0
60691 },
60692 {
60693 body: null,
60694 abort: null,
60695 onConnect(abort) {
60696 const { connection } = fetchParams.controller;
60697 if (connection.destroyed) {
60698 abort(new DOMException3("The operation was aborted.", "AbortError"));
60699 } else {
60700 fetchParams.controller.on("terminated", abort);
60701 this.abort = connection.abort = abort;
60702 }
60703 },
60704 onHeaders(status, headersList, resume2, statusText) {
60705 if (status < 200) {
60706 return;
60707 }
60708 let codings = [];
60709 let location = "";
60710 const headers = new Headers6();
60711 if (Array.isArray(headersList)) {
60712 for (let n2 = 0; n2 < headersList.length; n2 += 2) {
60713 const key = headersList[n2 + 0].toString("latin1");
60714 const val = headersList[n2 + 1].toString("latin1");
60715 if (key.toLowerCase() === "content-encoding") {
60716 codings = val.toLowerCase().split(",").map((x5) => x5.trim());
60717 } else if (key.toLowerCase() === "location") {
60718 location = val;
60719 }
60720 headers[kHeadersList].append(key, val);
60721 }
60722 } else {
60723 const keys = Object.keys(headersList);
60724 for (const key of keys) {
60725 const val = headersList[key];
60726 if (key.toLowerCase() === "content-encoding") {
60727 codings = val.toLowerCase().split(",").map((x5) => x5.trim()).reverse();
60728 } else if (key.toLowerCase() === "location") {
60729 location = val;
60730 }

Callers 3

httpNetworkFetchFunction · 0.85

Calls 2

requestCurrentURLFunction · 0.85
dispatchMethod · 0.80

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…