External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-02-01 01:28:09 -03:30
Code Issues Packages Projects Releases Wiki Activity

Get nested resources in tastypie largely operational.

Browse Source
This commit is contained in:
Michael DeHaan
2013-03-19 00:02:52 -04:00
parent 728f9961b4
commit 3f4842d9e7
6 changed files with 717 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
lib/cli/main.py
View File

@@ -18,21 +18,26 @@ AUTH = HTTPBasicAuth(username, password)
# wrappers around URL request functions
def get(url_seg, expect=200):
resp = requests.get("%s/api/v1/%s" % (server, url_seg), auth=AUTH)
resp = None
if 'api/v1' not in url_seg:
url = "%s/api/v1/%s" % (server, url_seg)
else:
url = "%s%s" % (server, url_seg)
resp = requests.get(url, auth=AUTH)
if resp.status_code != expect:
assert "GET: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
assert False, "GET: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
return resp
def post(url_seg, data, expect=201):
resp = requests.post("%s/api/v1/%s" % (server, url_seg), auth=AUTH, data=data, headers=HEADERS)
if resp.status_code != expect:
assert "POST: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
assert False, "POST: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
return resp
def update_item(item, data, expect=200):
resp = requests.put("%s/%s" % (server, item.resource_uri), auth=AUTH, data=data, headers=HEADERS)
def update_item(item, data, expect=204):
resp = requests.put("%s%s" % (server, item.resource_uri), auth=AUTH, data=data, headers=HEADERS)
if resp.status_code != expect:
assert "PUT: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
assert False, "PUT: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
return resp
def delete(url_seg, expect=204):
@@ -40,7 +45,7 @@ def delete(url_seg, expect=204):
url_seg = "%s/" % url_seg
resp = requests.delete("%s%s" % (server, url_seg), auth=AUTH, headers=HEADERS)
if resp.status_code != expect:
assert "DELETE: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
assert False, "DELETE: Expecting %s got %s: %s" % (expect, resp.status_code, resp.text)
return resp
# =============================================================
@@ -56,12 +61,17 @@ class Collection(object):
try:
self.data = json.loads(self.response.text)
except Exception, e:
print self.response.text
raise e
try:
self.meta = self.data['meta']
except Exception, e:
print self.response.text
raise e
self.meta = self.data['meta']
self.objects = self.data['objects']
self.meta = self.data['meta']
self.objects = self.data['objects']
def base_url(self):
return exceptions.NotImplementedError()
@@ -91,6 +101,12 @@ class Entry(object):
def __repr__(self):
return repr(self.data)
def refresh(self):
print "URI=%s" % self.resource_uri
data = get(self.resource_uri)
print "Data=%s" % data
return Entry(json.loads(data.text))
def update(self, data):
json_data = json.dumps(data)
return update_item(self, json_data)
@@ -157,6 +173,9 @@ try:
orgs = Organizations()
orgs.add(dict(description="new org?", name="new org"))
last_org = list(Organizations())[-1]
last_org.refresh()
Organizations().print_display()
print "*** adding a project"