Изменить метод, когда http-запрос возвращает что-то новое (python) - PullRequest
Новая
       2

Изменить метод, когда http-запрос возвращает что-то новое (python)

0 голосов
/ 31 марта 2020

Неэффективная версия того, что я пытаюсь сделать, такова: 

while(True):
    dynamic_variable = http(request) # where http request is subject to change values
    method(dynamic_variable)

Где method(dynamic_variable не гарантируется до sh, а если http(request) возвращает значение, отличное от method(dynamic_variable) становится бесполезной функцией.

Похоже, я должен быть в состоянии изменить dynamic_variable более эффективно, если бы он "автоматически" обновлялся всякий раз, когда http(request) изменяет значение.

Я думаю, что я хочу сделать, это называется «шаблон наблюдателя», но я недостаточно хорошо разбираюсь в коде, чтобы знать, правильный ли это шаблон или как его реализовать.

Простой пример был бы очень признателен!

Редактировать: 

from web3 import Web3
import json
from hexbytes import HexBytes

import numpy as np
import os
import time

INFURA_ROPSTEN_URL = "https://ropsten.infura.io/v3/<api_key>"

# metamask account information
PUBLIC_KEY = "0x3FaD9AccC3A39aDbd9887E82F94602cEA6c7F86f"
PRIVATE_KEY = "myprivatekey"

UNITS_ADDRESS = "units_address"
# from truffle build. For ABI
JSON_PATH = "../truffle/build/contracts/Units.json"

def set_up_web3():
    web3 = Web3(Web3.HTTPProvider(INFURA_ROPSTEN_URL))
    web3.eth.defaultAccount = PUBLIC_KEY
    return web3

def get_units_contract_object():
    with open(JSON_PATH, 'r') as json_file:
        abi = json.load(json_file)['abi']
    return web3.eth.contract(address=UNITS_ADDRESS,abi=abi)

def solve(web3, units):
    nonce = np.random.randint(0,1e10)
    while True:
        challenge_number_hex = HexBytes(units.functions.getChallengeNumber().call()).hex()
        my_digest_hex = web3.solidityKeccak(
                            ['bytes32','address','uint256'],
                            [challenge_number_hex, PUBLIC_KEY, nonce]).hex()
        my_digest_number = int(my_digest_hex,0)
        target = units.functions.getMiningTarget().call()
        if my_digest_number < target:
            return (nonce, my_digest_hex)
        else:
            nonce += 1

def build_transaction(units, nonce, digest_hex, txn_count):
    return units.functions.mint(
                    nonce,
                    digest_hex
            ).buildTransaction({
                "nonce" : txn_count,
        })

if __name__ == "__main__":    
    web3 = set_up_web3()

    txn_count = web3.eth.getTransactionCount(PUBLIC_KEY)
    units = get_units_contract_object()

    _cycle_goal = 20
    _prev_finish = time.time()
    _wait_time = 0
    while True:
        target = units.functions.getMiningTarget().call()
        nonce, digest_hex = solve(web3, units)

        mint_txn = build_transaction(units, nonce,digest_hex, txn_count)
        signed_txn = web3.eth.account.sign_transaction(mint_txn, private_key=PRIVATE_KEY)
        txn_address = web3.eth.sendRawTransaction(signed_txn.rawTransaction)
        txn_count += 1
        print(f"Solution found! nonce={nonce}, digest_hex={digest_hex}")

        _finished = time.time()
        _elapsed = _finished - _prev_finish
        _additional_wait = _cycle_goal - _elapsed
        _wait_time += _additional_wait
        print(f"Waiting {_wait_time}")
        _prev_finish = _finished
        time.sleep(_wait_time)

challenge_hex_number - это переменная, которую я хочу обновить

...