changeset 2201:f15056b29472

patch queue: notify.patch

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/hgext/notify.py	Thu May 04 12:25:10 2006 -0700
@@ -0,0 +1,95 @@
+from mercurial.demandload import *
+from mercurial.i18n import gettext as _
+from mercurial.node import *
+demandload(globals(), 'email.MIMEText mercurial:templater,util fnmatch socket')
+demandload(globals(), 'time')
+
+class notifier(object):
+    def __init__(self, ui, repo):
+        self.ui = ui
+        self.ui.readconfig(self.ui.config('notify', 'config'))
+        self.repo = repo
+        self.stripcount = self.ui.config('notify', 'strip')
+        self.root = self.strip(self.repo.root)
+
+    def strip(self, path):
+        path = util.pconvert(path)
+        count = self.stripcount
+        while path and count >= 0:
+            c = path.find('/')
+            if c == -1:
+                break
+            path = path[c+1:]
+            count -= 1
+        return path
+
+    def subscribers(self):
+        subs = []
+        for user, pat in self.ui.configitems('usersubs'):
+            if fnmatch.fnmatch(self.root, pat):
+                subs.append(user)
+        for pat, users in self.ui.configitems('reposubs'):
+            if fnmatch.fnmatch(self.root, pat):
+                subs.extend([u.strip() for u in users.split(',')])
+        subs.sort()
+        return subs
+
+    def seen(self, node):
+        pass
+
+    def url(self, path=None):
+        return self.ui.config('web', 'baseurl') + (path or self.root)
+
+    def message(self, node, changes):
+        sio = templater.stringio()
+        seen = self.seen(node)
+        if seen:
+            seen = self.strip(seen)
+            sio.write('Changeset %s merged to %s\n' %
+                      (short(node), self.url()))
+            sio.write('First seen in %s\n' % self.url(seen))
+        else:
+            sio.write('Changeset %s new to %s\n' % (short(node), self.url()))
+        sio.write('Committed by %s at %s\n' %
+                  (changes[1], templater.isodate(changes[2])))
+        sio.write('See %s?cmd=changeset;node=%s for full details\n' %
+                  (self.url(), short(node)))
+        sio.write('\nDescription:\n')
+        sio.write(templater.indent(changes[4], '  '))
+        msg = email.MIMEText.MIMEText(sio.getvalue(), 'plain')
+        firstline = changes[4].lstrip().split('\n', 1)[0].rstrip()
+        subject = '%s %s: %s' % (self.root, self.repo.rev(node), firstline)
+        if seen:
+            subject = '[merge] ' + subject
+        if subject.endswith('.'):
+            subject = subject[:-1]
+        if len(subject) > 67:
+            subject = subject[:64] + '...'
+        msg['Subject'] = subject
+        msg['X-Hg-Repo'] = self.root
+        if '@' in changes[1]:
+            msg['From'] = changes[1]
+        else:
+            msg['From'] = self.ui.config('email', 'from')
+        msg['Message-Id'] = '<hg.%s.%s.%s@%s>' % (hex(node),
+                                                  int(time.time()),
+                                                  hash(self.repo.root),
+                                                  socket.getfqdn())
+        return msg
+
+    def node(self, node):
+        mail = self.ui.sendmail()
+        changes = self.repo.changelog.read(node)
+        fromaddr = self.ui.config('email', 'from', changes[1])
+        msg = self.message(node, changes)
+        subs = self.subscribers()
+        msg['To'] = ', '.join(subs)
+        msgtext = msg.as_string(0)
+        mail.sendmail(templater.email(fromaddr),
+                      [templater.email(s) for s in subs],
+                      msgtext)
+
+
+def hook(ui, repo, hooktype, node=None, **kwargs):
+    n = notifier(ui, repo)
+    n.node(bin(node))