/brz/remove-bazaar

« back to all changes in this revision

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

• browse files at revision 7490.77.11
• compare with another revision
• download diff
• download tarball
• view history from revision 7490.77.11

• reverse the comparison (7490.77.11 to 7519.1.1)
• stop comparing with revision 7519.1.1

Show diffs side-by-side

added

removed

breezy/plugins/gitlab/hoster.py

16

16

 

17

17

"""Support for GitLab."""

18

18

 

 

19

from __future__ import absolute_import

 

20

 

19

21

import json

20

22

import os

21

23

import time

28

30

    urlutils,

29

31

    )

30

32

from ...git.urls import git_url_to_bzr_url

 

33

from ...sixish import PY3

31

34

from ...trace import mutter

32

35

from ...transport import get_transport

33

36

 

97

100

        self.error = error

98

101

 

99

102

 

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

 

 

108

103

class ForkingDisabled(errors.BzrError):

109

104

 

110

105

    _fmt = ("Forking on project %(project)s is disabled.")

302

297

 

303

298

 

304

299

def gitlab_url_to_bzr_url(url, name):

 

300

    if not PY3:

 

301

        name = name.encode('utf-8')

305

302

    return git_url_to_bzr_url(url, branch=name)

306

303

 

307

304

 

341

338

            raise KeyError('no such user %s' % username)

342

339

        if response.status == 200:

343

340

            return json.loads(response.data)

344

 

        raise errors.UnexpectedHttpStatus(path, response.status)

 

341

        raise errors.InvalidHttpResponse(path, response.text)

345

342

 

346

343

    def _get_user_by_email(self, email):

347

344

        path = 'users?search=%s' % urlutils.quote(str(email), '')

353

350

            if len(ret) != 1:

354

351

                raise ValueError('unexpected number of results; %r' % ret)

355

352

            return ret[0]

356

 

        raise errors.UnexpectedHttpStatus(path, response.status)

 

353

        raise errors.InvalidHttpResponse(path, response.text)

357

354

 

358

355

    def _get_project(self, project_name):

359

356

        path = 'projects/%s' % urlutils.quote(str(project_name), '')

362

359

            raise NoSuchProject(project_name)

363

360

        if response.status == 200:

364

361

            return json.loads(response.data)

365

 

        raise errors.UnexpectedHttpStatus(path, response.status)

 

362

        raise errors.InvalidHttpResponse(path, response.text)

366

363

 

367

 

    def _fork_project(self, project_name, timeout=50, interval=5, owner=None):

 

364

    def _fork_project(self, project_name, timeout=50, interval=5):

368

365

        path = 'projects/%s/fork' % urlutils.quote(str(project_name), '')

369

 

        fields = {}

370

 

        if owner is not None:

371

 

            fields['namespace'] = owner

372

 

        response = self._api_request('POST', path, fields=fields)

 

366

        response = self._api_request('POST', path)

373

367

        if response.status == 404:

374

368

            raise ForkingDisabled(project_name)

375

 

        if response.status == 409:

376

 

            resp = json.loads(response.data)

377

 

            raise GitLabConflict(resp.get('message'))

378

369

        if response.status not in (200, 201):

379

 

            raise errors.UnexpectedHttpStatus(path, response.status)

 

370

            raise errors.InvalidHttpResponse(path, response.text)

380

371

        # The response should be valid JSON, but let's ignore it

381

372

        project = json.loads(response.data)

382

373

        # Spin and wait until import_status for new project

390

381

            project = self._get_project(project['path_with_namespace'])

391

382

        return project

392

383

 

393

 

    def get_current_user(self):

 

384

    def _get_logged_in_username(self):

394

385

        return self._current_user['username']

395

386

 

396

 

    def get_user_url(self, username):

397

 

        return urlutils.join(self.base_url, username)

398

 

 

399

387

    def _list_paged(self, path, parameters=None, per_page=None):

400

388

        if parameters is None:

401

389

            parameters = {}

412

400

            if response.status == 403:

413

401

                raise errors.PermissionDenied(response.text)

414

402

            if response.status != 200:

415

 

                raise errors.UnexpectedHttpStatus(path, response.status)

 

403

                raise errors.InvalidHttpResponse(path, response.text)

416

