From d469c643d41ede0c79b06ee502e7101247263d18 Mon Sep 17 00:00:00 2001
From: Bill Min <nmin@ebay.com>
Date: Mon, 28 Nov 2022 12:02:21 -0500
Subject: [PATCH] fix: check for out.global.req/request when looking for
 incomingMessage

---
 .../renders.expected/loading.0.html           |  6 +++
 .../renders.expected/loading.1.html           | 38 +++++++++++++++++++
 .../renders.expected/loading.2.html           | 30 +++++++++++++++
 .../fixtures/ssr-behind-reorder/embed.marko   | 25 ++++++++++++
 .../fixtures/ssr-behind-reorder/index.marko   | 25 ++++++++++++
 .../fixtures/ssr-behind-reorder/slot_1.html   |  1 +
 .../fixtures/ssr-behind-reorder/slot_2.html   |  1 +
 .../micro-frame-sse/__tests__/server.test.ts  |  5 +++
 .../renders.expected/loading.0.html           |  6 +++
 .../renders.expected/loading.1.html           | 20 ++++++++++
 .../renders.expected/loading.2.html           | 16 ++++++++
 .../fixtures/ssr-behind-reorder/embed.marko   |  4 ++
 .../fixtures/ssr-behind-reorder/index.marko   | 19 ++++++++++
 .../micro-frame/__tests__/server.test.ts      |  5 +++
 .../micro-frame/component/node.marko          |  4 +-
 .../stream-source/component/node.marko        |  4 +-
 16 files changed, 205 insertions(+), 4 deletions(-)
 create mode 100644 src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.0.html
 create mode 100644 src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.1.html
 create mode 100644 src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.2.html
 create mode 100644 src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/embed.marko
 create mode 100644 src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/index.marko
 create mode 100644 src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_1.html
 create mode 100644 src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_2.html
 create mode 100644 src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.0.html
 create mode 100644 src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.1.html
 create mode 100644 src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.2.html
 create mode 100644 src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/embed.marko
 create mode 100644 src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/index.marko

