Malin
fa5bf17eb8
Complete conversion of the WordOps stack from Nginx + PHP-FPM to OpenLiteSpeed + LSPHP + LSCache. This is a full rewrite across all 7 phases of the codebase: - Foundation: OLS paths, variables, services, removed pynginxconfig dep - Templates: 11 new OLS mustache templates, removed nginx-specific ones - Stack: stack_pref, stack, stack_services, stack_upgrade, stack_migrate - Site: site_functions, site, site_create, site_update - Plugins: debug, info, log, clean rewritten for OLS - SSL/ACME: acme.sh deploy uses lswsctrl, OLS vhssl blocks - Other: secure, backup, clone, install script Additional features: - Debian 13 (trixie) support - PHP 8.5 support - WP Fort Knox mu-plugin integration (wo secure --lockdown/--unlock) - --nginx CLI flag preserved for backward compatibility Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
199 lines
8.4 KiB
Python
199 lines
8.4 KiB
Python
"""WordOps Service Manager"""
|
|
import subprocess
|
|
|
|
from wo.core.logging import Log
|
|
|
|
|
|
class WOService():
|
|
"""Intialization for service"""
|
|
def ___init__():
|
|
pass
|
|
|
|
def start_service(self, service_name):
|
|
"""
|
|
start service
|
|
Similar to `service xyz start`
|
|
"""
|
|
try:
|
|
if service_name in ['lsws']:
|
|
Log.wait(self, "Testing OpenLiteSpeed configuration ")
|
|
sub = subprocess.Popen(
|
|
'/usr/local/lsws/bin/openlitespeed -t',
|
|
stdout=subprocess.PIPE,
|
|
stderr=subprocess.PIPE, shell=True)
|
|
output = sub.communicate()
|
|
if sub.returncode == 0:
|
|
Log.valide(self, "Testing OpenLiteSpeed configuration ")
|
|
Log.wait(self, "Starting OpenLiteSpeed")
|
|
service_cmd = ('/usr/local/lsws/bin/lswsctrl start')
|
|
retcode = subprocess.getstatusoutput(service_cmd)
|
|
if retcode[0] == 0:
|
|
Log.valide(self, "Starting OpenLiteSpeed ")
|
|
return True
|
|
else:
|
|
Log.failed(self, "Starting OpenLiteSpeed")
|
|
else:
|
|
Log.failed(self, "Testing OpenLiteSpeed configuration ")
|
|
return False
|
|
else:
|
|
service_cmd = ('service {0} start'.format(service_name))
|
|
|
|
Log.info(self, "Start : {0:10}" .format(service_name), end='')
|
|
retcode = subprocess.getstatusoutput(service_cmd)
|
|
if retcode[0] == 0:
|
|
Log.info(self, "[" + Log.ENDC + Log.OKGREEN +
|
|
"OK" + Log.ENDC + Log.OKBLUE + "]")
|
|
return True
|
|
else:
|
|
Log.debug(self, "{0}".format(retcode[1]))
|
|
Log.info(self, "[" + Log.FAIL +
|
|
"Failed" + Log.OKBLUE + "]")
|
|
return False
|
|
except OSError as e:
|
|
Log.debug(self, "{0}".format(e))
|
|
Log.error(self, "\nFailed to start service {0}"
|
|
.format(service_name))
|
|
|
|
def stop_service(self, service_name):
|
|
"""
|
|
Stop service
|
|
Similar to `service xyz stop`
|
|
"""
|
|
try:
|
|
if service_name in ['lsws']:
|
|
Log.info(self, "Stop : {0:10}" .format(service_name), end='')
|
|
retcode = subprocess.getstatusoutput(
|
|
'/usr/local/lsws/bin/lswsctrl stop')
|
|
else:
|
|
Log.info(self, "Stop : {0:10}" .format(service_name), end='')
|
|
retcode = subprocess.getstatusoutput('service {0} stop'
|
|
.format(service_name))
|
|
if retcode[0] == 0:
|
|
Log.info(self, "[" + Log.ENDC + Log.OKGREEN + "OK" +
|
|
Log.ENDC + Log.OKBLUE + "]")
|
|
return True
|
|
else:
|
|
Log.debug(self, "{0}".format(retcode[1]))
|
|
Log.info(self, "[" + Log.FAIL + "Failed" + Log.OKBLUE + "]")
|
|
return False
|
|
except OSError as e:
|
|
Log.debug(self, "{0}".format(e))
|
|
Log.error(self, "\nFailed to stop service : {0}"
|
|
.format(service_name))
|
|
|
|
def restart_service(self, service_name):
|
|
"""
|
|
Restart service
|
|
Similar to `service xyz restart`
|
|
"""
|
|
try:
|
|
if service_name in ['lsws']:
|
|
Log.wait(self, "Testing OpenLiteSpeed configuration ")
|
|
sub = subprocess.Popen(
|
|
'/usr/local/lsws/bin/openlitespeed -t',
|
|
stdout=subprocess.PIPE,
|
|
stderr=subprocess.PIPE, shell=True)
|
|
output, error_output = sub.communicate()
|
|
if sub.returncode == 0:
|
|
Log.valide(self, "Testing OpenLiteSpeed configuration ")
|
|
Log.wait(self, "Restarting OpenLiteSpeed")
|
|
service_cmd = ('/usr/local/lsws/bin/lswsctrl restart')
|
|
retcode = subprocess.getstatusoutput(service_cmd)
|
|
if retcode[0] == 0:
|
|
Log.valide(self, "Restarting OpenLiteSpeed")
|
|
return True
|
|
else:
|
|
Log.failed(self, "Testing OpenLiteSpeed configuration ")
|
|
return False
|
|
else:
|
|
service_cmd = ('service {0} restart'.format(service_name))
|
|
Log.wait(self, "Restarting {0:10}".format(
|
|
service_name))
|
|
retcode = subprocess.getstatusoutput(service_cmd)
|
|
if retcode[0] == 0:
|
|
Log.valide(self, "Restarting {0:10}".format(
|
|
service_name))
|
|
return True
|
|
else:
|
|
Log.debug(self, "{0}".format(retcode[1]))
|
|
Log.failed(self, "Restarting {0:10}".format(
|
|
service_name))
|
|
return False
|
|
except OSError as e:
|
|
Log.debug(self, "{0} {1}".format(e.errno, e.strerror))
|
|
Log.error(self, "\nFailed to restart service : {0}"
|
|
.format(service_name))
|
|
|
|
def reload_service(self, service_name):
|
|
"""
|
|
Reload service
|
|
Similar to `service xyz reload`
|
|
"""
|
|
try:
|
|
if service_name in ['lsws']:
|
|
Log.wait(self, "Testing OpenLiteSpeed configuration ")
|
|
sub = subprocess.Popen(
|
|
'/usr/local/lsws/bin/openlitespeed -t',
|
|
stdout=subprocess.PIPE,
|
|
stderr=subprocess.PIPE, shell=True)
|
|
output, error_output = sub.communicate()
|
|
if sub.returncode == 0:
|
|
Log.valide(self, "Testing OpenLiteSpeed configuration ")
|
|
Log.wait(self, "Reloading OpenLiteSpeed")
|
|
service_cmd = ('/usr/local/lsws/bin/lswsctrl restart')
|
|
retcode = subprocess.getstatusoutput(service_cmd)
|
|
if retcode[0] == 0:
|
|
Log.valide(self, "Reloading OpenLiteSpeed")
|
|
return True
|
|
else:
|
|
Log.failed(self, "Testing OpenLiteSpeed configuration ")
|
|
return False
|
|
else:
|
|
service_cmd = ('service {0} reload'.format(service_name))
|
|
Log.wait(self, "Reloading {0:10}".format(
|
|
service_name))
|
|
retcode = subprocess.getstatusoutput(service_cmd)
|
|
if retcode[0] == 0:
|
|
Log.valide(self, "Reloading {0:10}".format(
|
|
service_name))
|
|
return True
|
|
else:
|
|
Log.debug(self, "{0}".format(retcode[1]))
|
|
Log.failed(self, "Reloading {0:10}".format(
|
|
service_name))
|
|
return False
|
|
except OSError as e:
|
|
Log.debug(self, "{0}".format(e))
|
|
Log.error(self, "\nFailed to reload service {0}"
|
|
.format(service_name))
|
|
|
|
def get_service_status(self, service_name):
|
|
|
|
try:
|
|
if service_name in ['lsws']:
|
|
retcode = subprocess.getstatusoutput(
|
|
'/usr/local/lsws/bin/lswsctrl status')
|
|
if retcode[0] == 0:
|
|
return True
|
|
else:
|
|
Log.debug(self, "{0}".format(retcode[1]))
|
|
return False
|
|
else:
|
|
is_exist = subprocess.getstatusoutput('command -v {0}'
|
|
.format(service_name))
|
|
if is_exist[0] == 0:
|
|
retcode = subprocess.getstatusoutput('service {0} status'
|
|
.format(service_name))
|
|
if retcode[0] == 0:
|
|
return True
|
|
else:
|
|
Log.debug(self, "{0}".format(retcode[1]))
|
|
return False
|
|
else:
|
|
return False
|
|
except OSError as e:
|
|
Log.debug(self, "{0}{1}".format(e.errno, e.strerror))
|
|
Log.error(self, "Unable to get services status of {0}"
|
|
.format(service_name))
|
|
return False
|