From c7fbf4ec81f49125004dfe72af0bb3d18c13a0fb Mon Sep 17 00:00:00 2001
From: Tomas Kopecek <tkopecek@redhat.com>
Date: Oct 11 2017 05:05:41 +0000
Subject: move _list_task to client lib


---

diff --git a/cli/koji_cli/commands.py b/cli/koji_cli/commands.py
index f071639..31733cb 100644
--- a/cli/koji_cli/commands.py
+++ b/cli/koji_cli/commands.py
@@ -37,7 +37,7 @@ from koji_cli.lib import _, OptionParser, activate_session, parse_arches, \
         _unique_path, _running_in_bg, _progress_callback, watch_tasks, \
         arg_filter, linked_upload, list_task_output_all_volumes, \
         print_task_headers, print_task_recurse, download_file, watch_logs, \
-        error, greetings
+        error, greetings, _list_tasks
 
 
 def _printable_unicode(s):
@@ -6010,59 +6010,6 @@ def handle_set_task_priority(goptions, session, args):
         session.setTaskPriority(task_id, options.priority, options.recurse)
 
 
-def _list_tasks(options, session):
-    "Retrieve a list of tasks"
-
-    callopts = {
-        'state' : [koji.TASK_STATES[s] for s in ('FREE', 'OPEN', 'ASSIGNED')],
-        'decode' : True,
-    }
-
-    if options.mine:
-        user = session.getLoggedInUser()
-        if not user:
-            print("Unable to determine user")
-            sys.exit(1)
-        callopts['owner'] = user['id']
-    if options.user:
-        user = session.getUser(options.user)
-        if not user:
-            print("No such user: %s" % options.user)
-            sys.exit(1)
-        callopts['owner'] = user['id']
-    if options.arch:
-        callopts['arch'] = parse_arches(options.arch, to_list=True)
-    if options.method:
-        callopts['method'] = options.method
-    if options.channel:
-        chan = session.getChannel(options.channel)
-        if not chan:
-            print("No such channel: %s" % options.channel)
-            sys.exit(1)
-        callopts['channel_id'] = chan['id']
-    if options.host:
-        host = session.getHost(options.host)
-        if not host:
-            print("No such host: %s" % options.host)
-            sys.exit(1)
-        callopts['host_id'] = host['id']
-
-    qopts = {'order' : 'priority,create_time'}
-    tasklist = session.listTasks(callopts, qopts)
-    tasks = dict([(x['id'], x) for x in tasklist])
-
-    #thread the tasks
-    for t in tasklist:
-        if t['parent'] is not None:
-            parent = tasks.get(t['parent'])
-            if parent:
-                parent.setdefault('children',[])
-                parent['children'].append(t)
-                t['sub'] = True
-
-    return tasklist
-
-
 def handle_list_tasks(goptions, session, args):
     "[info] Print the list of tasks"
     usage = _("usage: %prog list-tasks [options]")
@@ -6246,11 +6193,6 @@ def anon_handle_watch_logs(goptions, session, args):
     activate_session(session, goptions)
 
     if options.mine:
-        options.user = None
-        options.arch = None
-        options.method = None
-        options.channel = None
-        options.host = None
         tasks = _list_tasks(options, session)
         tasks = [t['id'] for t in tasks]
     else:
diff --git a/cli/koji_cli/lib.py b/cli/koji_cli/lib.py
index 694c347..5dadd5b 100644
--- a/cli/koji_cli/lib.py
+++ b/cli/koji_cli/lib.py
@@ -577,3 +577,56 @@ def activate_session(session, options):
     ensure_connection(session)
     if options.debug:
         print("successfully connected to hub")
+
+
+def _list_tasks(options, session):
+    "Retrieve a list of tasks"
+
+    callopts = {
+        'state' : [koji.TASK_STATES[s] for s in ('FREE', 'OPEN', 'ASSIGNED')],
+        'decode' : True,
+    }
+
+    if getattr(options, 'mine'):
+        user = session.getLoggedInUser()
+        if not user:
+            print("Unable to determine user")
+            sys.exit(1)
+        callopts['owner'] = user['id']
+    if getattr(options, 'user'):
+        user = session.getUser(options.user)
+        if not user:
+            print("No such user: %s" % options.user)
+            sys.exit(1)
+        callopts['owner'] = user['id']
+    if getattr(options, 'arch'):
+        callopts['arch'] = parse_arches(options.arch, to_list=True)
+    if getattr(options, 'method'):
+        callopts['method'] = options.method
+    if getattr(options, 'channel'):
+        chan = session.getChannel(options.channel)
+        if not chan:
+            print("No such channel: %s" % options.channel)
+            sys.exit(1)
+        callopts['channel_id'] = chan['id']
+    if getattr(options, 'host'):
+        host = session.getHost(options.host)
+        if not host:
+            print("No such host: %s" % options.host)
+            sys.exit(1)
+        callopts['host_id'] = host['id']
+
+    qopts = {'order' : 'priority,create_time'}
+    tasklist = session.listTasks(callopts, qopts)
+    tasks = dict([(x['id'], x) for x in tasklist])
+
+    #thread the tasks
+    for t in tasklist:
+        if t['parent'] is not None:
+            parent = tasks.get(t['parent'])
+            if parent:
+                parent.setdefault('children',[])
+                parent['children'].append(t)
+                t['sub'] = True
+
+    return tasklist