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

Merge branch 'python' of github.com:rtCamp/easyengine into python

bugfixes
harshadyeola 10 years ago
parent
84844b93dc d0bc5f22f5
commit
d48c67bdc2
20 changed files with 125 additions and 128 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. 6
      ee/cli/controllers/base.py
  2. 2
      ee/cli/main.py
  3. 52
      ee/cli/plugins/clean.py
  4. 41
      ee/cli/plugins/debug.py
  5. 2
      ee/cli/plugins/import_slow_log.py
  6. 16
      ee/cli/plugins/info.py
  7. 20
      ee/cli/plugins/secure.py
  8. 32
      ee/cli/plugins/site.py
  9. 36
      ee/cli/plugins/site_functions.py
  10. 6
      ee/cli/plugins/sitedb.py
  11. 12
      ee/cli/plugins/stack_services.py
  12. 1
      ee/core/addswap.py
  13. 3
      ee/core/apt_repo.py
  14. 3
      ee/core/database.py
  15. 1
      ee/core/domainvalidate.py
  16. 3
      ee/core/git.py
  17. 1
      ee/core/logging.py
  18. 4
      ee/core/shellexec.py
  19. 8
      ee/core/symboliclink.py
  20. 4
      ee/core/variables.py

6
ee/cli/controllers/base.py
View File

@ -6,9 +6,9 @@ from cement.core.controller import CementBaseController, expose
class EEBaseController(CementBaseController):
class Meta:
label = 'base'
description = ("easyengine is the commandline tool to manage your"
" websites based on wordpress and nginx with easy to"
" use commands.")
description = ("EasyEngine is the commandline tool to manage your"
" websites based on WordPress and Nginx with easy to"
" use commands")
@expose(hide=True)
def default(self):

2
ee/cli/main.py
View File

@ -47,7 +47,7 @@ class EEApp(foundation.CementApp):
# Internal plugins (ship with application code)
plugin_bootstrap = 'ee.cli.plugins'
extensions = ['mustache', 'json']
extensions = ['mustache']
# default output handler
output_handler = 'mustache'

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

