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

Function fetchFinale

out/cli.cjs:60236–60284  ·  view source on GitHub ↗
(fetchParams, response)

Source from the content-addressed store, hash-verified

60234 }
60235 }
60236 function finalizeResponse(fetchParams, response) {
60237 fetchParams.request.done = true;
60238 if (fetchParams.processResponseDone != null) {
60239 queueMicrotask(() => fetchParams.processResponseDone(response));
60240 }
60241 }
60242 function fetchFinale(fetchParams, response) {
60243 if (response.type === "error") {
60244 response.urlList = [fetchParams.request.urlList[0]];
60245 response.timingInfo = createOpaqueTimingInfo({
60246 startTime: fetchParams.timingInfo.startTime
60247 });
60248 }
60249 const processResponseEndOfBody = () => {
60250 fetchParams.request.done = true;
60251 if (fetchParams.processResponseEndOfBody != null) {
60252 queueMicrotask(() => fetchParams.processResponseEndOfBody(response));
60253 }
60254 };
60255 if (fetchParams.processResponse != null) {
60256 queueMicrotask(() => fetchParams.processResponse(response));
60257 }
60258 if (response.body == null) {
60259 processResponseEndOfBody();
60260 } else {
60261 const identityTransformAlgorithm = (chunk, controller) => {
60262 controller.enqueue(chunk);
60263 };
60264 const transformStream = new TransformStream3({
60265 start() {
60266 },
60267 transform: identityTransformAlgorithm,
60268 flush: processResponseEndOfBody
60269 }, {
60270 size() {
60271 return 1;
60272 }
60273 }, {
60274 size() {
60275 return 1;
60276 }
60277 });
60278 response.body = { stream: response.body.stream.pipeThrough(transformStream) };
60279 }
60280 if (fetchParams.processResponseConsumeBody != null) {
60281 const processBody = (nullOrBytes) => fetchParams.processResponseConsumeBody(response, nullOrBytes);
60282 const processBodyError = (failure) => fetchParams.processResponseConsumeBody(response, failure);
60283 if (response.body == null) {
60284 queueMicrotask(() => processBody(null));
60285 } else {
60286 return fullyReadBody(response.body, processBody, processBodyError);
60287 }

Callers 3

processBodyErrorFunction · 0.85
processBodyFunction · 0.85
mainFetchFunction · 0.85

Calls 6

createOpaqueTimingInfoFunction · 0.85
processResponseEndOfBodyFunction · 0.85
processBodyFunction · 0.85
fullyReadBodyFunction · 0.85
processResponseMethod · 0.80
pipeThroughMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…