🚧 Support of issues management

- issue listing
- issue get/set/toggle of labels, milestones and open-close status
- issue edit of issue
- parsing of notification mail to extract repo_slug and issue number
- tests of the whole

fixes #104

Signed-off-by: Guyzmo <[email protected]>

Author: guyzmo

git_repo/repo.py

@@ -29,6 +29,22 @@
     {self} [--path=<path>] [-v...] <target> (gist|snippet) fetch <gist> [<gist_file>]
     {self} [--path=<path>] [-v...] <target> (gist|snippet) create [--secret] <description> [<gist_path> <gist_path>...]
     {self} [--path=<path>] [-v...] <target> (gist|snippet) delete <gist> [-f]
+    {self} [--path=<path>] [-v...] <target> issue (list|ls) [--filter=<filter>]
+    {self} [--path=<path>] [-v...] <target> issue (list|ls) [<action>|<issue_id>]
+    {self} [--path=<path>] [-v...] <target> issue get <action> [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue set <action> <value> [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue unset <action> [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue toggle <action> <value> [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue edit [<issue_id>]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> (list|ls) [--filter=<filter>]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> (list|ls) [<action>|<issue_id>]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> get <action> [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> set <action> [<value>] [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> unset <action> [<value>] [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> toggle <action> [<value>] [--filter=<filter>] [<issue_id> <issue_id>...]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> edit [<issue_id>]
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> add <action> <value>
+    {self} [--path=<path>] [-v...] <target> issue <user>/<repo> delete [-f] <action>
     {self} [--path=<path>] [-v...] <target> config [--config=<gitconfig>]
     {self} [-v...] config [--config=<gitconfig>]
     {self} --help
@@ -44,6 +60,7 @@
     list                     Lists the repositories for a given user
     gist                     Manages gist files
     request                  Handles requests for merge
+    issue                    Handles issues
     open                     Open the given or current repository in a browser
     config                   Run authentication process and configure the tool
 
@@ -92,6 +109,16 @@
     -t,--title=<title>       Title to give to the request for merge
     -m,--message=<message>   Description for the request for merge
 
+Options for issues:
+    get                      Gets a value for the given action listed below
+    set                      Sets a value for the given action listed below
+    unset                    Unsets a value for the given action listed below
+    toggle                   Toggles a value for the given action listed below
+    <action>                 Action: label, milestone or mark
+    <value>                  Value for what shall be set
+    --filter=<filter>        Filters the list of issues [Default: ]
+    <issue_id>               Issue's number
+
 Configuration options:
     alias                    Name to use for the git remote
     fqdn                     URL of the repository
@@ -147,6 +174,29 @@
 
 EXTRACT_URL_RE = re.compile('[^:]*(://|@)[^/]*/')
 
+def blue(s):
+    return '\033[94m{}\033[0m'.format(s)
+def green(s):
+    return '\033[92m{}\033[0m'.format(s)
+def red(s):
+    return '\033[91m{}\033[0m'.format(s)
+
+def confirm(what, where):
+    '''
+    Method to show a CLI based confirmation message, waiting for a yes/no answer.
+    "what" and "where" are used to better define the message.
+    '''
+    ans = input('Are you sure you want to delete the '
+                '{} {} from the service?\n[yN]> '.format(what, where))
+    if 'y' in ans:
+        ans = input('Are you really sure? there\'s no coming back!\n'
+                    '[type \'burn!\' to proceed]> ')
+        if 'burn!' != ans:
+            return False
+    else:
+        return False
+    return True
+
 
 class GitRepoRunner(KeywordArgumentParser):
 
@@ -247,6 +297,14 @@ def set_branch(self, branch):
 
         self.branch = branch
 
+    @store_parameter('<action>')
+    def set_action(self, action):
+        self.action = action
+
+    @store_parameter('<issue_id>')
+    def set_issue_action(self, issue_id):
+        self.issues = issue_id
+
     @store_parameter('<repo>')
     def set_target_repo(self, repo):
         self.target_repo = repo
@@ -511,6 +569,185 @@ def do_gist_delete(self):
         log.info('Successfully deleted gist!')
         return 0
 
+    '''Issues'''
+
+    @register_action('issue', 'ls')
+    @register_action('issue', 'list')
+    def do_issue_list(self):
+        service = self.get_service()
+        if self.action:
+            if self.action in ('milestones', 'milestone', 'm'):
+                milestones = service.issue_milestone_list(self.user_name, self.repo_name)
+                print(blue(next(milestones)), file=sys.stderr)
+                for milestone in milestones:
+                    print(milestone)
+                return 0
+            elif self.action in ('labels', 'label', 'l'):
+                labels = service.issue_label_list(self.user_name, self.repo_name)
+                print(blue(next(labels)), file=sys.stderr)
+                for label in labels:
+                    print(label)
+                return 0
+            elif self.action in ('mark', 'm'):
+                print('opened\nclosed\nread')
+                return 0
+            else:
+                issue = service.issue_grab(self.user_name, self.repo_name, self.action)
+                print('\n'.join([
+                        'Issue #{} ({}) by @{}'.format(
+                            issue['id'],
+                            green(issue['state']) if issue['state'] == 'open' else red(issue['state']),
+                            issue['poster']),
+                        'Created at:\t{} {}'.format(
+                            issue['creation'],
+                            '' if not issue['state'] == 'closed' else 'and closed at: {} by @{}'.format(
+                                issue['closed_at'], issue['closed_by']
+                            )
+                        ),
+                        'Assigned:\t{}'.format('@{}'.format(issue['assignee']) or 'ø'),
+                        'Milestone:\t{}'.format(issue['milestone']),
+                        'Labels:\t\t{}'.format(', '.join(issue['labels'])),
+                        'URI:\t\t{}'.format(issue['uri']),
+                        'Title:\t\t{}'.format(issue['title']),
+                        'Body:', '',
+                        issue['body'],
+                    ])
+                )
+        else:
+
+
+            def format_issue(issue):
+                if issue[0] == None:
+                    status_icon = ' '
+                elif not issue[5]:
+                    status_icon = green('📖') if issue[0] else red('📕')
+                else:
+                    status_icon = green('📦') if issue[0] else red('📦')
+                number = issue[1].rjust(3)
+                labels = issue[2][:20].ljust(20) + ("…" if len(issue[2]) > 20 else "")
+                title = issue[3][:60].ljust(60) + ("…" if len(issue[3]) > 60 else "")
+                uri = issue[4]
+                return '{} {}\t{}\t{}\t{}'.format(status_icon, number, labels, title, uri)
+
+            issues = service.issue_list(self.user_name, self.repo_name, self.filter or '')
+            print(blue(format_issue(next(issues))), file=sys.stderr)
+            for issue in issues:
+                print(format_issue(issue))
+            return 0
+
+    def check_issues_parameter(self):
+        if self.issues == [] and self.filter == '':
+            if self.value:
+                self.issues = [self.value]
+                self.value = None
+            else:
+                raise ArgumentError("Need at least one issue or a --filter parameter")
+        if len(self.issues) == 1 and self.issues[0] in ('*', 'all'):
+            self.issues = []
+
+    @register_action('issue', 'get')
+    def do_issue_get(self):
+        service = self.get_service()
+        if len(self.issues) == 1 and self.issues[0] == '-':
+            self.user_name, self.repo_name, self.issues = service.issue_extract_from_file(sys.stdin)
+        issue_data = service.issue_get(self.user_name, self.repo_name, self.action, self.filter or '', self.issues)
+        print(blue(next(issue_data)), file=sys.stderr)
+        for data in issue_data:
+            print('{}'.format(data))
+
+    @register_action('issue', 'set')
+    def do_issue_set(self):
+        self.check_issues_parameter()
+        service = self.get_service()
+        if len(self.issues) == 1 and self.issues[0] == '-':
+            self.user_name, self.repo_name, self.issues = service.issue_extract_from_file(sys.stdin)
+        rv = 1
+        if all(service.issue_set(self.user_name, self.repo_name, self.action, self.value, self.filter or '', self.issues)):
+            rv = 0
+        self.do_issue_get()
+        return rv
+
+    @register_action('issue', 'unset')
+    def do_issue_unset(self):
+        self.check_issues_parameter()
+        service = self.get_service()
+        if len(self.issues) == 1 and self.issues[0] == '-':
+            self.user_name, self.repo_name, self.issues = service.issue_extract_from_file(sys.stdin)
+        rv = 1
+        if all(service.issue_unset(self.user_name, self.repo_name, self.action, self.value, self.filter or '', self.issues)):
+            rv = 0
+        self.do_issue_get()
+        return rv
+
+    @register_action('issue', 'toggle')
+    def do_issue_toggle(self):
+        self.check_issues_parameter()
+        service = self.get_service()
+        if len(self.issues) == 1 and self.issues[0] == '-':
+            self.user_name, self.repo_name, self.issues = service.issue_extract_from_file(sys.stdin)
+        rv = 1
+        if all(service.issue_toggle(self.user_name, self.repo_name, self.action, self.value, self.filter or '', self.issues)):
+            rv = 0
+        self.do_issue_get()
+        return rv
+
+    @register_action('issue', 'edit')
+    def do_issue_edit(self):
+        do_ask=False
+        if len(self.issues) == 1 and self.issues[0] == '-':
+            self.user_name, self.repo_name, self.issues = service.issue_extract_from_file(sys.stdin)
+            do_ask=True
+
+        def edit_issue(title, body):
+            from tempfile import NamedTemporaryFile
+            from subprocess import call
+            with NamedTemporaryFile(
+                    prefix='git-repo-issue-',
+                    suffix='.md',
+                    mode='w+b') as issue_file:
+                issue_file.write('Title: {}\n\nBody:\n{}\n'.format(title, body).encode('utf-8'))
+                issue_file.flush()
+                call("{} {}".format(os.environ['EDITOR'], issue_file.name), shell=True)
+                issue_file.seek(0)
+                updated_issue = issue_file.read().decode('utf-8')
+                try:
+                    _, updated_issue = updated_issue.split('Title: ')
+                    title, body, *tail = updated_issue.split('\n\nBody:\n')
+                    body = ''.join([body]+tail)
+                except Exception:
+                    raise ResourceError("Format of the modified issue cannot be parsed.")
+
+                print('New issue\'s details:')
+                print('Title: {}'.format(title))
+                print('Body:\n{}'.format(body))
+                if do_ask and input('Do you confirm it\'s ok? [Yn] ').lower().startswith('n'):
+                    return None
+                return {'title': title, 'body': body}
+
+        service = self.get_service()
+        if service.issue_edit(self.user_name, self.repo_name, self.issues[0], edit_issue):
+            return 0
+        return 1
+
+    @register_action('issue', 'add')
+    def do_issue_action_add(self):
+        service = self.get_service()
+        if service.issue_action_add(self.user_name, self.repo_name, self.action, self.value):
+            return 0
+        return 1
+
+    @register_action('issue', 'del')
+    def do_issue_action_delete(self):
+        service = self.get_service()
+        if not self.force: # pragma: no cover
+            if not confirm('Action {} will be removed'.format(self.action), self.repo_slug):
+                return 0
+        if service.issue_action_del(self.user_name, self.repo_name, self.action, self.value):
+            return 0
+        return 1
+
+    '''Configuration'''
+
     @register_action('config')
     def do_config(self):
         from getpass import getpass