Removed Update related functions

Author: br41nlet

dkg/data/interfaces/UnfinalizedStateStorage.json

@@ -424,37 +424,6 @@ def claim_voter_reward(
     _get_updating_knowledge_asset_states = Method(
         BlockchainRequest.get_updating_knowledge_asset_states
     )
-    _process_updated_knowledge_asset_states_metadata = Method(
-        BlockchainRequest.process_updated_knowledge_asset_states_metadata
-    )
-
-    def update_claimable_rewards(self, ual: UAL) -> dict[str, str | HexStr | TxReceipt]:
-        parsed_ual = parse_ual(ual)
-        knowledge_asset_storage, knowledge_asset_token_id = (
-            parsed_ual["contract_address"],
-            parsed_ual["token_id"],
-        )
-
-        paranet_id = Web3.solidity_keccak(
-            ["address", "uint256"], [knowledge_asset_storage, knowledge_asset_token_id]
-        )
-
-        updating_states = self._get_updating_knowledge_asset_states(
-            self.manager.blockchain_provider.account.address,
-            paranet_id,
-        )
-        receipt: TxReceipt = self._process_updated_knowledge_asset_states_metadata(
-            knowledge_asset_storage,
-            knowledge_asset_token_id,
-            0,
-            len(updating_states),
-        )
-
-        return {
-            "paranetUAL": ual,
-            "paranetId": paranet_id,
-            "operation": json.loads(Web3.to_json(receipt)),
-        }
 
     def _get_incentives_pool_contract(
         self,

dkg/paranet.py

@@ -93,23 +93,6 @@ class BlockchainRequest:
         function="burnAsset",
         args={"tokenId": int},
     )
-    update_asset_state = ContractTransaction(
-        contract="ContentAsset",
-        function="updateAssetState",
-        args={
-            "tokenId": int,
-            "assertionId": bytes | HexStr,
-            "size": int,
-            "triplesNumber": int,
-            "chunksNumber": int,
-            "updateTokenAmount": int,
-        },
-    )
-    cancel_asset_state_update = ContractTransaction(
-        contract="ContentAsset",
-        function="cancelAssetStateUpdate",
-        args={"tokenId": int},
-    )
     extend_asset_storing_period = ContractTransaction(
         contract="ContentAsset",
         function="extendAssetStoringPeriod",
@@ -120,11 +103,6 @@ class BlockchainRequest:
         function="increaseAssetTokenAmount",
         args={"tokenId": int, "tokenAmount": int},
     )
-    increase_asset_update_token_amount = ContractTransaction(
-        contract="ContentAsset",
-        function="increaseAssetUpdateTokenAmount",
-        args={"tokenId": int, "tokenAmount": int},
-    )
 
     transfer_asset = ContractTransaction(
         contract="ContentAssetStorage",
@@ -249,16 +227,6 @@ class BlockchainRequest:
             "paranetId": HexStr,
         },
     )
-    process_updated_knowledge_asset_states_metadata = ContractTransaction(
-        contract="Paranet",
-        function="processUpdatedKnowledgeAssetStatesMetadata",
-        args={
-            "paranetKAStorageContract": Address,
-            "paranetKATokenId": int,
-            "start": int,
-            "end": int,
-        },
-    )
 
     is_knowledge_miner_registered = ContractCall(
         contract="ParanetsRegistry",

dkg/utils/blockchain_request.py

@@ -69,18 +69,6 @@ class NodeRequest:
             "hashFunctionId": int,
         },
     )
-    update = NodeCall(
-        method=HTTPRequestMethod.POST,
-        path="update",
-        data={
-            "assertionId": str,
-            "assertion": NQuads,
-            "blockchain": str,
-            "contract": Address,
-            "tokenId": int,
-            "hashFunctionId": int,
-        },
-    )
     get = NodeCall(
         method=HTTPRequestMethod.POST,
         path="get",
@@ -115,17 +103,6 @@ class PublishOperationStatus(Enum):
     PUBLISH_END = auto()
 
 
-class UpdateOperationStatus(AutoStrEnumUpperCase):
-    UPDATE_START = auto()
-    UPDATE_INIT_START = auto()
-    UPDATE_INIT_END = auto()
-    UPDATE_REPLICATE_START = auto()
-    UPDATE_REPLICATE_END = auto()
-    VALIDATING_UPDATE_ASSERTION_REMOTE_START = auto()
-    VALIDATING_UPDATE_ASSERTION_REMOTE_END = auto()
-    UPDATE_END = auto()
-
-
 class StoreTypes(AutoStrEnumUpperCase):
     TRIPLE = auto()
     PENDING = auto()
@@ -171,7 +148,6 @@ class OperationStatus(AutoStrEnumUpperCase):
     DIAL_PROTOCOL_END = auto()
     LOCAL_STORE = LocalStoreOperationStatus
     PUBLISH = PublishOperationStatus
-    UPDATE = UpdateOperationStatus
     GET = GetOperationStatus
     QUERY = QueryOperationStatus
 

dkg/utils/node_request.py

@@ -154,26 +154,6 @@ def print_json(json_dict: dict):
 print_json(get_asset_result)
 divider()
 
-update_asset_result = dkg.asset.update(
-    create_asset_result["UAL"],
-    {
-        "private": {
-            "@context": ["https://schema.org"],
-            "@graph": [
-                {
-                    "@id": "uuid:user:1",
-                    "name": "Adam",
-                    "lastname": "Smith",
-                    "identifier": f"{math.floor(random.random() * 1e10)}",
-                },
-            ],
-        },
-    },
-)
-print("======================== ASSET UPDATED")
-print_json(update_asset_result)
-divider()
-
 get_latest_asset_result = dkg.asset.get(create_asset_result["UAL"], "latest", "all")
 print("======================== ASSET LATEST RESOLVED")
 print_json(get_latest_asset_result)
@@ -206,13 +186,6 @@ def print_json(json_dict: dict):
 print_json(get_first_state_by_hash)
 divider()
 
-get_second_state_by_hash = dkg.asset.get(
-    create_asset_result["UAL"], update_asset_result["publicAssertionId"], "all"
-)
-print("======================== ASSET SECOND STATE (GET BY STATE HASH) RESOLVED")
-print_json(get_second_state_by_hash)
-divider()
-
 query_result = dkg.graph.query(
     "construct { ?s ?p ?o } where { ?s ?p ?o . <uuid:user:1> ?p ?o }", "privateCurrent"
 )

examples/demo.py

@@ -307,39 +307,3 @@ def print_reward_stats(is_voter: bool = False):
 divider()
 
 print_reward_stats()
-
-divider()
-
-update_asset_result = dkg.asset.update(
-    create_submit_ka1_result["UAL"],
-    {
-        "private": {
-            "@context": ["https://schema.org"],
-            "@graph": [
-                {
-                    "@id": "uuid:user:1",
-                    "name": "Adam",
-                    "lastname": "Smith",
-                },
-            ],
-        },
-    },
-    100000000000000000000
-)
-
-print("======================== KA1 UPDATED")
-print_json(update_asset_result)
-
-print("Waiting 30 seconds for the update finalization...")
-time.sleep(30)
-
-divider()
-
-update_claimable_rewards_result = dkg.paranet.update_claimable_rewards(paranet_ual)
-
-print("======================== UPDATED CLAIMABLE REWARDS")
-print_json(update_claimable_rewards_result)
-
-divider()
-
-print_reward_stats()