Untitled

##
##
####CLOUDDA CALISACAK KODLAR
##
##

from websocket import create_connection
import json
import requests



ws_new = create_connection(
    'wss://pushstream.tradingview.com/message-pipe-ws/private_0funsOks1AglRu5A9hWGT4nBKs9mmHmmGi-p4grB5lg')

def buy_coin(quantity, price, symbol):

    url = "https://www.binance.com/bapi/mbx/v1/private/mbxgateway/order/place"

    payload = json.dumps({
    "quantity": quantity,
    "side": "BUY",
    "type": "LIMIT",
    "price": price,
    "symbol": symbol
    })
    headers = {
   #headers
    }

    response = requests.request("POST", url, headers=headers, data=payload)

    print(response.text)


def sell_coin(quantity, price, symbol):


    url = "https://www.binance.com/bapi/mbx/v1/private/mbxgateway/order/place"

    payload = json.dumps({
    "type": "LIMIT",
    "side": "SELL",
    "price": price,
    "quantity": quantity,
    "symbol": symbol
    })
    headers = {
   #headers
    }

    response = requests.request("POST", url, headers=headers, data=payload)

    print(response.text)


def get_total(symbol):
    url = "https://www.binance.info/bapi/capital/v1/private/capital/config/getOne?coin="+symbol

    payload = {}
    headers = {
    #headers
    }

    response = requests.request("GET", url, headers=headers, data=payload)

    return response.text

alinacak_ve_satilacak_miktar_USDT = 6
coin_miktari = 0
current_price = 0
import json
while True:
    try:
        result = ws_new.recv()
        if isinstance(result, str):
            result = json.loads(result)
            message = result["text"]["content"]["p"]["message"]
            current_price = message.split('-')[1]
            coin_miktari = "{:.2f}".format(float(alinacak_ve_satilacak_miktar_USDT) / float(current_price))
            # total = get_total("NEO")
            # total = json.loads(total)
            # total = "{:.2f}".format(float(total["data"]["totalAmount"]))
            print("##################")
            # print("total:"+total)
            # print("coin_miktari:"+coin_miktari)     
            # print("price:"+current_price)
            print(message)
            print("##################")
            # if(message.split('-')[0] == 'buy'):
            #     buy_coin(coin_miktari, current_price, "NEOUSDT")
            # if(message.split('-')[0] == 'sell'):
            #     sell_coin(total, current_price, "NEOUSDT")

    except Exception as e:
        pass