contrib/nitrpg/src/listener.nit

   1 # This file is part of NIT ( http://www.nitlanguage.org ).
   2 #
   3 # Copyright 2014-2015 Alexandre Terrasa <alexandre@moz-code.org>
   4 #
   5 # Licensed under the Apache License, Version 2.0 (the "License");
   6 # you may not use this file except in compliance with the License.
   7 # You may obtain a copy of the License at
   8 #
   9 #     http://www.apache.org/licenses/LICENSE-2.0
  10 #
  11 # Unless required by applicable law or agreed to in writing, software
  12 # distributed under the License is distributed on an "AS IS" BASIS,
  13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 # See the License for the specific language governing permissions and
  15 # limitations under the License.
  16
  17 # This tool is runned to listen to `Github::Event` and update the game.
  18 module listener
  19
  20 import reactors
  21 import achievements
  22 import github::hooks
  23
  24 # `HookListener` that redirects events to a `Game` instance.
  25 class RpgHookListener
  26    super HookListener
  27
  28         # Registered reactors list.
  29         var reactors = new Array[GameReactor]
  30
  31         # Dispatch event to registered `reactors`.
  32         redef fun apply_event(event) do
  33                 var game = new Game(api, event.repo)
  34                 # TODO handle verbosity with opts
  35                 game.verbose_lvl = 1
  36                 game.message(1, "Received event {event} for {game.repo.full_name}")
  37                 for reactor in reactors do
  38                         game.message(2, "Apply reactor {reactor} on {event}")
  39                         reactor.react_event(game, event)
  40                 end
  41         end
  42
  43         # Register a reactor for this listener.
  44         fun add_reactor(reactors: GameReactor...) do self.reactors.add_all reactors
  45 end
  46
  47 if args.length != 2 then
  48         print "Error: missing argument"
  49         print ""
  50         print "Usage:"
  51         print "listener <host> <port>"
  52         exit 1
  53 end
  54
  55 var host = args[0]
  56 var port = args[1].to_i
  57
  58 var api = new GithubAPI(get_github_oauth)
  59
  60 var l = new RpgHookListener(api, host, port)
  61 l.add_reactor(new StatisticsReactor, new PlayerReactor)
  62 l.add_reactor(new Player1Issue, new Player100Issues, new Player1KIssues)
  63 l.add_reactor(new Player1Pull, new Player100Pulls, new Player1KPulls)
  64 l.add_reactor(new Player1Commit, new Player100Commits, new Player1KCommits)
  65 l.add_reactor(new IssueAboutNitdoc, new IssueAboutFFI)
  66 l.add_reactor(new Player1Comment, new Player100Comments, new Player1KComments)
  67 l.add_reactor(new PlayerPingGod, new PlayerFirstReview, new PlayerSaysNitcoin)
  68
  69 print "Listening events on {host}:{port}"
  70 l.listen