39 lines
1.1 KiB
Python
39 lines
1.1 KiB
Python
import json
|
|
import websocket
|
|
json_payload = {
|
|
"jsonrpc": 2,
|
|
"method": "enter_order",
|
|
"params": {
|
|
"price": 1646.8,
|
|
"quantity": 1,
|
|
"order_type": "limit",
|
|
"side": "buy",
|
|
"account": "main",
|
|
"user": "bts",
|
|
"exchange_securty_name": "ETH-31MAR23",
|
|
"venue": "deribit",
|
|
"custom": {}
|
|
},
|
|
"id": 1
|
|
}
|
|
json_string = json.dumps(json_payload)
|
|
ws_url = "ws://localhost:8080"
|
|
# Define a callback function to handle received messages
|
|
def on_message(ws, message):
|
|
print("Received message: ", message)
|
|
ws.close()
|
|
|
|
# Define a callback function to handle the WebSocket connection opening
|
|
def on_open(ws):
|
|
print("WebSocket connection opened")
|
|
ws.send(json_string)
|
|
|
|
# Define a callback function to handle the WebSocket connection closing
|
|
def on_close(ws):
|
|
print("WebSocket connection closed")
|
|
# Create a WebSocket connection and send the JSON payload
|
|
ws = websocket.WebSocketApp(ws_url, on_message=on_message, on_open=on_open, on_close=on_close)
|
|
|
|
# Start the WebSocket connection and listen for incoming messages
|
|
ws.run_forever()
|
|
input("press any key to continue") |