if USE_LOG:
    l = open("./log.txt", 'a', encoding='utf-8')
    print(datetime.now(), *args, file=l)
    l.close()
print(datetime.now(),' ', *args)

payload = {'nonce': int(round(time.time()*1000))}

if kwargs:
    payload.update(kwargs)
payload =  urllib.parse.urlencode(payload)

H = hmac.new(key=API_SECRET, digestmod=hashlib.sha512)
H.update(payload.encode('utf-8'))
sign = H.hexdigest()
 
headers = {"Content-type": "application/x-www-form-urlencoded",
       "Key":API_KEY,
       "Sign":sign}
conn = http.client.HTTPSConnection(API_URL, timeout=90)
conn.request(http_method, "/"+API_VERSION + "/" + api_method, payload, headers)
response = conn.getresponse().read()
 
conn.close()

try:
    obj = json.loads(response.decode('utf-8'))

    if 'error' in obj and obj['error']:
        raise ScriptError(obj['error'])
    return obj
except json.decoder.JSONDecodeError:
    raise ScriptError('Ошибка анализа возвращаемых данных, получена строка', response)

chart_data = {} # сформируем словарь с ценой закрытия по 5 минут
for item in reversed(data[pair]):
    d = int(float(item['date'])/(PERIOD*60))*(PERIOD*60) # Округляем время сделки до PERIOD минут
    chart_data[d] = float(item['price']) 
return chart_data

macd, macdsignal, macdhist = talib.MACD(numpy.asarray([chart_data[item] for item in sorted(chart_data)]), fastperiod=12, slowperiod=26, signalperiod=9)
 
idx = numpy.argwhere(numpy.diff(numpy.sign(macd - macdsignal)) != 0).reshape(-1) + 0
inters = []

for offset, elem in enumerate(macd):
    if offset in idx:
        inters.append(elem)
    else:
        inters.append(numpy.nan)
trand = 'BULL' if macd[-1] > macdsignal[-1] else 'BEAR'
hist_data = []
max_v = 0
growing = False
for offset, elem in enumerate(macdhist):
    growing = False       
    curr_v = macd[offset] - macdsignal[offset]
    if abs(curr_v) > abs(max_v):
        max_v = curr_v
    perc = curr_v/max_v
     
    if       (   (macd[offset] > macdsignal[offset] and perc*100 > BULL_PERC) # восходящий тренд
                 or      (
                             macd[offset] < macdsignal[offset] and perc*100 < (100-BEAR_PERC)
                        )

            ):
        v = 1
        growing = True
    else:
        v = 0
         
    if offset in idx and not numpy.isnan(elem):
        # тренд изменился
        max_v = curr_v = 0 # обнуляем пик спреда между линиями
    hist_data.append(v*1000)

return ({'trand':trand, 'growing':growing})

if USE_LOG:
    l = open("./log.txt", 'a', encoding='utf-8')
    print(datetime.now(), *args, file=l)
    l.close()
print(datetime.now(),' ', *args)

offers = call_api('order_book', pair=pair)[pair]

try:
    #current_rate =  float(offers['ask'][0][0]) # покупка по лучшей цене
    #current_rate = sum([float(item[0]) for item in offers['ask'][:3]])/3 # покупка по средней цене из трех лучших в стакане
    current_rate = sum([float(item[0]) for item in offers['ask'][:1]])+0.0000001 # покупка по самой выгодной цене в стакане (покупки)
    can_buy = CAN_SPEND/current_rate
    print('buy', can_buy, current_rate)                            
    log(pair, """
        Текущая цена - %0.8f
        На сумму %0.8f %s можно купить %0.8f %s
        Создаю ордер на покупку
        """ % (current_rate, CAN_SPEND, pair[0], can_buy, pair[1])
    )       
    new_order = call_api(
        'order_create',
        pair = pair,
        quantity = can_buy,
        price = current_rate,
        type = 'buy'
        )                
    log("Создан ордер на покупку %s" % new_order['order_id'] )
except ZeroDivisionError:
    print('Не удается вычислить цену', prices)