diff --git a/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.0.html b/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.0.html
new file mode 100644
index 0000000..c451db0
--- /dev/null
+++ b/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.0.html
@@ -0,0 +1,6 @@
+<div>
+  Host app
+</div>
+<noscript
+  id="GENERATED-0"
+/>
\ No newline at end of file
diff --git a/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.1.html b/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.1.html
new file mode 100644
index 0000000..2ff9291
--- /dev/null
+++ b/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.1.html
@@ -0,0 +1,38 @@
+<div>
+  Host app
+</div>
+<noscript
+  id="GENERATED-0"
+/>
+<div
+  id="GENERATED-1"
+  style="display:none"
+/>
+<div
+  id="GENERATED-2"
+  style="display:none"
+>
+  <div
+    data-src="embed"
+    id="GENERATED-3"
+  >
+    <noscript
+      id="GENERATED-4"
+    />
+  </div>
+  <div
+    data-from="test"
+    data-slot="slot_1"
+    id="GENERATED-5"
+  >
+    Could not get request from stream/global. Please assign out.global.req with proper request object.
+  </div>
+  <div
+    data-from="test"
+    data-slot="slot_2"
+    id="GENERATED-6"
+  />
+</div>
+<script>
+  function $af(d,a,e,l,g,h,k,b,f,c){c=$af;if(a&&!c[a])(c[a+="$"]||(c[a]=[])).push(d);else{e=document;l=e.getElementById("af"+d);g=e.getElementById("afph"+d);h=e.createDocumentFragment();k=l.childNodes;b=0;for(f=k.length;b&lt;f;b++)h.appendChild(k.item(0));g&&g.parentNode.replaceChild(h,g);c[d]=1;if(a=c[d+"$"])for(b=0,f=a.length;b&lt;f;b++)c(a[b])}};$af(1);$af(0)
+</script>
\ No newline at end of file
diff --git a/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.2.html b/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.2.html
new file mode 100644
index 0000000..c7f6087
--- /dev/null
+++ b/src/components/micro-frame-sse/__tests__/__snapshots__/micro-frame-sse/ssr-behind-reorder/renders.expected/loading.2.html
@@ -0,0 +1,30 @@
+<div>
+  Host app
+</div>
+<div
+  data-src="embed"
+  id="GENERATED-0"
+/>
+<div
+  data-from="test"
+  data-slot="slot_1"
+  id="GENERATED-1"
+>
+  Could not get request from stream/global. Please assign out.global.req with proper request object.
+</div>
+<div
+  data-from="test"
+  data-slot="slot_2"
+  id="GENERATED-2"
+/>
+<div
+  id="GENERATED-3"
+  style="display:none"
+/>
+<div
+  id="GENERATED-4"
+  style="display:none"
+/>
+<script>
+  function $af(d,a,e,l,g,h,k,b,f,c){c=$af;if(a&&!c[a])(c[a+="$"]||(c[a]=[])).push(d);else{e=document;l=e.getElementById("af"+d);g=e.getElementById("afph"+d);h=e.createDocumentFragment();k=l.childNodes;b=0;for(f=k.length;b&lt;f;b++)h.appendChild(k.item(0));g&&g.parentNode.replaceChild(h,g);c[d]=1;if(a=c[d+"$"])for(b=0,f=a.length;b&lt;f;b++)c(a[b])}};$af(1);$af(0)
+</script>
\ No newline at end of file
diff --git a/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/embed.marko b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/embed.marko
new file mode 100644
index 0000000..d51be64
--- /dev/null
+++ b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/embed.marko
@@ -0,0 +1,25 @@
+import { wait } from "../../../../../__tests__/queue";
+import fs from "fs";
+import path from "path";
+
+$ const slot_1_html = fs.readFileSync(path.resolve(__dirname ,'slot_1.html'), 'utf8');
+$ const slot_2_html = fs.readFileSync(path.resolve(__dirname ,'slot_2.html'), 'utf8');
+$ const first = `id: slot_1\ndata: ${slot_1_html.replace(/\r?\n/g, '')}\n\n`;
+$ const second = `id: slot_2\ndata: ${slot_2_html.replace(/\r?\n/g, '')}\n\n`;
+$ const third = `id: slot_1\ntype: update\ndata: next chunk for slot_1`;
+
+<await(wait())>
+  <@then>
+    $!{first}
+    <await(wait())>
+      <@then>
+        $!{second}
+        <await(wait())>
+          <@then>
+            $!{third}
+          </@then>
+        </await>
+      </@then>
+    </await>
+  </@then>
+</await>
diff --git a/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/index.marko b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/index.marko
new file mode 100644
index 0000000..ad697c5
--- /dev/null
+++ b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/index.marko
@@ -0,0 +1,25 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Simple Example</title>
+    <esbuild-assets/>
+  </head>
+  <body>
+    <div>Host app</div>
+    <await(new Promise((res) => setTimeout(res))) client-reorder>
+      <@then>
+        <micro-frame-sse
+          src="embed"
+          name="test"
+          read=((e) => [e.lastEventId, e.data])
+        />
+        <micro-frame-slot from="test" slot="slot_1">
+          <@catch|err|>${err.message}</@catch>
+        </micro-frame-slot>
+        <micro-frame-slot from="test" slot="slot_2"/>
+      </@then>
+    </await>
+  </body>
+</html>
diff --git a/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_1.html b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_1.html
new file mode 100644
index 0000000..e4f8443
--- /dev/null
+++ b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_1.html
@@ -0,0 +1 @@
+<p>test_html for slot_1</p>
\ No newline at end of file
diff --git a/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_2.html b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_2.html
new file mode 100644
index 0000000..bc6bb6a
--- /dev/null
+++ b/src/components/micro-frame-sse/__tests__/fixtures/ssr-behind-reorder/slot_2.html
@@ -0,0 +1 @@
+<p>test_html for slot_2</p>
\ No newline at end of file
diff --git a/src/components/micro-frame-sse/__tests__/server.test.ts b/src/components/micro-frame-sse/__tests__/server.test.ts
index a6cacdf..19754d1 100644
--- a/src/components/micro-frame-sse/__tests__/server.test.ts
+++ b/src/components/micro-frame-sse/__tests__/server.test.ts
@@ -196,4 +196,9 @@ describe("micro-frame-sse", () => {
     "ssr timeout",
     fixture(path.join(__dirname, "fixtures/ssr-timeout"))
   );
+
+  describe(
+    "ssr behind reorder",
+    fixture(path.join(__dirname, "fixtures/ssr-behind-reorder"))
+  );
 });
