YunoHost/yunorunner
1
0
Fork 0
mirror of https://github.com/YunoHost/yunorunner.git synced 2024-09-03 20:05:52 +02:00
Code Issues Projects Releases Packages Wiki Activity

[enh] implement cli delete command

Browse source
This commit is contained in:
Laurent Peuch 2018-09-03 06:19:25 +02:00
parent dbc68a4e04
commit 573d5099fc
1 changed files with 20 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
cli.py
View file

@ -26,7 +26,7 @@ def require_token():
open("token", "w").write(token) open("token", "w").write(token)
def request_api(path, domain, verb, data): def request_api(path, domain, verb, data={}, check_return_code=True):
assert verb in ("get", "post", "put", "delete") assert verb in ("get", "post", "put", "delete")
https = False https = False
@ -43,8 +43,9 @@ def request_api(path, domain, verb, data):
print(f"Error: access refused because '{response.json()['status']}'") print(f"Error: access refused because '{response.json()['status']}'")
sys.exit(1) sys.exit(1)
# TODO: real error message if check_return_code:
assert response.status_code == 200, response.content # TODO: real error message
assert response.status_code == 200, response.content
return response return response
@ -80,11 +81,26 @@ def list_(all=False, domain=DOMAIN):
print(f"{i['id']:4d} - {i['name']}") print(f"{i['id']:4d} - {i['name']}")
def delete(job_id, domain=DOMAIN): pass def delete(job_id, domain=DOMAIN):
response = request_api(
path=f"job/{job_id}",
verb="delete",
domain=domain,
check_return_code=False
)
if response.status_code == 404:
print(f"Error: no job with the id '{job_id}'")
sys.exit(1)
assert response.status_code == 200, response.content
def update(job_id, domain=DOMAIN): pass def update(job_id, domain=DOMAIN): pass
def stop(job_id, domain=DOMAIN): pass def stop(job_id, domain=DOMAIN): pass
def resume(job_id, domain=DOMAIN): pass def resume(job_id, domain=DOMAIN): pass
if __name__ == '__main__': if __name__ == '__main__':
require_token() require_token()
argh.dispatch_commands([add, list_, delete, update, stop, resume]) argh.dispatch_commands([add, list_, delete, update, stop, resume])