mirror of
https://github.com/frappe/bench.git
synced 2025-01-25 07:58:24 +00:00
90 lines
3.0 KiB
Python
90 lines
3.0 KiB
Python
import os
|
|
from .utils import exec_cmd, get_frappe, check_git_for_shallow_clone, get_config, build_assets, restart_supervisor_processes, get_cmd_output
|
|
|
|
import logging
|
|
import requests
|
|
import json
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
def get_apps(bench='.'):
|
|
try:
|
|
with open(os.path.join(bench, 'sites', 'apps.txt')) as f:
|
|
return f.read().strip().split('\n')
|
|
except IOError:
|
|
return []
|
|
|
|
def add_to_appstxt(app, bench='.'):
|
|
apps = get_apps(bench=bench)
|
|
if app not in apps:
|
|
apps.append(app)
|
|
return write_appstxt(apps, bench=bench)
|
|
|
|
def remove_from_appstxt(app, bench='.'):
|
|
apps = get_apps(bench=bench)
|
|
if app in apps:
|
|
apps.remove(app)
|
|
return write_appstxt(apps, bench=bench)
|
|
|
|
def write_appstxt(apps, bench='.'):
|
|
with open(os.path.join(bench, 'sites', 'apps.txt'), 'w') as f:
|
|
return f.write('\n'.join(apps))
|
|
|
|
def get_app(app, git_url, branch=None, bench='.'):
|
|
logger.info('getting app {}'.format(app))
|
|
shallow_clone = '--depth 1' if check_git_for_shallow_clone() and get_config().get('shallow_clone') else ''
|
|
branch = '--branch {branch}'.format(branch=branch) if branch else ''
|
|
exec_cmd("git clone {git_url} {branch} {shallow_clone} --origin upstream {app}".format(
|
|
git_url=git_url,
|
|
app=app,
|
|
shallow_clone=shallow_clone,
|
|
branch=branch),
|
|
cwd=os.path.join(bench, 'apps'))
|
|
print 'installing', app
|
|
install_app(app, bench=bench)
|
|
build_assets(bench=bench)
|
|
conf = get_config()
|
|
if conf.get('restart_supervisor_on_update'):
|
|
restart_supervisor_processes(bench=bench)
|
|
|
|
def new_app(app, bench='.'):
|
|
logger.info('creating new app {}'.format(app))
|
|
exec_cmd("{frappe} --make_app {apps}".format(frappe=get_frappe(bench=bench), apps=os.path.join(bench, 'apps')))
|
|
install_app(app, bench=bench)
|
|
|
|
def install_app(app, bench='.'):
|
|
logger.info('installing {}'.format(app))
|
|
conf = get_config()
|
|
find_links = '--find-links={}'.format(conf.get('wheel_cache_dir')) if conf.get('wheel_cache_dir') else ''
|
|
exec_cmd("{pip} install -q {find_links} -e {app}".format(
|
|
pip=os.path.join(bench, 'env', 'bin', 'pip'),
|
|
app=os.path.join(bench, 'apps', app),
|
|
find_links=find_links))
|
|
add_to_appstxt(app, bench=bench)
|
|
|
|
def pull_all_apps(bench='.'):
|
|
apps_dir = os.path.join(bench, 'apps')
|
|
apps = [app for app in os.listdir(apps_dir) if os.path.isdir(os.path.join(apps_dir, app))]
|
|
rebase = '--rebase' if get_config().get('rebase_on_pull') else ''
|
|
for app in apps:
|
|
app_dir = os.path.join(apps_dir, app)
|
|
if os.path.exists(os.path.join(app_dir, '.git')):
|
|
logger.info('pulling {0}'.format(app))
|
|
exec_cmd("git pull {rebase} upstream {branch}".format(rebase=rebase, branch=get_current_branch(app_dir)), cwd=app_dir)
|
|
|
|
def get_current_branch(repo_dir):
|
|
return get_cmd_output("basename $(git symbolic-ref -q HEAD)", cwd=repo_dir)
|
|
|
|
def install_apps_from_path(path, bench='.'):
|
|
apps = get_apps_json(path)
|
|
for app in apps:
|
|
get_app(app['name'], app['url'], branch=app.get('branch'), bench=bench)
|
|
|
|
def get_apps_json(path):
|
|
if path.startswith('http'):
|
|
r = requests.get(path)
|
|
return r.json()
|
|
else:
|
|
with open(path) as f:
|
|
return json.load(f)
|