coffeecoin-multiminer.py

import multiprocessing
import string
import uuid
import time
import json
import urllib
import urllib2
from random import randint
import platform, subprocess, os
import random, hashlib, string
import sys

args_passed = False

if(len(sys.argv)-2 == 0):
    print("Need 2 args")
    args_passed = True

if(args_passed):
    sys.exit()

# First args is number of processes
# Second arg is hash function to use
    # 0 - md5
    # 1 - sha1
    # 2 - sha2

# Function to Detect CPU
def detectCPUs():
 """
 Detects the number of CPUs on a system.
 """
 # Linux, Unix and MacOS:
 if hasattr(os, "sysconf"):
     if os.sysconf_names.has_key("SC_NPROCESSORS_ONLN"):
         # Linux & Unix:
         ncpus = os.sysconf("SC_NPROCESSORS_ONLN")
         if isinstance(ncpus, int) and ncpus > 0:
             return ncpus
     else: # OSX:
         return int(os.popen2("sysctl -n hw.ncpu")[1].read())
 # Windows:
 if os.environ.has_key("NUMBER_OF_PROCESSORS"):
         ncpus = int(os.environ["NUMBER_OF_PROCESSORS"]);
         if ncpus > 0:
             return ncpus
 return 1 # Default

# Define Class
class Miner:
    def __init__(self, miner_threads,  miner_cpu, miner_gpu):
        #self.miner_address = uuid.uuid4()
        self.miner_address = randint(0,1000)
        #self.miner_address = miner_name
        self.miner_coins_earned = 0
        self.miner_cpu = miner_cpu
        self.miner_gpu = miner_gpu
        self.miner_threads = miner_threads
        self.hashrate = 0
        self.efficiency = 0
        self.profitability = 0

# Miner Class Constructor
miner = Miner(
    sys.argv[1],
    detectCPUs(),
    4 ** detectCPUs()
)

def spawn(num, v, h):

    # print("received " + str(v.value))
    # v.value+=1s
    # print(miner.miner_coins_earned)

    #get Challenge
    req = urllib2.Request("http://10.0.0.70:5000/info", json.dumps({ 'miner_address' : miner.miner_address, 'coins_earned' : v.value , 'miner_cpu' : miner.miner_cpu, 'miner_gpu' : miner.miner_gpu, 'miner_threads' : miner.miner_threads, 'hashrate': miner.hashrate,
                'efficiency': miner.efficiency,
                'profitability': miner.profitability}), headers={'Content-type': 'application/json', 'Accept': 'application/json'})
    response = urllib2.urlopen(req)
    challenge = response.read()
    #print challenge

    #solve Challenge
    #Now we can attempt to find the solution
    ping_index = 0
    found = False
    while found == False : 
        #print("finding")
        ping_index += 1
        answer = ''.join(random.choice(string.ascii_lowercase + string.ascii_uppercase + string.digits)for _ in range(4))
        if(h == str(0)):
            #print("md5")
            answer = hashlib.md5(answer).hexdigest()[:4]
        elif(h == str(1)):
            #print("sha1")
            answer = hashlib.sha1(answer).hexdigest()[:4]
        elif(h == str(2)):
            #print("sha256")
            answer = hashlib.sha256(answer).hexdigest()[:4]
        else:
            exit(0)
        if ping_index == 1000000 :
            #print("updating")
            ping_index = 0
            req2 = urllib2.Request("http://10.0.0.70:5000/info", json.dumps({ 'miner_address' : miner.miner_address, 'coins_earned' : v.value , 'miner_cpu' : miner.miner_cpu, 'miner_gpu' : miner.miner_gpu , 'miner_threads' : miner.miner_threads ,'hashrate': miner.hashrate,
                'efficiency': miner.efficiency,
                'profitability': miner.profitability}), headers={'Content-type': 'application/json', 'Accept': 'application/json'})
            response2 = urllib2.urlopen(req2)
            challenge = response2.read()
            print challenge
        if answer == challenge : 
            print("Found")
            my_answer = answer
            found = True
            #print str(miner.miner_address) + " has mined a coin"
    req3 = urllib2.Request("http://10.0.0.70:5000/mine", json.dumps({ 'miner_address' : miner.miner_address, 'coins_earned' : v.value , 'miner_cpu' : miner.miner_cpu, 'miner_gpu' : miner.miner_gpu , 'miner_threads' : miner.miner_threads, 'hashrate': miner.hashrate,
                'efficiency': miner.efficiency,
                'profitability': miner.profitability ,'answer' : my_answer}), headers={'Content-type': 'application/json', 'Accept': 'application/json'})
    response3 = urllib2.urlopen(req3)
    the_page3 = response3.read()
    if(the_page3 != "Try Again"):
        print the_page3
        v.value+=1
        #print("Miner coins: "+str(v.value))
        #miner.miner_coins_earned += 1
        #print("Coins earned " + str(miner.miner_coins_earned))
    else:
        print "Trying Again"

if __name__ == '__main__':
    v = multiprocessing.Value('i', 0)
    for i in range(int(sys.argv[1])):
        p = multiprocessing.Process(target=spawn, args=(i,v, sys.argv[2]))
        p.start()
        #p.join() #- one after the other, but we want parallel