3 application = iotdm.application
4 container = iotdm.container
5 contentInstance = iotdm.contentInstance
8 def connect_to_iotdm(host, user, pw, p):
9 return iotdm.connect(host, base="InCSE1", auth=(user, pw), protocol=p)
12 def create_resource(connection, parent, restype, a=None):
13 restype = int(restype)
15 x = connection.create(parent, restype)
17 x = connection.create(parent, restype, attr=a)
19 raise AssertionError("Cannot create this resource")
20 elif hasattr(x, "status_code"):
21 if x.status_code < 200 or x.status_code > 299:
23 "Cannot create this resource [%d] : %s" % (x.status_code, x.text)
28 # this might not be necessary now that the library functions can take dicts
31 def create_subscription(connection, parent, ip, port):
32 uri = "http://%s:%d" % (ip, int(port))
33 x = connection.create(
36 {"notificationURI": uri, "notificationContentType": "wholeResource"},
39 raise AssertionError("Cannot create this subscription")
40 elif hasattr(x, "status_code"):
41 if x.status_code < 200 or x.status_code > 299:
43 "Cannot create subscription [%d] : %s" % (x.status_code, x.text)
48 def retrieve_resource(connection, resid):
49 x = connection.retrieve(resid)
51 raise AssertionError("Cannot retrieve this resource")
52 elif hasattr(x, "status_code"):
53 if x.status_code < 200 or x.status_code > 299:
55 "Cannot retrieve this resource [%d] : %s" % (x.status_code, x.text)
60 def update_resource(connection, resid, attr):
61 x = connection.update(resid, attr)
63 raise AssertionError("Cannot update this resource")
64 elif hasattr(x, "status_code"):
65 if x.status_code < 200 or x.status_code > 299:
67 "Cannot update this resource [%d] : %s" % (x.status_code, x.text)
72 def delete_resource(connection, resid):
73 x = connection.delete(resid)
75 raise AssertionError("Cannot delete this resource")
76 elif hasattr(x, "status_code"):
77 if x.status_code < 200 or x.status_code > 299:
79 "Cannot delete this resource [%d] : %s" % (x.status_code, x.text)
97 return x.elapsed.total_seconds()