USE_LOG = False   

                            #time_passed = time.time() + STOCK_TIME_OFFSET*60*60 - int(order['created'])
                            time_passed = time.time() - int(order['created'])

                            if time_passed > ORDER_LIFE_TIME * 60:
                                log('Пора отменять ордер %s' % order)
                                # Ордер уже давно висит, никому не нужен, отменяем
                                call_api('order_cancel', order_id=order['order_id'])  
                                log('Ордер %s отменен' % order)
                                raise ScriptQuitCondition('Отменяем ордер -за ' + str(ORDER_LIFE_TIME) + ' минут не удалось купить '+ str(CURRENCY_1))
                            else:
                                raise ScriptQuitCondition('Выход, продолжаем надеяться купить валюту по указанному ранее курсу, со времени создания ордера прошло %s секунд' % str(time_passed))
                        else:
                            raise ScriptQuitCondition(str(e))
            else: # Открытых ордеров нет
                balances = call_api('user_info')['balances']
                reserved = call_api('user_info')['reserved']
                min_quantityy = call_api('pair_settings',pair=pair)[pair]
                CURRENCY_1_MIN_QUANTITY = float(min_quantityy['min_quantity'])                    
                if float(balances[pair[:-4]]) >= CURRENCY_1_MIN_QUANTITY: # Есть ли в наличии CURRENCY_1, которую можно продать? 
                    print('Баланс: '+str(float(balances[pair[:-4]]))+' '+str(pair[:-4]))
                    if USE_MACD:
                            macd_advice = get_macd_advice(chart_data=get_ticks(pair)) # проверяем, можно ли создать sell
                            if macd_advice['trand'] == 'BEAR' or (macd_advice['trand'] == 'BULL' and macd_advice['growing']):
                                print('Продавать нельзя, т.к. ситуация на рынке неподходящая: Трэнд '+str(macd_advice['trand'])+'; Рост '+str(macd_advice['growing']))
                                #log(pair, 'Для ордера %s не создаем ордер на продажу, т.к. ситуация на рынке неподходящая' % order['oreder_id'] )
                            else:
                                print('Выставляем ордер на продажу, т.к ситуация подходящая: '+str(macd_advice['trand'])+' '+str(macd_advice['growing']))
                                log(pair, "Для выполненного ордера на покупку выставляем ордер на продажу")
                                create_sell(pair=pair)
                    else: # создаем sell если тенденция рынка позволяет
                        log(pair, "Для выполненного ордера на покупку выставляем ордер на продажу")
                        create_sell(pair=pair)
                else:                    
                    if float(balances[pair[-3:]]) >= CAN_SPEND: 
                        #log(pair, "Неисполненных ордеров нет, пора ли создать новый?")
                        # Проверяем MACD, если рынок в нужном состоянии, выставляем ордер на покупку
                        if USE_MACD:
                            macd_advice = get_macd_advice(chart_data=get_ticks(pair))
                            if macd_advice['trand'] == 'BEAR' and macd_advice['growing']:
                                log(pair, "Создаем ордер на покупку")
                                create_buy(pair=pair)
                            else:
                                log(pair, "Условия рынка не подходят для торговли", macd_advice)
                        else:
                            log(pair, "Создаем ордер на покупку")
                            create_buy(pair=pair)
                    else:
                        order = str(' В ордере :' + str(float(reserved[pair[:-4]])) + ' , ' + str(pair[:-4])) if float(reserved[pair[:-4]]) > 0.0 else ''
                        raise ScriptQuitCondition('Не хватает денег для торговли: баланс ' + str(round(float(balances[pair[-3:]]))) + ' ' + str(pair[-3:]) + order)
        except ScriptError as e:
                print(e)
        except ScriptQuitCondition as e:
            print(e)
        except Exception as e:
            print("!!!!",e)
    time.sleep(1)
except Exception as e:
    print(e)

def sha512(self, data):
    H = hmac.new(key = self.API_SECRET, digestmod = hashlib.sha512)
    H.update(data.encode('utf-8'))
    return H.hexdigest()

def api_query(self, api_method, params = {}):
    params['nonce'] = int(round(time.time() * 1000))
    params =  urllib.parse.urlencode(params)

    sign = self.sha512(params)
    headers = {
        "Content-type": "application/x-www-form-urlencoded",
        "Key": self.API_KEY,
        "Sign": sign
    }
    conn = http.client.HTTPSConnection(self.API_URL)
    conn.request("POST", "/" + self.API_VERSION + "/" + api_method, params, headers)
    response = conn.getresponse().read()

    conn.close()

    try:
        obj = json.loads(response.decode('utf-8'))
        if 'error' in obj and obj['error']:
            print(obj['error'])
            raise sys.exit()
        return obj
    except json.decoder.JSONDecodeError:
        print('Error while parsing response:', response)
        raise sys.exit()

except KeyError as e:
    print("Ордеров нет",e)
finally:
    print("V")

const CryptoJS = require('crypto-js');
const { createWSConnection } = require('./WebSocketsPolyfill');
const EXMO_WS_BASE_URL = `wss://ws-api.exmo.com:443/v1`;
const EXMO_WS_PUBLIC_URL = `${EXMO_WS_BASE_URL}/public`;
const EXMO_WS_PRIVATE_URL = `${EXMO_WS_BASE_URL}/private`;

function createExmoWSConnection(url, messages) {
  const socket = createWSConnection(url);
  const onMessage = (event) => console.log('message:', event);
  const onClose = (event) => console.log('connection closed:', event);
  const onError = (error) => console.log('connection error:', error);
  const onInitialize = () => {
    console.log('connection opened');

    for (let message of messages) {
      console.log('sending:', message);
      socket.send(message);
    }
  };

  socket.on('open', onInitialize);
  socket.on("message", onMessage);
  socket.on('close', onClose);
  socket.on('error', onError);
}

function connectExmoWSPublicApi() {
  const data = [
    '{"id":1,"method":"subscribe","topics":["spot/trades:BTC_USD","spot/ticker:LTC_USD", "spot/ticker:XXX_YYY"]}',
  ];

  createExmoWSConnection(EXMO_WS_PUBLIC_URL, data);
}