diff --git a/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.0.html b/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.0.html
new file mode 100644
index 0000000..c451db0
--- /dev/null
+++ b/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.0.html
@@ -0,0 +1,6 @@
+<div>
+  Host app
+</div>
+<noscript
+  id="GENERATED-0"
+/>
\ No newline at end of file
diff --git a/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.1.html b/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.1.html
new file mode 100644
index 0000000..bb4246a
--- /dev/null
+++ b/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.1.html
@@ -0,0 +1,20 @@
+<div>
+  Host app
+</div>
+<noscript
+  id="GENERATED-0"
+/>
+<div
+  id="GENERATED-1"
+  style="display:none"
+>
+  <div
+    data-src="embed"
+    id="GENERATED-2"
+  >
+    Could not get request from stream/global. Please assign out.global.req with proper request object.
+  </div>
+</div>
+<script>
+  function $af(d,a,e,l,g,h,k,b,f,c){c=$af;if(a&&!c[a])(c[a+="$"]||(c[a]=[])).push(d);else{e=document;l=e.getElementById("af"+d);g=e.getElementById("afph"+d);h=e.createDocumentFragment();k=l.childNodes;b=0;for(f=k.length;b&lt;f;b++)h.appendChild(k.item(0));g&&g.parentNode.replaceChild(h,g);c[d]=1;if(a=c[d+"$"])for(b=0,f=a.length;b&lt;f;b++)c(a[b])}};$af(0)
+</script>
\ No newline at end of file
diff --git a/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.2.html b/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.2.html
new file mode 100644
index 0000000..36cfb3a
--- /dev/null
+++ b/src/components/micro-frame/__tests__/__snapshots__/ssr-behind-reorder/renders.expected/loading.2.html
@@ -0,0 +1,16 @@
+<div>
+  Host app
+</div>
+<div
+  data-src="embed"
+  id="GENERATED-0"
+>
+  Could not get request from stream/global. Please assign out.global.req with proper request object.
+</div>
+<div
+  id="GENERATED-1"
+  style="display:none"
+/>
+<script>
+  function $af(d,a,e,l,g,h,k,b,f,c){c=$af;if(a&&!c[a])(c[a+="$"]||(c[a]=[])).push(d);else{e=document;l=e.getElementById("af"+d);g=e.getElementById("afph"+d);h=e.createDocumentFragment();k=l.childNodes;b=0;for(f=k.length;b&lt;f;b++)h.appendChild(k.item(0));g&&g.parentNode.replaceChild(h,g);c[d]=1;if(a=c[d+"$"])for(b=0,f=a.length;b&lt;f;b++)c(a[b])}};$af(0)
+</script>
\ No newline at end of file
diff --git a/src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/embed.marko b/src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/embed.marko
new file mode 100644
index 0000000..6ebe406
--- /dev/null
+++ b/src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/embed.marko
@@ -0,0 +1,4 @@
+<esbuild-assets/>
+<div>
+  Embedded App.
+</div>
diff --git a/src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/index.marko b/src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/index.marko
new file mode 100644
index 0000000..9169486
--- /dev/null
+++ b/src/components/micro-frame/__tests__/fixtures/ssr-behind-reorder/index.marko
@@ -0,0 +1,19 @@
+<!DOCTYPE html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>Simple Example</title>
+    <esbuild-assets/>
+  </head>
+  <body>
+    <div>Host app</div>
+    <await(new Promise((res) => setTimeout(res))) client-reorder>
+      <@then>
+        <micro-frame src="embed">
+          <@catch|err|>${err.message}</@catch>
+        </micro-frame>
+      </@then>
+    </await>
+  </body>
+</html>
diff --git a/src/components/micro-frame/__tests__/server.test.ts b/src/components/micro-frame/__tests__/server.test.ts
index 9bd8e3e..e2c9f9b 100644
--- a/src/components/micro-frame/__tests__/server.test.ts
+++ b/src/components/micro-frame/__tests__/server.test.ts
@@ -129,3 +129,8 @@ describe(
   "ssr custom fetch",
   fixture(path.join(__dirname, "fixtures/ssr-custom-fetch"))
 );
+
+describe(
+  "ssr behind reorder",
+  fixture(path.join(__dirname, "fixtures/ssr-behind-reorder"))
+);
diff --git a/src/components/micro-frame/component/node.marko b/src/components/micro-frame/component/node.marko
index 8bcae21..4e0cf73 100644
--- a/src/components/micro-frame/component/node.marko
+++ b/src/components/micro-frame/component/node.marko
@@ -5,10 +5,10 @@ static const cachePath = path.resolve("node_modules/.cache/fetch");
 static const strictSSL = process.env.NODE_TLS_REJECT_UNAUTHORIZED !== "0";
 
 static async function fetchStream(input, out) {
-  const incomingMessage = out.stream && (out.stream.req || out.stream.request);
+  const incomingMessage = out.stream && (out.stream.req || out.stream.request) || out.global.req || out.global.request;
 
   if (!incomingMessage) {
-    throw new Error("Could not get request from stream.");
+    throw new Error("Could not get request from stream/global. Please assign out.global.req with proper request object.");
   }
 
   const url = new URL(input.src, `${incomingMessage.protocol}://${incomingMessage.headers.host}`);
diff --git a/src/components/stream-source/component/node.marko b/src/components/stream-source/component/node.marko
index 58638bf..d229e82 100644
--- a/src/components/stream-source/component/node.marko
+++ b/src/components/stream-source/component/node.marko
@@ -5,10 +5,10 @@ import StreamSource, { STREAM_SOURCE_MAP } from "./StreamSource";
 static const cachePath = path.resolve("node_modules/.cache/fetch");
 
 $ const request = async () => {
-  const incomingMessage = out.stream && (out.stream.req || out.stream.request);
+  const incomingMessage = out.stream && (out.stream.req || out.stream.request) || out.global.req || out.global.request;
 
   if (!incomingMessage) {
-    throw new Error("Could not get request from stream.");
+    throw new Error("Could not get request from stream/global. Please assign out.global.req with proper request object.");
   }
 
   const url = new URL(input.src, `${incomingMessage.protocol}://${incomingMessage.headers.host}`);