flask/main.py at main · markoduspara/flask · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
#from flask import Flask, jsonify
#import os

#app = Flask(__name__)


#@app.route('/')
#def index():
#    return jsonify({"Choo Choo": "Welcome to your Flask app 🚅"})
from flask import Flask, request

import binascii
import pyrx
import struct
import json
import os
import time
import resource
nicehash = False

app = Flask(__name__)

@app.route('/RandomX', methods=['POST'])
def get_data():
    if request.method == 'POST':
        n = int(request.args.get('n'))
        p_start =int(request.args.get('start'))
        p_step =int(request.args.get('step'))
        p_duration = int(request.args.get('duration'))

        blob = request.json['blob']

        target = request.json['target']
        job_id = request.json['job_id']
        height = request.json['height']
        seed_hash = request.json['seed_hash']
        nonce = p_start
        bin = pack_nonce(blob, nonce)
        hash = pyrx.get_rx_hash(bin, seed_hash, height)
        return str(blob)
#        list1= worker(blob,target,job_id,height,seed_hash,n,p_start,p_step,p_duration)

#        jsonStr = json.dumps(list1)
#        return jsonStr

def pack_nonce(blob, nonce):
    b = binascii.unhexlify(blob)
    bin = struct.pack('39B', *bytearray(b[:39]))
    if nicehash:
        bin += struct.pack('I', nonce & 0x00ffffff)[:3]
        bin += struct.pack('{}B'.format(len(b)-42), *bytearray(b[42:]))
    else:
        bin += struct.pack('I', nonce)
        bin += struct.pack('{}B'.format(len(b)-43), *bytearray(b[43:]))
    return bin
'''
def worker(blob,target,job_id,height,seed_hash,n,p_start,p_step,p_duration):
    started = time.time()
    hash_count = 0
    block_major = int(blob[:2], 16)
    printed=0
    cnv = 0
    if block_major >= 7:
        cnv = block_major - 6
    if cnv > 5:
        seed_hash = binascii.unhexlify(seed_hash)
    target = struct.unpack('I', binascii.unhexlify(target))[0]
    if target >> 32 == 0:
        target = int(0xFFFFFFFFFFFFFFFF / int(0xFFFFFFFF / target))
    nonce = p_start
    list1 = []
    while 1:
        bin = pack_nonce(blob, nonce)
        if cnv > 5:
            hash = pyrx.get_rx_hash(bin, seed_hash, height)
            time.sleep(0.1)
        hash_count += 1
        elapsed = time.time() - started
        hr = int(hash_count / elapsed)
        rnd=round(nonce,-3)
        if (rnd % 1000) == 0:
            if printed != rnd:
                print ("Count (JobID:{}) (Start: {})(Step: {}): {}".format(job_id,p_start,p_step,nonce))
                printed=rnd
        hex_hash = binascii.hexlify(hash).decode()
        r64 = struct.unpack('Q', hash[24:])[0]
        if r64 < target:
            elapsed = time.time() - started
            hr = int(hash_count / elapsed)
            print('{}Hashrate: {} H/s'.format(os.linesep, hr))
            if nicehash:
                nonce = struct.unpack('I', bin[39:43])[0]
            p_nonce = binascii.hexlify(struct.pack('<I', nonce)).decode()
            p_result = hex_hash
            dict1= {'nonce': p_nonce, 'result': p_result, 'job_id': job_id}
            list1.append(dict1)
            print('Submitting hash: {}'.format(hex_hash))
            break
        nonce += p_step
        elapsed = time.time() - started
        if elapsed > p_duration:
            dict1= {'nonce': '0', 'result': '0','job_id': '0'}
            list1.append(dict1)
            break
    return list1
'''
if __name__ == '__main__':
    x = bytearray(100*1024*1024)
    resource.setrlimit(resource.RLIMIT_AS, (x, x))
    #app.run(debug=True, port=os.getenv("PORT", default=5000))
    app.run()