105 lines
3.9 KiB
Python
105 lines
3.9 KiB
Python
|
"""Clean Plugin for WordOps."""
|
||
|
|
|
||
|
|
from wo.core.shellexec import WOShellExec
|
||
|
|
from wo.core.aptget import WOAptGet
|
||
|
|
from wo.core.services import WOService
|
||
|
|
from wo.core.logging import Log
|
||
|
|
from cement.core.controller import CementBaseController, expose
|
||
|
|
from cement.core import handler, hook
|
||
|
|
import os
|
||
|
|
import urllib.request
|
||
|
|
|
||
|
|
|
||
|
|
def wo_clean_hook(app):
|
||
|
|
pass
|
||
|
|
|
||
|
|
|
||
|
|
class WOCleanController(CementBaseController):
|
||
|
|
class Meta:
|
||
|
|
label = 'clean'
|
||
|
|
stacked_on = 'base'
|
||
|
|
stacked_type = 'nested'
|
||
|
|
description = ('Clean NGINX FastCGI cache, Opcache, Memcache, Redis Cache')
|
||
|
|
arguments = [
|
||
|
|
(['--all'],
|
||
|
|
dict(help='Clean all cache', action='store_true')),
|
||
|
|
(['--fastcgi'],
|
||
|
|
dict(help='Clean FastCGI cache', action='store_true')),
|
||
|
|
(['--memcache'],
|
||
|
|
dict(help='Clean MemCache', action='store_true')),
|
||
|
|
(['--opcache'],
|
||
|
|
dict(help='Clean OpCache', action='store_true')),
|
||
|
|
(['--redis'],
|
||
|
|
dict(help='Clean Redis Cache', action='store_true')),
|
||
|
|
]
|
||
|
|
usage = "wo clean [options]"
|
||
|
|
|
||
|
|
@expose(hide=True)
|
||
|
|
def default(self):
|
||
|
|
if (not (self.app.pargs.all or self.app.pargs.fastcgi or
|
||
|
|
self.app.pargs.memcache or self.app.pargs.opcache or
|
||
|
|
self.app.pargs.redis)):
|
||
|
|
self.clean_fastcgi()
|
||
|
|
if self.app.pargs.all:
|
||
|
|
self.clean_memcache()
|
||
|
|
self.clean_fastcgi()
|
||
|
|
self.clean_opcache()
|
||
|
|
self.clean_redis()
|
||
|
|
if self.app.pargs.fastcgi:
|
||
|
|
self.clean_fastcgi()
|
||
|
|
if self.app.pargs.memcache:
|
||
|
|
self.clean_memcache()
|
||
|
|
if self.app.pargs.opcache:
|
||
|
|
self.clean_opcache()
|
||
|
|
if self.app.pargs.redis:
|
||
|
|
self.clean_redis()
|
||
|
|
@expose(hide=True)
|
||
|
|
def clean_redis(self):
|
||
|
|
"""This function clears Redis cache"""
|
||
|
|
if(WOAptGet.is_installed(self, "redis-server")):
|
||
|
|
Log.info(self, "Cleaning Redis cache")
|
||
|
|
WOShellExec.cmd_exec(self, "redis-cli flushall")
|
||
|
|
else:
|
||
|
|
Log.info(self, "Redis is not installed")
|
||
|
|
|
||
|
|
@expose(hide=True)
|
||
|
|
def clean_memcache(self):
|
||
|
|
try:
|
||
|
|
if(WOAptGet.is_installed(self, "memcached")):
|
||
|
|
WOService.restart_service(self, "memcached")
|
||
|
|
Log.info(self, "Cleaning MemCache")
|
||
|
|
else:
|
||
|
|
Log.info(self, "Memcache not installed")
|
||
|
|
except Exception as e:
|
||
|
|
Log.debug(self, "{0}".format(e))
|
||
|
|
Log.error(self, "Unable to restart Memcached", False)
|
||
|
|
|
||
|
|
@expose(hide=True)
|
||
|
|
def clean_fastcgi(self):
|
||
|
|
if(os.path.isdir("/var/run/nginx-cache")):
|
||
|
|
Log.info(self, "Cleaning NGINX FastCGI cache")
|
||
|
|
WOShellExec.cmd_exec(self, "rm -rf /var/run/nginx-cache/*")
|
||
|
|
else:
|
||
|
|
Log.error(self, "Unable to clean FastCGI cache", False)
|
||
|
|
|
||
|
|
@expose(hide=True)
|
||
|
|
def clean_opcache(self):
|
||
|
|
try:
|
||
|
|
Log.info(self, "Cleaning opcache")
|
||
|
|
wp = urllib.request.urlopen(" https://127.0.0.1:22222/cache"
|
||
|
|
"/opcache/opgui.php?page=reset").read()
|
||
|
|
except Exception as e:
|
||
|
|
Log.debug(self, "{0}".format(e))
|
||
|
|
Log.debug(self, "Unable hit url, "
|
||
|
|
" https://127.0.0.1:22222/cache/opcache/opgui.php?page=reset,"
|
||
|
|
" please check you have admin tools installed")
|
||
|
|
Log.debug(self, "please check you have admin tools installed,"
|
||
|
|
" or install them with `wo stack install --admin`")
|
||
|
|
Log.error(self, "Unable to clean opcache", False)
|
||
|
|
|
||
|
|
def load(app):
|
||
|
|
# register the plugin class.. this only happens if the plugin is enabled
|
||
|
|
handler.register(WOCleanController)
|
||
|
|
# register a hook (function) to run after arguments are parsed.
|
||
|
|
hook.register('post_argument_parsing', wo_clean_hook)
|