nitcorn
.Usage:
import github::hooks
# A simple hook listener that print received events in stdout.
class LogHookListener
super HookListener
# Use double dispatch to implement log behavior.
redef fun apply_event(event) do event.log_event(self)
end
redef class GithubEvent
# Log this event.
#
# Do nothing by default.
fun log_event(l: LogHookListener) do end
end
redef class CommitCommentEvent
redef fun log_event(l) do
print "new comment on commit {comment.commit_id}"
end
end
var api = new GithubAPI(get_github_oauth)
var listener = new LogHookListener(api, "127.0.0.1", 8080)
FileServer
action, which is a standard and minimal file server
HttpRequest
class and services to create it
Serializable::inspect
to show more useful information
more_collections :: more_collections
Highly specific, but useful, collections-related classes.curl :: native_curl
Binding of C libCurl which allow us to interact with network.serialization :: serialization_core
Abstract services to serialize Nit objects to different formatsdeserialize_json
and JsonDeserializer
serialize_to_json
and JsonSerializer
core :: union_find
union–find algorithm using an efficient disjoint-set data structure
# Github hook event listening with `nitcorn`.
#
# Usage:
#
# ~~~
# import github::hooks
#
# # A simple hook listener that print received events in stdout.
# class LogHookListener
# super HookListener
#
# # Use double dispatch to implement log behavior.
# redef fun apply_event(event) do event.log_event(self)
# end
#
# redef class GithubEvent
# # Log this event.
# #
# # Do nothing by default.
# fun log_event(l: LogHookListener) do end
# end
#
# redef class CommitCommentEvent
#
# redef fun log_event(l) do
# print "new comment on commit {comment.commit_id}"
# end
# end
#
# var api = new GithubAPI(get_github_oauth)
# var listener = new LogHookListener(api, "127.0.0.1", 8080)
# # listener.listen # uncomment to start listening
# ~~~
module hooks
import events
import nitcorn
# A nitcorn listener for Github hooks.
abstract class HookListener
# Api client used to perform Github API requests.
var api: GithubAPI
# Host to listen.
var host: String
# Port to listen.
var port: Int
# VirtualHost listened
private var vh: VirtualHost is noinit
init do
vh = new VirtualHost("{host}:{port}")
vh.routes.add new Route("/", new HookAction(self))
end
# Verbosity level (0: quiet, 1: debug).
# Default: 0
var verbosity = 0
# Print `message` if `lvl` <= `verbosity`
fun message(lvl: Int, message: String) do
if lvl <= verbosity then print message
end
# Start listening and responding to event.
fun listen do
message(1, "Hook listening on {host}:{port}")
var factory = new HttpFactory.and_libevent
factory.config.virtual_hosts.add vh
factory.run
end
# How to build events from received json objects.
fun event_factory(kind: String, json: String): nullable GithubEvent do
if kind == "commit_comment" then
return api.deserialize(json).as(CommitCommentEvent)
else if kind == "create" then
return api.deserialize(json).as(CreateEvent)
else if kind == "delete" then
return api.deserialize(json).as(DeleteEvent)
else if kind == "deployment" then
return api.deserialize(json).as(DeploymentEvent)
else if kind == "deployment_status" then
return api.deserialize(json).as(DeploymentStatusEvent)
else if kind == "fork" then
return api.deserialize(json).as(ForkEvent)
else if kind == "issues" then
return api.deserialize(json).as(IssuesEvent)
else if kind == "issue_comment" then
return api.deserialize(json).as(IssueCommentEvent)
else if kind == "member" then
return api.deserialize(json).as(MemberEvent)
else if kind == "pull_request" then
return api.deserialize(json).as(PullRequestEvent)
else if kind == "pull_request_review_comment" then
return api.deserialize(json).as(PullRequestPullCommentEvent)
else if kind == "push" then
return api.deserialize(json).as(PushEvent)
else if kind == "status" then
return api.deserialize(json).as(StatusEvent)
end
return null
end
# What to do when we receive an event from a hook?
fun apply_event(event: GithubEvent) is abstract
end
# A nitcorn action dedicated to GitHub hook listening.
private class HookAction
super Action
# Listener that contains this action.
#
# The `listener` is used for its `event_factory` method
# and the `apply_event`.
var listener: HookListener
# Parse hook request then call `listener.apply_event`.
redef fun answer(request, uri) do
# get event type
var kind = request.header.get_or_null("X-GitHub-Event")
if kind == null then return new HttpResponse(403)
# parse event
var event = listener.event_factory(kind, request.body)
if event == null then return new HttpResponse(403)
listener.apply_event(event)
return new HttpResponse(200)
end
end
lib/github/hooks.nit:15,1--147,3