Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion requirements.txt
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,10 @@ grpcio-tools>=1.71.0
wheel>=0.45.0
rlp>=4.1.0
web3==7.*
ipfshttpclient>=0.7.0
ipfshttpclient==0.4.13
rfc3986>=2.0.0
base58>=2.1.1
grpcio-health-checking>=1.71.0
snet-contracts==1.0.1
lighthouseweb3>=0.1.4
pymultihash==0.*
2 changes: 1 addition & 1 deletion snet/sdk/account.py
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ def _send_signed_transaction(self, contract_fn, *args):
signed_txn = self.web3.eth.account.sign_transaction(
transaction, private_key=self.private_key)
return self.web3.to_hex(
self.web3.eth.send_raw_transaction(signed_txn.rawTransaction)
self.web3.eth.send_raw_transaction(signed_txn.raw_transaction)
)

def send_transaction(self, contract_fn, *args):
Expand Down
2 changes: 1 addition & 1 deletion snet/sdk/mpe/payment_channel.py
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ def _get_current_channel_state(self):
self.channel_id,current_block_number
]
)
signature = self.web3.eth.account.signHash(defunct_hash_message(message), self.account.signer_private_key).signature
signature = self.web3.eth.account._sign_hash(defunct_hash_message(message), self.account.signer_private_key).signature
with add_to_path(str(RESOURCES_PATH.joinpath("proto"))):
state_service_pb2 = importlib.import_module("state_service_pb2")
request = state_service_pb2.ChannelStateRequest(
Expand Down
5 changes: 3 additions & 2 deletions snet/sdk/mpe/payment_channel_provider.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,10 @@ def __init__(self, w3, mpe_contract):

self.mpe_contract = mpe_contract
self.event_topics = [self.web3.keccak(
text="ChannelOpen(uint256,uint256,address,address,address,bytes32,uint256,uint256)").hex()]
text="ChannelOpen(uint256,uint256,address,address,address,bytes32,uint256,uint256)")]
self.deployment_block = get_contract_deployment_block(self.web3, "MultiPartyEscrow")
self.mpe_address = mpe_contract.contract.address
print(self.mpe_address)
self.channels_file = CHANNELS_DIR.joinpath(str(self.mpe_address), "channels.pickle")

def update_cache(self):
Expand Down Expand Up @@ -78,7 +79,7 @@ def _get_all_channels_from_blockchain_logs_to_dicts(self, starting_block_number,
"topics": self.event_topics})
from_block = to_block + 1

event_abi = self.mpe_contract.contract._find_matching_event_abi(event_name="ChannelOpen")
event_abi = self.mpe_contract.contract.events.ChannelOpen._get_event_abi()

event_data_list = [get_event_data(codec, event_abi, l)["args"] for l in logs]
channels_opened = list(map(self._event_data_args_to_dict, event_data_list))
Expand Down
4 changes: 2 additions & 2 deletions snet/sdk/service_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -199,7 +199,7 @@ def get_price(self) -> int:
return self.group["pricing"][0]["price_in_cogs"]

def generate_signature(self, message: bytes) -> bytes:
return bytes(self.sdk_web3.eth.account.signHash(
return bytes(self.sdk_web3.eth.account._sign_hash(
defunct_hash_message(message), self.account.signer_private_key
).signature)

Expand All @@ -210,7 +210,7 @@ def generate_training_signature(self, text: str, address: str,
["string", "address", "uint256"],
[text, address, block_number]
)
return self.sdk_web3.eth.account.signHash(
return self.sdk_web3.eth.account._sign_hash(
defunct_hash_message(message), self.account.signer_private_key
).signature

Expand Down
4 changes: 2 additions & 2 deletions tests/unit_tests/test_service_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ def test_get_current_block_number(self):
def test_generate_signature(self):
message = b"test_message"
mock_signature = MagicMock()
self.client.sdk_web3.eth.account.signHash = MagicMock(
self.client.sdk_web3.eth.account._sign_hash = MagicMock(
return_value=MagicMock(signature=mock_signature)
)
result = self.client.generate_signature(message)
Expand All @@ -153,7 +153,7 @@ def test_generate_training_signature(self, mock_solidity_keccak):
block_number = "test_block_number"
mock_solidity_keccak.return_value = b"test_message"
mock_signature = MagicMock()
self.client.sdk_web3.eth.account.signHash = MagicMock(
self.client.sdk_web3.eth.account._sign_hash = MagicMock(
return_value=MagicMock(signature=mock_signature)
)
result = self.client.generate_training_signature(text, address,
Expand Down
Loading