Created _provider_account. Edit PlanModule to handle sentprov... from _provider_account

Author: freQniK

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>sentinel-python-sdk</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.python.pydev.PyDevBuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.python.pydev.pythonNature</nature>
+	</natures>
+</projectDescription>

.pydevproject

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<?eclipse-pydev version="1.0"?><pydev_project>
+    <pydev_property name="org.python.pydev.PYTHON_PROJECT_INTERPRETER">Default</pydev_property>
+    <pydev_property name="org.python.pydev.PYTHON_PROJECT_VERSION">python interpreter</pydev_property>
+</pydev_project>

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "sentinel_sdk"
-version = "0.0.1"
+version = "0.0.2"
 description = "A Sentinel SDK Written in Python"
 authors = [
     { name = "NAST0R" },

src/sentinel_sdk/modules/plan.py

@@ -11,9 +11,10 @@
 
 
 class PlanModule(Querier, Transactor):
-    def __init__(self, channel: grpc.Channel, account, client):
+    def __init__(self, channel: grpc.Channel, account, provider_account, client):
         self.__stub = sentinel_plan_v2_querier_pb2_grpc.QueryServiceStub(channel)
         self._account = account 
+        self._provider_account = provider_account
         self._client = client
 
     def QueryPlan(self, plan_id: int) -> Any:
@@ -59,7 +60,7 @@ def Create(self, duration: int, gigabytes: int, prices: int, tx_params: TxParams
 
     def LinkNode(self, plan_id: int, node_address: str, tx_params: TxParams = TxParams()):
         msg = msg_pb2.MsgLinkNodeRequest(
-            frm = self._account.address,
+            frm = self._provider_account.address,
             id = plan_id,
             node_address = node_address,
         )
@@ -75,15 +76,15 @@ def Subscribe(self, denom: str, plan_id: int, tx_params: TxParams = TxParams()):
 
     def UnlinkNode(self, plan_id: int, node_address: str, tx_params: TxParams = TxParams()):
         msg = msg_pb2.MsgUnlinkNodeRequest(
-            frm = self._account.address,
+            frm = self._provider_account.address,
             id = plan_id,
             node_address = node_address,
         )
         return self.transaction([msg], tx_params)
 
     def UpdateStatus(self, plan_id: int, status: int, tx_params: TxParams = TxParams()):
         msg = msg_pb2.MsgUpdateStatusRequest(
-            frm = self._account.address,
+            frm = self._provider_account.address,
             id = plan_id,
             status = status,
         )

src/sentinel_sdk/sdk.py

@@ -59,6 +59,7 @@ def __create_and_verify_channel(
 
     def __setup_account_and_client(self, grpcaddr: str, grpcport: int, secret: str, use_ssl: bool = False):
         self._account = self.__create_account(secret)
+        self._provider_account = self.__create_provider_account(secret)
         self._client = self.__create_client(grpcaddr, grpcport, use_ssl)
         self._client.load_account_data(account=self._account)
 
@@ -87,6 +88,32 @@ def __create_account(self, secret: str):
             protobuf="sentinel",
         )
         return account
+    
+    def __create_provider_account(self, secret: str):
+        try:
+            Bip39MnemonicValidator().Validate(secret)
+            seed_bytes = Bip39SeedGenerator(secret).Generate()
+            bip44_def_ctx = Bip44.FromSeed(seed_bytes, Bip44Coins.COSMOS).DeriveDefaultPath()
+        except:
+            try:
+                int(secret, 16)
+                bip44_def_ctx = Bip44.FromPrivateKey(bytes.fromhex(secret), Bip44Coins.COSMOS)
+            except:
+                raise ValueError("Unrecognized secret either as a mnemonic or hex private key")
+
+        sha_key = SHA256.new()
+        ripemd_key = RIPEMD160.new()
+        sha_key.update(bip44_def_ctx.PublicKey().RawCompressed().m_data_bytes)
+        ripemd_key.update(sha_key.digest())
+        bech32_pub = Bech32Encoder.Encode("sent", ripemd_key.digest())
+        account_num = self.__get_account_number(bech32_pub)
+        account = Account(
+            private_key=bip44_def_ctx.PrivateKey().Raw().ToHex(),
+            hrp="sentprov",
+            account_number=account_num,
+            protobuf="sentinel",
+        )
+        return account
 
     def __create_client(self, grpcaddr: str, grpcport: int, use_ssl: bool = False):
         client = GRPCClient(
@@ -109,7 +136,7 @@ def __get_account_number(self, address: str):
     def __load_modules(self):
         self.nodes = NodeModule(self._channel, 10, self._account, self._client)
         self.deposits = DepositModule(self._channel)
-        self.plans = PlanModule(self._channel, self._account, self._client)
+        self.plans = PlanModule(self._channel, self._account, self._provider_account, self._client)
         self.providers = ProviderModule(self._channel, self._account, self._client)
         self.sessions = SessionModule(self._channel, self._account, self._client)
         self.subscriptions = SubscriptionModule(self._channel, self._account, self._client)