lukechilds
/
easyengine
mirror of https://github.com/lukechilds/easyengine.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
Browse Source

ee site commands done

bugfixes
harshadyeola 10 years ago
parent
7713f844ac 3b78cf0b1f
commit
487424d37d
13 changed files with 356 additions and 341 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 24
      ee/cli/plugins/clean.py
  2. 117
      ee/cli/plugins/debug.py
  3. 15
      ee/cli/plugins/secure.py
  4. 373
      ee/cli/plugins/stack.py
  5. 59
      ee/cli/plugins/stack_services.py
  6. 1
      ee/core/aptget.py
  7. 21
      ee/core/download.py
  8. 5
      ee/core/extract.py
  9. 22
      ee/core/fileutils.py
  10. 15
      ee/core/git.py
  11. 9
      ee/core/mysql.py
  12. 32
      ee/core/services.py
  13. 4
      ee/core/shellexec.py

24
ee/cli/plugins/clean.py
View File

@ -5,6 +5,7 @@ from cement.core.controller import CementBaseController, expose
from cement.core import handler, hook
import os
import urllib.request
from ee.core.logging import Log
def clean_plugin_hook(app):
@ -49,30 +50,31 @@ class EECleanController(CementBaseController):
@expose(hide=True)
def clean_memcache(self):
if(EEAptGet.is_installed("memcached")):
self.app.log.info("memcache is installed")
EEService.restart_service(self, "memcached")
self.app.log.info("Cleaning memcache..")
else:
self.app.log.info("memcache is not installed")
try:
if(EEAptGet.is_installed("memcached")):
EEService.restart_service(self, "memcached")
Log.info(self, "Cleaning memcache..")
else:
Log.error(self, "Memcache not installed")
except:
Log.error(self, "Unable to restart memcached")
@expose(hide=True)
def clean_fastcgi(self):
if(os.path.isdir("/var/run/nginx-cache")):
self.app.log.info("Cleaning fastcgi...")
Log.info(self, "Cleaning NGINX FastCGI cache, please wait...")
EEShellExec.cmd_exec(self, "rm -rf /var/run/nginx-cache/*")
else:
self.app.log.info("Error occur while Cleaning fastcgi..")
Log.error(self, "Unable to clean FastCGI cache")
@expose(hide=True)
def clean_opcache(self):
try:
self.app.log.info("Cleaning opcache.... ")
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:
self.app.log.info("Unable to clean opacache\n {0}{1}"
.format(e.errno, e.strerror))
Log.error(self, "Unable to clean opacache {0}".format(e))
def load(app):

117
ee/cli/plugins/debug.py
View File

