notify.py 11.3 KB
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
#!/usr/bin/python3

import configparser
import email.mime.text
import mysql.connector
import os
import smtplib
import subprocess
import sys
import textwrap

config = configparser.RawConfigParser()
config.read(os.path.dirname(os.path.realpath(__file__)) + '/../conf/config')

aur_db_host = config.get('database', 'host')
aur_db_name = config.get('database', 'name')
aur_db_user = config.get('database', 'user')
aur_db_pass = config.get('database', 'password')
aur_db_socket = config.get('database', 'socket')

aur_location = config.get('options', 'aur_location')
aur_request_ml = config.get('options', 'aur_request_ml')

sendmail = config.get('notifications', 'sendmail')
sender = config.get('notifications', 'sender')
reply_to = config.get('notifications', 'reply-to')


29
30
31
def headers_cc(cclist):
    return {'Cc': str.join(', ', cclist)}

32
33
34
def headers_msgid(thread_id):
    return {'Message-ID': thread_id}

35
36
37
38
def headers_reply(thread_id):
    return {'In-Reply-To': thread_id, 'References': thread_id}

def send_notification(to, subject, body, refs, headers={}):
39
40
41
42
    wrapped = ''
    for line in body.splitlines():
        wrapped += textwrap.fill(line, break_long_words=False) + '\n'
    body = wrapped + '\n' + refs
43
44
45
46
47
48
49
50

    for recipient in to:
        msg = email.mime.text.MIMEText(body, 'plain', 'utf-8')
        msg['Subject'] = subject
        msg['From'] = sender
        msg['Reply-to'] = reply_to
        msg['To'] = recipient

51
52
        for key, value in headers.items():
            msg[key] = value
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

        p = subprocess.Popen([sendmail, '-t', '-oi'], stdin=subprocess.PIPE)
        p.communicate(msg.as_bytes())

def username_from_id(cur, uid):
    cur.execute('SELECT UserName FROM Users WHERE ID = %s', [uid])
    return cur.fetchone()[0]

def pkgbase_from_id(cur, pkgbase_id):
    cur.execute('SELECT Name FROM PackageBases WHERE ID = %s', [pkgbase_id])
    return cur.fetchone()[0]

def pkgbase_from_pkgreq(cur, reqid):
    cur.execute('SELECT PackageBaseID FROM PackageRequests WHERE ID = %s',
                [reqid])
    return cur.fetchone()[0]

70
71
72
73
def get_user_email(cur, uid):
    cur.execute('SELECT Email FROM Users WHERE ID = %s', [uid])
    return cur.fetchone()[0]

74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
def get_maintainer_email(cur, pkgbase_id):
    cur.execute('SELECT Users.Email FROM Users ' +
                'INNER JOIN PackageBases ' +
                'ON PackageBases.MaintainerUID = Users.ID WHERE ' +
                'PackageBases.ID = %s', [pkgbase_id])
    return cur.fetchone()[0]

def get_recipients(cur, pkgbase_id, uid):
    cur.execute('SELECT DISTINCT Users.Email FROM Users ' +
                'INNER JOIN CommentNotify ' +
                'ON CommentNotify.UserID = Users.ID WHERE ' +
                'CommentNotify.UserID != %s AND ' +
                'CommentNotify.PackageBaseID = %s', [uid, pkgbase_id])
    return [row[0] for row in cur.fetchall()]

def get_request_recipients(cur, pkgbase_id, uid):
    cur.execute('SELECT DISTINCT Users.Email FROM Users ' +
                'INNER JOIN PackageBases ' +
                'ON PackageBases.MaintainerUID = Users.ID WHERE ' +
                'Users.ID = %s OR PackageBases.ID = %s', [uid, pkgbase_id])
    return [row[0] for row in cur.fetchall()]

96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
def get_comment(cur, comment_id):
    cur.execute('SELECT Comments FROM PackageComments WHERE ID = %s',
                [comment_id])
    return cur.fetchone()[0]

def get_flagger_comment(cur, pkgbase_id):
    cur.execute('SELECT FlaggerComment FROM PackageBases WHERE ID = %s',
                [pkgbase_id])
    return cur.fetchone()[0]

def get_request_comment(cur, reqid):
    cur.execute('SELECT Comments FROM PackageRequests WHERE ID = %s', [reqid])
    return cur.fetchone()[0]

def get_request_closure_comment(cur, reqid):
    cur.execute('SELECT ClosureComment FROM PackageRequests WHERE ID = %s',
                [reqid])
    return cur.fetchone()[0]

115
116
117
118
119
120
121
def send_resetkey(cur, uid):
    cur.execute('SELECT UserName, Email, ResetKey FROM Users WHERE ID = %s',
                [uid])
    username, to, resetkey = cur.fetchone()

    subject = 'AUR Password Reset'
    body = 'A password reset request was submitted for the account %s ' \