@ -1,11 +1,13 @@
"""Clean Plugin for EasyEngine."""
from ee.core.shellexec import EEShellExec
from ee.core.aptget import EEAptGet
from ee.core.services import EEService
from ee.core.logging import Log
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):
@ -18,52 +20,50 @@ class EECleanController(CementBaseController):
label = 'clean'
stacked_on = 'base'
stacked_type = 'nested'
description = ('clean command cleans different cache with following '
'options')
description = ('Clean NGINX FastCGI cache, Opcacache, Memcache')
arguments = [
(['--all'],
dict(help='clean all cache', action='store_true')),
dict(help='Clean all cache', action='store_true')),
(['--fastcgi'],
dict(help='clean fastcgi cache', action='store_true')),
dict(help='Clean FastCGI cache', action='store_true')),
(['--memcache'],
dict(help='clean memcache', action='store_true')),
dict(help='Clean MemCache', action='store_true')),
(['--opcache'],
dict(help='clean opcode cache cache', action='store_true'))
dict(help='Clean OpCache', action='store_true'))
]
@expose(hide=True)
def default(self):
# TODO Default action for ee clean command here
if (not (self.app.pargs.all or self.app.pargs.fastcgi or
self.app.pargs.memcache or self.app.pargs.opcache)):
self.clean_fastcgi()
if self.app.pargs.all:
self.clean_memcache()
self.clean_fastcgi()
self.clean_opcache()
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 (not (self.app.pargs.all or self.app.pargs.fastcgi or
self.app.pargs.memcache or self.app.pargs.opcache)):
self.clean_fastcgi()
if self.app.pargs.all:
self.clean_memcache()
self.clean_fastcgi()
self.clean_opcache()
if self.app.pargs.fastcgi:
self.clean_fastcgi()
if self.app.pargs.memcache:
self.clean_memcache()
if self.app.pargs.opcache:
self.clean_opcache()
@expose(hide=True)
def clean_memcache(self):
try:
if(EEAptGet.is_installed("memcached")):
EEService.restart_service(self, "memcached")
Log.info(self, "Cleaning memcache...")
Log.info(self, "Cleaning MemCache")
else:
Log.error(self, "Memcache not installed")
except Exception as e:
Log.debug(self, "{0}".format(e))
Log.error(self, "Unable to restart memcached")
Log.error(self, "Unable to restart Memcached")
@expose(hide=True)
def clean_fastcgi(self):
if(os.path.isdir("/var/run/nginx-cache")):
Log.info(self, "Cleaning NGINX FastCGI cache, please wait...")
Log.info(self, "Cleaning NGINX FastCGI cache")
EEShellExec.cmd_exec(self, "rm -rf /var/run/nginx-cache/*")
else:
Log.error(self, "Unable to clean FastCGI cache")
@ -71,12 +71,12 @@ class EECleanController(CementBaseController):
@expose(hide=True)
def clean_opcache(self):
try:
Log.info(self, "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:
Log.debug(self, "{0}".format(e))
Log.error(self, "Unable to clean opacache")
Log.error(self, "Unable to clean OpCache")
def load(app):

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

@ -1,12 +1,12 @@
"""Debug Plugin for EasyEngine."""
"""Debug Plugin for EasyEngine"""
from cement.core.controller import CementBaseController, expose
from cement.core import handler, hook
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
import os
def debug_plugin_hook(app):
@ -17,7 +17,7 @@ def debug_plugin_hook(app):
class EEDebugController(CementBaseController):
class Meta:
label = 'debug'
description = 'debug command enables/disbaled stack debug'
description = 'Used for server level debugging'
stacked_on = 'base'
stacked_type = 'nested'
arguments = [
@ -58,7 +58,7 @@ class EEDebugController(CementBaseController):
for ip_addr in debug_address:
if not ("debug_connection "+ip_addr in open('/etc/nginx/'
'nginx.conf').read()):
Log.info(self, "Setting up NGINX debug connection"
Log.info(self, "Setting up Nginx debug connection"
" for "+ip_addr)
EEShellExec.cmd_exec(self, "sed -i \"/events {{/a\\ \\ \\ "
"\\ $(echo debug_connection "
@ -67,7 +67,7 @@ class EEDebugController(CementBaseController):
self.trigger_nginx = True
if not self.trigger_nginx:
Log.info(self, "NGINX debug connection already enabled")
Log.info(self, "Nginx debug connection already enabled")
self.msg = self.msg + [" /var/log/nginx/*.error.log"]
@ -79,7 +79,7 @@ class EEDebugController(CementBaseController):
" /etc/nginx/nginx.conf")
self.trigger_nginx = True
else:
Log.info(self, "Nginx debug connection already disbaled")
Log.info(self, "Nginx debug connection already disabled")
# start site specific debug
elif self.start and self.app.pargs.site_name:
@ -120,7 +120,7 @@ class EEDebugController(CementBaseController):
else:
Log.info(self, "Debug for site allready disbaled")
Log.info(self, "Debug for site allready disabled")
else:
Log.info(self, "{0} domain not valid"
.format(self.app.pargs.site_name))
@ -135,7 +135,7 @@ class EEDebugController(CementBaseController):
"| grep 9001")):
Log.info(self, "Enabling PHP debug")
data = dict(php="9001", debug="9001")
Log.info(self, 'writting the nginx configration to file'
Log.info(self, 'Writting the Nginx debug 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)
@ -153,14 +153,14 @@ class EEDebugController(CementBaseController):
"| grep 9001"):
Log.info(self, "Disabling PHP debug")
data = dict(php="9000", debug="9001")
Log.info(self, 'writting the nginx configration to file'
Log.info(self, 'Writting the Nginx debug 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:
Log.info(self, "PHP debug is allready disbaled")
Log.info(self, "PHP debug is allready disabled")
@expose(hide=True)
def debug_fpm(self):
@ -187,8 +187,7 @@ class EEDebugController(CementBaseController):
"/php-fpm.conf")
self.trigger_php = True
else:
Log.info(self, "PHP5-FPM log_level = debug "
" already disabled")
Log.info(self, "PHP5-FPM log_level = debug already disabled")
@expose(hide=True)
def debug_mysql(self):
@ -291,12 +290,12 @@ class EEDebugController(CementBaseController):
"SAVEQUERIES\', "
"true);/d\" {0}".format(wp_config))
else:
Log.info(self, "WordPress debug all already disbaled")
Log.info(self, "WordPress debug all already disabled")
else:
Log.info(self, "{0} domain not valid"
.format(self.app.pargs.site_name))
Log.error(self, "{0} domain not valid"
.format(self.app.pargs.site_name))
else:
Log.info(self, "Missing argument site_name")
Log.error(self, "Missing argument site name")
@expose(hide=True)
def debug_rewrite(self):
@ -309,7 +308,7 @@ class EEDebugController(CementBaseController):
"rewrite_log on;\' /etc/nginx/nginx.conf")
self.trigger_nginx = True
else:
Log.info(self, "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']
@ -323,14 +322,14 @@ class EEDebugController(CementBaseController):
" /etc/nginx/nginx.conf")
self.trigger_nginx = True
else:
Log.info(self, "NGINX rewrite logs already disbaled")
Log.info(self, "Nginx rewrite logs already disabled")
# 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)):
Log.info(self, "Setting up NGINX rewrite logs for {0}"
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}"
@ -351,14 +350,14 @@ class EEDebugController(CementBaseController):
.format(self.app.pargs.site_name))
if EEShellExec.cmd_exec(self, "grep \"rewrite_log on;\" {0}"
.format(config_path)):
Log.info(self, "Disabling NGINX rewrite logs for {0}"
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:
Log.info(self, "Nginx rewrite logs for {0} allready "
" disbaled".format(self.app.pargs.site_name))
" disabled".format(self.app.pargs.site_name))
@expose(hide=True)
def default(self):

