合约编译
#!/usr/bin/env python# coding: utf8import jsonimport os# Solc Compilerfrom functools import reduceSOLC = "solc"BASE_PATH = os.path.dirname(os.path.abspath(__file__))src_dir = os.path.join(BASE_PATH, "contracts")dst_dir = os.path.join(BASE_PATH, "build")# dst_tmp = os.path.join(BASE_PATH, "build/contracts")bin_dir = os.path.join(BASE_PATH, "build/bin")abi_dir = os.path.join(BASE_PATH, "build/abi")ast_dir = os.path.join(BASE_PATH, "build/ast")src_entry = os.path.join(src_dir, "main.sol")build_target = os.path.join(BASE_PATH, "build/contracts.json")def rmdir(path): for root, dirs, files in os.walk(path, topdown=False): for name in files: os.remove(os.path.join(root, name)) for name in dirs: os.rmdir(os.path.join(root, name)) os.rmdir(path)def diff_path(): if not os.path.exists(dst_dir): os.mkdir(dst_dir) # if not os.path.exists(dst_tmp): # os.mkdir(dst_tmp) if not os.path.exists(bin_dir): os.mkdir(bin_dir) if not os.path.exists(abi_dir): os.mkdir(abi_dir) if not os.path.exists(ast_dir): os.mkdir(ast_dir) assert (os.path.exists(src_dir) and os.path.isdir(src_dir)) assert (os.path.exists(dst_dir) and os.path.isdir(dst_dir)) # assert (os.path.exists(dst_tmp) and os.path.isdir(dst_tmp)) assert (os.path.exists(bin_dir) and os.path.isdir(bin_dir)) assert (os.path.exists(abi_dir) and os.path.isdir(abi_dir)) assert (os.path.exists(ast_dir) and os.path.isdir(ast_dir)) # src_paths = map(lambda root, dirs, files: root.replace(src_dir, ""), os.walk(src_dir)) # dst_paths = map(lambda root, dirs, files: root.replace(dst_tmp, ""), os.walk(dst_tmp)) # _paths = filter(lambda p: p not in src_paths, dst_paths) # paths = map(lambda p: os.path.join(dst_tmp, p[1:] if p.startswith("/") else p), _paths) # map(lambda p: rmdir(p), paths) # _paths = filter(lambda p: p not in dst_paths, src_paths) # paths = map(lambda p: os.path.join(dst_tmp, p[1:] if p.startswith("/") else p), _paths) # map(lambda p: os.mkdir(p), paths)def clean_dst_path(): if os.path.exists(dst_dir): rmdir(dst_dir) os.mkdir(dst_dir)def find_compilers(): paths = os.environ["PATH"].split(":") solc = [p for p in paths if os.path.exists(os.path.join(p, "solc")) and os.path.isfile(os.path.join(p, "solc"))] serpent = [p for p in paths if os.path.exists(os.path.join(p, "serpent")) and os.path.isfile(os.path.join(p, "serpent"))] lllc = [p for p in paths if os.path.exists(os.path.join(p, "lllc")) and os.path.isfile(os.path.join(p, "lllc"))] result = [] if len(solc) > 0: result.append("Solidity") if len(serpent) > 0: result.append("Serpent") if len(lllc) > 0: result.append("LLL") return resultdef complie_soldity(): """ solc --optimize --bin -o ./build/bin contract.sol solc --optimize --ast -o ./build/ast contract.sol solc --optimize --abi -o ./build contract.sol """ assert (os.path.exists(src_entry) and os.path.isfile(src_entry)) commands = [ [SOLC, "--optimize", "--bin", "--overwrite", "-o", os.path.relpath(bin_dir), os.path.relpath(src_entry)], [SOLC, "--optimize", "--ast", "--overwrite", "-o", os.path.relpath( ast_dir), os.path.relpath(src_entry)], [SOLC, "--optimize", "--abi", "--overwrite", "-o", os.path.relpath(abi_dir), os.path.relpath(src_entry)] ] print("======================Complie Solidity Language=========================") for cmd in commands: command = " ".join(cmd) print(command) os.system(command) # os.system("cp %s/* %s" % (bin_dir, dst_dir)) # result = map(lambda cmd: os.system(" ".join(cmd)), commands ) # print(result)def restruct(): contract = {} bin_files = [os.path.join(root, f) for root, dirs, files in os.walk(bin_dir) for f in files] abi_files = [os.path.join(root, f) for root, dirs, files in os.walk(abi_dir) for f in files] ast_files = [os.path.join(root, f) for root, dirs, files in os.walk(ast_dir) for f in files] def path_handle(data, filepath): _, filename = os.path.split(filepath) assert (filename.endswith(".bin") or filename.endswith(".abi")) key = "" if filename.endswith(".bin"): key = "code" elif filename.endswith(".abi"): key = "interface" else: pass object_name = filename[:-4] _tmp = object_name.split(":") if len(_tmp) > 1: object_name = _tmp[-1] if object_name not in data or type(data[object_name]) != dict: data[object_name] = {} if key not in data[object_name]: res = open(filepath, "rb").read() if key == "interface": open(os.path.join(abi_dir, object_name + ".abi"), "wb").write(res) data[object_name][key] = json.loads(res) elif key == "code": res = "" + res.decode("utf-8") data[object_name][key] = res else: data[object_name][key] = res return data data = reduce(path_handle, abi_files, reduce(path_handle, bin_files, {})) print("======================Contract=========================") output = json.dumps(data) open(build_target, "w").write(output)def usage(): message = """ $ python solidity.py -src ./src -entry main.sol -out ./build -target contract.json -src solidity source dir -entry source entry file -out output dir -target solidity bytecode and interface file (JSON Format) --help show this help text """ print(message)def main(): compilers = find_compilers() print("====================Compilers====================") print(compilers) assert ("Solidity" in compilers) clean_dst_path() diff_path() complie_soldity() restruct() os.system("ls -lah build/")if __name__ == '__main__': main() 合约部署
from __future__ import unicode_literalsimport jsonimport sysfrom time import sleep, timefrom web3 import Web3, HTTPProvidercontracts_path = "build/contracts.json"deploy_address_path = "deploy_address.json"contracts_address_path = "contracts_address.json"def check_deploy(): contracts_address = json.loads(open(contracts_path).read() or "{}") deploy_address = json.loads(open(deploy_address_path).read() or "{}") for name, deploy_addr in list(deploy_address.items()): if name == "version": break web3 = Web3(HTTPProvider('http://106.15.40.225:8545')) web3.eth.defaultAccount = b'0x8c0f94d8a7974aa60ebf4e9a9e742da29dcf7590' _count = 0 deploy_receipt = None while 1: sleep(2) deploy_receipt = web3.eth.getTransactionReceipt(deploy_addr) if deploy_receipt: print("{0} 部署成功".format(name)) print(deploy_receipt, "\n\n") break if _count > 10: break _count += 1 if deploy_receipt: contracts_address[name]["contract_address"] = deploy_receipt["contractAddress"] print("检查成功\n\n") contracts_address["version"] = deploy_address["version"] open(contracts_address_path, "w").write(json.dumps(contracts_address))def deploy(): contracts = json.load(open(contracts_path)) or {} _data = {} for name, contract in contracts.items(): _abi = contract["interface"] _code = contract["code"] web3 = Web3(HTTPProvider('http://106.15.40.225:8545')) web3.eth.defaultAccount = b'0x8c0f94d8a7974aa60ebf4e9a9e742da29dcf7590' _Contract = web3.eth.contract(abi=_abi, bytecode=_code) print("start deploy {0}".format(name)) deploy_txn = _Contract.deploy( # transaction={ # 'from': web3.eth.defaultAccount, # 'value': 12345, # }, # args=('DGD', 18) ) print("{0} address: {1}\n\n".format(name, deploy_txn)) _data[name] = deploy_txn else: print("部署成功") _data["version"] = str(time()) open(deploy_address_path, "w").write(json.dumps(_data))if __name__ == '__main__': if len(sys.argv) == 1: print( """ python solidity_deploy.py deploy ＃部署合约 python solidity_deploy.py check ＃检查合约是否部署成功 """ ) if len(sys.argv) > 1: _argv = sys.argv[1] if _argv == "deploy": deploy() if _argv == "check": check_deploy() 合约调用
import web3.personal as wpfrom web3 import Web3, HTTPProviderweb3 = Web3(HTTPProvider('http://127.0.0.1:8545'))web3.eth.defaultAccount = b'account address 0x336495440ce8dd55029bd394f'print("unlockAccount")p = wp.Personal(web3)print(p.unlockAccount("account address", "account passwd"))print("unlockAccount ok")_BYTECODE="6060604052341561000f57600080fd5b5b61070c8061001f6000396000f300606060405263ffffffff7c01000000000000000000000000000000000000000000000000000000006000350416630c90d8448114610048578063685a4bd21461017c575b600080fd5b341561005357600080fd5b61009960046024813581810190830135806020601f8201819004810201604051908101604052818152929190602084018383808284375094965061026595505050505050565b604051808060200180602001838103835285818151815260200191508051906020019080838360005b838110156100db5780820151818401525b6020016100c2565b50505050905090810190601f1680156101085780820380516001836020036101000a031916815260200191505b50838103825284818151815260200191508051906020019080838360005b8381101561013f5780820151818401525b602001610126565b50505050905090810190601f16801561016c5780820380516001836020036101000a031916815260200191505b5094505050505060405180910390f35b341561018757600080fd5b61025160046024813581810190830135806020601f8201819004810201604051908101604052818152929190602084018383808284378201915050505050509190803590602001908201803590602001908080601f01602080910402602001604051908101604052818152929190602084018383808284378201915050505050509190803590602001908201803590602001908080601f0160208091040260200160405190810160405281815292919060208401838380828437509496506104af95505050505050565b604051901515815260200160405180910390f35b61026d61062e565b61027561062e565b600080846040518082805190602001908083835b602083106102a957805182525b601f199092019160209182019101610289565b6001836020036101000a038019825116818451168082178552505050505050905001915050908152602001604051908190039020600381015490915060ff1615156001141561043b578060010181600201818054600181600116156101000203166002900480601f01602080910402602001604051908101604052809291908181526020018280546001816001161561010002031660029004801561038f5780601f106103645761010080835404028352916020019161038f565b820191906000526020600020905b81548152906001019060200180831161037257829003601f168201915b50505050509150808054600181600116156101000203166002900480601f01602080910402602001604051908101604052809291908181526020018280546001816001161561010002031660029004801561042b5780601f106104005761010080835404028352916020019161042b565b820191906000526020600020905b81548152906001019060200180831161040e57829003601f168201915b50505050509050925092506104a9565b604080519081016040908152600182527f300000000000000000000000000000000000000000000000000000000000000060208301528051908101604052600181527f3100000000000000000000000000000000000000000000000000000000000000602082015290935091505b50915091565b600080846040518082805190602001908083835b602083106104e357805182525b601f1990920191602091820191016104c3565b6001836020036101000a0380198251168184511680821785525050505050509050019150509081526020016040519081900390206003015460ff1615156001141561053057506000610627565b608060405190810160405280858152602001848152602001838152602001600115158152506000856040518082805190602001908083835b6020831061058857805182525b601f199092019160209182019101610568565b6001836020036101000a0380198251168184511680821785525050505050509050019150509081526020016040519081900390208151819080516105d0929160200190610640565b506020820151816001019080516105eb929160200190610640565b50604082015181600201908051610606929160200190610640565b506060820151600391909101805460ff191691151591909117905550600190505b9392505050565b60206040519081016040526000815290565b828054600181600116156101000203166002900490600052602060002090601f016020900481019282601f1061068157805160ff19168380011785556106ae565b828001600101855582156106ae579182015b828111156106ae578251825591602001919060010190610693565b5b506106bb9291506106bf565b5090565b6106dd91905b808211156106bb57600081556001016106c5565b5090565b905600a165627a7a72305820c903731c0280c5e226e2d07bdd2b07723ef114b68febe6991b33363f6e01e7960029"_ABI=json.loads("""[ { "constant": true, "inputs": [ { "name": "_dna", "type": "string" } ], "name": "getDNA", "outputs": [ { "name": "_type_", "type": "string" }, { "name": "_version", "type": "string" } ], "payable": false, "stateMutability": "view", "type": "function" }, { "constant": false, "inputs": [ { "name": "_dna", "type": "string" }, { "name": "_type_", "type": "string" }, { "name": "_version", "type": "string" } ], "name": "addDNA", "outputs": [ { "name": "", "type": "bool" }, { "name": "", "type": "string" } ], "payable": false, "stateMutability": "nonpayable", "type": "function" } ] """)MathContract = web3.eth.contract( abi=_ABI, # bytecode=_BYTECODE,)print("isConnected:", web3.isConnected())deploy_receipt = web3.eth.getTransactionReceipt(b"0xb2e contract deploy tx address")print(deploy_receipt)assert deploy_receipt is not None# math_contract = MathContract(address=deploy_receipt["contractAddress"])# math_contract = MathContract(address="0xec7c803dcc6e917c468139037513b9281574b395")# 发送一个tx到区块链上# print(math_contract.transact().addDNA(_a, _a, _a))# 发送一个tx到本地执行，不会写入到区块链上# print(math_contract.call().addDNA(_a, _a, _a))# print(math_contract.call().getDNA(_a))