/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to breezy/plugins/github/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/github/hoster.py

16

16

 

17

17

"""Support for GitHub."""

18

18

 

 

19

from __future__ import absolute_import

 

20

 

19

21

import json

20

22

import os

21

23

 

42

44

    version_string as breezy_version,

43

45

    )

44

46

from ...config import AuthenticationConfig, GlobalStack

45

 

from ...errors import (

46

 

    InvalidHttpResponse,

47

 

    PermissionDenied,

48

 

    UnexpectedHttpStatus,

49

 

    )

 

47

from ...errors import InvalidHttpResponse, PermissionDenied

50

48

from ...git.urls import git_url_to_bzr_url

51

49

from ...i18n import gettext

 

50

from ...sixish import PY3

52

51

from ...trace import note

53

52

from ...transport import get_transport

54

53

from ...transport.http import default_user_agent

124

123

    def __repr__(self):

125

124

        return "<%s at %r>" % (type(self).__name__, self.url)

126

125

 

127

 

    name = 'GitHub'

128

 

 

129

126

    @property

130

127

    def url(self):

131

128

        return self._pr['html_url']

168

165

        if response.status == 422:

169

166

            raise ValidationFailed(json.loads(response.text))

170

167

        if response.status != 200:

171

 

            raise UnexpectedHttpStatus(self._pr['url'], response.status)

 

168

            raise InvalidHttpResponse(self._pr['url'], response.text)

172

169

        self._pr = json.loads(response.text)

173

170

 

174

171

    def set_description(self, description):

205

202

        if response.status == 422:

206

203

            raise ValidationFailed(json.loads(response.text))

207

204

        if response.status != 200:

208

 

            raise UnexpectedHttpStatus(self._pr['url'], response.status)

 

205

            raise InvalidHttpResponse(self._pr['url'], response.text)

209

206

 

210

207

    def get_merged_by(self):

211

208

        merged_by = self._pr.get('merged_by')

227

224

        if response.status == 422:

228

225

            raise ValidationFailed(json.loads(response.text))

229

226

        if response.status != 201:

230

 

            raise UnexpectedHttpStatus(

231

 

                self._pr['comments_url'], response.status)

 

227

            raise InvalidHttpResponse(self._pr['comments_url'], response.text)

232

228

        json.loads(response.text)

233

229

 

234

230

 

250

246

 

251

247

 

252

248

def github_url_to_bzr_url(url, branch_name):

 

249

    if not PY3:

 

250

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

253

251

    return git_url_to_bzr_url(url, branch_name)

254

252

 

255

253

 

289

287

            raise NoSuchProject(path)

290

288

        if response.status == 200:

291

289

            return json.loads(response.text)

292

 

        raise UnexpectedHttpStatus(path, response.status)

 

290

        raise InvalidHttpResponse(path, response.text)

293

291

 

294

292

    def _get_repo_pulls(self, path, head=None, state=None):

295

293

        path = path + '?'

305

303

            raise NoSuchProject(path)

306

304

        if response.status == 200:

307

305

            return json.loads(response.text)

308

 

        raise UnexpectedHttpStatus(path, response.status)

 

306

        raise InvalidHttpResponse(path, response.text)

309

307

 

310

308

    def _create_pull(self, path, title, head, base, body=None, labels=None,

311

309

                     assignee=None, draft=False, maintainer_can_modify=False):

328

326

        if response.status == 403:

329

327

            raise PermissionDenied(path, response.text)

330

328

        if response.status != 201:

331

 

            raise UnexpectedHttpStatus(path, response.status)

 

329

            raise InvalidHttpResponse(path, 'req is invalid %d %r: %r' % (response.status, data, response.text))

332

330

        return json.loads(response.text)

333

331

 

334

332

    def _get_user_by_email(self, email):

335

333

        path = 'search/users?q=%s+in:email' % email

336

334

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

337

335

        if response.status != 200:

338

 

            raise UnexpectedHttpStatus(path, response.status)

 

336

            raise InvalidHttpResponse(path, response.text)

339

337

        ret = json.loads(response.text)

340

338

        if ret['total_count'] == 0:

341

339

            raise KeyError('no user with email %s' % email)

350

348

            path = 'user'

351

349

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

352

350

        if response.status != 200:

353

 

            raise UnexpectedHttpStatus(path, response.status)

 

351

            raise InvalidHttpResponse(path, response.text)

354

