smartnginx/ts/smartnginx.classes.smartnginx.ts

125 lines
3.7 KiB
TypeScript
Raw Normal View History

import * as plugins from './smartnginx.plugins';
import * as paths from './smartnginx.paths';
import * as snippets from './smartnginx.snippets';
import { NginxHost } from './smartnginx.classes.nginxhost';
import { NginxProcess } from './smartnginx.classes.nginxprocess';
2019-01-09 11:15:28 +00:00
import { IHostConfig } from './interfaces/hostconfig';
/**
* main class that manages a NginxInstance
*/
export class SmartNginx {
2019-01-09 11:15:28 +00:00
public logger: plugins.smartlog.Smartlog;
2019-01-17 23:45:29 +00:00
// the objectmaps
private deployedHosts = new plugins.lik.Objectmap<NginxHost>();
private hostCandidates = new plugins.lik.Objectmap<NginxHost>();
2019-01-09 11:15:28 +00:00
public nginxProcess: NginxProcess = new NginxProcess(this);
constructor(optionsArg: { logger?: plugins.smartlog.Smartlog }) {
optionsArg.logger
? (this.logger = optionsArg.logger)
: (this.logger = plugins.smartlog.defaultLogger);
}
// ===================
// interact with Hosts
// ===================
/**
* add a host
* @param nginxHostArg
*/
2019-01-17 23:45:29 +00:00
public addHostCandidate(optionsArg: IHostConfig): NginxHost {
2019-01-09 11:15:28 +00:00
const nginxHost = new NginxHost(this, optionsArg);
2019-01-17 23:45:29 +00:00
this.hostCandidates.add(nginxHost);
2018-08-11 13:09:19 +00:00
return nginxHost;
}
2019-01-09 11:15:28 +00:00
/**
* Gets a NginxHost by hostname
* @param hostNameArg
*/
2019-01-17 23:45:29 +00:00
public getDeployedNginxHostByHostName(hostNameArg: string): NginxHost {
return this.deployedHosts.find(nginxHost => {
2018-08-11 13:09:19 +00:00
return nginxHost.hostName === hostNameArg;
2019-01-09 11:15:28 +00:00
});
2018-08-11 13:09:19 +00:00
}
/**
* listHosts
*/
2019-01-17 23:45:29 +00:00
public async listDeployedHosts(): Promise<NginxHost[]> {
return this.deployedHosts.getArray();
}
/**
* remove a Host
* @param nginxHostArg
*/
2019-01-17 23:45:29 +00:00
public async removeDeployedHost(nginxHostArg: NginxHost) {
if (this.hostCandidates.isEmpty()) {
this.deployedHosts.forEach(hostArg => {
this.hostCandidates.add(hostArg);
});
}
this.hostCandidates.remove(nginxHostArg);
this.deploy();
2019-01-09 11:15:28 +00:00
}
/**
2019-01-17 23:45:29 +00:00
* check wether there has been a diverging host configuration
* this function will only redeploy the nginx configuration in case there has been a change
*/
2019-01-18 00:33:01 +00:00
private async areHostsDiverged(): Promise<boolean> {
2019-01-17 23:45:29 +00:00
let hostCounter = 0;
let unfoundHosts = 0;
2019-01-18 00:33:01 +00:00
await this.hostCandidates.forEach(async hostCandidateArg => {
2019-01-17 23:45:29 +00:00
let foundHost = false;
2019-01-18 00:33:01 +00:00
await this.deployedHosts.forEach(async deployedHostArg => {
2019-01-17 23:45:29 +00:00
if (
hostCandidateArg.hostName === deployedHostArg.hostName &&
hostCandidateArg.destination === deployedHostArg.destination
) {
hostCounter++;
foundHost = true;
}
});
if (!foundHost) {
unfoundHosts++;
}
});
return (
2019-01-18 00:33:01 +00:00
this.deployedHosts.getArray().length !== this.hostCandidates.getArray().length ||
2019-01-17 23:45:29 +00:00
hostCounter !== this.deployedHosts.getArray().length ||
unfoundHosts !== 0
);
}
/**
* deploy the current stack and restart nginx
*/
2019-01-09 11:15:28 +00:00
public async deploy() {
2019-01-18 00:33:01 +00:00
if (await this.areHostsDiverged()) {
2019-01-17 23:45:29 +00:00
this.logger.log('ok', `hosts have diverged, trigger config deployment and nginx reload!`);
this.deployedHosts.wipe();
this.deployedHosts.addArray(this.hostCandidates.getArray());
this.hostCandidates.wipe();
// write base config
plugins.smartfile.fs.ensureDirSync(paths.nginxConfigDirPath);
plugins.smartfile.memory.toFsSync(snippets.getBaseConfigString(), paths.nginxConfFile);
2019-01-09 11:15:28 +00:00
2019-01-17 23:45:29 +00:00
// deploy hosts
plugins.smartfile.fs.ensureEmptyDirSync(paths.nginxHostDirPath);
for (const host of this.deployedHosts.getArray()) {
await host.deploy();
this.logger.log('info', `Host ${host.hostName} deployed!`);
}
this.nginxProcess.reloadConfig();
} else {
this.logger.log('info', `hosts have not diverged, skipping nginx reload`);
2019-01-17 23:46:08 +00:00
this.hostCandidates.wipe();
2019-01-09 11:15:28 +00:00
}
}
}