Rietveld: add CQ status URL instead of comment.

appengine/chromium_rietveld/codereview/models.py

 # Copyright 2008 Google Inc.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
 # You may obtain a copy of the License at
 #
 #     http://www.apache.org/licenses/LICENSE-2.0
 #
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,
@@ skipping 486 matching lines @@
           return message.date
     return None
 
   def get_time_since_landed(self):
     """Returns approximate time since issue was landed or None."""
     landed = self.get_landed_date()
     if landed:
       return datetime.datetime.now() - landed
     return None
 
+  def update_cq_status_url_if_any(self, cq_message):
+    """Parses the cq_message for CQ status url and updates corresponding
+    patchset with it.
+    """
+    url, issue_num, patchset_num = utils.parse_cq_status_url_message(cq_message)
+    if not url:
+      return
+    if self.key.id() != issue_num:
+      logging.error('CQ posted CQ Status URL %s to the wrong issue %s',
+                    url, self.key.id())
+      return
+    for patchset in self.patchsets:
+      if patchset.key.id() == patchset_num:
+        patchset.cq_status_url = url
+        patchset.put()
+        logging.info('saved cq_status_url %s to patchset %s', url, patchset.key)
+        return
+    logging.error('CQ posted CQ Status URL %s with unrecognized patchset %s',
+                  url, patchset_num)
+
+
 
 def can_skip_checks_on_revert(landed_age):
   """Returns whether CQ checks on revert can be skipped."""
   if landed_age is None:
     return False
   return landed_age < REVERT_MAX_AGE_FOR_CHECKS_BYPASSING
 
 
 def _calculate_delta(patch, patchset_id, patchsets):
   """Calculates which files in earlier patchsets this file differs from.
@@ skipping 142 matching lines @@
   data = ndb.BlobProperty()
   url = ndb.StringProperty()
   created = ndb.DateTimeProperty(auto_now_add=True)
   modified = ndb.DateTimeProperty(auto_now=True)
   n_comments = ndb.IntegerProperty(default=0)
   # TODO(maruel): Deprecated, remove once the live instance has all its data
   # converted to TryJobResult instances.
   build_results = ndb.StringProperty(repeated=True)
   depends_on_patchset = ndb.StringProperty()
   dependent_patchsets = ndb.StringProperty(repeated=True)
+  cq_status_url = ndb.StringProperty()
 
   @property
   def depends_on_tokens(self):
     tokens = None
     if self.depends_on_patchset:
       issue_id, patchset_id = self.depends_on_patchset.split(':')
       issue = Issue.get_by_id(int(issue_id))
       patchset = PatchSet.get_by_id(int(patchset_id), parent=issue.key)
       tokens = (issue, patchset)
     return tokens
@@ skipping 1228 matching lines @@
   out.issues = sum((i.issues for i in items), [])
   out.latencies = sum((i.latencies for i in items), [])
   out.lgtms = sum((i.lgtms for i in items), [])
   out.review_types = sum((i.review_types for i in items), [])
   out.score = compute_score(out)
   return (
       prev_issues != out.issues or
       prev_latencies != out.latencies or
       prev_lgtms != out.lgtms or
       prev_review_types != out.review_types)