common.py

import json
import requests
from web3 import Web3
from web3.providers.rpc import HTTPProvider
from web3.providers.ipc import IPCProvider
from web3 import WebsocketProvider
from uniswap.uniswap import UniswapV2Client
from uniswap.uniswap import UniswapV2Utils as utils
from rpc import BatchHTTPProvider, BatchIPCProvider
import threading
import random

config = json.load(open('config.json'))
network = config['network']
address = config['address']
privkey = config['privkey']
http_addr = config[network]['http']
wss_addr = config[network]['wss']

uni = UniswapV2Client(address, privkey, http_addr)

# w3 = Web3(HTTPProvider(http_addr, request_kwargs={'timeout': 6000}))
w3 = Web3(IPCProvider('/data/geth/geth.ipc', timeout=6000))
ws = Web3(WebsocketProvider(wss_addr))
batch_provider = BatchHTTPProvider(config[network]['http'])
# batch_provider = BatchIPCProvider('/data/geth/geth.ipc', timeout = 6000)

pairABI = json.load(open('abi/IUniswapV2Pair.json'))['abi']
erc20abi = json.load(open('./abi/erc20.abi'))

def get_symbol(addr):
    c = w3.eth.contract(address=addr, abi=erc20abi)
    symbol = c.functions.symbol().call()
    return symbol

'''
# from eth_keys import keys
from eth_utils import int_to_big_endian
import ethereum
def pad32(value: bytes) -> bytes:
    return value.rjust(32, b'\x00')
def int_to_byte(value: int) -> bytes:
    return bytes([value])

def sig_to_addr(hash, v, r, s):
    v = int(v, 16)
    r = int(r, 16)
    s = int(s, 16)
    if v in (27, 28):
        vee = v
    else:
        vee = v - 10
    pub = ethereum.utils.ecrecover_to_pub(hash[2:], vee, r, s)
    addr = ethereum.utils.sha3(pub)[-20:].hex()
    return addr
'''