201 lines
6.8 KiB
Python
201 lines
6.8 KiB
Python
# Absolute import needed to import ~/.mopidy/settings.py and not ourselves
|
|
from __future__ import absolute_import
|
|
from copy import copy
|
|
import getpass
|
|
import logging
|
|
import os
|
|
from pprint import pformat
|
|
import sys
|
|
|
|
from mopidy import SettingsError, SETTINGS_PATH, SETTINGS_FILE
|
|
from mopidy.utils.log import indent
|
|
|
|
logger = logging.getLogger('mopidy.utils.settings')
|
|
|
|
class SettingsProxy(object):
|
|
def __init__(self, default_settings_module):
|
|
self.default = self._get_settings_dict_from_module(
|
|
default_settings_module)
|
|
self.local = self._get_local_settings()
|
|
self.runtime = {}
|
|
|
|
def _get_local_settings(self):
|
|
if not os.path.isfile(SETTINGS_FILE):
|
|
return {}
|
|
sys.path.insert(0, SETTINGS_PATH)
|
|
# pylint: disable = F0401
|
|
import settings as local_settings_module
|
|
# pylint: enable = F0401
|
|
return self._get_settings_dict_from_module(local_settings_module)
|
|
|
|
def _get_settings_dict_from_module(self, module):
|
|
settings = filter(lambda (key, value): self._is_setting(key),
|
|
module.__dict__.iteritems())
|
|
return dict(settings)
|
|
|
|
def _is_setting(self, name):
|
|
return name.isupper()
|
|
|
|
@property
|
|
def current(self):
|
|
current = copy(self.default)
|
|
current.update(self.local)
|
|
current.update(self.runtime)
|
|
return current
|
|
|
|
def __getattr__(self, attr):
|
|
if not self._is_setting(attr):
|
|
return
|
|
if attr not in self.current:
|
|
raise SettingsError(u'Setting "%s" is not set.' % attr)
|
|
value = self.current[attr]
|
|
if isinstance(value, basestring) and len(value) == 0:
|
|
raise SettingsError(u'Setting "%s" is empty.' % attr)
|
|
if not value:
|
|
return value
|
|
if attr.endswith('_PATH') or attr.endswith('_FILE'):
|
|
value = os.path.expanduser(value)
|
|
value = os.path.abspath(value)
|
|
return value
|
|
|
|
def __setattr__(self, attr, value):
|
|
if self._is_setting(attr):
|
|
self.runtime[attr] = value
|
|
else:
|
|
super(SettingsProxy, self).__setattr__(attr, value)
|
|
|
|
def validate(self, interactive):
|
|
if interactive:
|
|
self._read_missing_settings_from_stdin(self.current, self.runtime)
|
|
if self.get_errors():
|
|
logger.error(u'Settings validation errors: %s',
|
|
indent(self.get_errors_as_string()))
|
|
raise SettingsError(u'Settings validation failed.')
|
|
|
|
def _read_missing_settings_from_stdin(self, current, runtime):
|
|
for setting, value in sorted(current.iteritems()):
|
|
if isinstance(value, basestring) and len(value) == 0:
|
|
runtime[setting] = self._read_from_stdin(setting + u': ')
|
|
|
|
def _read_from_stdin(self, prompt):
|
|
if u'_PASSWORD' in prompt:
|
|
return (getpass.getpass(prompt)
|
|
.decode(sys.stdin.encoding, 'ignore'))
|
|
else:
|
|
sys.stdout.write(prompt)
|
|
return (sys.stdin.readline().strip()
|
|
.decode(sys.stdin.encoding, 'ignore'))
|
|
|
|
def get_errors(self):
|
|
return validate_settings(self.default, self.local)
|
|
|
|
def get_errors_as_string(self):
|
|
lines = []
|
|
for (setting, error) in self.get_errors().iteritems():
|
|
lines.append(u'%s: %s' % (setting, error))
|
|
return '\n'.join(lines)
|
|
|
|
|
|
def validate_settings(defaults, settings):
|
|
"""
|
|
Checks the settings for both errors like misspellings and against a set of
|
|
rules for renamed settings, etc.
|
|
|
|
Returns of setting names with associated errors.
|
|
|
|
:param defaults: Mopidy's default settings
|
|
:type defaults: dict
|
|
:param settings: the user's local settings
|
|
:type settings: dict
|
|
:rtype: dict
|
|
"""
|
|
errors = {}
|
|
|
|
changed = {
|
|
'CUSTOM_OUTPUT': 'OUTPUT',
|
|
'DUMP_LOG_FILENAME': 'DEBUG_LOG_FILENAME',
|
|
'DUMP_LOG_FORMAT': 'DEBUG_LOG_FORMAT',
|
|
'FRONTEND': 'FRONTENDS',
|
|
'GSTREAMER_AUDIO_SINK': 'CUSTOM_OUTPUT',
|
|
'LOCAL_MUSIC_FOLDER': 'LOCAL_MUSIC_PATH',
|
|
'LOCAL_OUTPUT_OVERRIDE': 'CUSTOM_OUTPUT',
|
|
'LOCAL_PLAYLIST_FOLDER': 'LOCAL_PLAYLIST_PATH',
|
|
'LOCAL_TAG_CACHE': 'LOCAL_TAG_CACHE_FILE',
|
|
'MIXER_ALSA_CONTROL': None,
|
|
'MIXER_EXT_PORT': None,
|
|
'MIXER_EXT_SPEAKERS_A': None,
|
|
'MIXER_EXT_SPEAKERS_B': None,
|
|
'SERVER': None,
|
|
'SERVER_HOSTNAME': 'MPD_SERVER_HOSTNAME',
|
|
'SERVER_PORT': 'MPD_SERVER_PORT',
|
|
'SPOTIFY_HIGH_BITRATE': 'SPOTIFY_BITRATE',
|
|
'SPOTIFY_LIB_APPKEY': None,
|
|
'SPOTIFY_LIB_CACHE': 'SPOTIFY_CACHE_PATH',
|
|
}
|
|
|
|
for setting, value in settings.iteritems():
|
|
if setting in changed:
|
|
if changed[setting] is None:
|
|
errors[setting] = u'Deprecated setting. It may be removed.'
|
|
else:
|
|
errors[setting] = u'Deprecated setting. Use %s.' % (
|
|
changed[setting],)
|
|
continue
|
|
|
|
if setting == 'BACKENDS':
|
|
if 'mopidy.backends.despotify.DespotifyBackend' in value:
|
|
errors[setting] = (
|
|
u'Deprecated setting value. '
|
|
u'"mopidy.backends.despotify.DespotifyBackend" is no '
|
|
u'longer available.')
|
|
continue
|
|
|
|
if setting == 'OUTPUTS':
|
|
errors[setting] = (
|
|
u'Deprecated setting, please change to OUTPUT. OUTPUT expectes '
|
|
u'a GStreamer bin describing your desired output.')
|
|
continue
|
|
|
|
if setting == 'SPOTIFY_BITRATE':
|
|
if value not in (96, 160, 320):
|
|
errors[setting] = (
|
|
u'Unavailable Spotify bitrate. Available bitrates are 96, '
|
|
u'160, and 320.')
|
|
|
|
if setting not in defaults:
|
|
errors[setting] = u'Unknown setting. Is it misspelled?'
|
|
continue
|
|
|
|
return errors
|
|
|
|
def list_settings_optparse_callback(*args):
|
|
"""
|
|
Prints a list of all settings.
|
|
|
|
Called by optparse when Mopidy is run with the :option:`--list-settings`
|
|
option.
|
|
"""
|
|
from mopidy import settings
|
|
print format_settings_list(settings)
|
|
sys.exit(0)
|
|
|
|
def format_settings_list(settings):
|
|
errors = settings.get_errors()
|
|
lines = []
|
|
for (key, value) in sorted(settings.current.iteritems()):
|
|
default_value = settings.default.get(key)
|
|
masked_value = mask_value_if_secret(key, value)
|
|
lines.append(u'%s: %s' % (key, indent(pformat(masked_value), places=2)))
|
|
if value != default_value and default_value is not None:
|
|
lines.append(u' Default: %s' %
|
|
indent(pformat(default_value), places=4))
|
|
if errors.get(key) is not None:
|
|
lines.append(u' Error: %s' % errors[key])
|
|
return '\n'.join(lines)
|
|
|
|
def mask_value_if_secret(key, value):
|
|
if key.endswith('PASSWORD') and value:
|
|
return u'********'
|
|
else:
|
|
return value
|