2
ee/cli/plugins/import_slow_log.py
View File

@ -21,6 +21,7 @@ class EEImportslowlogController(CementBaseController):
if os.path.isdir("/var/www/22222/htdocs/db/anemometer"):
if os.path.isfile("/var/log/mysql/mysql-slow.log"):
# Get Anemometer user name and password
Log.error(self, "Importing MySQL slow log to Anemometer")
host = os.popen("grep -e \"\'host\'\" /var/www/22222/htdocs/"
"db/anemometer/conf/config.inc.php "
"| head -1 | cut -d\\\' -f4 | "
@ -33,6 +34,7 @@ class EEImportslowlogController(CementBaseController):
"htdocs/db/anemometer/conf/config.inc.php "
"| head -1 | cut -d\\\' -f4 | "
"tr -d '\n'").read()
# Import slow log Anemometer using pt-query-digest
EEShellExec.cmd_exec(self, "pt-query-digest --user={0} "
"--password={1} "

16
ee/cli/plugins/info.py
View File

@ -19,17 +19,17 @@ class EEInfoController(CementBaseController):
label = 'info'
stacked_on = 'base'
stacked_type = 'nested'
description = 'info command used for debugging issued with stack or \
site specific configuration'
description = ('Display configuration information related to Nginx,'
' PHP and MySQL')
arguments = [
(['--mysql'],
dict(help='get mysql configuration information',
dict(help='Get MySQL configuration information',
action='store_true')),
(['--php'],
dict(help='get php configuration information',
dict(help='Get PHP configuration information',
action='store_true')),
(['--nginx'],
dict(help='get nginx configuration information',
dict(help='Get Nginx configuration information',
action='store_true')),
]
@ -174,19 +174,19 @@ class EEInfoController(CementBaseController):
if EEAptGet.is_installed(self, 'nginx-common'):
self.info_nginx()
else:
print("Nginx is not installed")
Log.error(self, "Nginx is not installed")
if self.app.pargs.php:
if EEAptGet.is_installed(self, 'php5-fpm'):
self.info_php()
else:
print("PHP5 is installed")
Log.error("PHP5 is not installed")
if self.app.pargs.mysql:
if EEShellExec.cmd_exec(self, "mysqladmin ping"):
self.info_mysql()
else:
print("MySQL is not installed")
Log.error("MySQL is not installed")
def load(app):

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

@ -2,12 +2,12 @@ from cement.core.controller import CementBaseController, expose
from cement.core import handler, hook
from ee.core.shellexec import EEShellExec
from ee.core.variables import EEVariables
from ee.core.logging import Log
import string
import random
import sys
import hashlib
import getpass
from ee.core.logging import Log
def secure_plugin_hook(app):
@ -15,7 +15,7 @@ def secure_plugin_hook(app):
pass
class EEsecureController(CementBaseController):
class EESecureController(CementBaseController):
class Meta:
label = 'secure'
stacked_on = 'base'
@ -43,8 +43,8 @@ class EEsecureController(CementBaseController):
@expose(hide=True)
def secure_auth(self):
passwd = ''.join([random.choice
(string.ascii_letters + string.digits)
for n in range(6)])
(string.ascii_letters + string.digits)
for n in range(6)])
username = input("Provide HTTP authentication user "
"name [{0}] :".format(EEVariables.ee_user))
password = input("Provide HTTP authentication "
@ -75,20 +75,18 @@ class EEsecureController(CementBaseController):
"/etc/nginx/sites-available/22222"
.format(port=port))
else:
Log.info(self, "Unable to change EasyEngine admin port{0}"
.format("[FAIL]"))
Log.error(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{0}"
.format("[FAIL]"))
Log.error(self, "Unable to change EasyEngine admin port")
@expose(hide=True)
def secure_ip(self):
#TODO:remaining with ee.conf updation in file
# TODO:remaining with ee.conf updation in file
newlist = []
ip = input("Enter the comma separated IP addresses "
"to white list [127.0.0.1]:")
@ -102,7 +100,7 @@ class EEsecureController(CementBaseController):
for check_ip in user_list_ip:
if check_ip not in exist_ip_list:
newlist.extend(exist_ip_list)
# changes in acl.conf file
# changes in acl.conf file
if len(newlist) != 0:
EEShellExec.cmd_exec(self, "sed -i \"/allow.*/d\" /etc/nginx"
"/common/acl.conf")
@ -115,6 +113,6 @@ class EEsecureController(CementBaseController):
def load(app):
# register the plugin class.. this only happens if the plugin is enabled
handler.register(EEsecureController)
handler.register(EESecureController)
# register a hook (function) to run after arguments are parsed.
hook.register('post_argument_parsing', secure_plugin_hook)

32
ee/cli/plugins/site.py
View File

@ -8,11 +8,11 @@ from ee.cli.plugins.site_functions import *
from ee.core.services import EEService
from ee.cli.plugins.sitedb import *
from ee.core.git import EEGit
from subprocess import Popen
import sys
import os
import glob
import subprocess
from subprocess import Popen
def ee_site_hook(app):
@ -26,18 +26,18 @@ class EESiteController(CementBaseController):
label = 'site'
stacked_on = 'base'
stacked_type = 'nested'
description = ('site command manages website configuration'
description = ('Site command manages website configuration'
' with the help of the following subcommands')
arguments = [
(['site_name'],
dict(help='website name')),
dict(help='Website name')),
]
@expose(hide=True)
def default(self):
self.app.args.print_help()
@expose(help="enable site example.com")
@expose(help="Enable site example.com")
def enable(self):
(ee_domain, ee_www_domain) = ValidateDomain(self.app.pargs.site_name)
if os.path.isfile('/etc/nginx/sites-available/{0}'
@ -51,7 +51,7 @@ class EESiteController(CementBaseController):
else:
Log.error(self, " site {0} does not exists".format(ee_domain))
@expose(help="disable site example.com")
@expose(help="Disable site example.com")
def disable(self):
(ee_domain, ee_www_domain) = ValidateDomain(self.app.pargs.site_name)
if os.path.isfile('/etc/nginx/sites-available/{0}'
@ -63,7 +63,7 @@ class EESiteController(CementBaseController):
else:
Log.error(self, " site {0} does not exists".format(ee_domain))
@expose(help="get example.com information")
@expose(help="Get example.com information")
def info(self):
(ee_domain, ee_www_domain) = ValidateDomain(self.app.pargs.site_name)
ee_db_name = ''
@ -105,7 +105,7 @@ class EESiteController(CementBaseController):
else:
Log.error(self, " site {0} does not exists".format(ee_domain))
@expose(help="Edit example.com's nginx configuration")
@expose(help="Edit Nginx configuration of example.com")
def edit(self):
(ee_domain, ee_www_domain) = ValidateDomain(self.app.pargs.site_name)
if os.path.isfile('/etc/nginx/sites-available/{0}'
@ -121,7 +121,7 @@ class EESiteController(CementBaseController):
else:
Log.error(self, " site {0} does not exists".format(ee_domain))
@expose(help="Display example.com's nginx configuration")
@expose(help="Display Nginx configuration of example.com")
def show(self):
# TODO Write code for ee site edit command here
(ee_domain, ee_www_domain) = ValidateDomain(self.app.pargs.site_name)
@ -136,7 +136,7 @@ class EESiteController(CementBaseController):
else:
Log.error(self, " site {0} does not exists".format(ee_domain))
@expose(help="change directory to site webroot")
@expose(help="Change directory to site webroot")
def cd(self):
(ee_domain, ee_www_domain) = ValidateDomain(self.app.pargs.site_name)
@ -455,7 +455,7 @@ class EESiteUpdateController(CementBaseController):
label = 'update'
stacked_on = 'site'
stacked_type = 'nested'
description = ('this command updates websites configuration to '
description = ('This command updates websites configuration to '
'another as per the options are provided')
arguments = [
(['site_name'],
@ -484,7 +484,7 @@ class EESiteUpdateController(CementBaseController):
dict(help="update to wpsc cache", action='store_true')),
]
@expose(help="update site type or cache")
@expose(help="Update site type or cache")
def default(self):
data = ''
(ee_domain,
@ -897,7 +897,7 @@ class EESiteDeleteController(CementBaseController):
label = 'delete'
stacked_on = 'site'
stacked_type = 'nested'
description = 'delete command deletes website'
description = 'To delete website'
arguments = [
(['site_name'],
dict(help='domain name to be deleted')),
@ -912,7 +912,7 @@ class EESiteDeleteController(CementBaseController):
dict(help="delete webroot only", action='store_true')),
]
@expose(help="delete website configuration and files")
@expose(help="Delete website configuration and files")
def default(self):
# TODO Write code for ee site update here
(ee_domain, ee_www_domain) = ValidateDomain(self.app.pargs.site_name)
@ -1022,12 +1022,12 @@ class EESiteListController(CementBaseController):
label = 'list'
stacked_on = 'site'
stacked_type = 'nested'
description = 'list websites'
description = 'List websites'
arguments = [
(['--enabled'],
dict(help='list enabled websites', action='store_true')),
dict(help='List enabled websites', action='store_true')),
(['--disabled'],
dict(help="list disabled websites", action='store_true')),
dict(help="List disabled websites", action='store_true')),
]
@expose(help="Lists websites")

36
ee/cli/plugins/site_functions.py
View File

@ -1,8 +1,3 @@
import os
import random
import string
import sys
import getpass
from ee.cli.plugins.stack import EEStackController
from ee.core.fileutils import EEFileUtils
from ee.core.mysql import EEMysql
@ -10,6 +5,11 @@ from ee.core.shellexec import EEShellExec
from ee.core.variables import EEVariables
from ee.core.aptget import EEAptGet
from ee.core.logging import Log
import os
import random
import string
import sys
import getpass
import glob
@ -109,20 +109,20 @@ def setupdatabase(self, data):
ee_db_name = (ee_db_name[0:6] + ee_random10)
# create MySQL database
Log.info(self, "Setting Up Database\t\t", end='')
Log.debug(self, "creating databse {0}".format(ee_db_name))
Log.info(self, "Setting up database\t\t", end='')
Log.debug(self, "Creating databse {0}".format(ee_db_name))
EEMysql.execute(self, "create database {0}"
.format(ee_db_name))
# Create MySQL User
Log.debug(self, "creating user {0}".format(ee_db_username))
Log.debug(self, "Creating user {0}".format(ee_db_username))
EEMysql.execute(self,
"create user {0}@{1} identified by '{2}'"
.format(ee_db_username, ee_mysql_grant_host,
ee_db_password))
# Grant permission
Log.debug(self, "setting up user privileges")
Log.debug(self, "Setting up user privileges")
EEMysql.execute(self,
"grant all privileges on {0}.* to {1}@{2}"
.format(ee_db_name, ee_db_username, ee_mysql_grant_host))
@ -201,14 +201,14 @@ def setupwordpress(self, data):
if not ee_wp_user:
ee_wp_user = EEVariables.ee_user
while not ee_wp_user:
Log.warn(self, "Usernames can have only alphanumeric"
Log.warn(self, "Username can have only alphanumeric"
"characters, spaces, underscores, hyphens,"
"periods and the @ symbol.")
try:
ee_wp_user = input('Enter WordPress username: ')
except EOFError as e:
Log.debug(self, "{0}".format(e))
Log.error(self, "Unable to input wp user name")
Log.error(self, "Unable to input WordPress user name")
if not ee_wp_pass:
ee_wp_pass = ee_random
@ -220,12 +220,12 @@ def setupwordpress(self, data):
ee_wp_email = input('Enter WordPress email: ')
except EOFError as e:
Log.debug(self, "{0}".format(e))
Log.error(self, "Unable to input wp user email")
Log.error(self, "Unable to input WordPress user email")
Log.debug(self, "setting up WordPress Tables")
Log.debug(self, "Setting up WordPress tables")
if not data['multisite']:
Log.debug(self, "creating tables for WordPress Single site")
Log.debug(self, "Creating tables for WordPress Single site")
EEShellExec.cmd_exec(self, "php /usr/bin/wp --allow-root core install "
"--url={0} --title={0} --admin_name={1} "
.format(data['www_domain'], ee_wp_user)
@ -233,7 +233,7 @@ def setupwordpress(self, data):
.format(ee_wp_pass, ee_wp_email),
errormsg="Unable to setup WordPress Tables")
else:
Log.debug(self, "creating tables for WordPress multisite")
Log.debug(self, "Creating tables for WordPress multisite")
EEShellExec.cmd_exec(self, "php /usr/bin/wp --allow-root "
"core multisite-install "
"--url={0} --title={0} --admin_name={1} "
@ -307,7 +307,7 @@ def uninstallwp_plugin(self, plugin_name, data):
def setwebrootpermissions(self, webroot):
Log.debug(self, "Setting Up Permissions")
Log.debug(self, "Setting up permissions")
EEFileUtils.chown(self, webroot, EEVariables.ee_php_user,
EEVariables.ee_php_user, recursive=True)
@ -317,7 +317,7 @@ def sitebackup(self, data):
backup_path = ee_site_webroot + '/backup/{0}'.format(EEVariables.ee_date)
if not EEFileUtils.isexist(self, backup_path):
EEFileUtils.mkdir(self, backup_path)
Log.info(self, "Backup Location : {0}".format(backup_path))
Log.info(self, "Backup location : {0}".format(backup_path))
EEFileUtils.copyfile(self, '/etc/nginx/sites-available/{0}'
.format(data['site_name']), backup_path)
@ -332,7 +332,7 @@ def sitebackup(self, data):
ee_db_name = (EEFileUtils.grep(self, configfiles[0],
'DB_NAME').split(',')[1]
.split(')')[0].strip().replace('\'', ''))
Log.info(self, 'Backing up Database \t\t', end='')
Log.info(self, 'Backing up database \t\t', end='')
EEShellExec.cmd_exec(self, "mysqldump {0} > {1}/{0}.sql"
.format(ee_db_name, backup_path),
errormsg="\nFailed: Backup Database")

6
ee/cli/plugins/sitedb.py
View File

@ -3,9 +3,9 @@ from sqlalchemy import ForeignKey, func
from sqlalchemy.orm import relationship, backref
from sqlalchemy.ext.declarative import declarative_base
from ee.core.logging import Log
import sys
from ee.core.database import db_session
from ee.core.models import SiteDB
import sys
def addNewSite(self, site, stype, cache, path,
@ -64,7 +64,7 @@ def deleteSiteInfo(self, site):
q = SiteDB.query.filter(SiteDB.sitename == site).first()
except Exception as e:
Log.debug(self, "{0}".format(e))
Log.error(self, "Unable to query database :")
Log.error(self, "Unable to query database")
if not q:
Log.error(self, "{0} does not exist in database".format(site))
@ -83,4 +83,4 @@ def getAllsites(self):
return q
except Exception as e:
Log.debug(self, "{0}".format(e))
Log.error(self, "Unable to query database :")
Log.error(self, "Unable to query database")

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

@ -9,7 +9,7 @@ class EEStackStatusController(CementBaseController):
label = 'stack_services'
stacked_on = 'stack'
stacked_type = 'embedded'
description = 'stack command manages stack operations'
description = 'Get status of stack'
arguments = [
(['--memcache'],
dict(help='start/stop/restart stack', action='store_true')),
@ -17,7 +17,7 @@ class EEStackStatusController(CementBaseController):
dict(help='start/stop/restart dovecot', action='store_true')),
]
@expose(help="start stack services")
@expose(help="Start stack services")
def start(self):
services = []
if self.app.pargs.nginx:
@ -44,7 +44,7 @@ class EEStackStatusController(CementBaseController):
for service in services:
EEService.start_service(self, service)
@expose(help="stop stack services")
@expose(help="Stop stack services")
def stop(self):
services = []
if self.app.pargs.nginx:
@ -71,7 +71,7 @@ class EEStackStatusController(CementBaseController):
for service in services:
EEService.stop_service(self, service)
@expose(help="restart stack services")
@expose(help="Restart stack services")
def restart(self):
services = []
if self.app.pargs.nginx:
@ -98,7 +98,7 @@ class EEStackStatusController(CementBaseController):
Log.debug(self, "nginx,php5-fpm,mysql,postfix services restart")
EEService.restart_service(self, service)
@expose(help="get stack status")
@expose(help="Get stack status")
def status(self):
services = []
if self.app.pargs.nginx:
@ -126,7 +126,7 @@ class EEStackStatusController(CementBaseController):
if EEService.get_service_status(self, service):
Log.info(self, "{0:10}: {1}".format(service, "Running"))
@expose(help="reload stack services")
@expose(help="Reload stack services")
def reload(self):
services = []
if self.app.pargs.nginx:

1
ee/core/addswap.py
View File

@ -1,3 +1,4 @@
"""EasyEngine SWAP creation"""
from ee.core.variables import EEVariables
from ee.core.shellexec import EEShellExec
from ee.core.fileutils import EEFileUtils

3
ee/core/apt_repo.py
View File

@ -1,6 +1,7 @@
import os
"""EasyEngine packages repository operations"""
from ee.core.shellexec import EEShellExec
from ee.core.variables import EEVariables
import os
class EERepo():

3
ee/core/database.py
View File

@ -1,8 +1,9 @@
"""EasyEngine generic database creation module"""
from sqlalchemy import create_engine
from sqlalchemy.orm import scoped_session, sessionmaker
from sqlalchemy.ext.declarative import declarative_base
#db_path = self.app.config.get('site', 'db_path')
# db_path = self.app.config.get('site', 'db_path')
engine = create_engine('sqlite:////var/lib/ee/ee.sqlite', convert_unicode=True)
db_session = scoped_session(sessionmaker(autocommit=False,
autoflush=False,

1
ee/core/domainvalidate.py
View File

@ -1,3 +1,4 @@
"""EasyEngine domain validation module."""
from urllib.parse import urlparse

3
ee/core/git.py
View File

@ -1,6 +1,7 @@
"""EasyEngine GIT module"""
from sh import git, ErrorReturnCode
import os
from ee.core.logging import Log
import os
class EEGit:

1
ee/core/logging.py
View File

@ -1,3 +1,4 @@
"""EasyEngine log module"""
class Log:

4
ee/core/shellexec.py
View File

@ -1,9 +1,9 @@
"""EasyEngine shell executaion functions."""
from subprocess import Popen
from ee.core.logging import Log
import os
import sys
import subprocess
from subprocess import Popen
from ee.core.logging import Log
class EEShellExec():

8
ee/core/symboliclink.py
View File

@ -1,8 +0,0 @@
"""EasyEngine symbolic link creation module"""
class EESymbolicLink():
"""Intialization for symbolic link"""
def ___init__():
# TODO method for symbolic link
pass

4
ee/core/variables.py
View File

@ -44,8 +44,8 @@ class EEVariables():
ee_user = config['user']['name']
ee_email = config['user']['email']
except Exception as e:
print("Unable to find GIT user name and Email")
sys.exit(1)
ee_user = input("Enter username for Git:")
ee_email = input("Enter email for Git:")
# Get System RAM and SWAP details
ee_ram = psutil.virtual_memory().total / (1024 * 1024)

Write Preview
Loading…
Cancel
Save