| Left: | ||
| Right: |
| LEFT | RIGHT |
|---|---|
| 1 # coding: utf-8 | 1 # coding: utf-8 |
| 2 | 2 |
| 3 # This file is part of the Adblock Plus web scripts, | 3 # This file is part of the Adblock Plus web scripts, |
| 4 # Copyright (C) 2006-2012 Eyeo GmbH | 4 # Copyright (C) 2006-2012 Eyeo GmbH |
| 5 # | 5 # |
| 6 # Adblock Plus is free software: you can redistribute it and/or modify | 6 # Adblock Plus is free software: you can redistribute it and/or modify |
| 7 # it under the terms of the GNU General Public License version 3 as | 7 # it under the terms of the GNU General Public License version 3 as |
| 8 # published by the Free Software Foundation. | 8 # published by the Free Software Foundation. |
| 9 # | 9 # |
| 10 # Adblock Plus is distributed in the hope that it will be useful, | 10 # Adblock Plus is distributed in the hope that it will be useful, |
| (...skipping 28 matching lines...) Expand all Loading... | |
| 39 comment, hasscreenshot, knownissues | 39 comment, hasscreenshot, knownissues |
| 40 FROM #PFX#reports WHERE ctime >= FROM_UNIXTIME(%s) LIMIT %s OFFS ET %s''', | 40 FROM #PFX#reports WHERE ctime >= FROM_UNIXTIME(%s) LIMIT %s OFFS ET %s''', |
| 41 (startTime, count, offset)) | 41 (startTime, count, offset)) |
| 42 rows = cursor.fetchall() | 42 rows = cursor.fetchall() |
| 43 cursor.close() | 43 cursor.close() |
| 44 if len(rows) == 0: | 44 if len(rows) == 0: |
| 45 break | 45 break |
| 46 for row in rows: | 46 for row in rows: |
| 47 yield row | 47 yield row |
| 48 offset += len(rows) | 48 offset += len(rows) |
| 49 | |
| 50 def getReportsForUser(contact): | |
| 51 cursor = get_db().cursor(MySQLdb.cursors.DictCursor) | |
| 52 executeQuery(cursor, | |
| 53 '''SELECT guid, type, UNIX_TIMESTAMP(ctime) AS ctime, status, site , contact, | |
| 54 comment, hasscreenshot, knownissues | |
| 55 FROM #PFX#reports WHERE contact = %s ORDER BY ctime DESC LIMIT 100 ''', | |
| 56 (contact)) | |
| 57 rows = cursor.fetchall() | |
| 58 cursor.close() | |
| 59 return rows | |
| 49 | 60 |
| 50 def getReport(guid): | 61 def getReport(guid): |
| 51 cursor = get_db().cursor() | 62 cursor = get_db().cursor() |
| 52 executeQuery(cursor, | 63 executeQuery(cursor, |
| 53 '''SELECT dump FROM #PFX#reports WHERE guid = %s''', | 64 '''SELECT dump FROM #PFX#reports WHERE guid = %s''', |
| 54 (guid)) | 65 (guid)) |
| 55 report = cursor.fetchone() | 66 report = cursor.fetchone() |
| 56 if report == None: | 67 if report == None: |
| 57 return None | 68 return None |
| 58 | 69 |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 95 if id != None: | 106 if id != None: |
| 96 filterMatch = lambda f: any(u == sn['id'] for u in f.get('subscriptions' , [])) | 107 filterMatch = lambda f: any(u == sn['id'] for u in f.get('subscriptions' , [])) |
| 97 hasMatches = any(filterMatch(f) for f in reportData.get('filters', [])) | 108 hasMatches = any(filterMatch(f) for f in reportData.get('filters', [])) |
| 98 executeQuery(cursor, | 109 executeQuery(cursor, |
| 99 '''INSERT IGNORE INTO #PFX#sublists (report, list, hasmatches) VA LUES (%s, %s, %s)''', | 110 '''INSERT IGNORE INTO #PFX#sublists (report, list, hasmatches) VA LUES (%s, %s, %s)''', |
| 100 (guid, id[0], hasMatches)) | 111 (guid, id[0], hasMatches)) |
| 101 | 112 |
| 102 get_db().commit() | 113 get_db().commit() |
| 103 | 114 |
| 104 reportData['guid'] = guid | 115 reportData['guid'] = guid |
| 105 if contact: | 116 if contact: |
|
Wladimir Palant
2012/11/07 08:38:15
What if there is an email field but no contact? Th
Andrey Novikov
2012/11/07 09:38:48
Few lines above we have:
contact = getUserId(repor
| |
| 106 email = reportData['email'] | 117 email = reportData['email'] |
| 107 email = re.sub(r' at ', r'@', email) | 118 email = re.sub(r' at ', r'@', email) |
| 108 email = re.sub(r' dot ', r'.', email) | 119 email = re.sub(r' dot ', r'.', email) |
| 109 reportData['email'] = anonymizeMail(email) | 120 reportData['email'] = anonymizeMail(email) |
| 110 reportData['uid'] = contact | 121 reportData['uid'] = contact |
| 111 | 122 |
| 112 file = os.path.join(get_config().get('reports', 'dataPath'), guid[0], guid[1], guid[2], guid[3], guid + '.html') | 123 file = os.path.join(get_config().get('reports', 'dataPath'), guid[0], guid[1], guid[2], guid[3], guid + '.html') |
| 113 dir = os.path.dirname(file) | 124 dir = os.path.dirname(file) |
| 114 if not os.path.exists(dir): | 125 if not os.path.exists(dir): |
| 115 os.makedirs(dir) | 126 os.makedirs(dir) |
| (...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 243 dbpasswd = get_config().get('reports', 'dbpassword') | 254 dbpasswd = get_config().get('reports', 'dbpassword') |
| 244 if os.name == 'nt': | 255 if os.name == 'nt': |
| 245 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8', named_pipe=True) | 256 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8', named_pipe=True) |
| 246 else: | 257 else: |
| 247 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8') | 258 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8') |
| 248 | 259 |
| 249 def executeQuery(cursor, query, args=None): | 260 def executeQuery(cursor, query, args=None): |
| 250 tablePrefix = get_config().get('reports', 'dbprefix') | 261 tablePrefix = get_config().get('reports', 'dbprefix') |
| 251 query = re.sub(r'#PFX#', tablePrefix, query) | 262 query = re.sub(r'#PFX#', tablePrefix, query) |
| 252 cursor.execute(query, args) | 263 cursor.execute(query, args) |
| LEFT | RIGHT |