fix(angular): add support for devRemotes in module-federation-dev-ssr (…

…#13500)
nrwl · Nov 30, 2022 · 2d021a1 · 2d021a1
1 parent f545b29
commit 2d021a1
Showing 1 changed file with 47 additions and 21 deletions.
diff --git a/packages/angular/src/builders/module-federation-dev-ssr/module-federation-dev-ssr.impl.ts b/packages/angular/src/builders/module-federation-dev-ssr/module-federation-dev-ssr.impl.ts
@@ -14,10 +14,11 @@ import {
   getStaticRemotes,
   validateDevRemotes,
 } from '../utilities/module-federation';
-import { switchMap } from 'rxjs/operators';
+import { switchMap, tap } from 'rxjs/operators';
 import { from } from 'rxjs';
 import { join } from 'path';
 import { execSync, fork } from 'child_process';
+import { scheduleTarget } from 'nx/src/adapter/ngcli-adapter';
 
 export function executeModuleFederationDevSSRBuilder(
   schema: Schema,
@@ -80,26 +81,51 @@ export function executeModuleFederationDevSSRBuilder(
     }
 
     const remotePromise = new Promise<void>((res, rej) => {
-      const remoteProject = workspaceProjects[remote];
-      const remoteServerOutput = join(
-        workspaceRoot,
-        remoteProject.targets.server.options.outputPath,
-        'main.js'
-      );
-      execSync(
-        `npx nx run ${remote}:server${
-          context.target.configuration ? `:${context.target.configuration}` : ''
-        }`,
-        { stdio: 'inherit' }
-      );
-      const child = fork(remoteServerOutput, {
-        env: remoteProject.targets['serve-ssr'].options.port,
-      });
-      child.on('message', (msg) => {
-        if (msg === 'nx.server.ready') {
-          res();
-        }
-      });
+      if (target === 'static-server') {
+        const remoteProject = workspaceProjects[remote];
+        const remoteServerOutput = join(
+          workspaceRoot,
+          remoteProject.targets.server.options.outputPath,
+          'main.js'
+        );
+        execSync(
+          `npx nx run ${remote}:server${
+            context.target.configuration
+              ? `:${context.target.configuration}`
+              : ''
+          }`,
+          { stdio: 'inherit' }
+        );
+        const child = fork(remoteServerOutput, {
+          env: remoteProject.targets['serve-ssr'].options.port,
+        });
+        child.on('message', (msg) => {
+          if (msg === 'nx.server.ready') {
+            res();
+          }
+        });
+      }
+
+      if (target === 'serve-ssr') {
+        scheduleTarget(
+          context.workspaceRoot,
+          {
+            project: remote,
+            target,
+            configuration: context.target.configuration,
+            runOptions,
+          },
+          options.verbose
+        ).then((obs) =>
+          obs
+            .pipe(
+              tap((result) => {
+                result.success && res();
+              })
+            )
+            .toPromise()
+        );
+      }
     });
 
     remoteProcessPromises.push(remotePromise);