diff options
Diffstat (limited to 'sugar_network/client/injector.py')
| -rw-r--r-- | sugar_network/client/injector.py | 267 |
1 files changed, 0 insertions, 267 deletions
diff --git a/sugar_network/client/injector.py b/sugar_network/client/injector.py deleted file mode 100644 index 04a6765..0000000 --- a/sugar_network/client/injector.py +++ /dev/null @@ -1,267 +0,0 @@ -# Copyright (C) 2010-2013 Aleksey Lim -# -# This program 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. -# -# This program is distributed in the hope that it will be useful, -# but WITHOUT ANY WARRANTY; without even the implied warranty of -# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the -# GNU General Public License for more details. -# -# You should have received a copy of the GNU General Public License -# along with this program. If not, see <http://www.gnu.org/licenses/>. - -import os -import json -import shutil -import logging -from os.path import join, exists, basename, dirname - -from sugar_network import client, toolkit -from sugar_network.client import journal, cache -from sugar_network.toolkit import pipe, lsb_release - - -_PMS_PATHS = { - 'Debian': '/var/lib/dpkg/status', - 'Fedora': '/var/lib/rpm/Packages', - 'Ubuntu': '/var/lib/dpkg/status', - } - -_logger = logging.getLogger('client.injector') -_pms_path = _PMS_PATHS.get(lsb_release.distributor_id()) -_mtime = None - - -def make(guid): - return pipe.fork(_make, log_path=client.profile_path('logs', guid), - context=guid, session={'context': guid}) - - -def launch(guid, args=None, activity_id=None, object_id=None, uri=None, - color=None): - if object_id: - if not activity_id: - activity_id = journal.get(object_id, 'activity_id') - if not color: - color = journal.get(object_id, 'icon-color') - - if not activity_id: - activity_id = journal.create_activity_id() - - if args is None: - args = [] - args.extend([ - '-b', guid, - '-a', activity_id, - ]) - if object_id: - args.extend(['-o', object_id]) - if uri: - args.extend(['-u', uri]) - - return pipe.fork(_launch, log_path=client.profile_path('logs', guid), - context=guid, args=args, session={ - 'context': guid, - 'activity_id': activity_id, - 'color': color, - }) - - -def clone(guid): - return pipe.fork(_clone, log_path=client.profile_path('logs', guid), - context=guid, session={'context': guid}) - - -def clone_impl(context, **params): - return pipe.fork(_clone_impl, - log_path=client.profile_path('logs', context), - context_guid=context, params=params, session={'context': context}) - - -def invalidate_solutions(mtime): - global _mtime - _mtime = mtime - - -def _make(context): - pipe.feedback('analyze') - solution, stability = _solve(context) - pipe.feedback('solved', environ={'solution': solution}) - - to_install = [] - for impl in solution: - if 'install' in impl: - to_install.extend(impl.pop('install')) - if to_install: - pipe.trace('Install %s package(s)', - ', '.join([i['name'] for i in to_install])) - from sugar_network.client import packagekit - packagekit.install(to_install) - - for impl in solution: - if 'path' in impl or impl['stability'] == 'packaged': - continue - impl_path = cache.get(impl['id'], impl) - if 'prefix' in impl: - impl_path = join(impl_path, impl['prefix']) - impl['path'] = impl_path - - if stability is not None: - _set_cached_solution(context, stability, solution) - - pipe.feedback('ready') - return solution - - -def _launch(context, args): - solution = _make(context) - - args = solution[0]['command'] + (args or []) - _logger.info('Executing %r feed: %s', context, args) - pipe.feedback('exec') - - _activity_env(solution[0], os.environ) - os.execvpe(args[0], args, os.environ) - - -def _clone(context): - solution = _make(context) - - cloned = [] - try: - for impl in solution: - path = impl.get('path') - if not path or \ - path == '/': # Fake path set by "sugar" dependency - continue - dst_path = toolkit.unique_filename( - client.activity_dirs.value[0], basename(path)) - cloned.append(dst_path) - _logger.info('Clone implementation to %r', dst_path) - toolkit.cptree(path, dst_path) - impl['path'] = dst_path - except Exception: - while cloned: - shutil.rmtree(cloned.pop(), ignore_errors=True) - raise - - _set_cached_solution(context, None, solution) - - -def _clone_impl(context_guid, params): - conn = client.IPCConnection() - - context = conn.get(['context', context_guid], reply=['title']) - impl = conn.meta(['context', context_guid], cmd='clone', **params) - - src_path = cache.get(impl['guid'], impl) - if 'extract' in impl: - src_path = join(src_path, impl['extract']) - dst_path = toolkit.unique_filename( - client.activity_dirs.value[0], basename(src_path)) - - _logger.info('Clone implementation to %r', dst_path) - toolkit.cptree(src_path, dst_path) - - _set_cached_solution(context_guid, None, [{ - 'id': dst_path, - 'context': context_guid, - 'version': impl['version'], - 'name': context['title'], - 'stability': impl['stability'], - 'spec': join(dst_path, 'activity', 'activity.info'), - 'path': dst_path, - 'command': impl['commands']['activity']['exec'].split(), - }]) - - -def _solve(context): - pipe.trace('Start solving %s feed', context) - stability = client.stability(context) - - solution, stale = _get_cached_solution(context, stability) - if stale is False: - pipe.trace('Reuse cached solution') - return solution, None - - conn = client.IPCConnection() - if solution is not None and conn.get(cmd='status')['route'] == 'offline': - pipe.trace('Reuse stale cached solution in offline mode') - return solution, None - - from sugar_network.client import solver - - return solver.solve(conn, context, stability), stability - - -def _activity_env(impl, environ): - root = client.profile_path('data', impl['context']) - impl_path = impl['path'] - - for path in ['instance', 'data', 'tmp']: - path = join(root, path) - if not exists(path): - os.makedirs(path) - - environ['PATH'] = ':'.join([ - join(impl_path, 'activity'), - join(impl_path, 'bin'), - environ['PATH'], - ]) - environ['SUGAR_BUNDLE_PATH'] = impl_path - environ['SUGAR_BUNDLE_ID'] = impl['context'] - environ['SUGAR_BUNDLE_NAME'] = impl['name'].encode('utf8') - environ['SUGAR_BUNDLE_VERSION'] = impl['version'] - environ['SUGAR_ACTIVITY_ROOT'] = root - environ['PYTHONPATH'] = impl_path + ':' + environ.get('PYTHONPATH', '') - environ['SUGAR_LOCALEDIR'] = join(impl_path, 'locale') - - os.chdir(impl_path) - - -def _cached_solution_path(guid): - return client.path('cache', 'solutions', guid[:2], guid) - - -def _get_cached_solution(guid, stability): - path = _cached_solution_path(guid) - solution = None - if exists(path): - try: - with file(path) as f: - cached_api_url, cached_stability, solution = json.load(f) - except Exception, error: - _logger.debug('Cannot open %r solution: %s', path, error) - if solution is None: - return None, None - - stale = (cached_api_url != client.api_url.value) - if not stale and cached_stability is not None: - stale = set(cached_stability) != set(stability) - if not stale and _mtime is not None: - stale = (_mtime > os.stat(path).st_mtime) - if not stale and _pms_path is not None: - stale = (os.stat(_pms_path).st_mtime > os.stat(path).st_mtime) - - for impl in solution: - impl_path = impl.get('path') - if impl_path and not exists(impl_path): - os.unlink(path) - return None, None - if not stale: - spec = impl.get('spec') - if spec and exists(spec): - stale = (os.stat(spec).st_mtime > os.stat(path).st_mtime) - - return solution, stale - - -def _set_cached_solution(guid, stability, solution): - path = _cached_solution_path(guid) - if not exists(dirname(path)): - os.makedirs(dirname(path)) - with file(path, 'w') as f: - json.dump([client.api_url.value, stability, solution], f) |