[libeufin] branch master updated: Add tasks management to CLI.

[gnunet]

This is an automated email from the git hooks/post-receive script.

ms pushed a commit to branch master
in repository libeufin.

The following commit(s) were added to refs/heads/master by this push:
     new 9026299  Add tasks management to CLI.
9026299 is described below

commit 9026299ef0bc509619c356c849d14187c874678c
Author: MS <ms@taler.net>
AuthorDate: Thu Dec 17 19:10:14 2020 +0100

    Add tasks management to CLI.
---
 cli/libeufin-cli | 72 +++++++++++++++++++++++++++++++++++++++++++++++---------
 1 file changed, 61 insertions(+), 11 deletions(-)

diff --git a/cli/libeufin-cli b/cli/libeufin-cli
index f90dfb4..8779c20 100755
--- a/cli/libeufin-cli
+++ b/cli/libeufin-cli
@@ -7,7 +7,7 @@ import json
 import hashlib
 import errno
 from datetime import datetime
-from requests import post, get, auth
+from requests import post, get, auth, delete
 from urllib.parse import urljoin
 from getpass import getpass
 
@@ -86,9 +86,9 @@ def export_backup(obj, connection_name, passphrase, 
output_file):
 @connections.command(help="delete bank connection")
 @click.argument("connection-name")
 @click.pass_obj
-def delete(obj, connection_name):
+def delete_connection(obj, connection_name):
 
-    url = urljoin(obj.nexus_base_url, 
"/bank-connections/delete-connection".format(connection_name))
+    url = urljoin(obj.nexus_base_url, "/bank-connections/delete-connection")
     try:
         resp = post(
             url,
@@ -227,20 +227,70 @@ def list_offered_bank_accounts(obj, connection_name):
     print(resp.content.decode("utf-8"))
 
 @accounts.command(help="Schedules a new task")
-def task_schedule():
-    pass
+@click.argument("account-name")
+@click.option("--task-name", help="Name of the task", required=True)
+@click.option("--cronspec", help="Cronspec string", required=True)
+@click.option(
+    "--task-type",
+    help="'fetch' (downloads transactions histories) or 'submit' (uploads 
payments instructions)",
+    required=True
+)
+@click.option(
+    "--task-params",
+    help="valid values: 'REPORT', 'STATEMENT', 'ALL' (only applicable to the 
'fetch' type)",
+    required=True
+)
+@click.pass_obj
+def task_schedule(obj, account_name, task_name, cronspec , task_type, 
task_params):
+    url = urljoin(obj.nexus_base_url, 
"/bank-accounts/{}/schedule".format(account_name))
+    body = dict(name=task_name, type=task_type, params=task_params)
+    try:
+        resp = post(url, json=body, auth=auth.HTTPBasicAuth(obj.username, 
obj.password))
+    except Exception:
+        print("Could not reach nexus at " + url)
+        exit(1)
+    print(resp.content.decode("utf-8"))
+
 
 @accounts.command(help="Shows the status of one task")
-def task_status():
-    pass
+@click.argument("account-name")
+@click.option("--task-name", help="Name of the task", required=True)
+@click.pass_obj
+def task_status(obj, account_name, task_name):
+    url = urljoin(obj.nexus_base_url, 
"/bank-accounts/{}/schedule/{}".format(account_name, task_name))
+    try:
+        resp = get(url, auth = auth.HTTPBasicAuth(obj.username, obj.password))
+    except Exception:
+        print("Could not reach nexus " + url)
+        exit(1)
+    print(resp.content.decode("utf-8"))
 
 @accounts.command(help="Deletes one task")
-def task_delete():
-    pass
+@click.argument("account-name")
+@click.option("--task-name", help="Name of the task", required=True)
+@click.pass_obj
+def task_delete(obj, account_name, task_name):
+    url = urljoin(obj.nexus_base_url, 
"/bank-accounts/{}/schedule/{}".format(account_name, task_name))
+    try:
+        resp = delete(url, auth = auth.HTTPBasicAuth(obj.username, 
obj.password))
+    except Exception:
+        print("Could not reach nexus " + url)
+        exit(1)
+    print(resp.content.decode("utf-8"))
+
 
 @accounts.command(help="Shows all the active tasks")
-def tasks_show():
-    pass
+@click.argument("account-name")
+@click.pass_obj
+def tasks_show(obj, account_name):
+    url = urljoin(obj.nexus_base_url, 
"/bank-accounts/{}/schedule".format(account_name))
+    try:
+        resp = get(url, auth = auth.HTTPBasicAuth(obj.username, obj.password))
+    except Exception:
+        print("Could not reach nexus " + url)
+        exit(1)
+    print(resp.content.decode("utf-8"))
+
 
 @accounts.command(help="show accounts belonging to calling user")
 @click.pass_obj

-- 
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.