logos-blockchain/logos-blockchain-e2e-tests
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-e2e-tests.git synced 2026-01-03 21:53:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: add cluster and cryptarchia endpoints

Browse Source
This commit is contained in:
Roman 2025-03-28 03:05:51 +00:00
parent c3ef9302c0
commit 4684bbc70d
No known key found for this signature in database
GPG Key ID: 8857C6B7DBCEA320
4 changed files with 20 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/api_clients/invalid_rest.py
View File

@ -61,12 +61,12 @@ class InvalidRest(REST):
def __init__(self, rest_port): def __init__(self, rest_port):
super().__init__(rest_port) super().__init__(rest_port)
def send_dispersal_request(self, data): def da_disperse_data(self, data):
data = alter_dispersal_data(data) data = alter_dispersal_data(data)
response = self.rest_call("post", "disperse-data", json.dumps(data)) response = self.rest_call("post", "disperse-data", json.dumps(data))
return response return response
def send_get_range(self, query): def da_get_range(self, query):
query = alter_get_range_query(query) query = alter_get_range_query(query)
response = self.rest_call("post", "da/get-range", json.dumps(query)) response = self.rest_call("post", "da/get-range", json.dumps(query))
return response.json() return response.json()

14
src/api_clients/rest.py
View File

@ -19,14 +19,22 @@ class REST(BaseClient):
headers = {"accept": "text/plain", "Connection": "close"} headers = {"accept": "text/plain", "Connection": "close"}
return self.make_request(method, url, headers=headers, data=payload) return self.make_request(method, url, headers=headers, data=payload)
def info(self): def cl_metrics(self):
response = self.rest_call("get", "cl/metrics")
return response.json()
def cl_status(self, query):
response = self.rest_call("post", "cl/status", json.dumps(query))
return response.json()
def cryptarchia_info(self):
response = self.rest_call("get", "cryptarchia/info") response = self.rest_call("get", "cryptarchia/info")
return response.json() return response.json()
def send_dispersal_request(self, data): def da_disperse_data(self, data):
response = self.rest_call("post", "disperse-data", json.dumps(data)) response = self.rest_call("post", "disperse-data", json.dumps(data))
return response return response
def send_get_range(self, query): def da_get_range(self, query):
response = self.rest_call("post", "da/get-range", json.dumps(query)) response = self.rest_call("post", "da/get-range", json.dumps(query))
return response.json() return response.json()

8
src/client/proxy_client.py
View File

@ -91,12 +91,12 @@ class ProxyClient:
def send_dispersal_request(self, data, send_invalid=False): def send_dispersal_request(self, data, send_invalid=False):
if send_invalid: if send_invalid:
return self._invalid_api.send_dispersal_request(data) return self._invalid_api.da_disperse_data(data)
return self._api.send_dispersal_request(data) return self._api.da_disperse_data(data)
def send_get_data_range_request(self, data, send_invalid=False): def send_get_data_range_request(self, data, send_invalid=False):
if send_invalid: if send_invalid:
return self._invalid_api.send_get_range(data) return self._invalid_api.da_get_range(data)
return self._api.send_get_range(data) return self._api.da_get_range(data)

6
src/node/nomos_node.py
View File

@ -118,7 +118,7 @@ class NomosNode:
return "nomos" in self._container_name return "nomos" in self._container_name
def info(self): def info(self):
return self._api.info() return self._api.cryptarchia_info()
def node_type(self): def node_type(self):
return self._node_type return self._node_type
@ -153,7 +153,7 @@ class NomosNode:
logger.debug("No keyword matches found in the logs.") logger.debug("No keyword matches found in the logs.")
def send_dispersal_request(self, data): def send_dispersal_request(self, data):
return self._api.send_dispersal_request(data) return self._api.da_disperse_data(data)
def send_get_data_range_request(self, data): def send_get_data_range_request(self, data):
return self._api.send_get_range(data) return self._api.da_get_range(data)