Skip to content

Commit fb2b115

Browse files
tipatterson-devtipatterson-dev
committed
first pass datastreams
1 parent 7c880d7 commit fb2b115

2 files changed

Lines changed: 143 additions & 0 deletions

File tree

‎conSys/constants.py‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ class APITerms(Enum):
2020
ITEMS = 'items'
2121
COMPONENTS = 'components'
2222
CONFORMANCE = 'conformance'
23+
SCHEMA = 'schema'
2324

2425

2526
class SystemTypes(Enum):

‎conSys/part_2/datastreams.py‎

Lines changed: 142 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,142 @@
1+
import requests
2+
from pydantic import HttpUrl
3+
4+
from conSys.con_sys_api import ConnectedSystemsRequestBuilder
5+
from conSys.constants import APITerms
6+
7+
8+
def list_all_datastreams(server_addr: HttpUrl, api_root: str = APITerms.API.value):
9+
"""
10+
Lists all datastreams
11+
:return:
12+
"""
13+
builder = ConnectedSystemsRequestBuilder()
14+
api_request = (builder.with_server_url(server_addr)
15+
.with_api_root(api_root)
16+
.for_resource_type(APITerms.DATASTREAMS.value)
17+
.build_url_from_base()
18+
.build())
19+
resp = requests.get(api_request.url, params=api_request.body, headers=api_request.headers)
20+
return resp.json()
21+
22+
23+
def list_all_datastreams_of_system(server_addr: HttpUrl, system_id: str, api_root: str = APITerms.API.value):
24+
"""
25+
Lists all datastreams of a system
26+
:return:
27+
"""
28+
builder = ConnectedSystemsRequestBuilder()
29+
api_request = (builder.with_server_url(server_addr)
30+
.with_api_root(api_root)
31+
.for_resource_type(APITerms.SYSTEMS.value)
32+
.with_resource_id(system_id)
33+
.for_resource_type(APITerms.DATASTREAMS.value)
34+
.build_url_from_base()
35+
.build())
36+
resp = requests.get(api_request.url, params=api_request.body, headers=api_request.headers)
37+
return resp.json()
38+
39+
40+
def add_datastreams_to_system(server_addr: HttpUrl, system_id: str, request_body: dict,
41+
api_root: str = APITerms.API.value):
42+
"""
43+
Adds a datastream to a system by its id
44+
:return:
45+
"""
46+
builder = ConnectedSystemsRequestBuilder()
47+
api_request = (builder.with_server_url(server_addr)
48+
.with_api_root(api_root)
49+
.for_resource_type(APITerms.SYSTEMS.value)
50+
.with_resource_id(system_id)
51+
.for_resource_type(APITerms.DATASTREAMS.value)
52+
.with_request_body(request_body)
53+
.build_url_from_base()
54+
.build())
55+
resp = requests.post(api_request.url, params=api_request.body, headers=api_request.headers)
56+
return resp.json()
57+
58+
59+
def retrieve_datastream_by_id(server_addr: HttpUrl, datastream_id: str, api_root: str = APITerms.API.value):
60+
"""
61+
Retrieves a datastream by its id
62+
:return:
63+
"""
64+
builder = ConnectedSystemsRequestBuilder()
65+
api_request = (builder.with_server_url(server_addr)
66+
.with_api_root(api_root)
67+
.for_resource_type(APITerms.DATASTREAMS.value)
68+
.with_resource_id(datastream_id)
69+
.build_url_from_base()
70+
.build())
71+
resp = requests.get(api_request.url, params=api_request.body, headers=api_request.headers)
72+
return resp.json()
73+
74+
75+
def update_datastream_by_id(server_addr: HttpUrl, datastream_id: str, request_body: dict,
76+
api_root: str = APITerms.API.value):
77+
"""
78+
Updates a datastream by its id
79+
:return:
80+
"""
81+
builder = ConnectedSystemsRequestBuilder()
82+
api_request = (builder.with_server_url(server_addr)
83+
.with_api_root(api_root)
84+
.for_resource_type(APITerms.DATASTREAMS.value)
85+
.with_resource_id(datastream_id)
86+
.with_request_body(request_body)
87+
.build_url_from_base()
88+
.build())
89+
resp = requests.put(api_request.url, params=api_request.body, headers=api_request.headers)
90+
return resp.json()
91+
92+
93+
def delete_datastream_by_id(server_addr: HttpUrl, datastream_id: str, api_root: str = APITerms.API.value):
94+
"""
95+
Deletes a datastream by its id
96+
:return:
97+
"""
98+
builder = ConnectedSystemsRequestBuilder()
99+
api_request = (builder.with_server_url(server_addr)
100+
.with_api_root(api_root)
101+
.for_resource_type(APITerms.DATASTREAMS.value)
102+
.with_resource_id(datastream_id)
103+
.build_url_from_base()
104+
.build())
105+
resp = requests.delete(api_request.url, params=api_request.body, headers=api_request.headers)
106+
return resp.json()
107+
108+
109+
def retrieve_datastream_schema(server_addr: HttpUrl, datastream_id: str, api_root: str = APITerms.API.value):
110+
"""
111+
Retrieves a datastream schema by its id
112+
:return:
113+
"""
114+
builder = ConnectedSystemsRequestBuilder()
115+
api_request = (builder.with_server_url(server_addr)
116+
.with_api_root(api_root)
117+
.for_resource_type(APITerms.DATASTREAMS.value)
118+
.with_resource_id(datastream_id)
119+
.for_resource_type(APITerms.SCHEMA.value)
120+
.build_url_from_base()
121+
.build())
122+
resp = requests.get(api_request.url, params=api_request.body, headers=api_request.headers)
123+
return resp.json()
124+
125+
126+
def update_datastream_schema(server_addr: HttpUrl, datastream_id: str, request_body: dict,
127+
api_root: str = APITerms.API.value):
128+
"""
129+
Updates a datastream schema by its id
130+
:return:
131+
"""
132+
builder = ConnectedSystemsRequestBuilder()
133+
api_request = (builder.with_server_url(server_addr)
134+
.with_api_root(api_root)
135+
.for_resource_type(APITerms.DATASTREAMS.value)
136+
.with_resource_id(datastream_id)
137+
.for_resource_type(APITerms.SCHEMA.value)
138+
.with_request_body(request_body)
139+
.build_url_from_base()
140+
.build())
141+
resp = requests.put(api_request.url, params=api_request.body, headers=api_request.headers)
142+
return resp.json()

0 commit comments

Comments
 (0)