From 844dfc6570f2614c1c7fdb4692f967b15c6a4d86 Mon Sep 17 00:00:00 2001
From: 1yam <lyam.gomes@epitech.eu>
Date: Tue, 6 Jan 2026 20:32:50 +0100
Subject: [PATCH] feature: new method in AlephHttpClient
 `get_store_estimated_price`

---
 src/aleph/sdk/client/http.py | 55 ++++++++++++++++++++++++++++++++++++
 1 file changed, 55 insertions(+)

diff --git a/src/aleph/sdk/client/http.py b/src/aleph/sdk/client/http.py
index 2d4505b3..6fa6d4ac 100644
--- a/src/aleph/sdk/client/http.py
+++ b/src/aleph/sdk/client/http.py
@@ -524,6 +524,61 @@ async def watch_messages(
                 elif msg.type == aiohttp.WSMsgType.ERROR:
                     break
 
+    async def get_store_estimated_price(
+        self,
+        storage_size_mib: int,
+    ) -> PriceResponse:
+        """
+        Get the estimated price for a store operation.
+
+        :param storage_size_mib: size in mib you want to store
+        :return: Price response with cost information
+        """
+        content = {
+            "address": "0xWeDoNotNeedARealAddress",
+            "time": time.time(),
+            "item_type": ItemType.storage,
+            "estimated_size_mib": storage_size_mib,
+            "item_hash": compute_sha256("dummy_value"),
+        }
+
+        item_content: str = json.dumps(
+            content,
+            separators=(",", ":"),
+            default=extended_json_encoder,
+        )
+
+        message_dict = dict(
+            sender=content["address"],
+            chain=Chain.ETH,
+            type=MessageType.store,
+            content=content,
+            item_content=item_content,
+            time=time.time(),
+            channel=settings.DEFAULT_CHANNEL,
+            item_type=ItemType.inline,
+            item_hash=compute_sha256(item_content),
+            signature="0x" + "0" * 130,  # Add a dummy signature to pass validation
+        )
+
+        message = parse_message(message_dict)
+
+        async with self.http_session.post(
+            "/api/v0/price/estimate", json=dict(message=message)
+        ) as resp:
+            try:
+                resp.raise_for_status()
+                response_json = await resp.json()
+                cost = response_json.get("cost", None)
+
+                return PriceResponse(
+                    cost=cost,
+                    required_tokens=response_json["required_tokens"],
+                    payment_type=response_json["payment_type"],
+                )
+            except aiohttp.ClientResponseError as e:
+                raise e
+
     async def get_estimated_price(
         self,
         content: ExecutableContent,