122
123
124
           'associated with your email address. If you wish to reset your ' \
           'password follow the link [1] below, otherwise ignore this ' \
           'message and nothing will happen.' % (username)
125
    refs = '[1] ' + aur_location + '/passreset/?resetkey=' + resetkey
126

127
    send_notification([to], subject, body, refs)
128
129
130
131
132
133
134

def welcome(cur, uid):
    cur.execute('SELECT UserName, Email, ResetKey FROM Users WHERE ID = %s',
                [uid])
    username, to, resetkey = cur.fetchone()

    subject = 'Welcome to the Arch User Repository'
135
136
137
138
    body = 'Welcome to the Arch User Repository! In order to set an initial ' \
           'password for your new account, please click the link [1] below. ' \
           'If the link does not work, try copying and pasting it into your ' \
           'browser.'
139
    refs = '[1] ' + aur_location + '/passreset/?resetkey=' + resetkey
140

141
    send_notification([to], subject, body, refs)
142

143
def comment(cur, uid, pkgbase_id, comment_id):
144
145
146
    user = username_from_id(cur, uid)
    pkgbase = pkgbase_from_id(cur, pkgbase_id)
    to = get_recipients(cur, pkgbase_id, uid)
147
    text = get_comment(cur, comment_id)
148
149
150

    uri = aur_location + '/pkgbase/' + pkgbase + '/'

151
152
153
    user_uri = aur_location + '/account/' + user + '/'
    pkgbase_uri = aur_location + '/pkgbase/' + pkgbase + '/'

154
    subject = 'AUR Comment for %s' % (pkgbase)
155
156
157
158
159
    body = '%s [1] added the following comment to %s [2]:' % (user, pkgbase)
    body += '\n\n' + text + '\n\n'
    body += 'If you no longer wish to receive notifications about this ' \
            'package, please go to the package page [2] and select "%s".' % \
            ('Disable notifications')
160
161
    refs = '[1] ' + user_uri + '\n'
    refs += '[2] ' + pkgbase_uri
162
    thread_id = '<pkg-notifications-' + pkgbase + '@aur.archlinux.org>'
163
    headers = headers_reply(thread_id)
164

165
    send_notification(to, subject, body, refs, headers)
166
167
168
169
170

def flag(cur, uid, pkgbase_id):
    user = username_from_id(cur, uid)
    pkgbase = pkgbase_from_id(cur, pkgbase_id)
    to = [get_maintainer_email(cur, pkgbase_id)]
171
    text = get_flagger_comment(cur, pkgbase_id)
172
173
174
175
176

    user_uri = aur_location + '/account/' + user + '/'
    pkgbase_uri = aur_location + '/pkgbase/' + pkgbase + '/'

    subject = 'AUR Out-of-date Notification for %s' % (pkgbase)
177
    body = 'Your package %s [1] has been flagged out-of-date by %s [2]:' % \
178
           (pkgbase, user)
179
180
181
    body += '\n\n' + text
    refs = '[1] ' + pkgbase_uri + '\n'
    refs += '[2] ' + user_uri
182

183
    send_notification(to, subject, body, refs)
184

185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
def comaintainer_add(cur, pkgbase_id, uid):
    pkgbase = pkgbase_from_id(cur, pkgbase_id)
    to = [get_user_email(cur, uid)]

    pkgbase_uri = aur_location + '/pkgbase/' + pkgbase + '/'

    subject = 'AUR Co-Maintainer Notification for %s' % (pkgbase)
    body = 'You were added to the co-maintainer list of %s [1].' % (pkgbase)
    refs = '[1] ' + pkgbase_uri + '\n'

    send_notification(to, subject, body, refs)

def comaintainer_remove(cur, pkgbase_id, uid):
    pkgbase = pkgbase_from_id(cur, pkgbase_id)
    to = [get_user_email(cur, uid)]

    pkgbase_uri = aur_location + '/pkgbase/' + pkgbase + '/'

    subject = 'AUR Co-Maintainer Notification for %s' % (pkgbase)
    body = 'You were removed from the co-maintainer list of %s [1].' % \
            (pkgbase)
    refs = '[1] ' + pkgbase_uri + '\n'

    send_notification(to, subject, body, refs)

210
211
212
213
214
215
216
def delete(cur, uid, old_pkgbase_id, new_pkgbase_id=None):
    user = username_from_id(cur, uid)
    old_pkgbase = pkgbase_from_id(cur, old_pkgbase_id)
    if new_pkgbase_id:
        new_pkgbase = pkgbase_from_id(cur, new_pkgbase_id)
    to = get_recipients(cur, old_pkgbase_id, uid)

