Source code for toxicbuild.script

# -*- coding: utf-8 -*-

# Copyright 2016 Juca Crispim <>

# This file is part of toxicbuild.

# toxicbuild is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.

# toxicbuild is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# GNU General Public License for more details.

# You should have received a copy of the GNU General Public License
# along with toxicbuild. If not, see <>.

import asyncio
import os
import subprocess
import sys
from toxicbuild.core.cmd import command, main
from toxicbuild.core.utils import changedir
from toxicbuild.master import create as create_master
from toxicbuild.master import create_user
from toxicbuild.master import create_settings_and_connect
from toxicbuild.master.slave import Slave
from toxicbuild.slave import create as create_slave
from toxicbuild.ui import create as create_ui

main._generate_queue = []

[docs]def create(root_dir): # pragma no cover """ Creates a new toxicbuild environment. Environments for master, slave and ui will be created. :param --root_dir: Root directory for toxicbuild. """ slave_root = os.path.join(root_dir, 'slave') master_root = os.path.join(root_dir, 'master') ui_root = os.path.join(root_dir, 'ui') # first we create a slave and a master slave_token = create_slave(slave_root) master_token = create_master(master_root) # a super user to access stuff conffile = os.path.join(master_root, 'toxicmaster.conf') create_user(conffile, superuser=True) with changedir(master_root): create_settings_and_connect() loop = asyncio.get_event_loop() # now we add this slave to the master slave = Slave(name='LocalSlave', token=slave_token, host='localhost', port=7777) loop.run_until_complete( # and finally create a web ui create_ui(ui_root, master_token)
[docs]def start(workdir, loglevel='error'): # pragma no cover """Starts toxicbuild. New instances for master, slave and web ui wil be started. :param workdir: Work directory for toxicbuild. :param --loglevel: Level for logging messages.""" _call_processes(workdir, loglevel)
[docs]def stop(workdir): # pragma no cover """Stops toxicbuild The master, slave and web ui instances will be stopped. :param workdir: workdir for the instance to be stopped.""" _call_processes(workdir, daemonize=False)
[docs]def restart(workdir): """Restarts toxicbuild The instances of master, slave and web ui in ``workdir`` will be restarted. :param workdir: Workdir for master to be killed. """ stop(workdir) start(workdir)
def _call_processes(workdir, loglevel=None, daemonize=True): # pragma no cover # just pretend you didnt' see this function slave_root = os.path.join(workdir, 'slave') master_root = os.path.join(workdir, 'master') ui_root = os.path.join(workdir, 'ui') cmd = sys.argv[0].replace('-script', '') slave_cmd = cmd.replace('build', 'slave') master_cmd = cmd.replace('build', 'master') web_cmd = cmd.replace('build', 'web') slave_cmd_line = sys.argv[:] slave_cmd_line[0] = slave_cmd slave_cmd_line[2] = slave_root if daemonize: slave_cmd_line.append('--daemonize') if loglevel: slave_cmd_line.append('--loglevel') slave_cmd_line.append(loglevel) master_cmd_line = sys.argv[:] master_cmd_line[0] = master_cmd master_cmd_line[2] = master_root if daemonize: master_cmd_line.append('--daemonize') if loglevel: master_cmd_line.append('--loglevel') master_cmd_line.append(loglevel) web_cmd_line = sys.argv[:] web_cmd_line[0] = web_cmd web_cmd_line[2] = ui_root if daemonize: web_cmd_line.append('--daemonize') if loglevel: web_cmd_line.append('--loglevel') web_cmd_line.append(loglevel) if __name__ == '__main__': # pragma no cover main()