FabInfra-Mirror/zenflows-fabaccess
1
0
Fork 0
mirror of https://github.com/interfacerproject/zenflows-fabaccess.git synced 2025-03-12 15:01:44 +01:00
Code Issues Packages Projects Releases Wiki Activity

get current state

Browse Source
This commit is contained in:
Alberto Lerda 2023-02-14 15:07:10 +01:00
parent f897d42955
commit dd265d4e7c
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
main.py
View File

@ -48,11 +48,12 @@ class Command(BaseModel):
eddsa_public_key: str eddsa_public_key: str
eddsa_signature: str eddsa_signature: str
# TODO: keep the same session across multiple calls
app = FastAPI() app = FastAPI()
conf = Config() conf = Config()
@app.post("/command") @app.post("/command")
async def read_root(cmd: Command): async def command(cmd: Command):
# Verify DID exits on DID controller # Verify DID exits on DID controller
did_request = requests.get(f"{conf.did_url}{cmd.eddsa_public_key}") did_request = requests.get(f"{conf.did_url}{cmd.eddsa_public_key}")
@ -105,3 +106,13 @@ async def read_root(cmd: Command):
return {"success": True} return {"success": True}
@app.get("/state/{urn}")
async def state(urn: str):
session = await fabapi.connect(conf.fab_host, conf.fab_port, conf.fab_user, conf.fab_pass)
if session == None:
raise HTTPException(status_code=500, detail="Fabaccess not available")
info = session.machineSystem.info
ma = await info.getMachineURN(cmd.service).a_wait()
return {"state": ma.state}