217
218
219
    user_uri = aur_location + '/account/' + user + '/'
    pkgbase_uri = aur_location + '/pkgbase/' + pkgbase + '/'

220
221
222
    subject = 'AUR Package deleted: %s' % (old_pkgbase)
    if new_pkgbase_id:
        new_pkgbase_uri = aur_location + '/pkgbase/' + new_pkgbase + '/'
223
        body = '%s [1] merged %s [2] into %s [3].\n\n' \
224
225
226
               'If you no longer wish receive notifications about the new ' \
               'package, please go to [3] and click "%s".' %\
               (user, old_pkgbase, new_pkgbase, 'Disable notifications')
227
228
229
        refs = '[1] ' + user_uri + '\n'
        refs += '[2] ' + pkgbase_uri + '\n'
        refs += '[3] ' + new_pkgbase_uri
230
    else:
231
232
233
        body = '%s [1] deleted %s [2].\n\n' \
               'You will no longer receive notifications about this ' \
               'package.' % (user, old_pkgbase)
234
235
        refs = '[1] ' + user_uri + '\n'
        refs += '[2] ' + pkgbase_uri
236

237
    send_notification(to, subject, body, refs)
238
239
240
241
242
243

def request_open(cur, uid, reqid, reqtype, pkgbase_id, merge_into=None):
    user = username_from_id(cur, uid)
    pkgbase = pkgbase_from_id(cur, pkgbase_id)
    to = [aur_request_ml]
    cc = get_request_recipients(cur, pkgbase_id, uid)
244
    text = get_request_comment(cur, reqid)
245
246
247
248
249
250
251
252

    user_uri = aur_location + '/account/' + user + '/'
    pkgbase_uri = aur_location + '/pkgbase/' + pkgbase + '/'

    subject = '[PRQ#%d] %s Request for %s' % \
              (int(reqid), reqtype.title(), pkgbase)
    if merge_into:
        merge_into_uri = aur_location + '/pkgbase/' + merge_into + '/'
253
254
        body = '%s [1] filed a request to merge %s [2] into %s [3]:' % \
               (user, pkgbase, merge_into)
255
256
257
258
        body += '\n\n' + text
        refs = '[1] ' + user_uri + '\n'
        refs += '[2] ' + pkgbase_uri + '\n'
        refs += '[3] ' + merge_into_uri
259
    else:
260
261
        body = '%s [1] filed a %s request for %s [2]:' % \
               (user, reqtype, pkgbase)
262
263
264
        body += '\n\n' + text
        refs = '[1] ' + user_uri + '\n'
        refs += '[2] ' + pkgbase_uri + '\n'
265
    thread_id = '<pkg-request-' + reqid + '@aur.archlinux.org>'
266
267
    headers = headers_reply(thread_id)
    headers.update(headers_cc(cc))
268

269
    send_notification(to, subject, body, refs, headers)
270
271
272
273
274
275

def request_close(cur, uid, reqid, reason):
    user = username_from_id(cur, uid)
    pkgbase_id = pkgbase_from_pkgreq(cur, reqid)
    to = [aur_request_ml]
    cc = get_request_recipients(cur, pkgbase_id, uid)
276
    text = get_request_closure_comment(cur, reqid);
277
278
279
280
281
282

    user_uri = aur_location + '/account/' + user + '/'

    subject = '[PRQ#%d] Request %s' % (int(reqid), reason.title())
    body = 'Request #%d has been %s by %s [1]' % (int(reqid), reason, user)
    if text.strip() == '':
283
        body += '.'
284
    else:
285
286
        body += ':\n\n' + text
    refs = '[1] ' + user_uri
287
    thread_id = '<pkg-request-' + reqid + '@aur.archlinux.org>'
288
289
    headers = headers_reply(thread_id)
    headers.update(headers_cc(cc))
290

291
    send_notification(to, subject, body, refs, headers)
292
293
294
295
296
297
298
299
300


if __name__ == '__main__':
    action = sys.argv[1]
    action_map = {
        'send-resetkey': send_resetkey,
        'welcome': welcome,
        'comment': comment,
        'flag': flag,
301
302
        'comaintainer-add': comaintainer_add,
        'comaintainer-remove': comaintainer_remove,
303
304
305
306
307
308
309
310
311
312
313
314
315
316
        'delete': delete,
        'request-open': request_open,
        'request-close': request_close,
    }

    db = mysql.connector.connect(host=aur_db_host, user=aur_db_user,
                                 passwd=aur_db_pass, db=aur_db_name,
                                 unix_socket=aur_db_socket, buffered=True)
    cur = db.cursor()

    action_map[action](cur, *sys.argv[2:])

    db.commit()
    db.close()