handler.py

from relay_sdk import Interface, WebhookServer
from quart import Quart, request, jsonify, make_response

import logging
import json

relay = Interface()
app = Quart('pull-request-merged')

logging.getLogger().setLevel(logging.INFO)


@app.route('/', methods=['POST'])
async def handler():
    github_event = request.headers.get('X-GitHub-Event')

    if github_event is None:
        return {'message': 'not a valid GitHub event'}, 400, {}
    if github_event == 'ping':
        return {'message': 'success'}, 200, {}
    if github_event != 'pull_request':
        return {'message': 'only pull_request events are supported'}, 400, {}

    logging.info("Received event from GitHub: {}".format(github_event))

    event_payload = await request.get_json()
    logging.info("Received the following webhook payload: \n%s", json.dumps(event_payload, indent=4))

    if event_payload is None:
        return {'message': 'not a valid GitHub event'}, 400, {}

    pr = event_payload['pull_request']
    if event_payload['action'] == 'closed' and pr['merged'] is True:
        relay.events.emit({
            'url': pr['url'],
            'repository': event_payload['repository']['full_name'],
            'repositoryURL': pr['base']['repo']['html_url'],
            'repositoryGitURL': pr['base']['repo']['git_url'],
            'repositorySSHURL': pr['base']['repo']['ssh_url'],
            'branch': pr['base']['ref']
        })

    return {'message': 'success'}, 200, {}


if __name__ == '__main__':
    WebhookServer(app).serve_forever()