Show More
@@ -261,7 +261,6 b' def store(action, user, action_data=None' | |||||
261 | ip_address = safe_unicode(ip_addr) |
|
261 | ip_address = safe_unicode(ip_addr) | |
262 |
|
262 | |||
263 | with sa_session.no_autoflush: |
|
263 | with sa_session.no_autoflush: | |
264 | update_user_last_activity(sa_session, user_id) |
|
|||
265 |
|
264 | |||
266 | user_log = _store_log( |
|
265 | user_log = _store_log( | |
267 | action_name=action_name, |
|
266 | action_name=action_name, | |
@@ -275,11 +274,15 b' def store(action, user, action_data=None' | |||||
275 | ) |
|
274 | ) | |
276 |
|
275 | |||
277 | sa_session.add(user_log) |
|
276 | sa_session.add(user_log) | |
|
277 | if commit: | |||
|
278 | sa_session.commit() | |||
|
279 | entry_id = user_log.entry_id or '' | |||
|
280 | ||||
|
281 | update_user_last_activity(sa_session, user_id) | |||
278 |
|
282 | |||
279 | if commit: |
|
283 | if commit: | |
280 | sa_session.commit() |
|
284 | sa_session.commit() | |
281 |
|
285 | |||
282 | entry_id = user_log.entry_id or '' |
|
|||
283 | log.info('AUDIT[%s]: Logging action: `%s` by user:id:%s[%s] ip:%s', |
|
286 | log.info('AUDIT[%s]: Logging action: `%s` by user:id:%s[%s] ip:%s', | |
284 | entry_id, action_name, user_id, username, ip_address) |
|
287 | entry_id, action_name, user_id, username, ip_address) | |
285 |
|
288 | |||
@@ -295,4 +298,6 b' def update_user_last_activity(sa_session' | |||||
295 | log.debug( |
|
298 | log.debug( | |
296 | 'updated user `%s` last activity to:%s', user_id, _last_activity) |
|
299 | 'updated user `%s` last activity to:%s', user_id, _last_activity) | |
297 | except Exception: |
|
300 | except Exception: | |
298 | log.exception("Failed last activity update") |
|
301 | log.exception("Failed last activity update for user_id: %s", user_id) | |
|
302 | sa_session.rollback() | |||
|
303 |
@@ -1198,14 +1198,20 b' class PullRequestModel(BaseModel):' | |||||
1198 | pull_request=pull_request, |
|
1198 | pull_request=pull_request, | |
1199 | revision=commit_id) |
|
1199 | revision=commit_id) | |
1200 |
|
1200 | |||
|
1201 | # initial commit | |||
|
1202 | Session().commit() | |||
|
1203 | ||||
|
1204 | if pr_has_changes: | |||
1201 | # send update email to users |
|
1205 | # send update email to users | |
1202 | try: |
|
1206 | try: | |
1203 | self.notify_users(pull_request=pull_request, updating_user=updating_user, |
|
1207 | self.notify_users(pull_request=pull_request, updating_user=updating_user, | |
1204 | ancestor_commit_id=ancestor_commit_id, |
|
1208 | ancestor_commit_id=ancestor_commit_id, | |
1205 | commit_changes=commit_changes, |
|
1209 | commit_changes=commit_changes, | |
1206 | file_changes=file_changes) |
|
1210 | file_changes=file_changes) | |
|
1211 | Session().commit() | |||
1207 | except Exception: |
|
1212 | except Exception: | |
1208 | log.exception('Failed to send email notification to users') |
|
1213 | log.exception('Failed to send email notification to users') | |
|
1214 | Session().rollback() | |||
1209 |
|
1215 | |||
1210 | log.debug( |
|
1216 | log.debug( | |
1211 | 'Updated pull request %s, added_ids: %s, common_ids: %s, ' |
|
1217 | 'Updated pull request %s, added_ids: %s, common_ids: %s, ' | |
@@ -1221,7 +1227,7 b' class PullRequestModel(BaseModel):' | |||||
1221 | pull_request.pull_request_id, source_ref_id, |
|
1227 | pull_request.pull_request_id, source_ref_id, | |
1222 | pull_request.source_ref_parts.commit_id, |
|
1228 | pull_request.source_ref_parts.commit_id, | |
1223 | pull_request_version.pull_request_version_id) |
|
1229 | pull_request_version.pull_request_version_id) | |
1224 | Session().commit() |
|
1230 | ||
1225 | self.trigger_pull_request_hook(pull_request, pull_request.author, 'update') |
|
1231 | self.trigger_pull_request_hook(pull_request, pull_request.author, 'update') | |
1226 |
|
1232 | |||
1227 | return UpdateResponse( |
|
1233 | return UpdateResponse( |
General Comments 0
You need to be logged in to leave comments.
Login now