ltc not supported

[coincrypt]

Litecoin is currently not supported. It throws an error if you try to run avarice.py

[coincrypt]

Please see changes to WebSocketAPI.py to add ltc support import asyncio import hashlib import json

import websocket import websockets

class OKCoinWSPublic:

Ticker = None

def init(self, pair): self.pair = pair

@asyncio.coroutine def initialize(self): TickerFirstRun = True while True: if TickerFirstRun or not ws.open: TickerFirstRun = False if self.pair == 'btc_cny': sockpair = 'btccny' url = "wss://real.okcoin.cn:10440/websocket/okcoinapi" elif self.pair == 'btc_usd': sockpair = 'btcusd' url = "wss://real.okcoin.com:10440/websocket/okcoinapi" elif self.pair == 'ltc_cny': sockpair = 'ltccny' url = "wss://real.okcoin.cn:10440/websocket/okcoinapi" elif self.pair == 'ltc_usd': sockpair = 'ltcusd' url = "wss://real.okcoin.com:10440/websocket/okcoinapi" print('Connecting to Public OKCoin WebSocket...') try: ws = yield from websockets.connect(url)

Ticker

      yield from ws.send("{'event':'addChannel','channel':'ok_" + sockpair + "_ticker'}")
    except Exception:
      TickerFirstRun = True
  OKCoinWSPublic.Ticker = yield from ws.recv()

class OKCoinWSPrivate: TradeOrderID = None

def init(self, pair, api_key='', secret=''): self.pair = pair self.api_key = api_key self.secret = secret if self.pair == 'btc_cny': self.url = "wss://real.okcoin.cn:10440/websocket/okcoinapi" elif self.pair == 'btc_usd': self.url = "wss://real.okcoin.com:10440/websocket/okcoinapi" elif self.pair == 'ltc_cny': self.url = "wss://real.okcoin.cn:10440/websocket/okcoinapi" elif self.pair == 'ltc_usd': self.url = "wss://real.okcoin.com:10440/websocket/okcoinapi" print('Connecting to Private OKCoin WebSocket...') notconnected = True while notconnected: try: self.ws = websocket.create_connection(self.url) notconnected = False except Exception: pass

def buildMySign(self, params, secretKey): sign = '' for key in sorted(params.keys()): sign += key + '=' + str(params[key]) + '&' data = sign + 'secret_key=' + secretKey return hashlib.md5(data.encode("utf8")).hexdigest().upper()

def userinfo(self): params = {'api_key': self.api_key} sign = self.buildMySign(params, self.secret) try: self.ws.send("{'event':'addChannel', 'channel':'ok_spot" + self.pair[-3:] + "_userinfo',\ 'parameters':{ 'api_key':'" + self.api_key + "', 'sign':'" + sign + "'} }") info = self.ws.recv() except (websocket._exceptions.WebSocketTimeoutException, websocket._exceptions.WebSocketConnectionClosedException): self.ws = websocket.create_connection(self.url) self.ws.send("{'event':'addChannel', 'channel':'ok_spot" + self.pair[-3:] + "_userinfo',\ 'parameters':{ 'api_key':'" + self.api_key + "', 'sign':'" + sign + "'} }") info = self.ws.recv() return info

def cancelorder(self, order_id): params = {'api_key': self.api_key, 'symbol': self.pair, 'order_id': order_id} sign = self.buildMySign(params, self.secret) try: self.ws.send("{'event':'addChannel', 'channel':'ok_spot" + self.pair[-3:] + "_cancel_order', 'parameters':{ 'api_key':'" + self.api_key

• "', 'sign':'" + sign + "', 'symbol':'" + self.pair
• "', 'order_id':'" + order_id + "'} }")

  Don't muck up userinfo with executed order_id

  self.ws.recv() except (websocket._exceptions.WebSocketTimeoutException, websocket._exceptions.WebSocketConnectionClosedException): self.ws = websocket.create_connection(self.url) self.ws.send("{'event':'addChannel', 'channel':'ok_spot" + self.pair[-3:]

•            "_cancel_order', 'parameters':{ 'api_key':'" + self.api_key

• "', 'sign':'" + sign + "', 'symbol':'" + self.pair

• "', 'order_id':'" + order_id + "'} }")

  Don't muck up userinfo with executed order_id

  self.ws.recv()

  def trade(self, order, rate, amount): params = {'api_key': self.api_key, 'symbol': self.pair, 'type': order, 'price': rate, 'amount': amount} sign = self.buildMySign(params, self.secret) try: self.ws.send("{'event':'addChannel','channel':'ok_spot" + self.pair[-3:]

• "_trade','parameters':{'api_key':'" + self.api_key
• "','sign':'" + sign + "','symbol':'" + self.pair
• "','type':'" + order + "','price':'"
• str(rate) + "','amount':'" + str(amount) + "'}}") OKCoinWSPrivate.TradeOrderID = json.loads( self.ws.recv())[-1]['data']['order_id'] except (websocket._exceptions.WebSocketTimeoutException, websocket._exceptions.WebSocketConnectionClosedException): self.ws = websocket.create_connection(self.url) self.ws.send("{'event':'addChannel','channel':'ok_spot" + self.pair[-3:]
• "_trade','parameters':{'api_key':'" + self.api_key
• "','sign':'" + sign + "','symbol':'" + self.pair
• "','type':'" + order + "','price':'"

• str(rate) + "','amount':'" + str(amount) + "'}}") OKCoinWSPrivate.TradeOrderID = json.loads( self.ws.recv())[-1]['data']['order_id']

  Subscribes to channel, updates on new trade. Not in use since we store

  the order_id from trade

  def realtrades(self): params = {'api_key': self.apikey} sign = self.buildMySign(params, self.secret) self.ws.send("{'event':'addChannel','channel':'okspot" + self.pair[-3:]

  • "_cancel_order','parameters':{'api_key':'"
  • self.api_key + "','sign':'" + sign + "', 'symbol':'"
  • self.pair + "', 'order_id':'-1'} }") trades = self.ws.recv() return trades

[RealJohnGalt]

Thank you! I can't believe this slipped past me.