112 lines
3.9 KiB
Python
112 lines
3.9 KiB
Python
import os, shutil
|
|
from . import Executor
|
|
|
|
class Linker(Executor):
|
|
'''
|
|
Symbolically links dotfiles.
|
|
'''
|
|
|
|
_directive = 'link'
|
|
|
|
def can_handle(self, directive):
|
|
return directive == self._directive
|
|
|
|
def handle(self, directive, data):
|
|
if directive != self._directive:
|
|
raise ValueError('Linker cannot handle directive %s' % directive)
|
|
return self._process_links(data)
|
|
|
|
def _process_links(self, links):
|
|
success = True
|
|
for destination, source in links.items():
|
|
if isinstance(source, dict):
|
|
# extended config
|
|
path = source['path']
|
|
force = source.get('force', False)
|
|
if force:
|
|
success &= self._delete(destination)
|
|
else:
|
|
path = source
|
|
success &= self._link(path, destination)
|
|
if success:
|
|
self._log.info('All links have been set up')
|
|
else:
|
|
self._log.error('Some links were not successfully set up')
|
|
return success
|
|
|
|
def _is_link(self, path):
|
|
'''
|
|
Returns true if the path is a symbolic link.
|
|
'''
|
|
return os.path.islink(os.path.expanduser(path))
|
|
|
|
def _link_destination(self, path):
|
|
'''
|
|
Returns the absolute path to the destination of the symbolic link.
|
|
'''
|
|
path = os.path.expanduser(path)
|
|
rel_dest = os.readlink(path)
|
|
return os.path.join(os.path.dirname(path), rel_dest)
|
|
|
|
def _exists(self, path):
|
|
'''
|
|
Returns true if the path exists.
|
|
'''
|
|
path = os.path.expanduser(path)
|
|
return os.path.exists(path)
|
|
|
|
def _delete(self, path):
|
|
success = True
|
|
if self._exists(path) and not self._is_link(path):
|
|
fullpath = os.path.expanduser(path)
|
|
try:
|
|
if os.path.isdir(fullpath):
|
|
shutil.rmtree(fullpath)
|
|
else:
|
|
os.remove(fullpath)
|
|
except OSError:
|
|
self._log.warning('Failed to remove %s' % path)
|
|
success = False
|
|
else:
|
|
self._log.lowinfo('Removing %s' % path)
|
|
return success
|
|
|
|
def _link(self, source, link_name):
|
|
'''
|
|
Links link_name to source.
|
|
|
|
Returns true if successfully linked files.
|
|
'''
|
|
success = False
|
|
source = os.path.join(self._base_directory, source)
|
|
if (not self._exists(link_name) and self._is_link(link_name) and
|
|
self._link_destination(link_name) != source):
|
|
self._log.warning('Invalid link %s -> %s' %
|
|
(link_name, self._link_destination(link_name)))
|
|
elif not self._exists(link_name) and self._exists(source):
|
|
try:
|
|
os.symlink(source, os.path.expanduser(link_name))
|
|
except OSError:
|
|
self._log.warning('Linking failed %s -> %s' % (link_name, source))
|
|
else:
|
|
self._log.lowinfo('Creating link %s -> %s' % (link_name, source))
|
|
success = True
|
|
elif self._exists(link_name) and not self._is_link(link_name):
|
|
self._log.warning(
|
|
'%s already exists but is a regular file or directory' %
|
|
link_name)
|
|
elif self._is_link(link_name) and self._link_destination(link_name) != source:
|
|
self._log.warning('Incorrect link %s -> %s' %
|
|
(link_name, self._link_destination(link_name)))
|
|
elif not self._exists(source):
|
|
if self._is_link(link_name):
|
|
self._log.warning('Nonexistant target %s -> %s' %
|
|
(link_name, source))
|
|
else:
|
|
self._log.warning('Nonexistant target for %s : %s' %
|
|
(link_name, source))
|
|
else:
|
|
self._log.lowinfo('Link exists %s -> %s' % (link_name, source))
|
|
success = True
|
|
return success
|