/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/github/hoster.py

  • Committer: Breezy landing bot
  • Author(s): Jelmer Vernooij
  • Date: 2020-06-11 12:46:45 UTC
  • mfrom: (7511.1.1 actions-no-fork)
  • Revision ID: breezy.the.bot@gmail.com-20200611124645-4lx66gps99i0hmzh
Avoid using fork when running the testsuite in github actions.

Merged from https://code.launchpad.net/~jelmer/brz/actions-no-fork/+merge/385565

Show diffs side-by-side

added added

removed removed

Lines of Context:
breezy/plugins/github/hoster.py
42
42
    version_string as breezy_version,
43
43
    )
44
44
from ...config import AuthenticationConfig, GlobalStack
45
 
from ...errors import (
46
 
    InvalidHttpResponse,
47
 
    PermissionDenied,
48
 
    UnexpectedHttpStatus,
49
 
    )
 
45
from ...errors import InvalidHttpResponse, PermissionDenied
50
46
from ...git.urls import git_url_to_bzr_url
51
47
from ...i18n import gettext
52
48
from ...trace import note
124
120
    def __repr__(self):
125
121
        return "<%s at %r>" % (type(self).__name__, self.url)
126
122
 
127
 
    name = 'GitHub'
128
 
 
129
123
    @property
130
124
    def url(self):
131
125
        return self._pr['html_url']
138
132
    def get_source_branch_url(self):
139
133
        return self._branch_from_part(self._pr['head'])
140
134
 
141
 
    def get_source_revision(self):
142
 
        """Return the latest revision for the source branch."""
143
 
        from breezy.git.mapping import default_mapping
144
 
        return default_mapping.revision_id_foreign_to_bzr(
145
 
            self._pr['head']['sha'].encode('ascii'))
146
 
 
147
135
    def get_target_branch_url(self):
148
136
        return self._branch_from_part(self._pr['base'])
149
137
 
168
156
        if response.status == 422:
169
157
            raise ValidationFailed(json.loads(response.text))
170
158
        if response.status != 200:
171
 
            raise UnexpectedHttpStatus(self._pr['url'], response.status)
 
159
            raise InvalidHttpResponse(self._pr['url'], response.text)
172
160
        self._pr = json.loads(response.text)
173
161
 
174
162
    def set_description(self, description):
197
185
 
198
186
    def merge(self, commit_message=None):
199
187
        # https://developer.github.com/v3/pulls/#merge-a-pull-request-merge-button
200
 
        data = {}
201
 
        if commit_message:
202
 
            data['commit_message'] = commit_messae
203
 
        response = self._gh._api_request(
204
 
            'PUT', self._pr['url'] + "/merge", body=json.dumps(data).encode('utf-8'))
205
 
        if response.status == 422:
206
 
            raise ValidationFailed(json.loads(response.text))
207
 
        if response.status != 200:
208
 
            raise UnexpectedHttpStatus(self._pr['url'], response.status)
 
188
        self._pr.merge(commit_message=commit_message)
209
189
 
210
190
    def get_merged_by(self):
211
191
        merged_by = self._pr.get('merged_by')
220
200
        import iso8601
221
201
        return iso8601.parse_date(merged_at)
222
202
 
223
 
    def post_comment(self, body):
224
 
        data = {'body': body}
225
 
        response = self._gh._api_request(
226
 
            'POST', self._pr['comments_url'], body=json.dumps(data).encode('utf-8'))
227
 
        if response.status == 422:
228
 
            raise ValidationFailed(json.loads(response.text))
229
 
        if response.status != 201:
230
 
            raise UnexpectedHttpStatus(
231
 
                self._pr['comments_url'], response.status)
232
 
        json.loads(response.text)
233
 
 
234
203
 
