Merge remote-tracking branch 'origin/feat/fetch-status' into feat/fet…

…ch-status
umijs · Mar 6, 2024 · b3744dc · b3744dc
2 parents 69fe696 + 1cdaa06
commit b3744dc
Show file tree

Hide file tree

Showing 6 changed files with 36 additions and 14 deletions.
diff --git a/.changeset/poor-squids-hide.md b/.changeset/poor-squids-hide.md
@@ -0,0 +1,5 @@
+---
+"qiankun": patch
+---
+
+fix(qiankun): should remove internal cache of loadMicroApp while loading failed
diff --git a/.changeset/red-islands-mate.md b/.changeset/red-islands-mate.md
@@ -0,0 +1,6 @@
+---
+"@qiankunjs/loader": patch
+"qiankun": patch
+---
+
+feat(loader): supports passing Response as entry parameter for loadEntry function
diff --git a/packages/loader/src/index.ts b/packages/loader/src/index.ts
@@ -8,7 +8,6 @@ import type {
 } from '@qiankunjs/shared';
 import { Deferred, prepareDeferredQueue, QiankunError } from '@qiankunjs/shared';
 import { createTagTransformStream } from './TagTransformStream';
-import { isUrlHasOwnProtocol } from './utils';
 import WritableDOMStream from './writable-dom';
 
 type HTMLEntry = string;
@@ -42,10 +41,15 @@ const isDeferScript = (script: HTMLScriptElement): boolean => {
  * @param container
  * @param opts
  */
-export async function loadEntry<T>(entry: Entry, container: HTMLElement, opts: LoaderOpts): Promise<T | void> {
+export async function loadEntry<T>(
+  entry: Entry | { url: string; res: Response },
+  container: HTMLElement,
+  opts: LoaderOpts,
+): Promise<T | void> {
   const { fetch, streamTransformer, sandbox, nodeTransformer } = opts;
 
-  const res = isUrlHasOwnProtocol(entry) ? await fetch(entry) : new Response(entry, { status: 200, statusText: 'OK' });
+  const entryUrl = typeof entry === 'string' ? entry : entry.url;
+  const res = typeof entry === 'string' ? await fetch(entry) : entry.res;
   if (res.body) {
     let foundEntryScript = false;
     const entryScriptLoadedDeferred = new Deferred<T | void>();
@@ -120,7 +124,7 @@ export async function loadEntry<T>(entry: Entry, container: HTMLElement, opts: L
           if (isEntryScript(script)) {
             if (foundEntryScript) {
               throw new QiankunError(
-                `You should not set multiply entry script in one entry html, but ${entry} has at least 2 entry scripts`,
+                `You should not include more than 1 entry scripts in a single HTML entry ${entryUrl} !`,
               );
             }
 
@@ -139,7 +143,7 @@ export async function loadEntry<T>(entry: Entry, container: HTMLElement, opts: L
                 } else {
                   entryScriptLoadedDeferred.reject(
                     new QiankunError(
-                      `entry ${entry} load failed as entry script ${script.dataset.src || script.src} load failed}`,
+                      `Entry ${entryUrl} load failed as entry script ${script.dataset.src || script.src} load failed}`,
                     ),
                   );
                 }
@@ -176,5 +180,5 @@ export async function loadEntry<T>(entry: Entry, container: HTMLElement, opts: L
     return entryScriptLoadedDeferred.promise;
   }
 
-  throw new QiankunError(`entry ${entry} response body is empty!`);
+  throw new QiankunError(`The response body of entry ${entryUrl} is empty!`);
 }
diff --git a/packages/loader/src/utils.ts b/packages/loader/src/utils.ts
@@ -1,9 +1,3 @@
-export function getEntireUrl(uri: string, baseURI: string): string {
-  const publicPath = new URL(baseURI, window.location.href);
-  const entireUrl = new URL(uri, publicPath.toString());
-  return entireUrl.toString();
-}
-
 export function isUrlHasOwnProtocol(url: string): boolean {
   const protocols = ['http://', 'https://', '//', 'blob:', 'data:'];
   return protocols.some((protocol) => url.startsWith(protocol));

diff --git a/packages/qiankun/src/apis/loadMicroApp.ts b/packages/qiankun/src/apis/loadMicroApp.ts
@@ -71,12 +71,21 @@ export function loadMicroApp<T extends ObjectType>(
 
     const parcelConfigObjectGetterPromise = loadApp(app, userConfiguration, lifeCycles);
 
+    let parcelConfigObjectGetter: ParcelConfigObjectGetter | undefined;
+
     if (containerXPath) {
       const appContainerXPathKey = getContainerXPathKey(containerXPath);
       appConfigPromiseGetterMap.set(appContainerXPathKey, parcelConfigObjectGetterPromise);
+      try {
+        parcelConfigObjectGetter = await parcelConfigObjectGetterPromise;
+      } catch (e) {
+        appConfigPromiseGetterMap.delete(appContainerXPathKey);
+        throw e;
+      }
     }
 
-    return (await parcelConfigObjectGetterPromise)(container);
+    parcelConfigObjectGetter = parcelConfigObjectGetter || (await parcelConfigObjectGetterPromise);
+    return parcelConfigObjectGetter(container);
   };
 
   if (!started) {

diff --git a/packages/qiankun/src/core/loadApp.ts b/packages/qiankun/src/core/loadApp.ts
@@ -142,7 +142,11 @@ export default async function loadApp<T extends ObjectType>(
             initContainer(mountContainer, appName, { sandboxCfg: sandbox, mountTimes, instanceId });
             // html scripts should be removed to avoid repeatedly execute
             const htmlString = await getPureHTMLStringWithoutScripts(entry, enhancedFetch);
-            await loadEntry(htmlString, mountContainer, containerOpts);
+            await loadEntry(
+              { url: entry, res: new Response(htmlString, { status: 200, statusText: 'OK' }) },
+              mountContainer,
+              containerOpts,
+            );
           }
         },
         async () => {