fix(core): update

2024-05-08 20:49:10 +02:00
commit 1d6d056942
26 changed files with 6396 additions and 0 deletions
--- a/ts/spark.classes.updatemanager.ts
+++ b/ts/spark.classes.updatemanager.ts
@@ -0,0 +1,99 @@
+import * as plugins from './spark.plugins.js';
+import * as paths from './spark.paths.js';
+import { Spark } from './spark.classes.spark.js';
+import { logger } from './spark.logging.js';
+
+export class SparkUpdateManager {
+  public sparkRef: Spark;
+  public dockerHost: plugins.docker.DockerHost;
+  public smartupdate: plugins.smartupdate.SmartUpdate;
+  constructor(sparkrefArg: Spark) {
+    this.sparkRef = sparkrefArg;
+    this.dockerHost = new plugins.docker.DockerHost();
+    this.smartupdate = new plugins.smartupdate.SmartUpdate();
+  }
+
+  /**
+   * start the instance
+   */
+  public async start() {
+    await this.dockerHost.activateSwarm();
+  }
+
+  public async updateServices() {
+    if (
+      plugins.smartfile.fs.isDirectory(plugins.path.join(paths.homeDir, 'serve.zone/spark')) &&
+      (await plugins.smartfile.fs.fileExists(
+        plugins.path.join(paths.homeDir, 'serve.zone/spark/spark.json')
+      ))
+    ) {
+      const sparkJson = plugins.smartfile.fs.toObjectSync(
+        plugins.path.join(paths.homeDir, 'serve.zone/spark/spark.json')
+      );
+      const services: Array<{
+        name: string;
+        image: string;
+        url: string;
+        port: string;
+        environment: string;
+        secretJson: any;
+      }> = [];
+      for (const serviceKey of Object.keys(sparkJson.services)) {
+        services.push({
+          name: serviceKey,
+          image: sparkJson.services[serviceKey].image,
+          url: sparkJson.services[serviceKey].url,
+          environment: sparkJson.services[serviceKey].environment,
+          port: sparkJson.services[serviceKey].port,
+          secretJson: sparkJson.services[serviceKey].secretJson,
+        });
+      }
+      for (const service of services) {
+        const existingService = await plugins.docker.DockerService.getServiceByName(
+          this.dockerHost,
+          service.name
+        );
+        const existingServiceSecret = await plugins.docker.DockerSecret.getSecretByName(
+          this.dockerHost,
+          `${service.name}Secret`
+        );
+        if (existingService) {
+          const needsUpdate: boolean = await existingService.needsUpdate();
+          if (!needsUpdate) {
+            logger.log('info', `not needing update.`);
+            return;
+          }
+          logger.log('ok', `${service.name} needs to be updated!`);
+          await existingService.remove();
+          await existingServiceSecret.remove();
+        }
+        if (!existingService && existingServiceSecret) {
+          await existingServiceSecret.remove();
+        }
+
+        const newServiceImage = await plugins.docker.DockerImage.createFromRegistry(
+          this.dockerHost,
+          {
+            imageUrl: service.image,
+          }
+        );
+        const newServiceSecret = await plugins.docker.DockerSecret.createSecret(this.dockerHost, {
+          name: `${service.name}Secret`,
+          contentArg: plugins.smartjson.stringify(service.secretJson),
+          version: await newServiceImage.getVersion(),
+          labels: {},
+        });
+        const newService = await plugins.docker.DockerService.createService(this.dockerHost, {
+          image: newServiceImage,
+          labels: {},
+          name: service.name,
+          networkAlias: service.name,
+          networks: [],
+          secrets: [newServiceSecret],
+          ports: [`${service.port}:${service.secretJson.SERVEZONE_PORT}`],
+        });
+        logger.log('success', 'updated all services!');
+      }
+    }
+  }
+}