v0.0.1-alpha.13

Author: ScriptedAlchemy

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@module-federation/aegis",
-  "version": "0.0.1-alpha.12",
+  "version": "0.0.1-alpha.13",
   "main": "lib/",
   "module": "esm/",
   "repository": "git@github.com:module-federation/aegis.git",

src/services/federation-service.js

@@ -0,0 +1,68 @@
+"use strict";
+
+/**
+ * @returns {Promise<import('../models').ModelSpecification[]>}
+ */
+export async function importRemoteModels(remoteEntries) {
+  const label = "\ntime to import remote models";
+  console.time(label);
+
+  const remoteModels = [];
+  try {
+    for (const entry of remoteEntries) {
+      if (entry.type === "model") {
+        const models = await entry.importRemote();
+        remoteModels.push(models);
+      }
+    }
+  } catch (e) {
+    console.error(e);
+  }
+
+  console.timeEnd(label);
+
+  if (remoteModels.length === 0) return {};
+
+  return remoteModels.reduce((p, c) => ({ ...p, ...c }));
+}
+
+/**
+ * Imports remote service modules.
+ */
+export async function importRemoteServices(remoteEntries) {
+  const label = "\ntime to import remote services";
+  console.time(label);
+
+  let services = [];
+  for (const entry of remoteEntries) {
+    if (entry.type === "service") {
+      const service = await entry.importRemote();
+      services.push(service);
+    }
+  }
+
+  console.timeEnd(label);
+
+  if (services.length === 0) return {};
+
+  return services.reduce((p, c) => ({ ...p, ...c }));
+}
+
+export async function importRemoteAdapters(remoteEntries) {
+  const label = "\ntime to import remote adapters";
+  console.time(label);
+
+  let adapters = [];
+  for (const entry of remoteEntries) {
+    if (entry.type === "adapter") {
+      const adapter = await entry.importRemote();
+      adapters.push(adapter);
+    }
+  }
+
+  console.timeEnd(label);
+
+  if (adapters.length === 0) return {};
+
+  return adapters.reduce((p, c) => ({ ...p, ...c }));
+}

src/services/persistence-service.js

@@ -0,0 +1,17 @@
+"use strict";
+
+import DataSource from "../datasources";
+
+export const Persistence = {
+  async save(model) {
+    return DataSource.getDataSource(model.getName()).save(model.getId(), model);
+  },
+
+  async find(model) {
+    return DataSource.getDataSource(model.getName()).find(model.getId());
+  },
+
+  close() {
+    DataSource.getFactory().close();
+  },
+};

src/services/publish-event.js

@@ -0,0 +1,8 @@
+export default async (event, observer) => {
+  try {
+    const publishEvent = (await import("microservices/services")).publishEvent;
+    publishEvent(event, observer);
+  } catch (error) {
+    console.error(error);
+  }
+};