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

Function fetching

out/cli.cjs:60005–60069  ·  view source on GitHub ↗
({
      request: request3,
      processRequestBodyChunkLength,
      processRequestEndOfBody,
      processResponse,
      processResponseEndOfBody,
      processResponseConsumeBody,
      useParallelQueue = false,
      dispatcher
      // undici
    })

Source from the content-addressed store, hash-verified

60003 response.body.stream.cancel(error).catch((err) => {
60004 if (err.code === "ERR_INVALID_STATE") {
60005 return;
60006 }
60007 throw err;
60008 });
60009 }
60010 }
60011 function fetching({
60012 request: request3,
60013 processRequestBodyChunkLength,
60014 processRequestEndOfBody,
60015 processResponse,
60016 processResponseEndOfBody,
60017 processResponseConsumeBody,
60018 useParallelQueue = false,
60019 dispatcher
60020 // undici
60021 }) {
60022 let taskDestination = null;
60023 let crossOriginIsolatedCapability = false;
60024 if (request3.client != null) {
60025 taskDestination = request3.client.globalObject;
60026 crossOriginIsolatedCapability = request3.client.crossOriginIsolatedCapability;
60027 }
60028 const currenTime = coarsenedSharedCurrentTime(crossOriginIsolatedCapability);
60029 const timingInfo = createOpaqueTimingInfo({
60030 startTime: currenTime
60031 });
60032 const fetchParams = {
60033 controller: new Fetch(dispatcher),
60034 request: request3,
60035 timingInfo,
60036 processRequestBodyChunkLength,
60037 processRequestEndOfBody,
60038 processResponse,
60039 processResponseConsumeBody,
60040 processResponseEndOfBody,
60041 taskDestination,
60042 crossOriginIsolatedCapability
60043 };
60044 assert2(!request3.body || request3.body.stream);
60045 if (request3.window === "client") {
60046 request3.window = request3.client?.globalObject?.constructor?.name === "Window" ? request3.client : "no-window";
60047 }
60048 if (request3.origin === "client") {
60049 request3.origin = request3.client?.origin;
60050 }
60051 if (request3.policyContainer === "client") {
60052 if (request3.client != null) {
60053 request3.policyContainer = clonePolicyContainer(
60054 request3.client.policyContainer
60055 );
60056 } else {
60057 request3.policyContainer = makePolicyContainer();
60058 }
60059 }
60060 if (!request3.headersList.contains("accept")) {
60061 const value = "*/*";
60062 request3.headersList.append("accept", value);

Callers 3

fetch4Function · 0.85
addAllMethod · 0.85

Calls 10

createOpaqueTimingInfoFunction · 0.85
clonePolicyContainerFunction · 0.85
makePolicyContainerFunction · 0.85
mainFetchFunction · 0.85
containsMethod · 0.80
appendMethod · 0.45
hasMethod · 0.45
catchMethod · 0.45
terminateMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…