Improve get_tasks to allow arbitrary filtering

[etc/taskwarrior.git] / tasklib / task.py

diff --git a/tasklib/task.py b/tasklib/task.py
index f74e0d25510028853f52c4511b09d37956f32371..5e2b71b66a48d4b87e6ad8c27ccbb932bb76ace4 100644 (file)
--- a/tasklib/task.py
+++ b/tasklib/task.py
@@ -47,6 +47,9 @@ class Task(object):
 
 
 class TaskWarrior(object):
 
 
 class TaskWarrior(object):

+    DEFAULT_FILTERS = {
+        'status': 'pending',
+    }

 
     def __init__(self, data_location='~/.task', create=True):
         if not os.path.exists(data_location):
 
     def __init__(self, data_location='~/.task', create=True):
         if not os.path.exists(data_location):


@@ -70,10 +73,19 @@ class TaskWarrior(object):
             raise TaskWarriorException(stderr.strip())
         return stdout.strip().split('\n')
 
             raise TaskWarriorException(stderr.strip())
         return stdout.strip().split('\n')
 

-    def get_tasks(self, project=None, status=PENDING):
-        command = 'export status:{0}'.format(status)
-        if project is not None:
-            command += ' project:{0}'.format(project)
+    def _format_filter_kwarg(self, kwarg):
+        key, val = kwarg[0], kwarg[1]
+        if key in ['tag', 'tags']:
+            key = 'tags.equal'
+        key = key.replace('__', '.')
+        return '{0}:{1}'.format(key, val)
+
+    def get_tasks(self, **filter_kwargs):
+        filters = self.DEFAULT_FILTERS
+        filters.update(filter_kwargs)
+        filter_commands = ' '.join(map(self._format_filter_kwarg,
+                                       filters.items()))
+        command = '{0} export'.format(filter_commands)

         tasks = []
         for line in self._execute(command):
             if line:
         tasks = []
         for line in self._execute(command):
             if line: