import * as plugins from '../cloudly.plugins.js'; import * as paths from '../cloudly.paths.js'; import { Cloudly } from '../cloudly.classes.cloudly.js'; import { logger } from '../cloudly.logging.js'; import { Cluster } from './cluster.js'; export class ClusterManager { public ready = plugins.smartpromise.defer(); public cloudlyRef: Cloudly; public get db() { return this.cloudlyRef.mongodbConnector.smartdataDb; } public typedrouter = new plugins.typedrequest.TypedRouter(); public CCluster = plugins.smartdata.setDefaultManagerForDoc(this, Cluster); constructor(cloudlyRef: Cloudly) { this.cloudlyRef = cloudlyRef; this.cloudlyRef.typedrouter.addTypedRouter(this.typedrouter); this.typedrouter.addTypedHandler( new plugins.typedrequest.TypedHandler('createCluster', async (dataArg) => { const cluster = await this.storeCluster({ id: plugins.smartunique.uniSimple('cluster'), data: { name: dataArg.clusterName, jumpCode: plugins.smartunique.uniSimple('cluster'), jumpCodeUsedAt: null, secretKey: plugins.smartunique.shortId(16), acmeInfo: null, cloudlyUrl: `https://${this.cloudlyRef.config.data.publicUrl}:${this.cloudlyRef.config.data.publicPort}/`, servers: [], sshKeys: [], }, }); console.log(await cluster.createSavableObject()); this.cloudlyRef.serverManager.ensureServerInfrastructure(); return { clusterConfig: await cluster.createSavableObject(), }; }) ); this.typedrouter.addTypedHandler( new plugins.typedrequest.TypedHandler('getAllClusters', async (dataArg) => { // TODO: do authentication here const clusters = await this.getAllClusters(); return { clusters: await Promise.all( clusters.map((clusterArg) => clusterArg.createSavableObject()) ), }; }) ); } public async init() { // lets read the config folder logger.log('info', 'config manager is now initializing'); this.ready.resolve(); } /** * gets a cluster config by Name */ public async getClusterConfigBy_ServerIP() { await this.ready.promise; // TODO: implement getclusterConfigByServerIp } public async getClusterConfigBy_JumpCode(jumpCodeArg: string) { await this.ready.promise; return await Cluster.getInstance({ data: { jumpCode: jumpCodeArg, }, }); } public async getClusterConfigBy_ClusterIdentifier( clusterIdentifier: plugins.servezoneInterfaces.data.IClusterIdentifier ) { await this.ready.promise; return await Cluster.getInstance({ data: { name: clusterIdentifier.clusterName, secretKey: clusterIdentifier.secretKey, }, }); } /** * get config by id */ public async getConfigBy_ConfigID(configId: string) { await this.ready.promise; return await Cluster.getInstance({ id: configId, }); } /** * gets all cluster configs */ public async getAllClusters() { await this.ready.promise; return await Cluster.getInstances({}); } /** * allows storage of a config * @param configName * @param configObjectArg */ public async storeCluster(configObjectArg: plugins.servezoneInterfaces.data.ICluster) { let clusterInstance = await Cluster.getInstance({ id: configObjectArg.id }); if (!clusterInstance) { clusterInstance = await Cluster.fromConfigObject(configObjectArg); } else { Object.assign(clusterInstance, configObjectArg); } await clusterInstance.save(); return clusterInstance; } }