fix: update API routes for sniffer and bridge operations for consistency
All checks were successful
Build and Deploy MITM Webserver / build (push) Successful in 7s
All checks were successful
Build and Deploy MITM Webserver / build (push) Successful in 7s
This commit is contained in:
@@ -61,4 +61,4 @@ def nft_ruleset():
|
|||||||
# ---------------------
|
# ---------------------
|
||||||
|
|
||||||
app.include_router(network_api.router, prefix="/network", tags=["network"])
|
app.include_router(network_api.router, prefix="/network", tags=["network"])
|
||||||
app.include_router(sniffer_router.router, prefix="/sniff", tags=["sniffer"])
|
app.include_router(sniffer_router.router, prefix="/sniffer", tags=["sniffer"])
|
||||||
@@ -350,7 +350,7 @@ def full_state(
|
|||||||
"bridges": get_bridges(), # uses NDB internally
|
"bridges": get_bridges(), # uses NDB internally
|
||||||
}
|
}
|
||||||
|
|
||||||
@router.post("/create")
|
@router.post("/bridge/create")
|
||||||
def create_bridge(req: BridgeCreateRequest, ip: IPRoute = Depends(get_iproute)):
|
def create_bridge(req: BridgeCreateRequest, ip: IPRoute = Depends(get_iproute)):
|
||||||
if bridge_exists(req.name, ip):
|
if bridge_exists(req.name, ip):
|
||||||
raise HTTPException(400, f"Bridge {req.name} already exists")
|
raise HTTPException(400, f"Bridge {req.name} already exists")
|
||||||
@@ -382,7 +382,7 @@ def create_bridge(req: BridgeCreateRequest, ip: IPRoute = Depends(get_iproute)):
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@router.post("/remove")
|
@router.post("/bridge/remove")
|
||||||
def remove_bridge(req: BridgeRemoveRequest, ip: IPRoute = Depends(get_iproute)):
|
def remove_bridge(req: BridgeRemoveRequest, ip: IPRoute = Depends(get_iproute)):
|
||||||
if not bridge_exists(req.name, ip):
|
if not bridge_exists(req.name, ip):
|
||||||
raise HTTPException(404, f"Bridge {req.name} not found")
|
raise HTTPException(404, f"Bridge {req.name} not found")
|
||||||
|
|||||||
@@ -127,7 +127,7 @@ def handle_packet(pkt, bridge: str):
|
|||||||
"dst_ip": pkt[IP].dst if IP in pkt else None,
|
"dst_ip": pkt[IP].dst if IP in pkt else None,
|
||||||
"protocol": pkt[IP].proto if IP in pkt else None,
|
"protocol": pkt[IP].proto if IP in pkt else None,
|
||||||
"length": len(pkt),
|
"length": len(pkt),
|
||||||
"raw": bytes(pkt)
|
"raw": pkt.json()
|
||||||
}
|
}
|
||||||
|
|
||||||
asyncio.run_coroutine_threadsafe(db_insert_packet(pkt_info), async_loop)
|
asyncio.run_coroutine_threadsafe(db_insert_packet(pkt_info), async_loop)
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ from src.network_sniffer import start_sniffing, stop_sniffing
|
|||||||
|
|
||||||
router = APIRouter()
|
router = APIRouter()
|
||||||
|
|
||||||
@router.post("/sniffer/start")
|
@router.post("/start_sniffer")
|
||||||
async def start_sniffer(bridge: str):
|
async def start_sniffer(bridge: str):
|
||||||
"""
|
"""
|
||||||
Start packet sniffing on bridge member interfaces.
|
Start packet sniffing on bridge member interfaces.
|
||||||
@@ -18,7 +18,7 @@ async def start_sniffer(bridge: str):
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@router.post("/sniffer/stop")
|
@router.post("/stop_sniffer")
|
||||||
async def stop_sniffer_api():
|
async def stop_sniffer_api():
|
||||||
await stop_sniffing()
|
await stop_sniffing()
|
||||||
return {"status": "stopped"}
|
return {"status": "stopped"}
|
||||||
|
|||||||
Reference in New Issue
Block a user