fix yaml config loader
This commit is contained in:
parent
913d89192e
commit
82e9108aa8
3 changed files with 3 additions and 3 deletions
|
|
@ -32,7 +32,7 @@ from weboob.capabilities.messages import ICapMessages
|
||||||
from weboob.tools.application import BaseApplication
|
from weboob.tools.application import BaseApplication
|
||||||
|
|
||||||
class Monboob(BaseApplication):
|
class Monboob(BaseApplication):
|
||||||
APPNAME = 'mail'
|
APPNAME = 'monboob'
|
||||||
CONFIG = {'interval': 15,
|
CONFIG = {'interval': 15,
|
||||||
'domain': 'weboob.example.org',
|
'domain': 'weboob.example.org',
|
||||||
'recipient': 'weboob@example.org',
|
'recipient': 'weboob@example.org',
|
||||||
|
|
@ -45,7 +45,7 @@ class Monboob(BaseApplication):
|
||||||
print >>sys.stderr, "Also, you need to use 'weboobcfg' to set backend configs"
|
print >>sys.stderr, "Also, you need to use 'weboobcfg' to set backend configs"
|
||||||
return -1
|
return -1
|
||||||
|
|
||||||
self.weboob.load_modules(ICapMessages)
|
self.weboob.load_backends(ICapMessages)
|
||||||
|
|
||||||
self.weboob.schedule(self.config.get('interval'), self.process)
|
self.weboob.schedule(self.config.get('interval'), self.process)
|
||||||
self.weboob.loop()
|
self.weboob.loop()
|
||||||
|
|
|
||||||
|
|
@ -46,7 +46,7 @@ class BaseApplication(object):
|
||||||
if klass is None:
|
if klass is None:
|
||||||
# load Config only here because some applications don't want
|
# load Config only here because some applications don't want
|
||||||
# to depend on yaml and do not use this function
|
# to depend on yaml and do not use this function
|
||||||
from weboob.tools.config.yaml import YamlConfig
|
from weboob.tools.config.yamlconfig import YamlConfig
|
||||||
klass = YamlConfig
|
klass = YamlConfig
|
||||||
|
|
||||||
if path is None:
|
if path is None:
|
||||||
|
|
|
||||||
85
weboob/tools/config/yamlconfig.py
Normal file
85
weboob/tools/config/yamlconfig.py
Normal file
|
|
@ -0,0 +1,85 @@
|
||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
|
||||||
|
"""
|
||||||
|
Copyright(C) 2010 Romain Bignon
|
||||||
|
|
||||||
|
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, version 3 of the License.
|
||||||
|
|
||||||
|
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, write to the Free Software
|
||||||
|
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
|
from __future__ import with_statement
|
||||||
|
|
||||||
|
import yaml
|
||||||
|
|
||||||
|
from .iconfig import IConfig, ConfigError
|
||||||
|
|
||||||
|
class YamlConfig(IConfig):
|
||||||
|
def __init__(self, path):
|
||||||
|
self.path = path
|
||||||
|
self.values = {}
|
||||||
|
|
||||||
|
def load(self, default={}):
|
||||||
|
self.values = default.copy()
|
||||||
|
|
||||||
|
try:
|
||||||
|
with open(self.path, 'r') as f:
|
||||||
|
self.values = yaml.load(f)
|
||||||
|
except IOError:
|
||||||
|
pass
|
||||||
|
|
||||||
|
if self.values is None:
|
||||||
|
self.values = {}
|
||||||
|
|
||||||
|
def save(self):
|
||||||
|
with open(self.path, 'w') as f:
|
||||||
|
yaml.dump(self.values, f)
|
||||||
|
|
||||||
|
def get(self, *args, **kwargs):
|
||||||
|
default = None
|
||||||
|
if 'default' in kwargs:
|
||||||
|
default = kwargs['default']
|
||||||
|
|
||||||
|
v = self.values
|
||||||
|
for a in args[:-1]:
|
||||||
|
try:
|
||||||
|
v = v[a]
|
||||||
|
except KeyError:
|
||||||
|
if not default is None:
|
||||||
|
v[a] = {}
|
||||||
|
v = v[a]
|
||||||
|
else:
|
||||||
|
raise ConfigError()
|
||||||
|
except TypeError:
|
||||||
|
raise ConfigError()
|
||||||
|
|
||||||
|
try:
|
||||||
|
v = v[args[-1]]
|
||||||
|
except KeyError:
|
||||||
|
v[args[-1]] = default
|
||||||
|
v = v[args[-1]]
|
||||||
|
|
||||||
|
return v
|
||||||
|
|
||||||
|
def set(self, *args):
|
||||||
|
v = self.values
|
||||||
|
for a in args[:-2]:
|
||||||
|
try:
|
||||||
|
v = v[a]
|
||||||
|
except KeyError:
|
||||||
|
v[a] = {}
|
||||||
|
v = v[a]
|
||||||
|
except TypeError:
|
||||||
|
raise ConfigError()
|
||||||
|
|
||||||
|
v[args[-2]] = args[-1]
|
||||||
Loading…
Reference in a new issue