@ -6,6 +6,7 @@ from ee.core.shellexec import EEShellExec
from ee.core.mysql import EEMysql
from ee.core.services import EEService
import os
from ee.core.logging import Log
def debug_plugin_hook(app):
@ -57,8 +58,8 @@ class EEDebugController(CementBaseController):
for ip_addr in debug_address:
if not ("debug_connection "+ip_addr in open('/etc/nginx/'
'nginx.conf').read()):
self.app.log.info("Setting up NGINX debug connection"
" for "+ip_addr)
Log.info(self, "Setting up NGINX debug connection"
" for "+ip_addr)
EEShellExec.cmd_exec(self, "sed -i \"/events {{/a\\ \\ \\ "
"\\ $(echo debug_connection "
"{ip}\;)\" /etc/nginx/"
@ -66,19 +67,19 @@ class EEDebugController(CementBaseController):
self.trigger_nginx = True
if not self.trigger_nginx:
self.app.log.info("NGINX debug connection already enabled")
Log.info(self, "NGINX debug connection already enabled")
self.msg = self.msg + [" /var/log/nginx/*.error.log"]
# stop global debug
elif not self.start and not self.app.pargs.site_name:
if "debug_connection " in open('/etc/nginx/nginx.conf').read():
self.app.log.info("Disabling Nginx debug connections")
Log.info(self, "Disabling Nginx debug connections")
EEShellExec.cmd_exec(self, "sed -i \"/debug_connection.*/d\""
" /etc/nginx/nginx.conf")
self.trigger_nginx = True
else:
self.app.log.info("Nginx debug connection already disbaled")
Log.info(self, "Nginx debug connection already disbaled")
# start site specific debug
elif self.start and self.app.pargs.site_name:
@ -87,22 +88,21 @@ class EEDebugController(CementBaseController):
if os.path.isfile(config_path):
if not EEShellExec.cmd_exec("grep \"error.log debug\" {0}"
.format(config_path)):
self.app.log.info("Starting NGINX debug connection for "
"{0}"
.format(self.app.pargs.site_name))
Log.info(self, "Starting NGINX debug connection for "
"{0}".format(self.app.pargs.site_name))
EEShellExec.cmd_exec("sed -i \"s/error.log;/error.log "
"debug;/\" {0}".format(config_path))
self.trigger_nginx = True
else:
self.app.log.info("Debug for site allready enabled")
Log.info(self, "Debug for site allready enabled")
self.msg = self.msg + ['/var/www//logs/error.log'
.format(self.app.pargs.site_name)]
else:
self.app.log.info("{0} domain not valid"
.format(self.app.pargs.site_name))
Log.info(self, "{0} domain not valid"
.format(self.app.pargs.site_name))
# stop site specific debug
elif not self.start and self.app.pargs.site_name:
@ -111,19 +111,19 @@ class EEDebugController(CementBaseController):
if os.path.isfile(config_path):
if EEShellExec.cmd_exec("grep \"error.log debug\" {0}"
.format(config_path)):
self.app.log.info("Stoping NGINX debug connection for {0}"
.format(self.app.pargs.site_name))
Log.info(self, "Stoping NGINX debug connection for {0}"
.format(self.app.pargs.site_name))
EEShellExec.cmd_exec("sed -i \"s/error.log debug;/"
"error.log;/\" {0}"
.format(config_path))
self.trigger_nginx = True
else:
self.app.log.info("Debug for site allready disbaled")
Log.info(self, "Debug for site allready disbaled")
else:
self.app.log.info("{0} domain not valid"
.format(self.app.pargs.site_name))
Log.info(self, "{0} domain not valid"
.format(self.app.pargs.site_name))
@expose(hide=True)
def debug_php(self):
@ -133,16 +133,16 @@ class EEDebugController(CementBaseController):
"{/,/}/p \" /etc/nginx/"
"conf.d/upstream.conf "
"| grep 9001")):
self.app.log.info("Enabling PHP debug")
Log.info(self, "Enabling PHP debug")
data = dict(php="9001", debug="9001")
self.app.log.info('writting the nginx configration to file'
'/etc/nginx/conf.d/upstream.conf ')
Log.info(self, 'writting the nginx configration to file'
'/etc/nginx/conf.d/upstream.conf ')
ee_nginx = open('/etc/nginx/conf.d/upstream.conf', 'w')
self.app.render((data), 'upstream.mustache', out=ee_nginx)
ee_nginx.close()
self.trigger_php = True
else:
self.app.log.info("PHP debug is allready enabled")
Log.info(self, "PHP debug is allready enabled")
self.msg = self.msg + ['/var/log/php5/slow.log']
@ -151,16 +151,16 @@ class EEDebugController(CementBaseController):
if EEShellExec.cmd_exec(self, "sed -n \"/upstream php {/,/}/p\" "
"/etc/nginx/conf.d/upstream.conf "
"| grep 9001"):
self.app.log.info("Disabling PHP debug")
Log.info(self, "Disabling PHP debug")
data = dict(php="9000", debug="9001")
self.app.log.info('writting the nginx configration to file'
'/etc/nginx/conf.d/upstream.conf ')
Log.info(self, 'writting the nginx configration to file'
'/etc/nginx/conf.d/upstream.conf ')
ee_nginx = open('/etc/nginx/conf.d/upstream.conf', 'w')
self.app.render((data), 'upstream.mustache', out=ee_nginx)
ee_nginx.close()
self.trigger_php = True
else:
self.app.log.info("PHP debug is allready disbaled")
Log.info(self, "PHP debug is allready disbaled")
@expose(hide=True)
def debug_fpm(self):
@ -168,27 +168,27 @@ class EEDebugController(CementBaseController):
if self.start:
if not EEShellExec.cmd_exec(self, "grep \"log_level = debug\" "
"/etc/php5/fpm/php-fpm.conf"):
self.app.log.info("Setting up PHP5-FPM log_level = debug")
Log.info(self, "Setting up PHP5-FPM log_level = debug")
EEShellExec.cmd_exec(self, "sed -i \"s\';log_level.*\'log_"
"level = debug\'\" /etc/php5/fpm"
"/php-fpm.conf")
self.trigger_php = True
else:
self.app.log.info("PHP5-FPM log_level = debug already setup")
Log.info(self, "PHP5-FPM log_level = debug already setup")
self.msg = self.msg + ['/var/log/php5/fpm.log']
# PHP5-FPM stop global debug
else:
if EEShellExec.cmd_exec(self, "grep \"log_level = debug\" "
"/etc/php5/fpm/php-fpm.conf"):
self.app.log.info("Disabling PHP5-FPM log_level = debug")
Log.info(self, "Disabling PHP5-FPM log_level = debug")
EEShellExec.cmd_exec(self, "sed -i \"s\'log_level.*\';log_"
"level = notice\'\" /etc/php5/fpm"
"/php-fpm.conf")
self.trigger_php = True
else:
self.app.log.info("PHP5-FPM log_level = debug "
" already disabled")
Log.info(self, "PHP5-FPM log_level = debug "
" already disabled")
@expose(hide=True)
def debug_mysql(self):
@ -197,7 +197,7 @@ class EEDebugController(CementBaseController):
if not EEShellExec.cmd_exec(self, "mysql -e \"show variables like"
" \'slow_query_log\';\" | "
"grep ON"):
print("Setting up MySQL slow log")
Log.info(self, "Setting up MySQL slow log")
EEMysql.execute(self, "set global slow_query_log = "
"\'ON\';")
EEMysql.execute(self, "set global slow_query_log_file = "
@ -218,7 +218,7 @@ class EEDebugController(CementBaseController):
"n#EasyEngine end MySQL slow log\\\";"
" }} | crontab -\"".format(cron_time))
else:
self.app.log.info("MySQL slow log is allready enabled")
Log.info(self, "MySQL slow log is allready enabled")
self.msg = self.msg + ['/var/log/mysql/mysql-slow.log']
@ -226,7 +226,7 @@ class EEDebugController(CementBaseController):
else:
if EEShellExec.cmd_exec(self, "mysql -e \"show variables like \'"
"slow_query_log\';\" | grep ON"):
print("Disabling MySQL slow log")
Log.info(self, "Disabling MySQL slow log")
EEMysql.execute(self, "set global slow_query_log = \'OFF\';")
EEMysql.execute(self, "set global slow_query_log_file = \'"
"/var/log/mysql/mysql-slow.log\';")
@ -236,7 +236,7 @@ class EEDebugController(CementBaseController):
EEShellExec.cmd_exec(self, "crontab -l | sed \'/#EasyEngine "
"start/,/#EasyEngine end/d\' | crontab -")
else:
self.app.log.info("MySQL slow log already disabled")
Log.info(self, "MySQL slow log already disabled")
@expose(hide=True)
def debug_wp(self):
@ -247,7 +247,7 @@ class EEDebugController(CementBaseController):
if os.path.isfile(wp_config):
if not EEShellExec.cmd_exec(self, "grep \"\'WP_DEBUG\'\" {0} |"
" grep true".format(wp_config)):
self.app.log.info("Starting WordPress debug")
Log.info(self, "Starting WordPress debug")
open("{0}/htdocs/wp-content/debug.log".format(webroot),
'a').close()
EEShellExec.cmd_exec(self, "chown www-data: {0}/htdocs/wp-"
@ -265,10 +265,10 @@ class EEDebugController(CementBaseController):
"wp-content/plugins"
.format(webroot))
else:
self.app.log.info("WordPress debug log already enabled")
Log.info(self, "WordPress debug log already enabled")
else:
self.app.log.info("{0} domain not valid"
.format(self.app.pargs.site_name))
Log.info(self, "{0} domain not valid"
.format(self.app.pargs.site_name))
elif not self.start and self.app.pargs.site_name:
wp_config = ("/var/www/{0}/wp-config.php"
@ -277,7 +277,7 @@ class EEDebugController(CementBaseController):
if os.path.isfile(wp_config):
if EEShellExec.cmd_exec(self, "grep \"\'WP_DEBUG\'\" {0} | "
"grep true".format(wp_config)):
self.app.log.info("Disabling WordPress debug")
Log.info(self, "Disabling WordPress debug")
EEShellExec.cmd_exec(self, "sed -i \"s/define(\'WP_DEBUG\'"
", true);/define(\'WP_DEBUG\', "
"false);/\" {0}".format(wp_config))
@ -291,12 +291,12 @@ class EEDebugController(CementBaseController):
"SAVEQUERIES\', "
"true);/d\" {0}".format(wp_config))
else:
print("WordPress debug all already disbaled")
Log.info(self, "WordPress debug all already disbaled")
else:
self.app.log.info("{0} domain not valid"
.format(self.app.pargs.site_name))
Log.info(self, "{0} domain not valid"
.format(self.app.pargs.site_name))
else:
self.app.log.info("Missing argument site_name")
Log.info(self, "Missing argument site_name")
@expose(hide=True)
def debug_rewrite(self):
@ -304,12 +304,12 @@ class EEDebugController(CementBaseController):
if self.start and not self.app.pargs.site_name:
if not EEShellExec.cmd_exec(self, "grep \"rewrite_log on;\" "
"/etc/nginx/nginx.conf"):
self.app.log.info("Setting up Nginx rewrite logs")
Log.info(self, "Setting up Nginx rewrite logs")
EEShellExec.cmd_exec(self, "sed -i \'/http {/a \\\\t"
"rewrite_log on;\' /etc/nginx/nginx.conf")
self.trigger_nginx = True
else:
self.app.log.info("NGINX rewrite logs already enabled")
Log.info(self, "NGINX rewrite logs already enabled")
if '/var/log/nginx/*.error.log' not in self.msg:
self.msg = self.msg + ['/var/log/nginx/*.error.log']
@ -318,27 +318,27 @@ class EEDebugController(CementBaseController):
elif not self.start and not self.app.pargs.site_name:
if EEShellExec.cmd_exec(self, "grep \"rewrite_log on;\" "
"/etc/nginx/nginx.conf"):
self.app.log.info("Disabling Nginx rewrite logs")
Log.info(self, "Disabling Nginx rewrite logs")
EEShellExec.cmd_exec(self, "sed -i \"/rewrite_log.*/d\""
" /etc/nginx/nginx.conf")
self.trigger_nginx = True
else:
self.app.log.info("NGINX rewrite logs already disbaled")
Log.info(self, "NGINX rewrite logs already disbaled")
# Start Nginx rewrite for site
elif self.start and self.app.pargs.site_name:
config_path = ("/etc/nginx/sites-available/{0}.conf"
.format(self.app.pargs.site_name))
if not EEShellExec.cmd_exec(self, "grep \"rewrite_log on;\" {0}"
.format(config_path)):
self.app.log.info("Setting up NGINX rewrite logs for {0}"
.format(self.app.pargs.site_name))
Log.info(self, "Setting up NGINX rewrite logs for {0}"
.format(self.app.pargs.site_name))
EEShellExec.cmd_exec(self, "sed -i \"/access_log/i \\\\\\t"
"rewrite_log on;\" {0}"
.format(config_path))
self.trigger_nginx = True
else:
self.app.log.info("Nginx rewrite logs for {0} allready setup"
.format(self.app.pargs.site_name))
Log.info(self, "Nginx rewrite logs for {0} allready setup"
.format(self.app.pargs.site_name))
if ('/var/www/{0}/logs/error.log'.format(self.app.pargs.site_name)
not in self.msg):
@ -351,15 +351,14 @@ class EEDebugController(CementBaseController):
.format(self.app.pargs.site_name))
if EEShellExec.cmd_exec(self, "grep \"rewrite_log on;\" {0}"
.format(config_path)):
self.app.log.info("Disabling NGINX rewrite logs for {0}"
.format(self.app.pargs.site_name))
Log.info(self, "Disabling NGINX rewrite logs for {0}"
.format(self.app.pargs.site_name))
EEShellExec.cmd_exec(self, "sed -i \"/rewrite_log.*/d\" {0}"
.format(config_path))
self.trigger_nginx = True
else:
self.app.log.info("Nginx rewrite logs for {0} allready "
" disbaled"
.format(self.app.pargs.site_name))
Log.info(self, "Nginx rewrite logs for {0} allready "
" disbaled".format(self.app.pargs.site_name))
@expose(hide=True)
def default(self):
@ -404,10 +403,10 @@ class EEDebugController(CementBaseController):
# Reload PHP
if self.trigger_php:
EEService.reload_service(self, ['php5-fpm'])
if len(self.msg) > 0:
self.app.log.info("Use following command to check debug logs:"
"\n{0}".format(self.msg.join()))
#
# if len(self.msg) > 0:
# self.app.log.info("Use following command to check debug logs:"
# "\n{0}".format(self.msg.join()))
def load(app):

15
ee/cli/plugins/secure.py
View File

@ -7,6 +7,7 @@ import random
import sys
import hashlib
import getpass
from ee.core.logging import Log
def secure_plugin_hook(app):
@ -50,12 +51,12 @@ class EEsecureController(CementBaseController):
"password [{0}]".format(passwd))
if username == "":
username = EEVariables.ee_user
self.app.log.info("HTTP authentication username:{username}"
.format(username=username))
Log.info(self, "HTTP authentication username:{username}"
.format(username=username))
if password == "":
password = passwd
self.app.log.info("HTTP authentication password:{password}"
.format(password=password))
Log.info(self, "HTTP authentication password:{password}"
.format(password=password))
EEShellExec.cmd_exec(self, "printf \"{username}:"
"$(openssl passwd -crypt "
"{password} 2> /dev/null)\n\""
@ -73,11 +74,15 @@ class EEsecureController(CementBaseController):
"{port} default_server ssl spdy;/\" "
"/etc/nginx/sites-available/22222"
.format(port=port))
elif EEVariables.ee_platform_distro == 'Debian':
else:
Log.info(self, "Unable to change EasyEngine admin port")
if EEVariables.ee_platform_distro == 'Debian':
EEShellExec.cmd_exec(self, "sed -i \"s/listen.*/listen "
"{port} default_server ssl;/\" "
"/etc/nginx/sites-available/22222"
.format(port=port))
else:
Log.info(self, "Unable to change EasyEngine admin port")
@expose(hide=True)
def secure_ip(self):

373
ee/cli/plugins/stack.py
View File

