This commit is contained in:
DingZQ
2022-10-15 17:28:00 +08:00
parent 99a2fd4b65
commit 803d7c12f1

12
main.py
View File

@@ -6,7 +6,7 @@ from urllib.request import Request
from fastapi import FastAPI, File, UploadFile from fastapi import FastAPI, File, UploadFile
from pydantic import BaseModel from pydantic import BaseModel
from starlette.responses import FileResponse, JSONResponse from starlette.responses import FileResponse, JSONResponse
from fastapi import FastAPI, Response, status, Request from fastapi import FastAPI, Response, status, Request, Body
from tjnetwork import * from tjnetwork import *
JUNCTION = 0 JUNCTION = 0
@@ -97,14 +97,8 @@ async def fastapi_sync_with_server(network: str, operationid: int) -> ChangeSet:
return sync_with_server(network, operationid) return sync_with_server(network, operationid)
@app.post("/batch/") @app.post("/batch/")
async def fastapi_execute_batch_commands(network: str, request: Request) -> ChangeSet: async def fastapi_execute_batch_commands(network: str, payload: dict = Body(...)) -> ChangeSet:
print(request) cs = ChangeSet({})
jsTxt = await request.json()
print(jsTxt)
joOps = json.loads(jsTxt)['operations']
cs:ChangeSet = ChangeSet({})
for js in joOps:
cs.add(js)
return api.execute_batch_commands(network, cs) return api.execute_batch_commands(network, cs)
# node # node