python 智能合约日志操作

from __future__ import unicode_literals

import json

from time import sleep, time

# 中文编码

def encode_str(_str):

    try:

        return bytearray(_str, "utf-8").hex()

    except Exception as e:

        print(e)

# 中文解码

def decode_str(_str):

    try:

        return bytearray.fromhex(_str).decode("utf-8")

    except Exception as e:

        print(e)

MATH_BYTECODE = "6060604052341561000f57600080fd5b5b60c08061001e6000396000f300606060405263ffffffff7c0100000000000000000000000000000000000000000000000000000000600035041663696c75c68114603c575b600080fd5b3415604657600080fd5b60526004356024356054565b005b817f3ea5d667934df8dbb4978ddd30e65375fd1bf06f8ed39d033379c5cd3efb102c428360405191825260208201526040908101905180910390a25b50505600a165627a7a723058208d6649bbcad0893ba1e52ea3904adaf2ff4b9ed80f71f5ac5c6b982ce5bac3a20029"

# 6060604052341561000f57600080fd5b5b6105078061001f6000396000f300606060405263ffffffff7c01000000000000000000000000000000000000000000000000000000006000350416630c90d8448114610048578063d10fa94614610111575b600080fd5b341561005357600080fd5b61009960046024813581810190830135806020601f820181900481020160405190810160405281815292919060208401838380828437509496506101e395505050505050565b60405160208082528190810183818151815260200191508051906020019080838360005b838110156100d65780820151818401525b6020016100bd565b50505050905090810190601f1680156101035780820380516001836020036101000a031916815260200191505b509250505060405180910390f35b341561011c57600080fd5b61016260046024813581810190830135806020601f820181900481020160405190810160405281815292919060208401838380828437509496506102fa95505050505050565b604051821515815260406020820181815290820183818151815260200191508051906020019080838360005b838110156101a75780820151818401525b60200161018e565b50505050905090810190601f1680156101d45780820380516001836020036101000a031916815260200191505b50935050505060405180910390f35b6101eb610429565b600080836040518082805190602001908083835b6020831061021f57805182525b601f1990920191602091820191016101ff565b6001836020036101000a03801982511681845116808217855250505050505090500191505090815260200160405180910390209050806001018054600181600116156101000203166002900480601f0160208091040260200160405190810160405280929190818152602001828054600181600116156101000203166002900480156102ec5780601f106102c1576101008083540402835291602001916102ec565b820191906000526020600020905b8154815290600101906020018083116102cf57829003601f168201915b505050505091505b50919050565b6000610304610429565b60408051908101604052808481526020016040805190810160405280600981526020017fe4b88de5ad98e59ca800000000000000000000000000000000000000000000008152508152506000846040518082805190602001908083835b6020831061038157805182525b601f199092019160209182019101610361565b6001836020036101000a0380198251168184511680821785525050505050509050019150509081526020016040519081900390208151819080516103c992916020019061043b565b506020820151816001019080516103e492916020019061043b565b50905050600060408051908101604052600681527f6f6b6f6b31310000000000000000000000000000000000000000000000000000602082015290925090505b915091565b60206040519081016040526000815290565b828054600181600116156101000203166002900490600052602060002090601f016020900481019282601f1061047c57805160ff19168380011785556104a9565b828001600101855582156104a9579182015b828111156104a957825182559160200191906001019061048e565b5b506104b69291506104ba565b5090565b6104d891905b808211156104b657600081556001016104c0565b5090565b905600a165627a7a72305820faf711785ac7369219291016aa91535aa22004c60da82a8fcd956777c3b7a7000029

MATH_ABI = json.loads("""

[

      {

        "constant": false,

        "inputs": [

          {

            "name": "_type",

            "type": "bytes32"

          },

          {

            "name": "_metadata",

            "type": "bytes32"

          }

        ],

        "name": "publish",

        "outputs": [],

        "payable": false,

        "stateMutability": "nonpayable",

        "type": "function"

      },

      {

        "anonymous": false,

        "inputs": [

          {

            "indexed": true,

            "name": "_type",

            "type": "bytes32"

          },

          {

            "indexed": false,

            "name": "_created",

            "type": "uint256"

          },

          {

            "indexed": false,

            "name": "_metadata",

            "type": "bytes32"

          }

        ],

        "name": "ArticleOperationLog",

        "type": "event"

      }

    ]

    """)

import web3.personal as wp

from web3 import Web3, HTTPProvider

web3 = Web3(HTTPProvider('http://localhost:8545'))

web3.eth.defaultAccount = b'0x3364aa6342c8c18'

print("unlockAccount")

p = wp.Personal(web3)

print(p.unlockAccount("0x336394f4b93aa6342c8c18", "123456"))

print("unlockAccount ok")

MathContract = web3.eth.contract(

    abi=MATH_ABI,

    # bytecode=MATH_BYTECODE,

)

# deploy_txn = MathContract.deploy()

# transaction={

#     'from': b'0x336495440ce8dd55029bd394f4b93aa6342c8c18',

#     'value': 12345,

# },

# args=('DGD', 18)

print("isConnected:", web3.isConnected())

# print(deploy_txn)

# deploy_receipt = web3.eth.getTransactionReceipt("0x71ce48069f2e17079c2cf016f40bd47d995f4c77aab74d12ae89a9cf13cfeb77")

# print(deploy_receipt, "\n\n")

# print(deploy_txn)

# deploy_receipt = web3.eth.getTransactionReceipt(b"0xb2e4aacfbd147ddd6f807c0f4d47cc77c6a21ce7e2c9cbd17b7ba3d410473bd4")

# print(deploy_receipt)

# assert deploy_receipt is not None

# deploy_receipt["contractAddress"]

# math_contract = MathContract(address=deploy_receipt["contractAddress"])

import re

def my_callback(a):

    # print(a)

    args = a.get("args")

    print(decode_str(re.split(r"\W+", args.get("_type"))[0]))

    print(str(args.get("_created")))

    print(decode_str(re.split(r"\W+", args.get("_metadata"))[0]))

    print("\n\n")

def my_callback1(a):

    print("\n\n\n\npastEvents")

    # print(a)

    args = a.get("args")

    print(decode_str(re.split(r"\W+", args.get("_type"))[0]))

    print(str(args.get("_created")))

    print(decode_str(re.split(r"\W+", args.get("_metadata"))[0]))

math_contract = MathContract(address="0x8851accb27fc4b149bda886d6d579f2fb5c1a492")

# math_contract.on("ArticleOperationLog",{'filter': {'_type': 'hello'}}).watch(my_callback)

# math_contract.on("ArticleOperationLog").watch(my_callback)

# math_contract.on("ArticleOperationLog", {"filter": {"_type": encode_str("hello")}}).watch(my_callback)

# 历史日志

math_contract.pastEvents("ArticleOperationLog", {"filter": {"_type": encode_str("hello1")}}).watch(my_callback1)

# 历史日志

# math_contract.pastEvents("ArticleOperationLog").watch(my_callback1)

while 1:

    # math_contract.transact().publish(encode_str("hello1"), encode_str("hello1上海"))

    print(time())

    sleep(2)

# _a = "1234562"

# print(math_contract.encodeABI("addDNA", args=(_a,_a,_a)))

# 发送一个tx到区块链上

# print(math_contract.transact().addDNA(_a, _a, _a))

# 发送一个tx到本地执行，不会写入到区块链上

# print(math_contract.call().addDNA(_a, _a, _a))

# print(math_contract.call().getDNA(_a))