/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to breezy/plugins/gitlab/hoster.py

  • Committer: Jelmer Vernooij
  • Date: 2020-07-28 02:11:05 UTC
  • mfrom: (7490.40.78 work)
  • mto: This revision was merged to the branch mainline in revision 7520.
  • Revision ID: jelmer@jelmer.uk-20200728021105-fzq7g6f8bl1g0aet
Merge lp:brz/3.1.

Show diffs side-by-side

added added

removed removed

Lines of Context:
breezy/plugins/gitlab/hoster.py
97
97
        self.error = error
98
98
 
99
99
 
 
100
class GitLabConflict(errors.BzrError):
 
101
 
 
102
    _fmt = "Conflict during operation: %(reason)s"
 
103
 
 
104
    def __init__(self, reason):
 
105
        errors.BzrError(self, reason=reason)
 
106
 
 
107
 
100
108
class ForkingDisabled(errors.BzrError):
101
109
 
102
110
    _fmt = ("Forking on project %(project)s is disabled.")
356
364
            return json.loads(response.data)
357
365
        raise errors.UnexpectedHttpStatus(path, response.status)
358
366
 
359
 
    def _fork_project(self, project_name, timeout=50, interval=5):
 
367
    def _fork_project(self, project_name, timeout=50, interval=5, owner=None):
360
368
        path = 'projects/%s/fork' % urlutils.quote(str(project_name), '')
361
 
        response = self._api_request('POST', path)
 
369
        fields = {}
 
370
        if owner is not None:
 
371
            fields['namespace'] = owner
 
372
        response = self._api_request('POST', path, fields=fields)
362
373
        if response.status == 404:
363
374
            raise ForkingDisabled(project_name)
 
375
        if response.status == 409:
 
376
            resp = json.loads(response.data)
 
377
            raise GitLabConflict(resp.get('message'))
364
378
        if response.status not in (200, 201):
365
379
            raise errors.UnexpectedHttpStatus(path, response.status)
366
380
        # The response should be valid JSON, but let's ignore it
376
390
            project = self._get_project(project['path_with_namespace'])
377
391
        return project
378
392
 
379
 
    def _get_logged_in_username(self):
 
393
    def get_current_user(self):
380
394
        return self._current_user['username']
381
395
 
 
396
    def get_user_url(self, username):
 
397
        return urlutils.join(self.base_url, username)
 
398
 
382
399
    def _list_paged(self, path, parameters=None, per_page=None):
383
400
        if parameters is None:
384
401
            parameters = {}
478
495
                        allow_lossy=True, tag_selector=None):
479
496
        (host, base_project, base_branch_name) = parse_gitlab_branch_url(base_branch)
480
497
        if owner is None:
481
 
            owner = self._get_logged_in_username()
 
498
            owner = self.get_current_user()
482
499
        if project is None:
483
500
            project = self._get_project(base_project)['path']
484
501
        try:
485
502
            target_project = self._get_project('%s/%s' % (owner, project))
486
503
        except NoSuchProject:
487
 
            target_project = self._fork_project(base_project)
 
504
            target_project = self._fork_project(base_project, owner=owner)
488
505
        remote_repo_url = git_url_to_bzr_url(target_project['ssh_url_to_repo'])
489
506
        remote_dir = controldir.ControlDir.open(remote_repo_url)
490
507
        try:
504
521
    def get_derived_branch(self, base_branch, name, project=None, owner=None):
505
522
        (host, base_project, base_branch_name) = parse_gitlab_branch_url(base_branch)
506
523
        if owner is None:
507
 
            owner = self._get_logged_in_username()
 
524
            owner = self.get_current_user()
508
525
        if project is None:
509
526
            project = self._get_project(base_project)['path']
510
527
        try:
580
597
    def iter_my_proposals(self, status='open'):
581
598
        state = mp_status_to_status(status)
582
599
        for mp in self._list_merge_requests(
583
 
                owner=self._get_logged_in_username(), state=state):
 
600
                owner=self.get_current_user(), state=state):
584
601
            yield GitLabMergeProposal(self, mp)
585
602
 
586
603
    def iter_my_forks(self):
587
 
        for project in self._list_projects(owner=self._get_logged_in_username()):
 
604
        for project in self._list_projects(owner=self.get_current_user()):
588
605
            base_project = project.get('forked_from_project')
589
606
            if not base_project:
590
607
                continue