python-sample/trade.py at master · TheOceanTrade/python-sample · 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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
#!/usr/bin/env python

import asyncio

from web3 import Web3, HTTPProvider
from requests import Request, Session
import binascii
import requests
import time
import hmac
import hashlib
import base64
import json
import os

base_URL = 'https://kovan.theoceanx.com/api/v0' # The Ocean X staging environment

RESERVE_MARKET_ORDER = base_URL + '/market_order/reserve'
PLACE_MARKET_ORDER = base_URL + '/market_order/place'
USER_HISTORY = base_URL + '/user_history'

API_KEY = os.environ['API_KEY']
API_SECRET = os.environ['API_SECRET']
ETHEREUM_ADDRESS = os.environ['ETHEREUM_ADDRESS']
print(API_KEY, API_SECRET, ETHEREUM_ADDRESS)
WEB3_URL = 'http://localhost:8545'   # this is the default for parity

web3 = Web3(HTTPProvider(WEB3_URL))

def signOrder(order):
    signed_order = order
    signed_order['maker'] = ETHEREUM_ADDRESS
    values = [
        Web3.toChecksumAddress(signed_order['exchangeContractAddress']),
        Web3.toChecksumAddress(signed_order['maker']),
        Web3.toChecksumAddress(signed_order['taker']),
        Web3.toChecksumAddress(signed_order['makerTokenAddress']),
        Web3.toChecksumAddress(signed_order['takerTokenAddress']),
        Web3.toChecksumAddress(signed_order['feeRecipient']),

        int(signed_order['makerTokenAmount']),
        int(signed_order['takerTokenAmount']),
        int(signed_order['makerFee']),
        int(signed_order['takerFee']),
        int(signed_order['expirationUnixTimestampSec']),
        int(signed_order['salt'])
    ]
    types = [
        'address',
        'address',
        'address',
        'address',
        'address',
        'address',
        'uint256',
        'uint256',
        'uint256',
        'uint256',
        'uint256',
        'uint256'
    ]
    orderHash = Web3.soliditySha3(types, values).hex()
    signed_order['orderHash'] = orderHash
    hex_signature = web3.eth.sign(ETHEREUM_ADDRESS, hexstr=orderHash).hex()
    sig = Web3.toBytes(hexstr=hex_signature)
    v, r, s = Web3.toInt(sig[-1]), Web3.toHex(sig[:32]), Web3.toHex(sig[32:64])
    ecSignature = {'v': v, 'r': r, 's': s}
    signed_order['ecSignature'] = ecSignature


    signed_order['exchangeContractAddress'] = signed_order['exchangeContractAddress'].lower()
    signed_order['maker'] = signed_order['maker'].lower()
    signed_order['taker'] = signed_order['taker'].lower()
    signed_order['makerTokenAddress'] = signed_order['makerTokenAddress'].lower()
    signed_order['takerTokenAddress'] = signed_order['takerTokenAddress'].lower()
    signed_order['feeRecipient'] = signed_order['feeRecipient'].lower()

    return signed_order

def authenticated_request(URL, method, body):
    timestamp = str(int(round(time.time() * 1000)))
    prehash =  API_KEY + timestamp + method + json.dumps(body, separators=(',',':'))
    signature = base64.b64encode(hmac.new(API_SECRET.encode('utf-8'),
                                 msg = prehash.encode('utf-8'),
                                 digestmod = hashlib.sha256).digest())

    headers = {
      'TOX-ACCESS-KEY': API_KEY,
      'TOX-ACCESS-SIGN': signature,
      'TOX-ACCESS-TIMESTAMP': timestamp
    }
    request = requests.request(method,
        URL,
        headers = headers,
        json = body)

    return request

def new_market_order(baseTokenAddress, quoteTokenAddress, side, orderAmount, feeOption='feeInNative'):
    reserve_body = {
        'baseTokenAddress':baseTokenAddress,
        'quoteTokenAddress':quoteTokenAddress,
        'side':side,
        'orderAmount':orderAmount,
        'feeOption':feeOption
    }
    reserve_request = authenticated_request(RESERVE_MARKET_ORDER, 'POST', reserve_body)
    print(reserve_request.text)
    signed_order = signOrder(json.loads(reserve_request.text)['unsignedOrder'])
    market_order_ID = json.loads(reserve_request.text)['marketOrderID']

    place_body = {
        'marketOrderID': market_order_ID,
        'signedOrder': signed_order
    }

    place_request = authenticated_request(PLACE_MARKET_ORDER, 'POST', place_body)

    history_request = authenticated_request(USER_HISTORY, 'GET', {})

new_market_order(
    '0x6ff6c0ff1d68b964901f986d4c9fa3ac68346570',
    '0xd0a1e359811322d97991e03f863a0c30c2cf029c',
    'buy',
    '123456789012345678')