You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
73 lines
2.0 KiB
73 lines
2.0 KiB
1 year ago
|
import asyncio
|
||
|
|
import websockets
|
||
|
|
import json
|
||
|
|
|
||
|
|
|
||
|
|
from websockets.sync.client import connect
|
||
|
|
|
||
|
|
def hello():
|
||
|
|
print('peppo 1')
|
||
|
|
with connect("ws://localhost:12345") as websocket:
|
||
|
|
print('peppo 2')
|
||
|
|
websocket.send("Hello world!")
|
||
|
|
message = websocket.recv()
|
||
|
|
print(f"Received: {message}")
|
||
|
|
|
||
|
|
hello()
|
||
|
|
|
||
|
|
|
||
|
|
async def dap_client():
|
||
|
|
print('pippo1')
|
||
|
|
async with websockets.connect("ws://localhost:12345") as websocket:
|
||
|
|
# Initialize the debug session
|
||
|
|
print('pippo2')
|
||
|
|
initialize_request = {
|
||
|
|
"seq": 1,
|
||
|
|
"type": "request",
|
||
|
|
"command": "initialize",
|
||
|
|
"arguments": {}
|
||
|
|
}
|
||
|
|
await websocket.send(json.dumps(initialize_request))
|
||
|
|
response = await websocket.recv()
|
||
|
|
print("Initialize response:", response)
|
||
|
|
|
||
|
|
# Set a breakpoint
|
||
|
|
set_breakpoints_request = {
|
||
|
|
"seq": 2,
|
||
|
|
"type": "request",
|
||
|
|
"command": "setBreakpoints",
|
||
|
|
"arguments": {
|
||
|
|
"source": {"path": "example.py"},
|
||
|
|
"breakpoints": [{"line": 10}]
|
||
|
|
}
|
||
|
|
}
|
||
|
|
await websocket.send(json.dumps(set_breakpoints_request))
|
||
|
|
response = await websocket.recv()
|
||
|
|
print("Set breakpoints response:", response)
|
||
|
|
|
||
|
|
# Launch the debug session
|
||
|
|
launch_request = {
|
||
|
|
"seq": 3,
|
||
|
|
"type": "request",
|
||
|
|
"command": "launch",
|
||
|
|
"arguments": {
|
||
|
|
"program": "example.py"
|
||
|
|
}
|
||
|
|
}
|
||
|
|
await websocket.send(json.dumps(launch_request))
|
||
|
|
response = await websocket.recv()
|
||
|
|
print("Launch response:", response)
|
||
|
|
|
||
|
|
# Continue execution
|
||
|
|
continue_request = {
|
||
|
|
"seq": 4,
|
||
|
|
"type": "request",
|
||
|
|
"command": "continue",
|
||
|
|
"arguments": {}
|
||
|
|
}
|
||
|
|
await websocket.send(json.dumps(continue_request))
|
||
|
|
response = await websocket.recv()
|
||
|
|
print("Continue response:", response)
|
||
|
|
|
||
|
|
asyncio.run(dap_client())
|