go.py

#from http.server import HTTPServer, BaseHTTPRequestHandler
from jsonrpcserver import method, dispatch
from jsonrpcclient import request as jsonrequest
from collections import defaultdict
import json
import time
import re

@method
def eth_getWork(*params):
  response = jsonrequest("http://127.0.0.1:8545", "eth_getWork", *params)
  return response.data.result

@method
def eth_submitHashrate(*params):
  response = jsonrequest("http://127.0.0.1:8545", "eth_submitHashrate", *params)
  print("***** SUBMIT HASH RATE *****", params)
  return response.data.result

@method
def eth_submitWork(*params):
  response = jsonrequest("http://127.0.0.1:8545", "eth_submitWork", *params)
  print("***** SUBMIT WORK *****", params)
  return response.data.result

xcnt = defaultdict(int)
pcnt = defaultdict(int)
import socketserver
addre = re.compile(b"^0x[a-fA-F0-9]{40}$")
class MyTCPHandler(socketserver.StreamRequestHandler):
  def handle(self):
    cl = 0
    addr = None
    while 1:
      hh = self.rfile.readline().strip()
      if b'POST /' in hh:
        addr = hh.split(b'POST /')[1].split(b' ')[0]
      if b'Content-Length: ' in hh:
        cl = int(hh.split(b'Content-Length: ')[1])
      if hh == b"":
        #print("done")
        break
    if addr is None:
      snd = "CONNECTED:"+str(xcnt)+"\n\n\nFOUND BLOCK:"+str(pcnt)
      self.wfile.write(b'HTTP/1.0 200 OK\r\n\r\n'+snd.encode('utf-8'))
      return
    if addre.fullmatch(addr) is None:
      print("BAD ADDRESS", addr)
      return
    idat = self.rfile.read(cl).decode('utf-8')
    print("<<", addr, idat)
    dat = dispatch(idat)
    print(">>", dat)
    print(pcnt)
    xcnt[addr] += 1
    if 'eth_submitWork' in idat:
      pcnt[addr] += 1
    self.wfile.write(b'HTTP/1.0 200 OK\r\n\r\n'+str(dat).encode('utf-8'))

socketserver.TCPServer.allow_reuse_address = True
class ThreadedTCPServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
  pass

if __name__ == "__main__":
  HOST, PORT = "0.0.0.0", 8080

  with ThreadedTCPServer((HOST, PORT), MyTCPHandler) as server:
    server.serve_forever()