diff rhodecode/lib/hooks.py @ 547:1e757ac98988

renamed project to rhodecode
author Marcin Kuzminski <marcin@python-works.com>
date Wed, 06 Oct 2010 03:18:16 +0200
parents pylons_app/lib/hooks.py@39203995f2c4
children 5cc96df705b9
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/rhodecode/lib/hooks.py	Wed Oct 06 03:18:16 2010 +0200
@@ -0,0 +1,78 @@
+#!/usr/bin/env python
+# encoding: utf-8
+# custom hooks for application
+# Copyright (C) 2009-2010 Marcin Kuzminski <marcin@python-works.com>
+#
+# This program is free software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; version 2
+# of the License or (at your opinion) any later version of the license.
+# 
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+# 
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
+# MA  02110-1301, USA.
+"""
+Created on Aug 6, 2010
+
+@author: marcink
+"""
+
+import sys
+import os
+from rhodecode.lib import helpers as h
+from rhodecode.model import meta
+from rhodecode.model.db import UserLog, User
+
+def repo_size(ui, repo, hooktype=None, **kwargs):
+
+    if hooktype != 'changegroup':
+        return False
+    size_hg, size_root = 0, 0
+    for path, dirs, files in os.walk(repo.root):
+        if path.find('.hg') != -1:
+            for f in files:
+                size_hg += os.path.getsize(os.path.join(path, f))
+        else:
+            for f in files:
+                size_root += os.path.getsize(os.path.join(path, f))
+                
+    size_hg_f = h.format_byte_size(size_hg)
+    size_root_f = h.format_byte_size(size_root)
+    size_total_f = h.format_byte_size(size_root + size_hg)
+    sys.stdout.write('Repository size .hg:%s repo:%s total:%s\n' \
+                     % (size_hg_f, size_root_f, size_total_f))
+    
+    user_action_mapper(ui, repo, hooktype, **kwargs)
+
+def user_action_mapper(ui, repo, hooktype=None, **kwargs):
+    """
+    Maps user last push action to new changeset id, from mercurial
+    @param ui:
+    @param repo:
+    @param hooktype:
+    """
+    
+    try:
+        sa = meta.Session
+        username = kwargs['url'].split(':')[-1]
+        user_log = sa.query(UserLog)\
+            .filter(UserLog.user == sa.query(User)\
+                                    .filter(User.username == username).one())\
+            .order_by(UserLog.user_log_id.desc()).first()
+        
+        if user_log and not user_log.revision:
+            user_log.revision = str(repo['tip'])
+            sa.add(user_log)
+            sa.commit()
+        
+    except Exception, e:
+        sa.rollback()
+        raise
+    finally:
+        meta.Session.remove()