132 lines
3.7 KiB
TypeScript
132 lines
3.7 KiB
TypeScript
import * as plugins from '../plugins.js';
|
|
import * as paths from '../paths.js';
|
|
import { Cloudly } from '../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<plugins.servezoneInterfaces.requests.cluster.IRequest_CreateCluster>(
|
|
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<plugins.servezoneInterfaces.requests.cluster.IRequest_GetAllClusters>(
|
|
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;
|
|
}
|
|
}
|