example.py

#! /usr/bin/python

# this code was written by folkert@vanheusden.com
# it has been released under AGPL v3.0

# it requires 'pycurl'
# in debian this can be found in the 'python-pycurl' package

import base64
import ConfigParser
import hashlib
import hmac
import json
import pycurl
import sys
import urllib

try:
    from io import BytesIO
except ImportError:
    from StringIO import StringIO as BytesIO

from datetime import datetime
from time import mktime

class Bl3pApi:
	url = None
	pubKey = None
	secKey = None
	verbose = False

	def __init__(self, u, pk, sk):
		self.url = u
		self.pubKey = pk
		self.secKey = sk

	def setVerbose(self, v):
		self.verbose = v

	def apiCall(self, path, params):
		dt = datetime.utcnow()
		us = mktime(dt.timetuple()) * 1000 * 1000 + dt.microsecond
		nonce = '%d' % us

		# generate the POST data string
		post_data = urllib.urlencode(params)

		body = '%s%c%s' % (path, 0x00, post_data)

		privkey_bin = base64.b64decode(self.secKey)

		signature_bin = hmac.new(privkey_bin, body, hashlib.sha512).digest()

		signature = base64.b64encode(signature_bin)

		fullpath = '%s%s' % (self.url, path)

		headers = [ 'Rest-Key: %s' % self.pubKey, 'Rest-Sign: %s' % signature ]

		buffer = BytesIO()

		c = pycurl.Curl()
		c.setopt(c.USERAGENT, 'Mozilla/4.0 (compatible; BL3P Python client written by folkert@vanheusden.com; 0.1)');
		c.setopt(c.WRITEFUNCTION, buffer.write)
		c.setopt(c.URL, fullpath);
		c.setopt(c.POST, 1);
		c.setopt(c.POSTFIELDS, post_data);
		c.setopt(c.HTTPHEADER, headers);
		c.setopt(c.SSLVERSION, 1);
		c.setopt(c.SSL_VERIFYPEER, True);
		c.setopt(c.SSL_VERIFYHOST, 2);
		c.setopt(c.CONNECTTIMEOUT, 5);
		c.setopt(c.TIMEOUT, 10);

		if self.verbose:
			c.setopt(c.VERBOSE, 1)
		else:
			c.setopt(c.VERBOSE, 0)

		c.perform()

		response_code = c.getinfo(c.RESPONSE_CODE)
		if response_code != 200:
			raise Exception('unexpected response code: %d' % response_code)

		c.close()

		return json.loads(buffer.getvalue())

	# multiply the btc value (e.g 1.3BTC) with this and round-up/down
	def getBtcMultiplier(self):
		return 100000000

	def getEurMutiplier(self):
		return 100000

	# Add order to your account.
	# @method addOrder
	# @param  market        'EUR'
	# @param  order_type   	'bid' or 'ask'
	#                       bid: used if you want to buy bitcoins
	#                       ask: if you want to sell bitcoins
	# @param  order_amount 	Amount to order *1e8 (so 1 bitcoin is 100000000)
	# @param  order_price  	Price of order *1e5 (1 euro is 100000)
	# @return Result of the add order call
	def addOrder(self, market, order_type, order_amount, order_price):

		params = {
			'type' : order_type,
			'amount_int' : order_amount,
			'price_int' : order_price,
			'fee_currency' : 'BTC'
			}

		return self.apiCall('%sEUR/money/order/add' % market, params)

	# Cancel a specific order.
	# @method cancelOrder
	# @param  market        'EUR'
	# @param  order_id 	Id of the order
	# @return Direct resulf of the '<market>/money/order/cancel' call
	def cancelOrder(self, market, order_id):
		params = { 'order_id' : order_id }

		return self.apiCall("%sEUR/money/order/cancel" % market, params)

	# Fetch information about an specific order
	# @method orderInfo
	# @param  market        'EUR'
	# @param  order_id 	Id of the order
	# @return Direct resulf of the '<market>/money/order/result' call
	def orderInfo(self, market, order_id):
		params = { 'order_id' : order_id }

		return self.apiCall("%sEUR/money/order/result" % market, params)

	# Fetch complete orderbook
	# @method fullDepth
	# @param  market        'EUR'
	# @return Direct resulf of the '<market>/money/depth/full' call
	def fullDepth(self, market):
		return self.apiCall("%sEUR/money/depth/full" % market, { })

	# Get new deposit address.
	# @method getNewDepositAddress
	# @param  market        'EUR'
	# @return new deposit address
	def getNewDepositAddress(self, market):
		return self.apiCall("%sEUR/money/new_deposit_address" % market, { })

	# Get the most recent generated deposit address
	# @method getLastDepositAddress
	# @param  market        'EUR'
	# @return most recent generated deposit address
	def getLastDepositAddress(self, market):
		return self.apiCall("%sEUR/money/deposit_address" % market, { })

	# Get the last 1000 trades that where executed before an specific trade_id
	# @method fetchTrades
	# @param  market        'EUR'
	# @param  trade_id    id of the trade
	# @return array of last 1000 executed trades.
	def fetchLast1000Trades(self, market, trade_id):
		params = { 'trade_id' : trade_id }

		return self.apiCall("%sEUR/money/trades/fetch" % market, params)

	# Get the transaction history
	# @method walletHistory
	# @param  currency  currency which currency
	# @param  n         how many to retrieve
	# @return array   json structure with the transaction history
	def walletHistory(self, currency, n):
		params = { 'currency' : currency, 'recs_per_page' : n }

		return self.apiCall('GENMKT/money/wallet/history', params)

	# Get all open orders.
	# @method getAllActiveOrders
	# @param  market        'EUR'
	# @return array of open orders
	def getAllActiveOrders(self, market):
		return self.apiCall("%sEUR/money/orders" % market, { });

	# Get the balances
	# @method getBalances
	# @return array   json structure with the wallet balances
	def getBalances(self):
		params = { }
		return self.apiCall('GENMKT/money/info', params)
        
def d(j):
	print json.dumps(j, sort_keys=True, indent=4, separators=(',', ': '))

# example:
config = ConfigParser.RawConfigParser()

if len(sys.argv) == 2:
	config.read(sys.argv[1])
else:
	config.read('example.cfg')

public_key = config.get('bl3p', 'public_key') # ........-....-....-....-............
secret_key = config.get('bl3p', 'secret_key') # (long string with a-z/A-Z/0-9 and =)

b = Bl3pApi('https://api.bl3p.eu/1/', public_key, secret_key)

d(b.walletHistory('BTC', 10))