We can pass information about this build around in real time.
"""
- def get_current_user(self):
- name, password = self.get_basic_auth_credentials()
- if name is None:
- return
-
- return self.backend.builders.auth(name, password)
-
- @property
- def builder(self):
- return self.current_user
+ # Don't allow users to authenticate
+ allow_users = False
@tornado.web.authenticated
def open(self, job_id):
raise tornado.web.HTTPError(404, "Could not find job %s" % job_id)
# Check if the builder matches
- if not self.builder == self.job.builder:
+ if not self.current_user == self.job.builder:
raise tornado.web.HTTPError(403, "Job %s belongs to %s, not %s" % \
- (self.job, self.job.builder, self.builder))
+ (self.job, self.job.builder, self.current_user))
- logging.debug("Connection opened for %s by %s" % (self.job, self.builder))
+ logging.debug("Connection opened for %s by %s" % (self.job, self.current_user))
async def on_message(self, message):
# Decode JSON message