server.coffee

   1 listen_port = 8333
   2 sys = require 'sys'
   3 fs = require 'fs'
   4 http = require 'http'
   5 querystring = require 'querystring'
   6 url = require 'url'
   7 less = require 'less'
   8 coffee = require 'coffee-script'
   9 model = require './common.coffee'
  10
  11 games = {}
  12
  13 # timeout function with args in convenient order
  14 timeout = (ms, func) -> setTimeout func, ms
  15
  16 css_handler = (args, out, request, url_parts) ->
  17         fs.readFile 'style.less', 'utf8', (err, data) ->
  18                 if err
  19                         return out.end 'Server failed to read style.less'
  20                 less.render data, (err, css) ->
  21                         if err
  22                                 return out.end "Server failed to make css: #{err}"
  23                         out.end css
  24
  25 js_handler = (args, out, request, url_parts) ->
  26         basename = url_parts.pathname.substr 1, (url_parts.pathname.length - 4)
  27         if basename is 'client'
  28                 filename = 'client.coffee'
  29         else if basename is 'common'
  30                 filename = 'common.coffee'
  31         else
  32                 error = "Unknown js basename: #{basename}"
  33                 console.log error
  34                 out.end(error)
  35                 return
  36
  37         fs.readFile filename, 'utf8', (err, data) ->
  38                 if err
  39                         return out.end "Server failed to read #{filename}"
  40                 out.end coffee.compile data
  41
  42 html_handler = (args, out, request, url_parts) ->
  43         fs.readFile 'index.html', 'utf8', (err, data) ->
  44                 if err
  45                         return out.end 'Server failed to read index.html'
  46                 out.end data
  47
  48 clean_pathname_regex = new RegExp('[^a-zA-Z/_.-]')
  49 clean_pathname_regex2 = new RegExp('/[.]')
  50 clean_pathname_regex3 = new RegExp('^[.-]')
  51 clean_pathname = (str) ->
  52         str = str.replace clean_pathname_regex, '_'
  53         str = str.replace clean_pathname_regex2, '/_'
  54         return str.replace clean_pathname_regex3, '_'
  55
  56 # serve javascript files from within /usr/share/javascript
  57 javascript_handler = (args, out, request, url_parts) ->
  58         filename = clean_pathname "/usr/share/#{url_parts.pathname}"
  59         fs.readFile filename, 'utf8', (err, data) ->
  60                 if err
  61                         out.writeHead 404
  62                         return out.end "Server failed to read #{filename}"
  63                 out.writeHead 200, 'Content-Type': 'text/javascript'
  64                 out.end data
  65
  66
  67 get_handler = (args, out, request, url_parts) ->
  68         unless args.game?.length
  69                 out.writeHead 404, "Content-Type": 'text/plain'
  70                 out.end 'Missing (or empty) "game" argument'
  71                 return
  72
  73         unless args.agent is 'p1' or args.agent is 'p2'
  74                 out.writeHead 404, "Content-Type": 'text/plain'
  75                 out.end '"agent" argument must be set to p1 or p2'
  76                 return
  77
  78         unless games[args.game]?
  79                 out.writeHead 404, "Content-Type": 'text/plain'
  80                 out.end 'Game not found'
  81                 return
  82
  83         game = games[args.game]
  84
  85         waiter = games["#{args.agent}_waiter"]
  86         if waiter?
  87                 waiter.writeHead 200, 'Content-Type': 'text/javascript'
  88                 waiter.end '[]'
  89
  90         game["#{args.agent}_waiter"] = out
  91
  92         answer_soon game # in case there's something queued already
  93
  94 set_handler = (args, out, request, url_parts) ->
  95         unless args.game?.length
  96                 out.writeHead 404, "Content-Type": 'text/plain'
  97                 out.end 'Missing (or empty) "game" argument'
  98                 return
  99
 100         unless args.agent is 'p1' or args.agent is 'p2'
 101                 out.writeHead 404, "Content-Type": 'text/plain'
 102                 out.end '"agent" argument must be set to p1 or p2'
 103                 return
 104
 105         unless args.messages?
 106                 out.writeHead 404, "Content-Type": 'text/plain'
 107                 out.end '"messages" argument must be set'
 108                 return
 109
 110         unless games[args.game]?
 111                 out.writeHead 404, "Content-Type": 'text/plain'
 112                 out.end 'Game not found'
 113                 return
 114
 115         game = games[args.game]
 116
 117         # FIXME add error checking (json validity at least)
 118         game.process_messages JSON.parse args.messages
 119
 120         out.writeHead 200, "Content-Type": 'text/plain'
 121         out.end '{"status":0,"text_status":"Success"}'
 122
 123 # don't call this directly, call answer_soon instead
 124 answer_now = (game) ->
 125         if game.p1_waiter and game.p1_queue.length
 126                 waiter = game.p1_waiter
 127                 queue = game.p1_queue
 128                 game.p1_waiter = false
 129                 game.p1_queue = []
 130                 waiter.writeHead 200, 'Content-Type': 'text/javascript'
 131                 waiter.end JSON.stringify queue
 132         if game.p2_waiter and game.p2_queue.length
 133                 waiter = game.p2_waiter
 134                 queue = game.p2_queue
 135                 game.p2_waiter = false
 136                 game.p2_queue = []
 137                 timeout 2000, -> # FIXME remove this delay for player 2 (just here to test lag handling)
 138                         waiter.writeHead 200, 'Content-Type': 'text/javascript'
 139                         waiter.end JSON.stringify queue
 140
 141 # this marks a game as "dirty" and makes sure there's exactly one timeout
 142 # that'll respond to any clients that are waiting, and now have messages.
 143 answer_soon = (game) ->
 144         unless game.replier_id
 145                 game.replier_id = timeout 1, ->
 146                         delete game.replier_id
 147                         answer_now game
 148
 149 forward_events = (message...) ->
 150         unless message[1] is 'p1'
 151                 @p1_queue.push message
 152                 answer_soon this
 153         unless message[1] is 'p2'
 154                 @p2_queue.push message
 155                 answer_soon this
 156
 157 new_game = (id) ->
 158         game = games[id] = model.new 'server'
 159         game.p1_waiter = false
 160         game.p2_waiter = false
 161         game.p1_queue = []
 162         game.p2_queue = []
 163
 164         game.on 'move', (agent, card, x, y, z) ->
 165                 forward_events.call this, 'move', agent, card, x, y, z
 166         game.on 'mark', (agent, card, state) ->
 167                 forward_events.call this, 'mark', agent, card, state
 168         game.on 'flip', (agent, card, state) ->
 169                 forward_events.call this, 'flip', agent, card, state
 170         game.on 'set_cards', (agent, cards) ->
 171                 forward_events.call this, 'set_cards', agent, cards
 172         game.on 'send_state', (agent) ->
 173                 timeout 10, =>
 174                         if agent is 'p1'
 175                                 @p1_queue.push ['set_cards', 'server', @cards]
 176                                 answer_soon this
 177                         if agent is 'p2'
 178                                 @p2_queue.push ['set_cards', 'server', @cards]
 179                                 answer_soon this
 180
 181         return game
 182
 183 test_init = ->
 184         test_game = new_game 'test'
 185         timeout 4000, ->
 186                 test_game.set_cards 'server', [
 187                         { text: "Wildabeast 2/2", x: 220, y: 200, owner: 'p2'}
 188                         { text: "Boar 2/2", x: 360, y: 200, owner: 'p2', pile: 'p2_discard'}
 189                         { text: "Angora bunny 1/1", x: 500, y: 200, owner: 'p2'}
 190                         { text: "Ambulatory Cactus 2/1", x: 660, y: 200, owner: 'p2'}
 191                         { text: "Ent 0/5", x: 800, y: 200, owner: 'p2'}
 192                         { text: "Carnivore 2/1", x: 220, y: 420, owner: 'p1'}
 193                         { text: "Herbivore 1/2", x: 360, y: 420, owner: 'p1'}
 194                         { text: "Stone Wall 0/10", x: 500, y: 420, owner: 'p1', pile: 'p1_draw', flipped: true}
 195                         { text: "Log 0/1", x: 660, y: 420, owner: 'p1', pile: 'p1_draw', flipped: true}
 196                         { text: "Ent 0/5", x: 800, y: 420, owner: 'p1', pile: 'p1_draw', flipped: true}
 197                         { text: "Barricade 0/10", x: 500, y: 420, owner: 'p1', pile: 'p1_draw', flipped: true}
 198                         { text: "O(log(n)) 0/1", x: 660, y: 420, owner: 'p1', pile: 'p1_draw', flipped: true}
 199                         { text: "Fence 0/5", x: 800, y: 420, owner: 'p1', pile: 'p1_draw', flipped: true}
 200                 ]
 201
 202 test_init()
 203
 204
 205 http_server = http.createServer (req, res) ->
 206         url_parts = url.parse req.url, true
 207         if url_parts.query is undefined
 208                 url_parts.query = {}
 209
 210         rel_path = url_parts.pathname.substr 1
 211
 212         if rel_path.substr(0, 11) is 'javascript/'
 213                 return javascript_handler url_parts.query, res, req, url_parts
 214         else if rel_path.substr(rel_path.length - 4) is '.css'
 215                 res.writeHead 200, 'Content-Type': 'text/css'
 216                 return css_handler url_parts.query, res, req, url_parts
 217         else if rel_path.substr(rel_path.length - 3) is '.js'
 218                 res.writeHead 200, 'Content-Type': 'text/javascript'
 219                 return js_handler url_parts.query, res, req, url_parts
 220         else if rel_path.substr(rel_path.length - 4) is '/set'
 221                 data = ''
 222                 req.on 'data', (chunk) ->
 223                         data += chunk
 224                 req.on 'end', ->
 225                         query = url_parts.query
 226                         post_args = querystring.parse data
 227                         for key, parg of post_args
 228                                 query[key] = parg
 229                         return set_handler query, res, req, url_parts
 230         else if rel_path.substr(rel_path.length - 4) is '/get'
 231                 return get_handler url_parts.query, res, req, url_parts
 232         else if rel_path.substr(rel_path.length - 4) is '.ico'
 233                 res.writeHead 404
 234                 return res.end()
 235
 236         return html_handler url_parts.query, res, req, url_parts
 237
 238 http_server.listen listen_port, "127.0.0.1"
 239 console.log "Server running at http://127.0.0.1:#{listen_port}/"