From: W. Trevor King Date: Fri, 26 Oct 2012 17:09:21 +0000 (-0400) Subject: command: use mapfiles (JSON) instead of YAML for the command server X-Git-Tag: 1.1.0~36 X-Git-Url: http://git.tremily.us/?a=commitdiff_plain;h=1f771c68eec0cb191bd7d82f0f08134850a88e62;p=be.git command: use mapfiles (JSON) instead of YAML for the command server --- diff --git a/libbe/command/base.py b/libbe/command/base.py index 61404c1..36769f1 100644 --- a/libbe/command/base.py +++ b/libbe/command/base.py @@ -24,10 +24,10 @@ import os.path import StringIO import sys import urlparse -import yaml import libbe import libbe.storage +import libbe.storage.util.mapfile import libbe.ui.util.user import libbe.util.encoding import libbe.util.http @@ -348,10 +348,10 @@ class Command (object): raise NotImplementedError def _run_remote(self, **kwargs): - data = yaml.safe_dump({ + data = libbe.storage.util.mapfile.generate({ 'command': self.name, 'parameters': kwargs, - }) + }, context=0) url = urlparse.urljoin(self.server, 'run') page,final_url,info = libbe.util.http.get_post_url( url=url, get=False, data=data, agent=self.user_agent) diff --git a/libbe/command/serve_commands.py b/libbe/command/serve_commands.py index 4628bfb..442beea 100644 --- a/libbe/command/serve_commands.py +++ b/libbe/command/serve_commands.py @@ -30,11 +30,10 @@ import re import urllib import wsgiref.simple_server -import yaml - import libbe import libbe.command import libbe.command.base +import libbe.storage.util.mapfile import libbe.util.wsgi import libbe.version @@ -113,7 +112,7 @@ class ServerApp (libbe.util.wsgi.WSGI_AppObject, # handler utility functions def _parse_post(self, post): - return yaml.safe_load(post) + return libbe.storage.util.mapfile.parse(post) def check_login(self, environ): user = environ.get('be-auth.user', None) @@ -208,10 +207,10 @@ if libbe.TESTING: def test_run_list(self): list = libbe.command.list.List() params = list._parse_options_args() - data = yaml.safe_dump({ + data = libbe.storage.util.mapfile.generate({ 'command': 'list', 'parameters': params, - }) + }, context=0) self.getURL(self.app, '/run', method='POST', data=data) self.failUnless(self.status.startswith('200 '), self.status) self.failUnless(