github
/
teleport
mirror of https://github.com/tp4a/teleport
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
teleport/dist/server/script/main.py

652 lines
23 KiB
Python
Raw Normal View History

temp.
2017-03-24 18:31:09 +00:00
# -*- coding: utf-8 -*-
import os
import sys
import time
temp.
2017-03-26 16:24:23 +00:00
import stat
temp.
2017-03-24 18:31:09 +00:00
from core.env import env
import core.colorconsole as cc
import core.utils as utils
class InstallerBase:
def __init__(self):
self._all_ok = True
self._err_msg = list()
self._is_installed = False
self._install_path = ''
self._config_path = ''
self._data_path = ''
self._log_path = ''
self._installed_ver_str = 'UNKNOWN'
self._current_ver = 'UNKNOWN'
self._def_install_path = ''
ver_file = os.path.join(env.root_path, 'data', 'www', 'teleport', 'app', 'eom_ver.py')
try:
with open(ver_file, 'r') as f:
x = f.readlines()
for i in x:
s = i.split('=', 1)
if 'TS_VER' == s[0].strip():
self._current_ver = s[1].strip()[1:-1]
break
except FileNotFoundError:
raise RuntimeError('Cannot detect installer version.')
temp.
2017-03-26 16:24:23 +00:00
def _init(self):
temp.
2017-03-24 18:31:09 +00:00
_width = 79
cc.v('')
cc.v('[]{}[]'.format('=' * (_width - 4)))
_str = 'Teleport Server Installation'
cc.o((cc.CR_VERBOSE, ' | '), (cc.CR_INFO, _str), (cc.CR_VERBOSE, '{}|'.format(' ' * (_width - 5 - len(_str)))))
cc.v(' |{}|'.format('=' * (_width - 4)))
temp.
2017-03-26 16:24:23 +00:00
cc.o((cc.CR_VERBOSE, ' | ver: '), (cc.CR_NORMAL, self._current_ver),
(cc.CR_VERBOSE, '{}|'.format(' ' * (_width - 13 - len(self._current_ver)))))
temp.
2017-03-24 18:31:09 +00:00
_str = 'author: apexliu@eomsoft.net'
cc.v(' | {}{}|'.format(_str, ' ' * (_width - 5 - len(_str))))
cc.v('[]{}[]'.format('=' * (_width - 4)))
cc.v('')
cc.v('Welcome to install Teleport Server!')
cc.v('')
# cc.v(' NOTICE: if you want to use the default settings, just press `Enter`...')
temp.
2017-03-26 16:24:23 +00:00
cc.o((cc.CR_VERBOSE,
'NOTICE: There are a few steps need you enter information or make choice,\n if you want to use the '),
(cc.CR_WARN, 'default settings'), (cc.CR_VERBOSE, ', just press `Enter` key.'))
cc.o((cc.CR_VERBOSE, ' Otherwise you need enter the '), (cc.CR_NORMAL, 'highlight character'),
(cc.CR_VERBOSE, ' to make choice.'))
temp.
2017-03-24 18:31:09 +00:00
cc.v('')
cc.v('')
cc.v('Prepare installation...')
self._check_installation()
self._check_installation_ver()
cc.v('')
def run(self):
temp.
2017-03-26 16:24:23 +00:00
self._init()
temp.
2017-03-24 18:31:09 +00:00
if not self._is_installed:
temp.
2017-03-26 16:24:23 +00:00
self._do_install()
temp.
2017-03-24 18:31:09 +00:00
else:
cc.v('')
cc.v('Found teleport server have installed at `{}` already.'.format(self._install_path))
while True:
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice('What are you wanna to do?',
[('upgrade', 2, True), ('uninstall', 0, False), ('quit', 0, False)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'q' == x:
temp.
2017-03-26 16:24:23 +00:00
break
temp.
2017-03-24 18:31:09 +00:00
elif 'u' == x:
temp.
2017-03-26 16:24:23 +00:00
self._do_uninstall()
break
temp.
2017-03-24 18:31:09 +00:00
elif 'g' == x:
temp.
2017-03-26 16:24:23 +00:00
self._do_upgrade()
break
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _do_install(self):
temp.
2017-03-24 18:31:09 +00:00
while True:
cc.v('')
self._install_path = self._prompt_input('Set installation path', self._def_install_path)
temp.
2017-03-26 16:24:23 +00:00
_use_anyway = False
temp.
2017-03-24 18:31:09 +00:00
if os.path.exists(self._install_path):
while True:
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice(
'The target path `{}` has already exists,\ndo you want to use it anyway?'.format(
self._install_path), [('Yes', 0, True), ('No', 0, False)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'y' == x:
temp.
2017-03-26 16:24:23 +00:00
_use_anyway = True
temp.
2017-03-24 18:31:09 +00:00
break
elif 'n' == x:
break
temp.
2017-03-26 16:24:23 +00:00
if _use_anyway:
temp.
2017-03-24 18:31:09 +00:00
break
else:
break
temp.
2017-03-26 16:24:23 +00:00
self._fix_path()
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
utils.make_dirs(self._install_path)
temp.
2017-03-24 18:31:09 +00:00
self._copy_files()
self._install_service()
self._start_service()
time.sleep(2)
self._check_service()
temp.
2017-03-26 16:24:23 +00:00
def _do_uninstall(self):
temp.
2017-03-24 18:31:09 +00:00
if not self._is_installed:
return
_del_settings = False
while True:
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice('Do you want to keep your database and settings?',
[('Yes', 0, True), ('No', 0, False)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'y' == x:
break
elif 'n' == x:
_del_settings = True
break
if _del_settings:
while True:
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice('Seriously!! Are you sure to remove all data and settings?',
[('Yes', 0, False), ('No', 0, True)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'y' == x:
break
elif 'n' == x:
_del_settings = False
break
self._stop_service()
time.sleep(2)
self._uninstall_service()
self._delete_files(_del_settings)
temp.
2017-03-26 16:24:23 +00:00
def _do_upgrade(self):
temp.
2017-03-24 18:31:09 +00:00
x = self._ver_compare(self._current_ver, self._installed_ver_str)
if x == 0:
while True:
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice(
'The same version `{}` installed, are you sure to overwrite?'.format(self._current_ver),
[('Yes', 0, False), ('No', 0, True)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'y' == x:
break
elif 'n' == x:
return
elif x < 0:
while True:
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice(
'A new version `{}` installed, rollback to old version `{}` may cause Teleport Server not functionally.\nAre you sure to rollback to old version?'.format(
self._installed_ver_str, self._current_ver), [('Yes', 0, False), ('No', 0, True)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'y' == x:
break
elif 'n' == x:
return
else:
while True:
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice(
'Now upgrade from version `{}` to `{}`, \nAre you sure to upgrade to new version?'.format(
self._installed_ver_str, self._current_ver), [('Yes', 0, False), ('No', 0, True)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'y' == x:
break
elif 'n' == x:
return
while True:
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
x = self._prompt_choice('Make sure you have backup your database and settings.\nAre you sure to continue?',
[('Yes', 0, False), ('No', 0, True)])
temp.
2017-03-24 18:31:09 +00:00
x = x.lower()
if 'y' == x:
break
elif 'n' == x:
return
self._stop_service()
time.sleep(2)
self._uninstall_service()
self._delete_files(False)
time.sleep(1)
self._copy_files()
self._install_service()
self._start_service()
time.sleep(2)
self._check_service()
@staticmethod
def _prompt_choice(message, choices):
cc.v('{} ['.format(message), end='')
def_choice = ''
for i in range(len(choices)):
if i > 0:
cc.v('/', end='')
msg = choices[i][0]
idx = choices[i][1]
if choices[i][2]:
msg = msg.upper()
def_choice = msg[idx].lower()
cc.w(msg[:idx], end='')
cc.n(msg[idx], end='')
cc.w(msg[idx + 1:], end='')
else:
msg = msg.lower()
cc.v(msg[:idx], end='')
cc.n(msg[idx], end='')
cc.v(msg[idx + 1:], end='')
cc.v(']: ', end='')
try:
x = input().strip()
if len(x) == 0:
x = def_choice
except EOFError:
x = def_choice
return x
@staticmethod
def _prompt_input(message, def_value):
cc.v('{} ['.format(message), end='')
cc.w(def_value, end='')
cc.v(']: ', end='')
try:
x = input().strip()
if len(x) == 0:
x = def_value
except EOFError:
x = def_value
return x
@staticmethod
def _ver_compare(left, right):
l = left.split('.')
r = right.split('.')
len_l = len(l)
len_r = len(r)
if len_l < len_r:
for i in range(len_r - len_l):
l.append('0')
elif len_l > len_r:
for i in range(len_l - len_r):
r.append('0')
cnt = len(l)
for i in range(cnt):
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
if int(l[i]) < int(r[i]):
temp.
2017-03-24 18:31:09 +00:00
return -1
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
elif int(l[i]) > int(r[i]):
temp.
2017-03-24 18:31:09 +00:00
return 1
return 0
def _check_installation(self):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`check_installation` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _check_installation_ver(self):
if not self._is_installed:
return
# try to get the installed version from www/teleport/app/eom_ver.py
cc.v(' - check installed version ... ', end='')
ver_file = os.path.join(self._install_path, 'www', 'teleport', 'app', 'eom_ver.py')
try:
with open(ver_file) as f:
x = f.readlines()
for i in x:
s = i.split('=', 1)
if 'TS_VER' == s[0].strip():
self._installed_ver_str = s[1].strip()[1:-1]
cc.i('[{}]'.format(self._installed_ver_str))
# self._installed_ver = self._ver_str_to_ver(self._installed_ver_str)
break
except FileNotFoundError:
cc.e('[failed]')
cc.e(' the installation maybe broken')
temp.
2017-03-26 16:24:23 +00:00
def _fix_path(self):
raise RuntimeError('`_fix_path` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _copy_files(self):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`copy_files` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _delete_files(self, del_settings):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`delete_files` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _install_service(self):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`install_service` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _start_service(self):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`start_service` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _stop_service(self):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`stop_service` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _uninstall_service(self):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`uninstall_service` not implement.')
temp.
2017-03-24 18:31:09 +00:00
def _check_service(self):
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('`check_service` not implement.')
temp.
2017-03-24 18:31:09 +00:00
class InstallerWin(InstallerBase):
def __init__(self):
super().__init__()
temp.
2017-03-26 16:24:23 +00:00
self._core_service_name = 'Teleport Core Service'
self._web_service_name = 'Teleport Web Service'
self._old_core_service_name = 'EOM Teleport Core Service'
self._old_web_service_name = 'EOM Teleport Web Service'
temp.
2017-03-24 18:31:09 +00:00
self._def_install_path = r'{}\teleport-server'.format(os.environ['SystemDrive'])
temp.
2017-03-26 16:24:23 +00:00
def _get_service_exec(self, service_name):
_err, _ = utils.sys_exec(r'sc query "{}"'.format(service_name))
temp.
2017-03-24 18:31:09 +00:00
if 1060 == _err:
temp.
2017-03-26 16:24:23 +00:00
return None
temp.
2017-03-24 18:31:09 +00:00
else:
temp.
2017-03-26 16:24:23 +00:00
_err, _o = utils.sys_exec(r'sc qc "{}"'.format(service_name))
temp.
2017-03-24 18:31:09 +00:00
if _err != 0:
temp.
2017-03-26 16:24:23 +00:00
raise RuntimeError('Can not get execute file path of service `{}`.'.format(service_name))
temp.
2017-03-24 18:31:09 +00:00
for i in _o:
_x = i.split(':', 1)
if 'BINARY_PATH_NAME' == _x[0].strip():
_path = _x[1].strip()
temp.
2017-03-26 16:24:23 +00:00
return _path
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
return None
def _check_installation(self):
cc.o(' - check local installation ... ', end='')
_check_service_name = [self._old_core_service_name, self._old_web_service_name, self._core_service_name,
self._web_service_name]
for _service_name in _check_service_name:
_exec_file = self._get_service_exec(_service_name)
if _exec_file is not None:
self._is_installed = True
self._install_path = os.path.abspath(os.path.join(os.path.dirname(_exec_file), '..'))
break
temp.
2017-03-24 18:31:09 +00:00
if self._is_installed:
fixme: core on linux, can not found core.ini after install.
2017-03-26 19:12:15 +00:00
cc.i('[{}]'.format(self._install_path))
temp.
2017-03-26 16:24:23 +00:00
self._fix_path()
temp.
2017-03-24 18:31:09 +00:00
else:
cc.i('[not exists]')
return
temp.
2017-03-26 16:24:23 +00:00
def _fix_path(self):
self._config_path = os.path.join(self._install_path, 'etc')
self._data_path = os.path.join(self._install_path, 'data')
self._log_path = os.path.join(self._install_path, 'log')
temp.
2017-03-24 18:31:09 +00:00
def _copy_files(self):
utils.copy_ex(os.path.join(env.src_path, 'bin'), os.path.join(self._install_path, 'bin'))
utils.copy_ex(os.path.join(env.src_path, 'www'), os.path.join(self._install_path, 'www'))
if not os.path.exists(self._config_path):
utils.copy_ex(os.path.join(env.src_path, 'tmp', 'etc'), self._config_path)
def _delete_files(self, del_settings):
utils.remove(os.path.join(self._install_path, 'bin'))
utils.remove(os.path.join(self._install_path, 'www'))
if del_settings:
utils.remove(self._data_path)
utils.remove(self._config_path)
utils.remove(self._log_path)
# only remove the installation path when it empty.
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
try:
os.rmdir(self._install_path)
except OSError:
pass
temp.
2017-03-24 18:31:09 +00:00
def _install_service(self):
cc.o(' - install teleport core service ... ', end='')
_core = os.path.join(self._install_path, 'bin', 'tp_core.exe')
_err, _ = utils.sys_exec(r'"{}" -i'.format(_core))
if _err == 0 or _err == 1:
cc.i('[done]')
else:
cc.e('[failed]')
raise RuntimeError('Install core service failed. error code: {}'.format(_err))
cc.o(' - install teleport web service ... ', end='')
_core = os.path.join(self._install_path, 'bin', 'tp_web.exe')
_err, _ = utils.sys_exec(r'"{}" -i'.format(_core))
if _err == 0 or _err == 1:
cc.i('[done]')
else:
cc.e('[failed]')
raise RuntimeError('Install web service failed. error code: {}'.format(_err))
return True
def _start_service(self):
cc.o(' - start teleport core service ... ', end='')
temp.
2017-03-26 16:24:23 +00:00
_err, _o = utils.sys_exec(r'sc start "{}"'.format(self._core_service_name))
temp.
2017-03-24 18:31:09 +00:00
# print('start core', _err, _o)
if _err == 0:
cc.i('[done]')
else:
cc.e('[failed]')
raise RuntimeError('Can not start core service.')
cc.o(' - start teleport web service ...', end='')
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
_err, _ = utils.sys_exec(r'sc start "{}"'.format(self._web_service_name))
temp.
2017-03-24 18:31:09 +00:00
if _err == 0:
cc.i('[done]')
else:
cc.e('[failed]')
raise RuntimeError('Can not start web service.')
def _stop_service(self):
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
_check_service_name = [self._old_core_service_name, self._old_web_service_name, self._core_service_name,
self._web_service_name]
temp.
2017-03-24 18:31:09 +00:00
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
for _service_name in _check_service_name:
cc.o(' - stop service [{}] ... '.format(_service_name), end='')
_err, _ = utils.sys_exec(r'sc stop "{}"'.format(_service_name))
if _err == 1060 or _err == 1062 or _err == 0:
cc.i('[done]')
elif _err == 1072:
cc.e('[failed]')
raise RuntimeError('can not stop service [{}]. please close Service Manager and try again.'.format(_service_name))
else:
cc.e('[failed]')
raise RuntimeError('can not stop service [{}].'.format(_service_name))
temp.
2017-03-24 18:31:09 +00:00
def _uninstall_service(self):
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
_check_service_name = [self._old_core_service_name, self._old_web_service_name, self._core_service_name,
self._web_service_name]
temp.
2017-03-24 18:31:09 +00:00
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
for _service_name in _check_service_name:
cc.o(' - remove service [{}] ... '.format(_service_name), end='')
_err, _ = utils.sys_exec(r'sc delete "{}"'.format(_service_name))
if _err == 1060 or _err == 0:
cc.i('[done]')
elif _err == 1072:
cc.e('[failed]')
raise RuntimeError('can not remove service [{}]. please close Service Manager and try again.'.format(_service_name))
else:
cc.e('[failed]')
raise RuntimeError('can not remove service [{}].'.format(_service_name))
temp.
2017-03-24 18:31:09 +00:00
def _check_service(self):
cc.o(' - check teleport core service status ... ', end='')
temp.
2017-03-26 16:24:23 +00:00
_err, _o = utils.sys_exec(r'sc query "{}"'.format(self._core_service_name))
temp.
2017-03-24 18:31:09 +00:00
if _err == 1060 or _err == 0:
cc.i('[running]')
else:
cc.e('[not running]')
cc.o(' - check teleport web service status ... ', end='')
修复调整路径带来的小bug。
2017-03-26 21:11:47 +00:00
_err, _o = utils.sys_exec(r'sc query "{}"'.format(self._web_service_name))
temp.
2017-03-24 18:31:09 +00:00
if _err == 1060 or _err == 0:
cc.i('[running]')
else:
cc.e('[not running]')
class InstallerLinux(InstallerBase):
def __init__(self):
super().__init__()
temp.
2017-03-26 16:24:23 +00:00
self._def_install_path = '/usr/local/teleport'
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _check_installation(self):
temp.
2017-03-26 17:30:07 +00:00
cc.o(' - check local installation ... ', end='')
temp.
2017-03-26 16:24:23 +00:00
# old version, the daemon named `eom_ts`.
# from 2.0.0.1, the daemon rename to `teleport`.
# we must check both.
temp.
2017-03-26 17:30:07 +00:00
if os.path.exists('/etc/init.d/eom_ts'):
self._is_installed = True
self._install_path = '/usr/local/eom/teleport'
# self._fix_path()
elif os.path.exists('/etc/init.d/teleport'):
temp.
2017-03-26 16:24:23 +00:00
self._is_installed = True
self._install_path = '/usr/local/teleport'
temp.
2017-03-26 17:30:07 +00:00
# self._fix_path()
if self._is_installed:
fixme: core on linux, can not found core.ini after install.
2017-03-26 19:12:15 +00:00
cc.i('[{}]'.format(self._install_path))
temp.
2017-03-26 16:24:23 +00:00
self._fix_path()
temp.
2017-03-26 17:30:07 +00:00
else:
cc.i('[not exists]')
return
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _fix_path(self):
self._config_path = '/etc/teleport'
temp.
2017-04-17 10:21:47 +00:00
self._data_path = os.path.join('/var/lib/teleport')
temp.
2017-03-26 16:24:23 +00:00
self._log_path = os.path.join('/var/log/teleport')
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _copy_files(self):
utils.copy_ex(os.path.join(env.src_path, 'bin'), os.path.join(self._install_path, 'bin'))
utils.copy_ex(os.path.join(env.src_path, 'www'), os.path.join(self._install_path, 'www'))
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
if not os.path.exists(self._config_path):
utils.copy_ex(os.path.join(env.src_path, 'tmp', 'etc'), self._config_path)
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _delete_files(self, del_settings):
utils.remove(os.path.join(self._install_path, 'bin'))
utils.remove(os.path.join(self._install_path, 'www'))
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
utils.remove(os.path.join(self._install_path, 'start.sh'))
utils.remove(os.path.join(self._install_path, 'stop.sh'))
utils.remove(os.path.join(self._install_path, 'status.sh'))
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
# only remove the installation path when it empty.
temp.
2017-03-24 18:31:09 +00:00
try:
temp.
2017-03-26 16:24:23 +00:00
os.rmdir(self._install_path)
except OSError:
pass # maybe the install path not empty.
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
if del_settings:
utils.remove(self._data_path)
utils.remove(self._config_path)
utils.remove(self._log_path)
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _install_service(self):
daemon_files = [
['daemon.in', '/etc/init.d/teleport'],
['start.sh.in', os.path.join(self._install_path, 'start.sh')],
['stop.sh.in', os.path.join(self._install_path, 'stop.sh')],
['status.sh.in', os.path.join(self._install_path, 'status.sh')],
]
for _d in daemon_files:
cc.v('process [{}] to [{}]'.format(_d[0], _d[1]))
_orig_file = os.path.join(env.root_path, 'daemon', _d[0])
with open(_orig_file, 'r') as f:
_text = f.read()
_text = _text.format(daemon_path=self._install_path)
with open(_d[1], 'w') as f:
f.write(_text)
if not os.path.exists(_d[1]):
raise RuntimeError('can not generate daemon file [{}].'.format(_d[1]))
# owner: RWX, group: RX, others: RX
os.chmod(_d[1], stat.S_IRWXU | stat.S_IRGRP | stat.S_IXGRP | stat.S_IROTH | stat.S_IXOTH)
# create symbolic link
os.symlink('/etc/init.d/teleport', '/etc/rc2.d/S50teleport')
os.symlink('/etc/init.d/teleport', '/etc/rc3.d/S50teleport')
os.symlink('/etc/init.d/teleport', '/etc/rc4.d/S50teleport')
os.symlink('/etc/init.d/teleport', '/etc/rc5.d/S50teleport')
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _start_service(self):
cc.v('')
cc.o('start services...')
fixme: core on linux, can not found core.ini after install.
2017-03-26 19:12:15 +00:00
_ret, _ = utils.sys_exec('service teleport start', direct_output=True)
if _ret != 0:
raise RuntimeError('not all services started.')
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _stop_service(self):
cc.o(' - stop teleport core service ... ', end='')
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
# old version, the daemon named `eom_ts`.
if os.path.exists('/etc/init.d/eom_ts'):
utils.sys_exec('/etc/init.d/eom_ts stop')
# from 2.0.0.1, the daemon rename to `teleport`.
if os.path.exists('/etc/init.d/teleport'):
utils.sys_exec('/etc/init.d/teleport stop')
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
cc.i('[done]')
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _uninstall_service(self):
# old version, the daemon named `eom_ts`.
utils.remove('/etc/init.d/eom_ts')
utils.remove('/etc/rc2.d/S50eom_ts')
utils.remove('/etc/rc3.d/S50eom_ts')
utils.remove('/etc/rc4.d/S50eom_ts')
utils.remove('/etc/rc5.d/S50eom_ts')
# from 2.0.0.1, the daemon rename to `teleport`.
utils.remove('/etc/init.d/teleport')
utils.remove('/etc/rc2.d/S50teleport')
utils.remove('/etc/rc3.d/S50teleport')
utils.remove('/etc/rc4.d/S50teleport')
utils.remove('/etc/rc5.d/S50teleport')
temp.
2017-03-24 18:31:09 +00:00
temp.
2017-03-26 16:24:23 +00:00
def _check_service(self):
cc.v('')
cc.o('check services status...')
utils.sys_exec('service teleport status', direct_output=True)
temp.
2017-03-24 18:31:09 +00:00
def _main():
cc.set_default(sep='', end='\n')
env.init()
if env.is_win:
_installer = InstallerWin()
elif env.is_linux:
_installer = InstallerLinux()
else:
raise RuntimeError('Sorry, teleport server does not support this platform yet.')
_installer.run()
def main():
try:
_main()
temp.
2017-03-26 16:24:23 +00:00
cc.i('\n--==[ ALL DONE ]==--\n')
return 0
temp.
2017-03-24 18:31:09 +00:00
except KeyboardInterrupt:
temp.
2017-03-26 16:24:23 +00:00
return 1
temp.
2017-03-24 18:31:09 +00:00
except RuntimeError as err:
cc.v('')
cc.v('')
cc.e(err.__str__())
cc.v('')
temp.
2017-03-26 16:24:23 +00:00
return 2
temp.
2017-03-24 18:31:09 +00:00
except:
cc.f('got exception.')
temp.
2017-03-26 16:24:23 +00:00
return 3
temp.
2017-03-24 18:31:09 +00:00
if __name__ == '__main__':
main()