@ -23,6 +23,7 @@ import os
import pwd
import grp
from ee.cli.plugins.stack_services import EEStackStatusController
from ee.core.logging import Log
def ee_stack_hook(app):
@ -69,12 +70,12 @@ class EEStackController(CementBaseController):
@expose(hide=True)
def default(self):
# TODO Default action for ee stack command
print("Inside EEStackController.default().")
Log.info(self, "Inside EEStackController.default().")
@expose(hide=True)
def pre_pref(self, apt_packages):
if set(EEVariables.ee_postfix).issubset(set(apt_packages)):
print("Pre-seeding postfix variables ... ")
Log.info(self, "Pre-seeding postfix variables ... ")
EEShellExec.cmd_exec(self, "echo \"postfix postfix"
"/main_mailer_type string \'Internet Site\'\""
" | debconf-set-selections")
@ -82,12 +83,12 @@ class EEStackController(CementBaseController):
" $(hostname -f)\" | debconf-set-selections")
if set(EEVariables.ee_mysql).issubset(set(apt_packages)):
print("Adding repository for MySQL ... ")
Log.info(self, "Adding repository for MySQL ... ")
EERepo.add(self, repo_url=EEVariables.ee_mysql_repo)
self.app.log.debug('Adding key of MySQL.')
Log.debug(self, 'Adding key of MySQL.')
EERepo.add_key(self, '1C4CBDCDCD2EFD2A')
chars = ''.join(random.sample(string.ascii_letters, 8))
print("Pre-seeding MySQL variables ... ")
Log.info(self, "Pre-seeding MySQL variables ... ")
EEShellExec.cmd_exec(self, "echo \"percona-server-server-5.6 "
"percona-server-server/root_password "
"password {chars}\" | "
@ -103,35 +104,35 @@ class EEStackController(CementBaseController):
""".format(chars=chars)
config = configparser.ConfigParser()
config.read_string(mysql_config)
self.app.log.debug('writting configartion into MySQL file.')
Log.debug(self, 'writting configartion into MySQL file.')
with open(os.path.expanduser("~")+'/.my.cnf', 'w') as configfile:
config.write(configfile)
if set(EEVariables.ee_nginx).issubset(set(apt_packages)):
print("Adding repository for Nginx ... ")
Log.info(self, "Adding repository for Nginx ... ")
if EEVariables.ee_platform_distro == 'Debian':
self.app.log.debug('Adding Dotdeb/nginx GPG key')
Log.debug(self, 'Adding Dotdeb/nginx GPG key')
EERepo.add(self, repo_url=EEVariables.ee_nginx_repo)
else:
self.app.log.debug('Adding ppa of Nginx')
Log.debug(self, 'Adding ppa of Nginx')
EERepo.add(self, ppa=EEVariables.ee_nginx_repo)
if set(EEVariables.ee_php).issubset(set(apt_packages)):
print("Adding repository for PHP ... ")
Log.info(self, "Adding repository for PHP ... ")
if EEVariables.ee_platform_distro == 'Debian':
self.app.log.debug('Adding repo_url of php for Debian')
Log.debug(self, 'Adding repo_url of php for Debian')
EERepo.add(self, repo_url=EEVariables.ee_php_repo)
self.app.log.debug('Adding Dotdeb/php GPG key')
Log.debug(self, 'Adding Dotdeb/php GPG key')
EERepo.add_key(self, '89DF5277')
else:
self.app.log.debug('Adding ppa for PHP')
Log.debug(self, 'Adding ppa for PHP')
EERepo.add(self, ppa=EEVariables.ee_php_repo)
if set(EEVariables.ee_mail).issubset(set(apt_packages)):
if EEVariables.ee_platform_codename == 'squeeze':
print("Adding repository for dovecot ... ")
Log.info(self, "Adding repository for dovecot ... ")
EERepo.add(self, repo_url=EEVariables.ee_dovecot_repo)
self.app.log.debug('Executing the command debconf-set-selections.')
Log.debug(self, 'Executing the command debconf-set-selections.')
EEShellExec.cmd_exec(self, "echo \"dovecot-core dovecot-core/"
"create-ssl-cert boolean yes\" "
"| debconf-set-selections")
@ -151,7 +152,7 @@ class EEStackController(CementBaseController):
if ((not os.path.isfile('/etc/nginx/conf.d/ee-nginx.conf')) and
os.path.isfile('/etc/nginx/nginx.conf')):
nc = NginxConfig()
self.app.log.debug('Loading file /etc/nginx/nginx.conf ')
Log.debug(self, 'Loading file /etc/nginx/nginx.conf ')
nc.loadf('/etc/nginx/nginx.conf')
nc.set('worker_processes', 'auto')
nc.append(('worker_rlimit_nofile', '100000'), position=2)
@ -160,106 +161,106 @@ class EEStackController(CementBaseController):
[('worker_connections', '4096'),
('multi_accept', 'on')]}, position=4)
nc.set([('http',), 'keepalive_timeout'], '30')
self.app.log.debug("Writting nginx configration to "
"file /etc/nginx/nginx.conf ")
Log.debug(self, "Writting nginx configration to "
"file /etc/nginx/nginx.conf ")
nc.savef('/etc/nginx/nginx.conf')
# Custom Nginx configuration by EasyEngine
data = dict(version='EasyEngine 3.0.1')
self.app.log.debug('writting the nginx configration to '
'file /etc/nginx/conf.d/ee-nginx.conf ')
Log.debug(self, 'writting the nginx configration to '
'file /etc/nginx/conf.d/ee-nginx.conf ')
ee_nginx = open('/etc/nginx/conf.d/ee-nginx.conf', 'w')
self.app.render((data), 'nginx-core.mustache',
out=ee_nginx)
ee_nginx.close()
data = dict()
self.app.log.debug('writting the nginx configration to'
'file /etc/nginx/conf.d/blockips.conf')
Log.debug(self, 'writting the nginx configration to'
'file /etc/nginx/conf.d/blockips.conf')
ee_nginx = open('/etc/nginx/conf.d/blockips.conf', 'w')
self.app.render((data), 'blockips.mustache', out=ee_nginx)
ee_nginx.close()
self.app.log.debug('writting the nginx configration to'
' file /etc/nginx/conf.d/fastcgi.conf')
Log.debug(self, 'writting the nginx configration to'
' file /etc/nginx/conf.d/fastcgi.conf')
ee_nginx = open('/etc/nginx/conf.d/fastcgi.conf', 'w')
self.app.render((data), 'fastcgi.mustache', out=ee_nginx)
ee_nginx.close()
data = dict(php="9000", debug="9001")
self.app.log.debug('writting the nginx configration to'
'file /etc/nginx/conf.d/upstream.conf ')
Log.debug(self, 'writting the nginx configration to'
'file /etc/nginx/conf.d/upstream.conf ')
ee_nginx = open('/etc/nginx/conf.d/upstream.conf', 'w')
self.app.render((data), 'upstream.mustache', out=ee_nginx)
ee_nginx.close()
# Setup Nginx common directory
if not os.path.exists('/etc/nginx/common'):
self.app.log.debug('Creating directory'
'/etc/nginx/common')
Log.debug(self, 'Creating directory'
'/etc/nginx/common')
os.makedirs('/etc/nginx/common')
data = dict()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/acl.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/acl.conf')
ee_nginx = open('/etc/nginx/common/acl.conf', 'w')
self.app.render((data), 'acl.mustache',
out=ee_nginx)
ee_nginx.close()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/locations.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/locations.conf')
ee_nginx = open('/etc/nginx/common/locations.conf', 'w')
self.app.render((data), 'locations.mustache',
out=ee_nginx)
ee_nginx.close()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/ php.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/ php.conf')
ee_nginx = open('/etc/nginx/common/php.conf', 'w')
self.app.render((data), 'php.mustache',
out=ee_nginx)
ee_nginx.close()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/w3tc.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/w3tc.conf')
ee_nginx = open('/etc/nginx/common/w3tc.conf', 'w')
self.app.render((data), 'w3tc.mustache',
out=ee_nginx)
ee_nginx.close()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/wpcommon.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/wpcommon.conf')
ee_nginx = open('/etc/nginx/common/wpcommon.conf', 'w')
self.app.render((data), 'wpcommon.mustache',
out=ee_nginx)
ee_nginx.close()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/wpfc.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/wpfc.conf')
ee_nginx = open('/etc/nginx/common/wpfc.conf', 'w')
self.app.render((data), 'wpfc.mustache',
out=ee_nginx)
ee_nginx.close()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/wpsc.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/wpsc.conf')
ee_nginx = open('/etc/nginx/common/wpsc.conf', 'w')
self.app.render((data), 'wpsc.mustache',
out=ee_nginx)
ee_nginx.close()
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/common/wpsubdir.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/common/wpsubdir.conf')
ee_nginx = open('/etc/nginx/common/wpsubdir.conf', 'w')
self.app.render((data), 'wpsubdir.mustache',
out=ee_nginx)
ee_nginx.close()
# 22222 port settings
self.app.log.debug('Writting the nginx configration to'
'file /etc/nginx/sites-available/'
'22222.conf')
Log.debug(self, 'Writting the nginx configration to'
'file /etc/nginx/sites-available/'
'22222.conf')
ee_nginx = open('/etc/nginx/sites-available/22222.conf',
'w')
self.app.render((data), '22222.mustache',
@ -269,7 +270,7 @@ class EEStackController(CementBaseController):
passwd = ''.join([random.choice
(string.ascii_letters + string.digits)
for n in range(6)])
EEShellExec.cmd_exec(self, "printf \"easyengine:"
EEShellExec.cmd_exec(self, "Log.infof \"easyengine:"
"$(openssl passwd -crypt "
"{password} 2> /dev/null)\n\""
"> /etc/nginx/htpasswd-ee 2>/dev/null"
@ -329,12 +330,12 @@ class EEStackController(CementBaseController):
if set(EEVariables.ee_php).issubset(set(apt_packages)):
# Create log directories
if not os.path.exists('/var/log/php5/'):
self.app.log.debug('Creating directory /var/log/php5/')
Log.debug(self, 'Creating directory /var/log/php5/')
os.makedirs('/var/log/php5/')
# Parse etc/php5/fpm/php.ini
config = configparser.ConfigParser()
self.app.log.debug("configring php file /etc/php5/fpm/php.ini")
Log.debug(self, "configring php file /etc/php5/fpm/php.ini")
config.read('/etc/php5/fpm/php.ini')
config['PHP']['expose_php'] = 'Off'
config['PHP']['post_max_size'] = '100M'
@ -342,8 +343,8 @@ class EEStackController(CementBaseController):
config['PHP']['max_execution_time'] = '300'
config['PHP']['date.timezone'] = time.tzname[time.daylight]
with open('/etc/php5/fpm/php.ini', 'w') as configfile:
self.app.log.debug("writting configration of php in to"
"file /etc/php5/fpm/php.ini")
Log.debug(self, "writting configration of php in to"
"file /etc/php5/fpm/php.ini")
config.write(configfile)
# Prase /etc/php5/fpm/php-fpm.conf
@ -351,8 +352,8 @@ class EEStackController(CementBaseController):
config.read('/etc/php5/fpm/php-fpm.conf')
config['global']['error_log'] = '/var/log/php5/fpm.log'
with open('/etc/php5/fpm/php-fpm.conf', 'w') as configfile:
self.app.log.debug("writting php5 configartion into "
" /etc/php5/fpm/php-fpm.conf")
Log.debug(self, "writting php5 configartion into "
" /etc/php5/fpm/php-fpm.conf")
config.write(configfile)
# Parse /etc/php5/fpm/pool.d/www.conf
@ -369,8 +370,8 @@ class EEStackController(CementBaseController):
config['www']['pm'] = 'ondemand'
config['www']['listen'] = '127.0.0.1:9000'
with open('/etc/php5/fpm/pool.d/www.conf', 'w') as configfile:
self.app.log.debug("writting PHP5 configartion into "
" /etc/php5/fpm/pool.d/www.conf")
Log.debug(self, "writting PHP5 configartion into "
" /etc/php5/fpm/pool.d/www.conf")
config.write(configfile)
# Generate /etc/php5/fpm/pool.d/debug.conf
@ -382,8 +383,8 @@ class EEStackController(CementBaseController):
config.read('/etc/php5/fpm/pool.d/debug.conf')
config['debug']['listen'] = '127.0.0.1:9001'
with open('/etc/php5/fpm/pool.d/debug.conf', 'w') as confifile:
self.app.log.debug("writting PHP5 configartion into "
" /etc/php5/fpm/pool.d/debug.conf")
Log.debug(self, "writting PHP5 configartion into "
" /etc/php5/fpm/pool.d/debug.conf")
config.write(confifile)
EEGit.add(self, ["/etc/php5"], msg="Adding PHP into Git")
EEService.reload_service(self, 'php5-fpm')
@ -414,7 +415,7 @@ class EEStackController(CementBaseController):
EEService.reload_service(self, 'mysql')
if set(EEVariables.ee_mail).issubset(set(apt_packages)):
self.app.log.debug("Executing mail commands")
Log.debug(self, "Executing mail commands")
EEShellExec.cmd_exec(self, "adduser --uid 5000 --home /var"
"/vmail --disabled-password --gecos ''"
" vmail")
@ -425,15 +426,15 @@ class EEStackController(CementBaseController):
"pem -keyout /etc/ssl/private/dovecot.pem"
.format(HOSTNAME=EEVariables.ee_fqdn,
EMAIL=EEVariables.ee_email))
self.app.log.debug("Adding Privillages to file "
"/etc/ssl/private/dovecot.pem ")
Log.debug(self, "Adding Privillages to file "
"/etc/ssl/private/dovecot.pem ")
EEShellExec.cmd_exec(self, "chmod 0600 /etc/ssl/private"
"/dovecot.pem")
# Custom Dovecot configuration by EasyEngine
data = dict()
self.app.log.debug("Writting configration into file"
"/etc/dovecot/conf.d/99-ee.conf ")
Log.debug(self, "Writting configration into file"
"/etc/dovecot/conf.d/99-ee.conf ")
ee_dovecot = open('/etc/dovecot/conf.d/99-ee.conf', 'w')
self.app.render((data), 'dovecot.mustache', out=ee_dovecot)
ee_dovecot.close()
@ -503,21 +504,21 @@ class EEStackController(CementBaseController):
# Sieve configuration
if not os.path.exists('/var/lib/dovecot/sieve/'):
self.app.log.debug('Creating directory'
'/var/lib/dovecot/sieve/ ')
Log.debug(self, 'Creating directory'
'/var/lib/dovecot/sieve/ ')
os.makedirs('/var/lib/dovecot/sieve/')
# Custom sieve configuration by EasyEngine
data = dict()
self.app.log.debug("Writting configaration of EasyEngine into"
"file /var/lib/dovecot/sieve/default.sieve")
Log.debug(self, "Writting configaration of EasyEngine into"
"file /var/lib/dovecot/sieve/default.sieve")
ee_sieve = open('/var/lib/dovecot/sieve/default.sieve', 'w')
self.app.render((data), 'default-sieve.mustache',
out=ee_sieve)
ee_sieve.close()
# Compile sieve rules
self.app.log.debug("Privillages to dovecot ")
Log.debug(self, "Privillages to dovecot ")
# EEShellExec.cmd_exec(self, "chown -R vmail:vmail /var/lib"
# "/dovecot")
EEFileUtils.chown(self, "/var/lig/dovecot", "vmail", "vmail",
@ -532,8 +533,8 @@ class EEStackController(CementBaseController):
if set(EEVariables.ee_mailscanner).issubset(set(apt_packages)):
# Set up Custom amavis configuration
data = dict()
self.app.log.debug("Configuring file /etc/amavis/conf.d"
"/15-content_filter_mode")
Log.debug(self, "Configuring file /etc/amavis/conf.d"
"/15-content_filter_mode")
ee_amavis = open('/etc/amavis/conf.d/15-content_filter_mode',
'w')
self.app.render((data), '15-content_filter_mode.mustache',
@ -550,17 +551,17 @@ class EEStackController(CementBaseController):
"_checks/\" /etc/postfix/master.cf")
# Amavis ClamAV configuration
self.app.log.debug("Adding new user clamav amavis")
Log.debug(self, "Adding new user clamav amavis")
EEShellExec.cmd_exec(self, "adduser clamav amavis")
self.app.log.debug("Adding new user amavis clamav")
Log.debug(self, "Adding new user amavis clamav")
EEShellExec.cmd_exec(self, "adduser amavis clamav")
self.app.log.debug("Privillages to file /var/lib/amavis/tmp ")
Log.debug(self, "Privillages to file /var/lib/amavis/tmp ")
EEShellExec.cmd_exec(self, "chmod -R 775 /var/lib/amavis/tmp")
# Update ClamAV database
self.app.log.debug("Updating database")
Log.debug(self, "Updating database")
EEShellExec.cmd_exec(self, "freshclam")
self.app.log.debug("Restarting service clamav-daemon")
Log.debug(self, "Restarting service clamav-daemon")
EEShellExec.cmd_exec(self, "service clamav-daemon restart")
EEGit.add(self, ["/etc/amavis"], msg="Adding Amvis into Git")
EEService.reload_service(self, 'dovecot')
@ -569,21 +570,21 @@ class EEStackController(CementBaseController):
if len(packages):
if any('/usr/bin/wp' == x[1] for x in packages):
self.app.log.debug("Privillages to /usr/bin/wp ")
Log.debug(self, "Privillages to /usr/bin/wp ")
EEShellExec.cmd_exec(self, "chmod +x /usr/bin/wp")
if any('/tmp/pma.tar.gz' == x[1]
for x in packages):
EEExtract.extract(self, '/tmp/pma.tar.gz', '/tmp/')
self.app.log.debug('Extracting file /tmp/pma.tar.gz to '
'loaction /tmp/')
Log.debug(self, 'Extracting file /tmp/pma.tar.gz to '
'loaction /tmp/')
if not os.path.exists('/var/www/22222/htdocs/db'):
self.app.log.debug("Creating new directory "
"/var/www/22222/htdocs/db")
Log.debug(self, "Creating new directory "
"/var/www/22222/htdocs/db")
os.makedirs('/var/www/22222/htdocs/db')
shutil.move('/tmp/phpmyadmin-STABLE/',
'/var/www/22222/htdocs/db/pma/')
self.app.log.debug('Privillages to www-data:www-data '
'/var/www/22222/htdocs/db/pma ')
Log.debug(self, 'Privillages to www-data:www-data '
'/var/www/22222/htdocs/db/pma ')
# EEShellExec.cmd_exec(self, 'chown -R www-data:www-data '
# '/var/www/22222/htdocs/db/pma')
EEFileUtils.chown(self, '/var/www/22222',
@ -591,12 +592,12 @@ class EEStackController(CementBaseController):
EEVariables.ee_php_user, recursive=True)
if any('/tmp/memcache.tar.gz' == x[1]
for x in packages):
self.app.log.debug("Extracting memcache.tar.gz to location"
" /var/www/22222/htdocs/cache/memcache ")
Log.debug(self, "Extracting memcache.tar.gz to location"
" /var/www/22222/htdocs/cache/memcache ")
EEExtract.extract(self, '/tmp/memcache.tar.gz',
'/var/www/22222/htdocs/cache/memcache')
self.app.log.debug("Privillages to"
" /var/www/22222/htdocs/cache/memcache")
Log.debug(self, "Privillages to"
" /var/www/22222/htdocs/cache/memcache")
# EEShellExec.cmd_exec(self, 'chown -R www-data:www-data '
# '/var/www/22222/htdocs/cache/memcache')
EEFileUtils.chown(self, '/var/www/22222',
@ -605,17 +606,17 @@ class EEStackController(CementBaseController):
if any('/tmp/webgrind.tar.gz' == x[1]
for x in packages):
self.app.log.debug("Extracting file webgrind.tar.gz to "
"location /tmp/ ")
Log.debug(self, "Extracting file webgrind.tar.gz to "
"location /tmp/ ")
EEExtract.extract(self, '/tmp/webgrind.tar.gz', '/tmp/')
if not os.path.exists('/var/www/22222/htdocs/php'):
self.app.log.debug("Creating directroy "
"/var/www/22222/htdocs/php")
Log.debug(self, "Creating directroy "
"/var/www/22222/htdocs/php")
os.makedirs('/var/www/22222/htdocs/php')
shutil.move('/tmp/webgrind-master/',
'/var/www/22222/htdocs/php/webgrind')
self.app.log.debug("Privillages www-data:www-data "
"/var/www/22222/htdocs/php/webgrind/ ")
Log.debug(self, "Privillages www-data:www-data "
"/var/www/22222/htdocs/php/webgrind/ ")
# EEShellExec.cmd_exec(self, 'chown -R www-data:www-data '
# '/var/www/22222/htdocs/php/webgrind/')
EEFileUtils.chown(self, '/var/www/22222',
@ -624,11 +625,11 @@ class EEStackController(CementBaseController):
if any('/tmp/anemometer.tar.gz' == x[1]
for x in packages):
self.app.log.debug("Extracting file anemometer.tar.gz to "
"location /tmp/ ")
Log.debug(self, "Extracting file anemometer.tar.gz to "
"location /tmp/ ")
EEExtract.extract(self, '/tmp/anemometer.tar.gz', '/tmp/')
if not os.path.exists('/var/www/22222/htdocs/db/'):
self.app.log.debug("Creating directory")
Log.debug(self, "Creating directory")
os.makedirs('/var/www/22222/htdocs/db/')
shutil.move('/tmp/Anemometer-master',
'/var/www/22222/htdocs/db/anemometer')
@ -642,7 +643,7 @@ class EEStackController(CementBaseController):
' BY \''+chars+'\'')
# Custom Anemometer configuration
self.app.log.debug("configration Anemometer")
Log.debug(self, "configration Anemometer")
data = dict(host='localhost', port='3306', user='anemometer',
password=chars)
ee_anemometer = open('/var/www/22222/htdocs/db/anemometer'
@ -658,24 +659,24 @@ class EEStackController(CementBaseController):
if any('/tmp/vimbadmin.tar.gz' == x[1] for x in packages):
# Extract ViMbAdmin
self.app.log.debug("Extracting ViMbAdmin.tar.gz to "
"location /tmp/")
Log.debug(self, "Extracting ViMbAdmin.tar.gz to "
"location /tmp/")
EEExtract.extract(self, '/tmp/vimbadmin.tar.gz', '/tmp/')
if not os.path.exists('/var/www/22222/htdocs/'):
self.app.log.debug("Creating directory "
" /var/www/22222/htdocs/")
Log.debug(self, "Creating directory "
" /var/www/22222/htdocs/")
os.makedirs('/var/www/22222/htdocs/')
shutil.move('/tmp/ViMbAdmin-3.0.10/',
'/var/www/22222/htdocs/vimbadmin/')
# Donwload composer and install ViMbAdmin
self.app.log.debug("Downloading composer "
"https://getcomposer.org/installer | php ")
Log.debug(self, "Downloading composer "
"https://getcomposer.org/installer | php ")
EEShellExec.cmd_exec(self, "cd /var/www/22222/htdocs"
"/vimbadmin; curl"
" -sS https://getcomposer.org/installer |"
" php")
self.app.log.debug("installation of composer")
Log.debug(self, "installation of composer")
EEShellExec.cmd_exec(self, "cd /var/www/22222/htdocs"
"/vimbadmin && "
"php composer.phar install --prefer-dist"
@ -684,17 +685,17 @@ class EEStackController(CementBaseController):
# Configure vimbadmin database
vm_passwd = ''.join(random.sample(string.ascii_letters, 8))
self.app.log.debug("Creating vimbadmin database if not exist")
Log.debug(self, "Creating vimbadmin database if not exist")
EEMysql.execute(self, "create database if not exists"
" vimbadmin")
self.app.log.debug("Granting all privileges on vimbadmin ")
Log.debug(self, "Granting all privileges on vimbadmin ")
EEMysql.execute(self, "grant all privileges on vimbadmin.* to"
" vimbadmin@localhost IDENTIFIED BY"
" '{password}'".format(password=vm_passwd))
# Configure ViMbAdmin settings
config = configparser.ConfigParser(strict=False)
self.app.log.debug("configuring ViMbAdmin ")
Log.debug(self, "configuring ViMbAdmin ")
config.read('/var/www/22222/htdocs/vimbadmin/application/'
'configs/application.ini.dist')
config['user']['defaults.mailbox.uid'] = '5000'
@ -725,9 +726,9 @@ class EEStackController(CementBaseController):
(string.ascii_letters
+ string.ascii_letters,
64)))
self.app.log.debug("Writting configration to file "
"/var/www/22222/htdocs/vimbadmin"
"/application/configs/application.ini ")
Log.debug(self, "Writting configration to file "
"/var/www/22222/htdocs/vimbadmin"
"/application/configs/application.ini ")
with open('/var/www/22222/htdocs/vimbadmin/application'
'/configs/application.ini', 'w') as configfile:
config.write(configfile)
@ -736,10 +737,10 @@ class EEStackController(CementBaseController):
".htaccess.dist",
"/var/www/22222/htdocs/vimbadmin/public/"
".htaccess")
self.app.log.debug("Executing command "
"/var/www/22222/htdocs/vimbadmin/bin"
"/doctrine2-cli.php orm:schema-tool:"
"create")
Log.debug(self, "Executing command "
"/var/www/22222/htdocs/vimbadmin/bin"
"/doctrine2-cli.php orm:schema-tool:"
"create")
EEShellExec.cmd_exec(self, "/var/www/22222/htdocs/vimbadmin"
"/bin/doctrine2-cli.php orm:schema-tool:"
"create")
@ -752,8 +753,8 @@ class EEStackController(CementBaseController):
# Vimbadmin
if not os.path.exists('/etc/postfix/mysql/'):
self.app.log.debug("Creating directory "
"/etc/postfix/mysql/")
Log.debug(self, "Creating directory "
"/etc/postfix/mysql/")
os.makedirs('/etc/postfix/mysql/')
data = dict(password=vm_passwd)
vm_config = open('/etc/postfix/mysql/virtual_alias_maps.cf',
@ -762,25 +763,25 @@ class EEStackController(CementBaseController):
out=vm_config)
vm_config.close()
self.app.log.debug("Configration of file "
"/etc/postfix/mysql"
"/virtual_domains_maps.cf")
Log.debug(self, "Configration of file "
"/etc/postfix/mysql"
"/virtual_domains_maps.cf")
vm_config = open('/etc/postfix/mysql/virtual_domains_maps.cf',
'w')
self.app.render((data), 'virtual_domains_maps.mustache',
out=vm_config)
vm_config.close()
self.app.log.debug("Configation of file "
"/etc/postfix/mysql"
"/virtual_mailbox_maps.cf ")
Log.debug(self, "Configation of file "
"/etc/postfix/mysql"
"/virtual_mailbox_maps.cf ")
vm_config = open('/etc/postfix/mysql/virtual_mailbox_maps.cf',
'w')
self.app.render((data), 'virtual_mailbox_maps.mustache',
out=vm_config)
vm_config.close()
self.app.log.debug("Configration of file ")
Log.debug(self, "Configration of file ")
vm_config = open('/etc/dovecot/dovecot-sql.conf.ext',
'w')
self.app.render((data), 'dovecot-sql-conf.mustache',
@ -801,22 +802,22 @@ class EEStackController(CementBaseController):
if any('/tmp/roundcube.tar.gz' == x[1] for x in packages):
# Extract RoundCubemail
self.app.log.debug("Extracting file /tmp/roundcube.tar.gz "
"to location /tmp/ ")
Log.debug(self, "Extracting file /tmp/roundcube.tar.gz "
"to location /tmp/ ")
EEExtract.extract(self, '/tmp/roundcube.tar.gz', '/tmp/')
if not os.path.exists('/var/www/roundcubemail'):
self.app.log.debug("Creating new directory "
" /var/www/roundcubemail/")
Log.debug(self, "Creating new directory "
" /var/www/roundcubemail/")
os.makedirs('/var/www/roundcubemail/')
shutil.move('/tmp/roundcubemail-1.0.4/',
'/var/www/roundcubemail/htdocs')
# Configure roundcube database
rc_passwd = ''.join(random.sample(string.ascii_letters, 8))
self.app.log.debug("Creating Database roundcubemail")
Log.debug(self, "Creating Database roundcubemail")
EEMysql.execute(self, "create database if not exists "
" roundcubemail")
self.app.log.debug("Grant all privileges on roundcubemail")
Log.debug(self, "Grant all privileges on roundcubemail")
EEMysql.execute(self, "grant all privileges"
" on roundcubemail.* to "
" roundcube@localhost IDENTIFIED BY "
@ -855,8 +856,8 @@ class EEStackController(CementBaseController):
ee_db_user='', ee_db_pass='', ee_db_host='',
rc=True)
self.app.log.debug('Writting the nginx configration for'
' RoundCubemail')
Log.debug(self, 'Writting the nginx configration for'
' RoundCubemail')
ee_rc = open('/etc/nginx/sites-available/webmail.conf', 'w')
self.app.render((data), 'virtualconf.mustache',
out=ee_rc)
@ -891,8 +892,8 @@ class EEStackController(CementBaseController):
@expose()
def install(self, packages=[], apt_packages=[]):
if self.app.pargs.web:
self.app.log.debug("Setting apt_packages variable for Nginx ,PHP"
" ,MySQL ")
Log.debug(self, "Setting apt_packages variable for Nginx ,PHP"
" ,MySQL ")
self.app.pargs.nginx = True
self.app.pargs.php = True
self.app.pargs.mysql = True
@ -914,111 +915,115 @@ class EEStackController(CementBaseController):
self.app.pargs.postfix = True
if not EEAptGet.is_installed('dovecot-core'):
self.app.log.debug("Setting apt_packages variable for mail")
Log.debug(self, "Setting apt_packages variable for mail")
apt_packages = apt_packages + EEVariables.ee_mail
packages = packages + [["https://github.com/opensolutions/"
"ViMbAdmin/archive/3.0.10.tar.gz",
"/tmp/vimbadmin.tar.gz"],
"/tmp/vimbadmin.tar.gz", "ViMbAdmin"],
["https://github.com/roundcube/"
"roundcubemail/releases/download/"
"1.0.4/roundcubemail-1.0.4.tar.gz",
"/tmp/roundcube.tar.gz"]]
"/tmp/roundcube.tar.gz",
"roundcubemail"]]
if EEVariables.ee_ram > 1024:
apt_packages = apt_packages + EEVariables.ee_mailscanner
else:
self.app.log.info("Mail server is allready installed")
Log.info(self, "Mail server is allready installed")
if self.app.pargs.nginx:
self.app.log.debug("Setting apt_packages variable for Nginx")
Log.debug(self, "Setting apt_packages variable for Nginx")
if not EEAptGet.is_installed('nginx-common'):
apt_packages = apt_packages + EEVariables.ee_nginx
else:
self.app.log.info("Nginx allready installed")
Log.info(self, "Nginx allready installed")
if self.app.pargs.php:
self.app.log.debug("Setting apt_packages variable for PHP")
Log.debug(self, "Setting apt_packages variable for PHP")
if not EEAptGet.is_installed('php5-common'):
apt_packages = apt_packages + EEVariables.ee_php
else:
self.app.log.info("PHP allready installed")
Log.info(self, "PHP allready installed")
if self.app.pargs.mysql:
self.app.log.debug("Setting apt_packages variable for MySQL")
Log.debug(self, "Setting apt_packages variable for MySQL")
if not EEShellExec.cmd_exec(self, "mysqladmin ping"):
apt_packages = apt_packages + EEVariables.ee_mysql
else:
self.app.log.info("MySQL connection is allready alive")
Log.info(self, "MySQL connection is allready alive")
if self.app.pargs.postfix:
self.app.log.debug("Setting apt_packages variable for PostFix")
Log.debug(self, "Setting apt_packages variable for PostFix")
if not EEAptGet.is_installed('postfix'):
apt_packages = apt_packages + EEVariables.ee_postfix
else:
self.app.log.info("Postfix is allready installed")
Log.info(self, "Postfix is allready installed")
if self.app.pargs.wpcli:
self.app.log.debug("Setting packages variable for WPCLI")
Log.debug(self, "Setting packages variable for WPCLI")
if not EEShellExec.cmd_exec(self, "which wp"):
packages = packages + [["https://github.com/wp-cli/wp-cli/"
"releases/download/v0.17.1/"
"wp-cli.phar", "/usr/bin/wp"]]
"wp-cli.phar", "/usr/bin/wp",
"wp-cli"]]
else:
self.app.log.info("WP-CLI is allready installed")
Log.info(self, "WP-CLI is allready installed")
if self.app.pargs.phpmyadmin:
self.app.log.debug("Setting packages varible for phpMyAdmin ")
Log.debug(self, "Setting packages varible for phpMyAdmin ")
packages = packages + [["https://github.com/phpmyadmin/phpmyadmin"
"/archive/STABLE.tar.gz",
"/tmp/pma.tar.gz"]]
"/tmp/pma.tar.gz", "phpMyAdmin"]]
if self.app.pargs.adminer:
self.app.log.debug("Setting packages variable for Adminer ")
Log.debug(self, "Setting packages variable for Adminer ")
packages = packages + [["http://downloads.sourceforge.net/adminer"
"/adminer-4.1.0.php", "/var/www/22222/"
"htdocs/db/adminer/index.php"]]
"htdocs/db/adminer/index.php", "adminer"]]
if self.app.pargs.utils:
self.app.log.debug("Setting packages variable for utils")
Log.debug(self, "Setting packages variable for utils")
packages = packages + [["http://phpmemcacheadmin.googlecode.com/"
"files/phpMemcachedAdmin-1.2.2"
"-r262.tar.gz", '/tmp/memcache.tar.gz'],
"-r262.tar.gz", '/tmp/memcache.tar.gz',
'phpMemcachedAdmin'],
["https://raw.githubusercontent.com/rtCamp/"
"eeadmin/master/cache/nginx/clean.php",
"/var/www/22222/htdocs/cache/"
"nginx/clean.php"],
"nginx/clean.php", "clean.php"],
["https://raw.github.com/rlerdorf/opcache-"
"status/master/opcache.php",
"/var/www/22222/htdocs/cache/"
"opcache/opcache.php"],
"opcache/opcache.php", "opcache.php"],
["https://raw.github.com/amnuts/opcache-gui"
"/master/index.php",
"/var/www/22222/htdocs/"
"cache/opcache/opgui.php"],
"cache/opcache/opgui.php", "index.php"],
["https://gist.github.com/ck-on/4959032/raw"
"/0b871b345fd6cfcd6d2be030c1f33d1ad6a475cb"
"/ocp.php",
"/var/www/22222/htdocs/cache/"
"opcache/ocp.php"],
"opcache/ocp.php", "ocp.php"],
["https://github.com/jokkedk/webgrind/"
"archive/master.tar.gz",
'/tmp/webgrind.tar.gz'],
'/tmp/webgrind.tar.gz', 'webgrind.tar.gz'],
["http://bazaar.launchpad.net/~percona-too"
"lkit-dev/percona-toolkit/2.1/download/he"
"ad:/ptquerydigest-20110624220137-or26tn4"
"expb9ul2a-16/pt-query-digest",
"/usr/bin/pt-query-advisor"],
"/usr/bin/pt-query-advisor",
"pt-query-digest"],
["https://github.com/box/Anemometer/archive"
"/master.tar.gz",
'/tmp/anemometer.tar.gz']
'/tmp/anemometer.tar.gz', 'Anemometer']
]
self.app.log.debug("Calling pre_pref ")
Log.debug(self, "Calling pre_pref ")
self.pre_pref(apt_packages)
if len(apt_packages):
EESwap.add(self)
self.app.log.debug("Updating apt-cache")
Log.debug(self, "Updating apt-cache")
EEAptGet.update()
self.app.log.debug("Installing all apt_packages")
Log.debug(self, "Installing all apt_packages")
EEAptGet.install(apt_packages)
if len(packages):
self.app.log.debug("Downloading all packages")
Log.debug(self, "Downloading all packages")
EEDownload.download(self, packages)
self.app.log.debug("Calling post_pref")
Log.debug(self, "Calling post_pref")
self.post_pref(apt_packages, packages)
@expose()
@ -1039,7 +1044,7 @@ class EEStackController(CementBaseController):
self.app.pargs.utils = True
if self.app.pargs.mail:
self.app.log.debug("Removing mail server packages")
Log.debug(self, "Removing mail server packages")
apt_packages = apt_packages + EEVariables.ee_mail
apt_packages = apt_packages + EEVariables.ee_mailscanner
packages = packages + ["/var/www/22222/htdocs/vimbadmin",
@ -1049,28 +1054,28 @@ class EEStackController(CementBaseController):
EEMysql.execute(self, "drop database IF EXISTS roundcubemail")
if self.app.pargs.nginx:
self.app.log.debug("Removing apt_packages variable of Nginx")
Log.debug(self, "Removing apt_packages variable of Nginx")
apt_packages = apt_packages + EEVariables.ee_nginx
if self.app.pargs.php:
self.app.log.debug("Removing apt_packages variable of PHP")
Log.debug(self, "Removing apt_packages variable of PHP")
apt_packages = apt_packages + EEVariables.ee_php
if self.app.pargs.mysql:
self.app.log.debug("Removing apt_packages variable of MySQL")
Log.debug(self, "Removing apt_packages variable of MySQL")
apt_packages = apt_packages + EEVariables.ee_mysql
if self.app.pargs.postfix:
self.app.log.debug("Removing apt_packages variable of Postfix")
Log.debug(self, "Removing apt_packages variable of Postfix")
apt_packages = apt_packages + EEVariables.ee_postfix
if self.app.pargs.wpcli:
self.app.log.debug("Removing package variable of WPCLI ")
Log.debug(self, "Removing package variable of WPCLI ")
packages = packages + ['/usr/bin/wp']
if self.app.pargs.phpmyadmin:
self.app.log.debug("Removing package variable of phpMyAdmin ")
Log.debug(self, "Removing package variable of phpMyAdmin ")
packages = packages + ['/var/www/22222/htdocs/db/pma']
if self.app.pargs.adminer:
self.app.log.debug("Removing package variable of Adminer ")
Log.debug(self, "Removing package variable of Adminer ")
packages = packages + ['/var/www/22222/htdocs/db/adminer']
if self.app.pargs.utils:
self.app.log.debug("Removing package variable of utils ")
Log.debug(self, "Removing package variable of utils ")
packages = packages + ['/var/www/22222/htdocs/php/webgrind/',
'/var/www/22222/htdocs/cache/opcache',
'/var/www/22222/htdocs/cache/nginx/'
@ -1080,7 +1085,7 @@ class EEStackController(CementBaseController):
'/var/www/22222/htdocs/db/anemometer']
if len(apt_packages):
self.app.log.debug("Removing apt_packages")
Log.debug(self, "Removing apt_packages")
EEAptGet.remove(apt_packages)
if len(packages):
EEFileUtils.remove(self, packages)
@ -1103,7 +1108,7 @@ class EEStackController(CementBaseController):
self.app.pargs.utils = True
if self.app.pargs.mail:
self.app.log.debug("Removing mail server packages")
Log.debug(self, "Removing mail server packages")
apt_packages = apt_packages + EEVariables.ee_mail
apt_packages = apt_packages + EEVariables.ee_mailscanner
packages = packages + ["/var/www/22222/htdocs/vimbadmin",
@ -1113,28 +1118,28 @@ class EEStackController(CementBaseController):
EEMysql.execute(self, "drop database IF EXISTS roundcubemail")
if self.app.pargs.nginx:
self.app.log.debug("Purge apt_packages variable of Nginx")
Log.debug(self, "Purge apt_packages variable of Nginx")
apt_packages = apt_packages + EEVariables.ee_nginx
if self.app.pargs.php:
self.app.log.debug("Purge apt_packages variable PHP")
Log.debug(self, "Purge apt_packages variable PHP")
apt_packages = apt_packages + EEVariables.ee_php
if self.app.pargs.mysql:
self.app.log.debug("Purge apt_packages variable MySQL")
Log.debug(self, "Purge apt_packages variable MySQL")
apt_packages = apt_packages + EEVariables.ee_mysql
if self.app.pargs.postfix:
self.app.log.debug("Purge apt_packages variable PostFix")
Log.debug(self, "Purge apt_packages variable PostFix")
apt_packages = apt_packages + EEVariables.ee_postfix
if self.app.pargs.wpcli:
self.app.log.debug("Purge package variable WPCLI")
Log.debug(self, "Purge package variable WPCLI")
packages = packages + ['/usr/bin/wp']
if self.app.pargs.phpmyadmin:
packages = packages + ['/var/www/22222/htdocs/db/pma']
self.app.log.debug("Purge package variable phpMyAdmin")
Log.debug(self, "Purge package variable phpMyAdmin")
if self.app.pargs.adminer:
self.app.log.debug("Purge package variable Adminer")
Log.debug(self, "Purge package variable Adminer")
packages = packages + ['/var/www/22222/htdocs/db/adminer']
if self.app.pargs.utils:
self.app.log.debug("Purge package variable utils")
Log.debug(self, "Purge package variable utils")
packages = packages + ['/var/www/22222/htdocs/php/webgrind/',
'/var/www/22222/htdocs/cache/opcache',
'/var/www/22222/htdocs/cache/nginx/'

59
ee/cli/plugins/stack_services.py
View File

@ -1,6 +1,7 @@
from cement.core.controller import CementBaseController, expose
from cement.core import handler, hook
from ee.core.services import EEService
from ee.core.logging import Log
class EEStackStatusController(CementBaseController):
@ -20,25 +21,25 @@ class EEStackStatusController(CementBaseController):
def start(self):
services = []
if self.app.pargs.nginx:
self.app.log.debug("nginx service start")
Log.debug(self, "nginx service start")
services = services + ['nginx']
elif self.app.pargs.php:
self.app.log.debug("php5-fpm service start")
Log.debug(self, "php5-fpm service start")
services = services + ['php5-fpm']
elif self.app.pargs.mysql:
self.app.log.debug("mysql service start")
Log.debug(self, "mysql service start")
services = services + ['mysql']
elif self.app.pargs.postfix:
self.app.log.debug("postfix service start")
Log.debug(self, "postfix service start")
services = services + ['postfix']
elif self.app.pargs.memcache:
self.app.log.debug("memcached service start")
Log.debug(self, "memcached service start")
services = services + ['memcached']
elif self.app.pargs.dovecot:
self.app.log.debug("dovecot service start")
Log.debug(self, "dovecot service start")
services = services + ['dovecot']
else:
self.app.log.debug("nginx,php5-fpm,mysql,postfix services start")
Log.debug(self, "nginx,php5-fpm,mysql,postfix services start")
services = services + ['nginx', 'php5-fpm', 'mysql', 'postfix']
for service in services:
EEService.start_service(self, service)
@ -47,26 +48,26 @@ class EEStackStatusController(CementBaseController):
def stop(self):
services = []
if self.app.pargs.nginx:
self.app.log.debug("nginx service stop")
Log.debug(self, "nginx service stop")
services = services + ['nginx']
elif self.app.pargs.php:
self.app.log.debug("php5-fpm service stop")
Log.debug(self, "php5-fpm service stop")
services = services + ['php5-fpm']
elif self.app.pargs.mysql:
self.app.log.debug("mysql service stop")
Log.debug(self, "mysql service stop")
services = services + ['mysql']
elif self.app.pargs.postfix:
self.app.log.debug("postfix service stop")
Log.debug(self, "postfix service stop")
services = services + ['postfix']
elif self.app.pargs.memcache:
self.app.log.debug("memcached service stop")
Log.debug(self, "memcached service stop")
services = services + ['memcached']
elif self.app.pargs.dovecot:
self.app.log.debug("dovecot service stop")
Log.debug(self, "dovecot service stop")
services = services + ['dovecot']
else:
services = services + ['nginx', 'php5-fpm', 'mysql', 'postfix']
self.app.log.debug("nginx,php5-fpm,mysql,postfix services stop")
Log.debug(self, "nginx,php5-fpm,mysql,postfix services stop")
for service in services:
EEService.stop_service(self, service)
@ -74,53 +75,53 @@ class EEStackStatusController(CementBaseController):
def restart(self):
services = []
if self.app.pargs.nginx:
self.app.log.debug("nginx service restart")
Log.debug(self, "nginx service restart")
services = services + ['nginx']
elif self.app.pargs.php:
self.app.log.debug("php5-fpm service restart")
Log.debug(self, "php5-fpm service restart")
services = services + ['php5-fpm']
elif self.app.pargs.mysql:
self.app.log.debug("mysql service restart")
Log.debug(self, "mysql service restart")
services = services + ['mysql']
elif self.app.pargs.postfix:
self.app.log.debug("postfix service restart")
Log.debug(self, "postfix service restart")
services = services + ['postfix']
elif self.app.pargs.memcache:
self.app.log.debug("memcached service restart")
Log.debug(self, "memcached service restart")
services = services + ['memcached']
elif self.app.pargs.dovecot:
self.app.log.debug("dovecot service restart")
Log.debug(self, "dovecot service restart")
services = services + ['dovecot']
else:
services = services + ['nginx', 'php5-fpm', 'mysql', 'postfix']
for service in services:
self.app.log.debug("nginx,php5-fpm,mysql,postfix services restart")
Log.debug(self, "nginx,php5-fpm,mysql,postfix services restart")
EEService.restart_service(self, service)
@expose(help="get stack status")
def status(self):
services = []
if self.app.pargs.nginx:
self.app.log.debug("nginx service status")
Log.debug(self, "nginx service status")
services = services + ['nginx']
elif self.app.pargs.php:
self.app.log.debug("php5-fpm service status")
Log.debug(self, "php5-fpm service status")
services = services + ['php5-fpm']
elif self.app.pargs.mysql:
self.app.log.debug("mysql service status")
Log.debug(self, "mysql service status")
services = services + ['mysql']
elif self.app.pargs.postfix:
services = services + ['postfix']
self.app.log.debug("postfix service status")
Log.debug(self, "postfix service status")
elif self.app.pargs.memcache:
self.app.log.debug("memcached service status")
Log.debug(self, "memcached service status")
services = services + ['memcached']
elif self.app.pargs.dovecot:
self.app.log.debug("dovecot service status")
Log.debug(self, "dovecot service status")
services = services + ['dovecot']
else:
self.app.log.debug("nginx,php5-fpm,mysql,postfix services status")
Log.debug(self, "nginx,php5-fpm,mysql,postfix services status")
services = services + ['nginx', 'php5-fpm', 'mysql', 'postfix']
for service in services:
if EEService.get_service_status(self, service):
print("{0}: Running".format(service))
Log.info(self, "{0}: Running".format(service))

1
ee/core/aptget.py
View File

@ -261,4 +261,3 @@ class EEAptGet():
except Exception as e:
cache.close()
return False

21
ee/core/download.py
View File

@ -2,6 +2,7 @@
import urllib.request
import urllib.error
import os
from ee.core.logging import Log
class EEDownload():
@ -13,24 +14,24 @@ class EEDownload():
for package in packages:
url = package[0]
filename = package[1]
pkg_name = package[2]
try:
directory = os.path.dirname(filename)
if not os.path.exists(directory):
os.makedirs(directory)
self.app.log.info("Downloading "+os.path.basename(url)+" ...")
Log.info(self, "Downloading "+pkg_name+" ...")
urllib.request.urlretrieve(url, filename)
self.app.log.info("Done")
except urllib.error.URLError as e:
self.app.log.info("Unable to donwload file, [{err}]"
.format(err=str(e.reason)))
Log.info(self, "Unable to donwload file, [{err}]"
.format(err=str(e.reason)))
return False
except urllib.error.HTTPError as e:
self.app.log.error("Package download failed. [{err}]"
.format(err=str(e.reason)))
Log.error(self, "Package download failed. [{err}]"
.format(err=str(e.reason)))
return False
except urllib.error.ContentTooShortError as e:
self.app.log.error("Package download failed. The amount of the"
" downloaded data is less than "
"the expected amount \{0} {1}"
.format(e.errno, e.strerror))
Log.error(self, "Package download failed. The amount of the"
" downloaded data is less than "
"the expected amount \{0} {1}"
.format(e.errno, e.strerror))
return False

5
ee/core/extract.py
View File

@ -1,6 +1,7 @@
"""EasyEngine extarct core classes."""
import tarfile
import os
from ee.core.logging import Log
class EEExtract():
@ -14,6 +15,6 @@ class EEExtract():
os.remove(file)
return True
except tarfile.TarError as e:
self.app.log.error('Unable to extract file \{0} {1}'
.format(e.errno, e.strerror))
Log.error(self, 'Unable to extract file \{0} {1}'
.format(e.errno, e.strerror))
return False

22
ee/core/fileutils.py
View File

@ -16,15 +16,13 @@ class EEFileUtils():
def remove(self, filelist):
for file in filelist:
if os.path.isfile(file):
self.app.log.info("Removing "+os.path.basename(file)+" ...")
Log.info(self, "Removing "+os.path.basename(file)+" ...")
os.remove(file)
self.app.log.debug('file Removed')
self.app.log.info("Done")
Log.debug(self, 'file Removed')
if os.path.isdir(file):
try:
print("Removing "+os.path.basename(file)+"...")
Log.info(self, "Removing "+os.path.basename(file)+"...")
shutil.rmtree(file)
self.app.log.info("Done")
except shutil.Error as e:
Log.error(self, 'Unable to Remove file {err}'
.format(err=str(e.reason)))
@ -37,11 +35,11 @@ class EEFileUtils():
try:
os.symlink(src, dst)
except Exception as e:
self.app.log.error("Unable to create symbolic link ...\n {0}"
" {1}".format(e.errno, e.strerror))
Log.error(self, "Unable to create symbolic link ...\n {0}"
" {1}".format(e.errno, e.strerror))
sys.exit(1)
else:
self.app.log.debug("Destination: {0} exists".format(dst))
Log.debug(self, "Destination: {0} exists".format(dst))
def remove_symlink(self, filepath):
try:
@ -55,17 +53,17 @@ class EEFileUtils():
try:
shutil.copy2(src, dest)
except shutil.Error as e:
print('Error: {0}'.format(e))
Log.info(self, 'Error: {0}'.format(e))
except IOError as e:
print('Error: {e}'.format(e.strerror))
Log.info(self, 'Error: {e}'.format(e.strerror))
def searchreplace(self, fnm, sstr, rstr):
try:
for line in fileinput.input(fnm, inplace=True):
print(line.replace(sstr, rstr), end='')
Log.info(line.replace(sstr, rstr), end='')
fileinput.close()
except Exception as e:
print('Error : {0}'.format(e))
Log.info(self, 'Error : {0}'.format(e))
def mvfile(self, src, dst):
try:

15
ee/core/git.py
View File

@ -1,5 +1,6 @@
from sh import git, ErrorReturnCode
import os
from ee.core.logging import Log
class EEGit:
@ -16,24 +17,24 @@ class EEGit:
if os.path.isdir(path):
if not os.path.isdir(path+"/.git"):
try:
self.app.log.debug("EEGit: git init at {0}"
.format(path))
Log.debug(self, "EEGit: git init at {0}"
.format(path))
git.init(path)
except ErrorReturnCode as e:
self.app.log.error(e)
Log.error(e)
sys.exit(1)
status = git.status("-s")
if len(status.splitlines()) > 0:
try:
self.app.log.debug("EEGit: git commit at {0}"
.format(path))
Log.debug(self, "EEGit: git commit at {0}"
.format(path))
git.add("--all")
git.commit("-am {0}".format(msg))
except ErrorReturnCode as e:
self.app.log.error(e)
Log.error(e)
sys.exit(1)
else:
self.app.log.debug("EEGit: Path {0} not present".format(path))
Log.debug(self, "EEGit: Path {0} not present".format(path))
def checkfilestatus(self, repo, filepath):
global git

9
ee/core/mysql.py
View File

@ -3,6 +3,7 @@ import pymysql
import configparser
from os.path import expanduser
import sys
from ee.core.logging import Log
class EEMysql():
@ -29,15 +30,15 @@ class EEMysql():
user=user, passwd=passwd)
cur = conn.cursor()
except Exception as e:
self.app.log.error('Unable to connect to database: {0}'
.format(e))
Log.error(self, 'Unable to connect to database: {0}'
.format(e))
sys.exit(1)
try:
cur.execute(statement)
except Exception as e:
self.app.log.error('Error occured while executing: {0}'
.format(e))
Log.error(self, 'Error occured while executing: {0}'
.format(e))
cur.close()
conn.close()
sys.exit(1)

32
ee/core/services.py
View File

@ -3,6 +3,7 @@ import os
import sys
import subprocess
from subprocess import Popen
from ee.core.logging import Log
class EEService():
@ -16,12 +17,12 @@ class EEService():
retcode = subprocess.getstatusoutput('service {0} start'
.format(service_name))
if retcode[0] == 0:
self.app.log.info("Started : {0}".format(service_name))
Log.info(self, "Started : {0}".format(service_name))
else:
self.app.log.error(retcode[1])
Log.error(self, retcode[1])
except OSError as e:
self.app.log.error("Failed to start service {0} {1}"
.format(e.errno, e.strerror))
Log.error(self, "Failed to start service {0} {1}"
.format(e.errno, e.strerror))
return False
def stop_service(self, service_name):
@ -29,13 +30,13 @@ class EEService():
retcode = subprocess.getstatusoutput('service {0} stop'
.format(service_name))
if retcode[0] == 0:
self.app.log.info("Stopped : {0}".format(service_name))
Log.info(self, "Stopped : {0}".format(service_name))
return True
else:
return False
except OSError as e:
self.app.log.error("Failed to stop service : {0}{1}"
.format(e.errno, e.strerror))
Log.error(self, "Failed to stop service : {0}{1}"
.format(e.errno, e.strerror))
return False
def restart_service(self, service_name):
@ -43,8 +44,8 @@ class EEService():
EEService.stop_service(self, service_name)
EEService.start_service(self, service_name)
except OSError as e:
self.app.log.error("Failed to restart services \{0} {1}"
.format(e.errno, e.strerror))
Log.error(self, "Failed to restart services \{0} {1}"
.format(e.errno, e.strerror))
def reload_service(self, service_name):
try:
@ -67,14 +68,15 @@ class EEService():
retcode = subprocess.getstatusoutput('service {0} reload'
.format(service_name))
if retcode[0] == 0:
self.app.log.info("reload : {0}".format(service_name))
Log.info(self, "reload : {0}".format(service_name))
return True
else:
return False
except OSError as e:
self.app.log.error("Failed to reload {0} {1}"
.format(service_name, e))
return False
Log.error(self, "Failed to reload {0} {1}"
.format(service_name, e))
sys.exit(1)
def get_service_status(self, service_name):
try:
@ -90,6 +92,6 @@ class EEService():
else:
return False
except OSError as e:
self.app.log.error("Unable to get services status \ {0}{1}"
.format(e.errno, e.strerror))
Log.error(self, "Unable to get services status \ {0}{1}"
.format(e.errno, e.strerror))
return False

4
ee/core/shellexec.py
View File

@ -13,12 +13,12 @@ class EEShellExec():
def cmd_exec(self, command, errormsg=''):
try:
self.app.log.debug("Running command: {0}".format(command))
Log.debug(self, "Running command: {0}".format(command))
retcode = subprocess.getstatusoutput(command)
if retcode[0] == 0:
return True
else:
self.app.log.debug(retcode[1])
Log.debug(self, retcode[1])
return False
except OSError as e:
if errormsg:

Write Preview
Loading…
Cancel
Save