1 files changed, 75 insertions, 0 deletions
diff --git a/webapp/codereview/internal/util.py b/webapp/codereview/internal/util.py
new file mode 100644
index 0000000000..267fe29348
--- /dev/null
+++ b/webapp/codereview/internal/util.py
@@ -0,0 +1,75 @@
+# 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,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import datetime
+
+from google.appengine.ext import db
+from codereview import models
+from codereview.need_retry_pb2 import RetryRequestLaterResponse
+
+class InternalAPI(object):
+  """
+    Marker superclass for service implementations which should be
+    restricted to only role accounts executing batch processing.
+  """
+  def __init__(self):
+    pass
+
+def u(str):
+  """Decode the UTF-8 byte sequence into a unicode object."""
+  return str.decode('utf_8')
+
+def commit_to_revision(proj, commit):
+  """Converts a GitCommit into a RevisionId data store object.
+  """
+  p_a = commit.author
+  p_c = commit.committer
+
+  return models.RevisionId.get_or_insert_revision(
+          project = proj,
+          id = commit.id,
+          ancestors = [p for p in commit.parent_id],
+          message = db.Text(u(commit.message)),
+
+          author_name = u(p_a.name),
+          author_email = db.Email(u(p_a.email)),
+          author_when = datetime.datetime.utcfromtimestamp(p_a.when),
+          author_tz = p_a.tz,
+
+          committer_name = u(p_c.name),
+          committer_email = db.Email(u(p_c.email)),
+          committer_when = datetime.datetime.utcfromtimestamp(p_c.when),
+          committer_tz = p_a.tz,
+          )
+
+def automatic_retry(func):
+  """Decorator that catches data store errors and sends a retry response."""
+  def retry_wrapper(self, rpc_controller, req, done):
+    try:
+      func(self, rpc_controller, req, done)
+
+    except db.InternalError:
+      rsp = RetryRequestLaterResponse()
+      done(rsp)
+
+    except db.Timeout:
+      rsp = RetryRequestLaterResponse()
+      done(rsp)
+
+    except db.TransactionFailedError:
+      rsp = RetryRequestLaterResponse()
+      done(rsp)
+
+  return retry_wrapper
+