Skip to content

Commit b653929

Browse files
committed
feat(core): delivery targets + dev tunnels + CLI + logs dashboard with detail view
1 parent caa00ba commit b653929

12 files changed

Lines changed: 586 additions & 655 deletions

File tree

services/api/delivery_targets.py

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -360,18 +360,21 @@ def test_delivery_target(target_id: str, user_id: str = Depends(get_current_user
360360
target_id=target_id
361361
)
362362

363-
db.execute(
364-
text("""
365-
UPDATE delivery_targets
366-
SET success_count = success_count + 1,
367-
last_used = CURRENT_TIMESTAMP
368-
WHERE id = :id
369-
"""),
370-
{"id": target_id}
371-
)
363+
# db.execute(
364+
# text("""
365+
# UPDATE delivery_targets
366+
# SET success_count = success_count + 1,
367+
# last_used = CURRENT_TIMESTAMP
368+
# WHERE id = :id
369+
# """),
370+
# {"id": target_id}
371+
# )
372372
db.commit()
373373

374-
return {"success": True, "result": result}
374+
return {
375+
"success": result["failed"] == 0,
376+
"result": result
377+
}
375378

376379
except Exception as e:
377380
db.execute(

services/api/main.py

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -263,19 +263,19 @@ def metrics_endpoint():
263263
# Dev tunnels
264264
# -----------------------------
265265

266-
tunnels = {}
266+
# tunnels = {}
267267

268-
@app.websocket("/ws/tunnel/{token}")
269-
async def websocket_tunnel(websocket: WebSocket, token: str):
270-
await websocket.accept()
268+
# @app.websocket("/ws/tunnel/{token}")
269+
# async def websocket_tunnel(websocket: WebSocket, token: str):
270+
# await websocket.accept()
271271

272-
tunnels[token] = websocket
272+
# tunnels[token] = websocket
273273

274-
print(f"[tunnel] connected: {token}")
274+
# print(f"[tunnel] connected: {token}")
275275

276-
try:
277-
while True:
278-
await websocket.receive_text()
279-
except WebSocketDisconnect:
280-
print(f"[tunnel] disconnected: {token}")
281-
tunnels.pop(token, None)
276+
# try:
277+
# while True:
278+
# await websocket.receive_text()
279+
# except WebSocketDisconnect:
280+
# print(f"[tunnel] disconnected: {token}")
281+
# tunnels.pop(token, None)

0 commit comments

Comments
 (0)