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!');
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
}
|