148 lines
4.6 KiB
TypeScript
148 lines
4.6 KiB
TypeScript
import * as plugins from './smartdaemon.plugins';
|
|
import * as paths from './smartdaemon.paths';
|
|
import { SmartDaemon } from './smartdaemon.classes.smartdaemon';
|
|
import {
|
|
ISmartDaemonServiceConstructorOptions,
|
|
SmartDaemonService,
|
|
} from './smartdaemon.classes.service';
|
|
|
|
export class SmartDaemonSystemdManager {
|
|
// STATIC
|
|
private static smartDaemonNamespace = 'smartdaemon';
|
|
|
|
public static createServiceNameFromServiceName(serviceNameArg: string) {
|
|
return `${SmartDaemonSystemdManager.smartDaemonNamespace}_${serviceNameArg}`;
|
|
}
|
|
|
|
public static createFileNameFromServiceName(serviceNameArg: string) {
|
|
return `${SmartDaemonSystemdManager.createServiceNameFromServiceName(serviceNameArg)}.service`;
|
|
}
|
|
|
|
public static createFilePathFromServiceName(serviceNameArg: string) {
|
|
return plugins.path.join(
|
|
paths.systemdDir,
|
|
SmartDaemonSystemdManager.createFileNameFromServiceName(serviceNameArg)
|
|
);
|
|
}
|
|
|
|
// INSTANCE
|
|
public smartdaemonRef: SmartDaemon;
|
|
public smartshellInstance: plugins.smartshell.Smartshell;
|
|
public smartsystem: plugins.smartsystem.Smartsystem;
|
|
|
|
public shouldExecute: boolean = false;
|
|
|
|
constructor(smartdaemonRefArg: SmartDaemon) {
|
|
this.smartdaemonRef = smartdaemonRefArg;
|
|
this.smartshellInstance = new plugins.smartshell.Smartshell({
|
|
executor: 'bash',
|
|
});
|
|
this.smartsystem = new plugins.smartsystem.Smartsystem();
|
|
}
|
|
|
|
public async checkElegibility() {
|
|
if (await this.smartsystem.env.isLinuxAsync()) {
|
|
this.shouldExecute = true;
|
|
} else {
|
|
console.log('Smartdaemon can only be used on Linux systems! Refusing to set up a service.');
|
|
this.shouldExecute = false;
|
|
}
|
|
return this.shouldExecute;
|
|
}
|
|
|
|
public async execute(commandArg: string) {
|
|
if (await this.checkElegibility()) {
|
|
await this.smartshellInstance.exec(commandArg);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* gets all services that are already present
|
|
*/
|
|
public async getServices() {
|
|
const existingServices: SmartDaemonService[] = [];
|
|
if (await this.checkElegibility()) {
|
|
const smartfmInstance = new plugins.smartfm.Smartfm({
|
|
fmType: 'yaml',
|
|
});
|
|
const availableServices = await plugins.smartfile.fs.fileTreeToObject(
|
|
paths.systemdDir,
|
|
'smartdaemon_*.service'
|
|
);
|
|
for (const serviceFile of availableServices) {
|
|
const data = smartfmInstance.parseFromComments('# ', serviceFile.contentBuffer.toString())
|
|
.data as ISmartDaemonServiceConstructorOptions;
|
|
const service = await SmartDaemonService.createFromOptions(this.smartdaemonRef, data);
|
|
service.alreadyExists = true;
|
|
existingServices.push(service);
|
|
}
|
|
}
|
|
return existingServices;
|
|
}
|
|
|
|
public async startService(serviceArg: SmartDaemonService) {
|
|
if (await this.checkElegibility()) {
|
|
await this.execute(
|
|
`systemctl start ${SmartDaemonSystemdManager.createServiceNameFromServiceName(
|
|
serviceArg.name
|
|
)}`
|
|
);
|
|
}
|
|
}
|
|
public async stopService(serviceArg: SmartDaemonService) {
|
|
if (await this.checkElegibility()) {
|
|
await this.execute(
|
|
`systemctl stop ${SmartDaemonSystemdManager.createServiceNameFromServiceName(
|
|
serviceArg.name
|
|
)}`
|
|
);
|
|
}
|
|
}
|
|
|
|
public async saveService(serviceArg: SmartDaemonService) {
|
|
if (await this.checkElegibility()) {
|
|
await plugins.smartfile.memory.toFs(
|
|
this.smartdaemonRef.templateManager.generateUnitFileForService(serviceArg),
|
|
SmartDaemonSystemdManager.createFilePathFromServiceName(serviceArg.name)
|
|
);
|
|
}
|
|
}
|
|
|
|
public async deleteService(serviceArg: SmartDaemonService) {
|
|
if (await this.checkElegibility()) {
|
|
await plugins.smartfile.fs.remove(
|
|
SmartDaemonSystemdManager.createServiceNameFromServiceName(serviceArg.name)
|
|
);
|
|
}
|
|
}
|
|
|
|
public async enableService(serviceArg: SmartDaemonService) {
|
|
if (await this.checkElegibility()) {
|
|
await this.saveService(serviceArg);
|
|
if (serviceArg.alreadyExists) {
|
|
await this.execute(`systemctl daemon-reload`);
|
|
}
|
|
await this.execute(
|
|
`systemctl enable ${SmartDaemonSystemdManager.createServiceNameFromServiceName(
|
|
serviceArg.name
|
|
)}`
|
|
);
|
|
}
|
|
}
|
|
public async disableService(serviceArg: SmartDaemonService) {
|
|
if (await this.checkElegibility()) {
|
|
await this.execute(
|
|
`systemctl disable ${SmartDaemonSystemdManager.createServiceNameFromServiceName(
|
|
serviceArg.name
|
|
)}`
|
|
);
|
|
}
|
|
}
|
|
|
|
public async reload() {
|
|
if (await this.checkElegibility()) {
|
|
await this.execute(`systemctl daemon-reload`);
|
|
}
|
|
}
|
|
}
|