+ ``pag`` helps you win at `pagure.io <https://pagure.io>`_.

+ 

+ Intended to mimic the `hub <https://github.com/github/hub>`_ cli tool for `github.com <https://github.com>`_.

+ from .commands import pullrequest

+ from pag.utils import repo_url

+                                   'forking project: %r.  Sent %r' % (

+     def submit_pull_request(self, name, base, head, title, comment):

+         url = 'https://pagure.io/{name}/diff/{base}..{head}'

+         url = url.format(name=name, base=base, head=head)

+ 

+         response = self._session.get(url)

+         if not bool(response):

+             raise PagureException("Couldn't get form to get "

+                                   "csrf token %r" % response)

+ 

+         soup = bs4.BeautifulSoup(response.text, "html.parser")

+         data = dict(

+             csrf_token=soup.find(id='csrf_token').attrs['value'],

+             branch_to=base,

+             title=title,

+             initial_comment=comment,

+         )

+         response = self._session.post(url, data=data)

+ 

+         if not bool(response):

+             del data['csrf_token']

+             raise PagureException('Bad status code from pagure when '

+                                   'creating pull request: %r.  Sent %r' % (

+                                       response, data))

+ 

+         return response.url

+ 

+ 

+     run(['git', 'clone', url, name.split('/')[-1]])

+         run(['git', 'clone', url, name.split('/')[-1]])

+         run(['git', 'remote', 'add', name, url])

+         run(['git', 'remote', 'add', 'origin', url])

+     run(['git', 'remote', 'add', name, url])

+ import getpass

+ import sys

+ 

+ import click

+ 

+ from pag.app import app

+ from pag.utils import (

+     configured,

+     assert_local_repo,

+     in_git_repo,

+     get_default_upstream_branch,

+     get_current_local_branch,

+     run,

+ )

+ from pag.client import client

+ 

+ HEADER = "Pull request title goes here."

+ MARKER = "# All lines below this marker are ignored."

+ 

+ 

+ @app.command('pull-request')

+ @assert_local_repo

+ @click.option('-b', '--base')

+ @click.option('-h', '--head')

+ @configured

+ def pullrequest(conf, base, head):

+ 

+     name = in_git_repo()

+ 

+     if base is None:

+         try:

+             base = get_default_upstream_branch(name)

+         except Exception:

+             click.echo("Failed to find default upstream branch for %r" % name)

+             click.echo("Please specify a base branch explicitly.")

+             sys.exit(1)

+ 

+     if head is None:

+         head = get_current_local_branch()

+ 

+     cmd = ['git', 'log', '{base}..{head}'.format(base=base, head=head)]

+     _, log = run(cmd, echo=False)

+ 

+     def modify(line):

+         if not line:

+             return line

+         if line[0].isspace():

+             return line.strip()

+         return '# ' + line

+ 

+     log = '\n'.join([modify(line) for line in log.split('\n')])

+     edited = click.edit(

+         "\n\n".join([HEADER, MARKER, log]),

+         env=dict(VIMINIT='set filetype="gitcommit"'),

+     )

+     title, comment = edited.split('\n', 1)

+     if not title:

+         click.echo("Aborting due to empty pull request message.")

+         sys.exit(1)

+     comment = comment.split(MARKER)[0]

+     comment = comment.strip()

+ 

+     username = conf['username']

+     if not client.is_logged_in:

+         password = getpass.getpass("FAS password for %r" % username)

+         client.login(username=username, password=password)

+     url = client.submit_pull_request(name, base, head, title, comment)

+     click.echo(url)

+     return run(['git', 'remote', 'add', name, url])

+ import subprocess as sp

+ import requests

+ 

+ def run(cmd, echo=True, graceful=True):

+     click.echo('  $ ' + " ".join(cmd))

+     proc = sp.Popen(cmd, stdout=sp.PIPE, stderr=sp.STDOUT)

+     output, _ = proc.communicate()

+     output = output.decode('utf-8')

+     if echo:

+         click.echo(output)

+     if not graceful and proc.returncode != 0:

+         sys.exit(1)

+     return proc.returncode, output

+ def get_default_upstream_branch(name):

+     url = 'https://pagure.io/api/0/projects'

+     response = requests.get(url, params=dict(pattern=name, fork=False))

+     if not bool(response):

+         raise IOError("Failed to talk to %r %r", (url, response))

+     data = response.json()

+     projects = data['projects']

+     if not projects:

+         raise ValueError("No such project %r" % name)

+     if len(projects) > 1:

+         raise ValueError("More than one project called %r found "

+                          "(%i of them, in fact)." % (name, len(projects)))

+     project = projects[0]

+     return project['default_branch']

+ 

+ 

+ def get_current_local_branch():

+     code, stdout = run(['git', 'branch', '--contains'])

+     return stdout.split(maxsplit=1)[1].strip()

+ 

+