100 lines
3.4 KiB
TypeScript
100 lines
3.4 KiB
TypeScript
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!');
|
|
}
|
|
}
|
|
}
|
|
}
|