235
204
def parse_github_url(url):
236
205
    (scheme, user, password, host, port, path) = urlutils.parse_url(
289
258
            raise NoSuchProject(path)
290
259
        if response.status == 200:
291
260
            return json.loads(response.text)
292
 
        raise UnexpectedHttpStatus(path, response.status)
 
261
        raise InvalidHttpResponse(path, response.text)
293
262
 
294
263
    def _get_repo_pulls(self, path, head=None, state=None):
295
264
        path = path + '?'
305
274
            raise NoSuchProject(path)
306
275
        if response.status == 200:
307
276
            return json.loads(response.text)
308
 
        raise UnexpectedHttpStatus(path, response.status)
 
277
        raise InvalidHttpResponse(path, response.text)
309
278
 
310
279
    def _create_pull(self, path, title, head, base, body=None, labels=None,
311
280
                     assignee=None, draft=False, maintainer_can_modify=False):
328
297
        if response.status == 403:
329
298
            raise PermissionDenied(path, response.text)
330
299
        if response.status != 201:
331
 
            raise UnexpectedHttpStatus(path, response.status)
 
300
            raise InvalidHttpResponse(path, 'req is invalid %d %r: %r' % (response.status, data, response.text))
332
301
        return json.loads(response.text)
333
302
 
334
303
    def _get_user_by_email(self, email):
335
304
        path = 'search/users?q=%s+in:email' % email
336
305
        response = self._api_request('GET', path)
337
306
        if response.status != 200:
338
 
            raise UnexpectedHttpStatus(path, response.status)
 
307
            raise InvalidHttpResponse(path, response.text)
339
308
        ret = json.loads(response.text)
340
309
        if ret['total_count'] == 0:
341
310
            raise KeyError('no user with email %s' % email)
350
319
            path = 'user'
351
320
        response = self._api_request('GET', path)
352
321
        if response.status != 200:
353
 
            raise UnexpectedHttpStatus(path, response.status)
 
322
            raise InvalidHttpResponse(path, response.text)
354
323
        return json.loads(response.text)
355
324
 
356
325
    def _get_organization(self, name):
357
326
        path = 'orgs/%s' % name
358
327
        response = self._api_request('GET', path)
359
328
        if response.status != 200:
360
 
            raise UnexpectedHttpStatus(path, response.status)
 
329
            raise InvalidHttpResponse(path, response.text)
361
330
        return json.loads(response.text)
362
331
 
363
332
    def _list_paged(self, path, parameters=None, per_page=None):
376
345
                ';'.join(['%s=%s' % (k, urlutils.quote(v))
377
346
                          for (k, v) in parameters.items()]))
378
347
            if response.status != 200:
379
 
                raise UnexpectedHttpStatus(path, response.status)
 
348
                raise InvalidHttpResponse(path, response.text)
380
349
            data = json.loads(response.text)
381
350
            for entry in data['items']:
382
351
                i += 1
390
359
        return self._list_paged(path, {'q': query}, per_page=DEFAULT_PER_PAGE)
391
360
 
392
361
    def _create_fork(self, path, owner=None):
393
 
        if owner and owner != self.current_user['login']:
 
362
        if owner and owner != self._current_user['login']:
394
363
            path += '?organization=%s' % owner
395
364
        response = self._api_request('POST', path)
396
365
        if response.status != 202:
397
 
            raise UnexpectedHttpStatus(path, response.status)
 
366
            raise InvalidHttpResponse(path, 'status: %d, %r' % (response.status, response.text))
398
367
        return json.loads(response.text)
399
368
 
400
369
    @property
404
373
    def __init__(self, transport):
405
374
        self._token = retrieve_github_token('https', GITHUB_HOST)
406
375
        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
 
376
        self._current_user = self._get_user()
414
377
 
415
378
    def publish_derived(self, local_branch, base_branch, name, project=None,
416
379
                        owner=None, revision_id=None, overwrite=False,
418
381
        base_owner, base_project, base_branch_name = parse_github_branch_url(base_branch)
419
382
        base_repo = self._get_repo(base_owner, base_project)
420
383
        if owner is None:
421
 
            owner = self.current_user['login']
 
384
            owner = self._current_user['login']
422
385
        if project is None:
423
386
            project = base_repo['name']
424
387
        try:
454
417
        base_owner, base_project, base_branch_name = parse_github_branch_url(base_branch)
455
418
        base_repo = self._get_repo(base_owner, base_project)
456
419
        if owner is None:
457
 
            owner = self.current_user['login']
 
420
            owner = self._current_user['login']
458
421
        if project is None:
459
422
            project = base_repo['name']
460
423
        try:
529
492
            query.append('is:closed')
530
493
        elif status == 'merged':
531
494
            query.append('is:merged')
532
 
        query.append('author:%s' % self.current_user['login'])
 
495
        query.append('author:%s' % self._current_user['login'])
533
496
        for issue in self._search_issues(query=' '.join(query)):
534
497
            url = issue['pull_request']['url']
535
498
            response = self._api_request('GET', url)
536
499
            if response.status != 200:
537
 
                raise UnexpectedHttpStatus(url, response.status)
 
500
                raise InvalidHttpResponse(url, response.text)
538
501
            yield GitHubMergeProposal(self, json.loads(response.text))
539
502
 
540
503
    def get_proposal_by_url(self, url):
543
506
    def iter_my_forks(self):
544
507
        response = self._api_request('GET', '/user/repos')
545
508
        if response.status != 200:
546
 
            raise UnexpectedHttpStatus(self.transport.user_url, response.status)
 
509
            raise InvalidHttpResponse(url, response.text)
547
510
        for project in json.loads(response.text):
548
511
            if not project['fork']:
549
512
                continue
558
521
            return
559
522
        if response.status == 200:
560
523
            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)
 
524
        raise InvalidHttpResponse(path, response.text)
568
525
 
569
526
 
570
527
class GitHubMergeProposalBuilder(MergeProposalBuilder):