vcs-ops: store user_id inside the extras for vcs context operations.

- we'll use this one for bootstrap of async tasks.

rhodecode/apps/ssh_support/lib/backends/base.py

@@ -93,6 +93,7 b' class VcsServer(object):'
         scm_data = {
             'ip': os.environ['SSH_CLIENT'].split()[0],
             'username': self.user.username,
+            'user_id': self.user.user_id,
             'action': action,
             'repository': self.repo_name,
             'scm': self.backend,

rhodecode/apps/ssh_support/tests/test_server_git.py

@@ -127,6 +127,7 b' class TestGitServer(object):'
 
         expected_data = {
             'username': git_server.user.username,
+            'user_id': git_server.user.user_id,
             'scm': 'git',
             'repository': git_server.repo_name,
             'make_lock': None,

rhodecode/lib/base.py

@@ -169,19 +169,20 b' def vcs_operation_context('
     make_lock = None
     locked_by = [None, None, None]
     is_anonymous = username == User.DEFAULT_USER
+    user = User.get_by_username(username)
     if not is_anonymous and check_locking:
         log.debug('Checking locking on repository "%s"', repo_name)
-        user = User.get_by_username(username)
         repo = Repository.get_by_repo_name(repo_name)
         make_lock, __, locked_by = repo.get_locking_state(
             action, user.user_id)
-
+    user_id = user.user_id
     settings_model = VcsSettingsModel(repo=repo_name)
     ui_settings = settings_model.get_ui_settings()
 
     extras = {
         'ip': get_ip_addr(environ),
         'username': username,
+        'user_id': user_id,
         'action': action,
         'repository': repo_name,
         'scm': scm,

rhodecode/tests/events/test_repo.py

@@ -37,6 +37,7 b' def scm_extras(user_regular, repo_stub):'
     extras = utils2.AttributeDict({
         'ip': '127.0.0.1',
         'username': user_regular.username,
+        'user_id': user_regular.user_id,
         'action': '',
         'repository': repo_stub.repo_name,
         'scm': repo_stub.scm_instance().alias,

rhodecode/tests/integrations/conftest.py

@@ -37,6 +37,7 b' def repo_push_event(backend, user_regula'
     scm_extras = {
         'ip': '127.0.0.1',
         'username': user_regular.username,
+        'user_id': user_regular.user_id,
         'action': '',
         'repository': repo.repo_name,
         'scm': repo.scm_instance().alias,

rhodecode/tests/lib/test_base.py

@@ -72,6 +72,8 b' def test_vcs_operation_context_can_skip_'
     base, 'get_enabled_hook_classes', Mock(return_value=['stub_hook']))
 @patch('rhodecode.lib.utils2.get_server_url',
        Mock(return_value='https://example.com'))
[e-mail](db.User, 'get_by_username',
+       Mock(return_value=Mock(return_value=1)))
 def call_vcs_operation_context(**kwargs_override):
     kwargs = {
         'repo_name': 'stub_repo_name',

rhodecode/tests/lib/test_hooks_base.py

@@ -28,6 +28,7 b' def test_post_push_truncates_commits(use'
     extras = {
         'ip': '127.0.0.1',
         'username': user_regular.username,
+        'user_id': user_regular.user_id,
         'action': 'push_local',
         'repository': repo_stub.repo_name,
         'scm': 'git',
@@ -64,6 +65,7 b' def hook_extras(user_regular, repo_stub)'
     extras = utils2.AttributeDict({
         'ip': '127.0.0.1',
         'username': user_regular.username,
+        'user_id': user_regular.user_id,
         'action': 'push',
         'repository': repo_stub.repo_name,
         'scm': '',

rhodecode/tests/models/test_pullrequest.py

@@ -458,6 +458,7 b' def merge_extras(user_regular):'
     extras = {
         'ip': '127.0.0.1',
         'username': user_regular.username,
+        'user_id': user_regular.user_id,
         'action': 'push',
         'repository': 'fake_target_repo_name',
         'scm': 'git',