From 0c66fd1c3735953c722c45f036fb408b11d966bd Mon Sep 17 00:00:00 2001
From: Roman <zajic@zajic.net>
Date: Fri, 28 Mar 2025 06:18:48 +0000
Subject: [PATCH] fix: remaining DA endpoints

---
 src/api_clients/rest.py | 32 ++++++++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)

diff --git a/src/api_clients/rest.py b/src/api_clients/rest.py
index e98fd40..0722c03 100644
--- a/src/api_clients/rest.py
+++ b/src/api_clients/rest.py
@@ -1,3 +1,5 @@
+from urllib.parse import quote
+
 from src.libs.custom_logger import get_custom_logger
 import json
 from src.api_clients.base_client import BaseClient
@@ -31,6 +33,14 @@ class REST(BaseClient):
         response = self.rest_call("get", "cryptarchia/info")
         return response.json()
 
+    def cryptarchia_headers(self, from_header_id, to_header_id):
+        response = self.rest_call("get", f"cryptarchia/headers?from={quote(from_header_id, safe='')}" f"&to={quote(to_header_id, safe='')}")
+        return response.json()
+
+    def da_add_share(self, data):
+        response = self.rest_call("post", "da/add-share", json.dumps(data))
+        return response
+
     def da_disperse_data(self, data):
         response = self.rest_call("post", "disperse-data", json.dumps(data))
         return response
@@ -38,3 +48,25 @@ class REST(BaseClient):
     def da_get_range(self, query):
         response = self.rest_call("post", "da/get-range", json.dumps(query))
         return response.json()
+
+    def da_get_commitments(self, query):
+        response = self.rest_call("get", "da/get-commitments", json.dumps(query))
+        return response.json()
+
+    def da_get_share(self, query):
+        response = self.rest_call("get", "da/get-share", json.dumps(query))
+        return response.json()
+
+    # DA_GET_SHARES: & str = "/da/sampling/shares"; Implemented ?
+
+    def da_block_peer(self, data):
+        response = self.rest_call("post", "da/block-peer", json.dumps(data))
+        return response
+
+    def da_unblock_peer(self, data):
+        response = self.rest_call("post", "da/unblock-peer", json.dumps(data))
+        return response
+
+    def da_blacklisted_peers(self):
+        response = self.rest_call("get", "da/blacklisted-peers")
+        return response.json()