352

        return json.loads(response.text)

355

353

 

356

354

    def _get_organization(self, name):

357

355

        path = 'orgs/%s' % name

358

356

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

359

357

        if response.status != 200:

360

 

            raise UnexpectedHttpStatus(path, response.status)

 

358

            raise InvalidHttpResponse(path, response.text)

361

359

        return json.loads(response.text)

362

360

 

363

361

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

376

374

                ';'.join(['%s=%s' % (k, urlutils.quote(v))

377

375

                          for (k, v) in parameters.items()]))

378

376

            if response.status != 200:

379

 

                raise UnexpectedHttpStatus(path, response.status)

 

377

                raise InvalidHttpResponse(path, response.text)

380

378

            data = json.loads(response.text)

381

379

            for entry in data['items']:

382

380

                i += 1

390

388

        return self._list_paged(path, {'q': query}, per_page=DEFAULT_PER_PAGE)

391

389

 

392

390

    def _create_fork(self, path, owner=None):

393

 

        if owner and owner != self.current_user['login']:

 

391

        if owner and owner != self._current_user['login']:

394

392

            path += '?organization=%s' % owner

395

393

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

396

394

        if response.status != 202:

397

 

            raise UnexpectedHttpStatus(path, response.status)

 

395

            raise InvalidHttpResponse(path, 'status: %d, %r' % (response.status, response.text))

398

396

        return json.loads(response.text)

399

397

 

400

398

    @property

404

402

    def __init__(self, transport):

405

403

        self._token = retrieve_github_token('https', GITHUB_HOST)

406

404

        self.transport = transport

407

 

        self._current_user = None

408

 

 

409

 

    @property

410

 

    def current_user(self):

411

 

        if self._current_user is None:

412

 

            self._current_user = self._get_user()

413

 

        return self._current_user

 

405

        self._current_user = self._get_user()

414

406

 

415

407

    def publish_derived(self, local_branch, base_branch, name, project=None,

416

408

                        owner=None, revision_id=None, overwrite=False,

418

410

        base_owner, base_project, base_branch_name = parse_github_branch_url(base_branch)

419

411

        base_repo = self._get_repo(base_owner, base_project)

420

412

        if owner is None:

421

 

            owner = self.current_user['login']

 

413

            owner = self._current_user['login']

422

414

        if project is None:

423

415

            project = base_repo['name']

424

416

        try:

454

446

        base_owner, base_project, base_branch_name = parse_github_branch_url(base_branch)

455

447

        base_repo = self._get_repo(base_owner, base_project)

456

448

        if owner is None:

457

 

            owner = self.current_user['login']

 

449

            owner = self._current_user['login']

458

450

        if project is None:

459

451

            project = base_repo['name']

460

452

        try:

529

521

            query.append('is:closed')

530

522

        elif status == 'merged':

531

523

            query.append('is:merged')

532

 

        query.append('author:%s' % self.current_user['login'])

 

524

        query.append('author:%s' % self._current_user['login'])

533

525

        for issue in self._search_issues(query=' '.join(query)):

534

526

            url = issue['pull_request']['url']

535

527

            response = self._api_request('GET', url)

536

528

            if response.status != 200:

537

 

                raise UnexpectedHttpStatus(url, response.status)

 

529

                raise InvalidHttpResponse(url, response.text)

538

530

            yield GitHubMergeProposal(self, json.loads(response.text))

539

531

 

540

532

    def get_proposal_by_url(self, url):

543

535

    def iter_my_forks(self):

544

536

        response = self._api_request('GET', '/user/repos')

545

537

        if response.status != 200:

546

 

            raise UnexpectedHttpStatus(self.transport.user_url, response.status)

 

538

            raise InvalidHttpResponse(url, response.text)

547

539

        for project in json.loads(response.text):

548

540

            if not project['fork']:

549

541

                continue

558

550

            return

559

551

        if response.status == 200:

560

552

            return json.loads(response.text)

561

 

        raise UnexpectedHttpStatus(path, response.status)

562

 

 

563

 

    def get_current_user(self):

564

 

        return self.current_user['login']

565

 

 

566

 

    def get_user_url(self, username):

567

 

        return urlutils.join(self.base_url, username)

 

553

        raise InvalidHttpResponse(path, response.text)

568

554

 

569

555

 

570

556

class GitHubMergeProposalBuilder(MergeProposalBuilder):

• Older »

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