collector.py 文件源码

def wsgi_app(self, environ, start_response):
        route = self.router.bind_to_environ(environ)
        try:
            endpoint, args = route.match()
        except RequestRedirect as e:
            return e
        except HTTPException:
            return NotFound()

        request = Request(environ)
        args = request.args
        response = Response()
        response.mimetype = 'text/plain'
        response.status_code = 200

        if endpoint == 'contestant':
            if 'mac' not in args or 'row' not in args or 'col' not in args:
                response.status_code = 400
                response.data = 'Required query parameters: mac, row, col'
            else:
                mac = args['mac']
                row = args['row']
                col = args['col']
                self.add_contestant(mac, row, col, response)

        elif endpoint == 'worker':
            if 'mac' not in args or 'num' not in args:
                response.status_code = 400
                response.data = 'Required query parameters: mac, num'
            else:
                mac = args['mac']
                num = args['num']
                self.add_worker(mac, num, response)

        elif endpoint == 'reboot_timestamp':
            response.data = str(self.reboot_string)

        return response