404

            page = response.getheader("X-Next-Page")

417

405

            for entry in json.loads(response.data):

418

406

                yield entry

435

423

        if response.status == 403:

436

424

            raise errors.PermissionDenied(response.text)

437

425

        if response.status != 200:

438

 

            raise errors.UnexpectedHttpStatus(path, response.status)

 

426

            raise errors.InvalidHttpResponse(path, response.text)

439

427

        return json.loads(response.data)

440

428

 

441

429

    def _list_projects(self, owner):

449

437

        response = self._api_request('PUT', path, fields=mr)

450

438

        if response.status == 200:

451

439

            return json.loads(response.data)

452

 

        raise errors.UnexpectedHttpStatus(path, response.status)

 

440

        raise errors.InvalidHttpResponse(path, response.text)

453

441

 

454

442

    def _post_merge_request_note(self, project_id, iid, kwargs):

455

443

        path = 'projects/%s/merge_requests/%s/notes' % (

458

446

        if response.status == 201:

459

447

            json.loads(response.data)

460

448

            return

461

 

        raise errors.UnexpectedHttpStatus(path, response.status)

 

449

        raise errors.InvalidHttpResponse(path, response.text)

462

450

 

463

451

    def _create_mergerequest(

464

452

            self, title, source_project_id, target_project_id,

481

469

        if response.status == 409:

482

470

            raise MergeRequestExists()

483

471

        if response.status != 201:

484

 

            raise errors.UnexpectedHttpStatus(path, response.status)

 

472

            raise errors.InvalidHttpResponse(path, response.text)

485

473

        return json.loads(response.data)

486

474

 

487

475

    def get_push_url(self, branch):

495

483

                        allow_lossy=True, tag_selector=None):

496

484

        (host, base_project, base_branch_name) = parse_gitlab_branch_url(base_branch)

497

485

        if owner is None:

498

 

            owner = self.get_current_user()

 

486

            owner = self._get_logged_in_username()

499

487

        if project is None:

500

488

            project = self._get_project(base_project)['path']

501

489

        try:

502

490

            target_project = self._get_project('%s/%s' % (owner, project))

503

491

        except NoSuchProject:

504

 

            target_project = self._fork_project(base_project, owner=owner)

 

492

            target_project = self._fork_project(base_project)

505

493

        remote_repo_url = git_url_to_bzr_url(target_project['ssh_url_to_repo'])

506

494

        remote_dir = controldir.ControlDir.open(remote_repo_url)

507

495

        try:

521

509

    def get_derived_branch(self, base_branch, name, project=None, owner=None):

522

510

        (host, base_project, base_branch_name) = parse_gitlab_branch_url(base_branch)

523

511

        if owner is None:

524

 

            owner = self.get_current_user()

 

512

            owner = self._get_logged_in_username()

525

513

        if project is None:

526

514

            project = self._get_project(base_project)['path']

527

515

        try:

570

558

                raise GitLabLoginMissing()

571

559

            else:

572

560

                raise GitlabLoginError(response.text)

573

 

        raise UnsupportedHoster(self.base_url)

 

561

        raise UnsupportedHoster(url)

574

562

 

575

563

    @classmethod

576

564

    def probe_from_url(cls, url, possible_transports=None):

597

585

    def iter_my_proposals(self, status='open'):

598

586

        state = mp_status_to_status(status)

599

587

        for mp in self._list_merge_requests(

600

 

                owner=self.get_current_user(), state=state):

 

588

                owner=self._get_logged_in_username(), state=state):

601

589

            yield GitLabMergeProposal(self, mp)

602

590

 

603

591

    def iter_my_forks(self):

604

 

        for project in self._list_projects(owner=self.get_current_user()):

 

592

        for project in self._list_projects(owner=self._get_logged_in_username()):

605

593

            base_project = project.get('forked_from_project')

606

594

            if not base_project:

607

595

                continue

629

617

        if response.status == 404:

630

618

            raise NoSuchProject(project)

631

619

        if response.status != 202:

632

 

            raise errors.UnexpectedHttpStatus(path, response.status)

 

620

            raise errors.InvalidHttpResponse(path, response.text)

633

621

 

634

622

 

635

623

class GitlabMergeProposalBuilder(MergeProposalBuilder):

• Older »

Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0