]>
Commit | Line | Data |
---|---|---|
8293875f AK |
1 | # -*- coding: utf-8 -*- |
2 | ||
76e24b1f EB |
3 | from trac.core import * |
4 | from trac.ticket import ITicketChangeListener | |
6ae9f02e | 5 | import subprocess |
b9d0b655 | 6 | import re |
76e24b1f | 7 | import textwrap |
1246b147 | 8 | import shlex |
76e24b1f | 9 | |
99f25bfd AK |
10 | quoted_re = re.compile('^(?:> ?\n)*> .+\n(?:>(?: .*)?\n)*', re.MULTILINE) |
11 | ||
76e24b1f | 12 | class ZephyrPlugin(Component): |
cace67b2 EB |
13 | implements(ITicketChangeListener) |
14 | ||
15 | def zwrite(self, id, message): | |
16 | zclass = self.config.get('ZephyrPlugin', 'class') | |
17 | if zclass == '': | |
18 | return | |
f503b22f | 19 | command = shlex.split(self.config.get('ZephyrPlugin', 'command').encode('utf-8')) |
da9785cf | 20 | if not command: |
d23d10ba | 21 | command = ['zwrite', '-q', '-l', '-d'] |
776bd957 EB |
22 | opcode = self.config.get('ZephyrPlugin', 'opcode') |
23 | if opcode: | |
24 | command += ['-O', opcode] | |
d23d10ba GT |
25 | p = subprocess.Popen(command + |
26 | ['-c', zclass, | |
cace67b2 EB |
27 | '-i', 'trac-#%s' % id], |
28 | stdin=subprocess.PIPE) | |
0e5f06a1 | 29 | p.stdin.write(message.replace('@', '@@').encode('utf-8', 'replace')) |
cace67b2 EB |
30 | p.stdin.close() |
31 | p.wait() | |
08cf6d42 AK |
32 | |
33 | def format_text(self, text): | |
99f25bfd | 34 | text = re.sub(quoted_re, u'> […]\n', text) |
08cf6d42 AK |
35 | lines = textwrap.fill(text).split('\n') |
36 | if len(lines) > 5: | |
37 | lines = lines[:5] + [u'[…]'] | |
38 | return '\n'.join(lines) | |
cace67b2 EB |
39 | |
40 | def ticket_created(self, ticket): | |
c00679cc GT |
41 | message = "%s filed a new %s ticket:\n%s\n\n%s" % (ticket['reporter'], |
42 | ticket['priority'], | |
43 | ticket['summary'], | |
44 | self.format_text(ticket['description'])) | |
cace67b2 EB |
45 | self.zwrite(ticket.id, message) |
46 | ||
47 | def ticket_changed(self, ticket, comment, author, old_values): | |
3271653b | 48 | message = "(%s)\n" % ticket['summary'] |
c5aba9f6 AK |
49 | for field in ticket.fields: |
50 | name = field['name'] | |
51 | if name not in old_values: | |
52 | pass | |
53 | elif field['type'] == 'textarea': | |
54 | message += "%s changed %s to:\n%s\n" % (author, name, self.format_text(ticket[name])) | |
55 | elif ticket[name] and old_values[name]: | |
56 | message += "%s changed %s from %s to %s.\n" % (author, name, old_values[name], ticket[name]) | |
57 | elif ticket[name]: | |
58 | message += "%s set %s to %s.\n" % (author, name, ticket[name]) | |
59 | elif old_values[name]: | |
60 | message += "%s deleted %s.\n" % (author, name) | |
cace67b2 | 61 | else: |
c5aba9f6 AK |
62 | message += "%s changed %s.\n" % (author, name) |
63 | if comment: | |
64 | message += "%s commented:\n%s\n" % (author, self.format_text(comment)) | |
cace67b2 EB |
65 | self.zwrite(ticket.id, message) |
66 | ||
67 | def ticket_deleted(self, ticket): | |
c5aba9f6 AK |
68 | message = "%s deleted ticket %d" % (author, ticket.id) |
69 | self.zwrite(ticket.id, message) |