Set created_by and updated_by on all database operations

services/chat_with_agent.py

@@ -73,6 +73,7 @@ async def chat_with_agent(
                 tools=tools,
                 model_id=current_model,
                 usage_id=usage_id,
+                created_by=f"{base_args['sender_id']}:{base_args['sender_name']}",
             )
             break
 

services/claude/chat_with_claude.py

@@ -37,6 +37,7 @@ def chat_with_claude(
     tools: list[ToolUnionParam],
     model_id: ClaudeModelId,
     usage_id: int,
+    created_by: str,
 ):
     # https://docs.anthropic.com/en/api/client-sdks
     # Apply message optimization functions to save tokens
@@ -131,6 +132,7 @@ def chat_with_claude(
         output_message=assistant_message,
         output_tokens=token_output,
         response_time_ms=response_time_ms,
+        created_by=created_by,
     )
 
     return (

services/claude/test_chat_with_claude.py

@@ -28,6 +28,7 @@ def test_chat_with_claude_success(mock_claude, mock_insert_llm_request):
         tools=tools,
         model_id=ClaudeModelId.SONNET_4_6,
         usage_id=123,
+        created_by="4:test-user",
     )
 
     assistant_message, tool_calls, token_input, token_output = result
@@ -84,6 +85,7 @@ def test_chat_with_claude_with_tool_use(mock_claude, mock_insert_llm_request):
         tools=tools,
         model_id=ClaudeModelId.SONNET_4_6,
         usage_id=456,
+        created_by="4:test-user",
     )
 
     _, tool_calls, _, _ = result
@@ -111,6 +113,7 @@ def test_chat_with_claude_no_usage_response(mock_claude, mock_insert_llm_request
         tools=[],
         model_id=ClaudeModelId.SONNET_4_6,
         usage_id=789,
+        created_by="4:test-user",
     )
 
     _, _, _, token_output = result
@@ -145,6 +148,7 @@ def test_chat_with_claude_calls_optimization_functions(
         tools=[],
         model_id=ClaudeModelId.SONNET_4_6,
         usage_id=101,
+        created_by="4:test-user",
     )
 
     mock_remove_outdated_apply_diff_to_file_attempts_and_results.assert_called_once()

services/supabase/coverages/test_update_issue_url.py

@@ -56,12 +56,13 @@ def test_update_issue_url_success(self, mock_supabase_success):
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
         mock_supabase.table.assert_called_once_with("coverages")
         mock_table.update.assert_called_once_with(
-            {"github_issue_url": github_issue_url}
+            {"github_issue_url": github_issue_url, "updated_by": "system"}
         )
         mock_table.eq.assert_any_call("repo_id", repo_id)
         mock_table.eq.assert_any_call("full_path", file_path)
@@ -82,12 +83,13 @@ def test_update_issue_url_with_empty_response(self, mock_supabase_empty_response
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
         mock_supabase.table.assert_called_once_with("coverages")
         mock_table.update.assert_called_once_with(
-            {"github_issue_url": github_issue_url}
+            {"github_issue_url": github_issue_url, "updated_by": "system"}
         )
         mock_table.eq.assert_any_call("repo_id", repo_id)
         mock_table.eq.assert_any_call("full_path", file_path)
@@ -108,6 +110,7 @@ def test_update_issue_url_with_zero_repo_id(self, mock_supabase_success):
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
@@ -128,6 +131,7 @@ def test_update_issue_url_with_negative_repo_id(self, mock_supabase_success):
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
@@ -148,6 +152,7 @@ def test_update_issue_url_with_empty_file_path(self, mock_supabase_success):
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
@@ -168,10 +173,13 @@ def test_update_issue_url_with_empty_github_url(self, mock_supabase_success):
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
-        mock_table.update.assert_called_once_with({"github_issue_url": ""})
+        mock_table.update.assert_called_once_with(
+            {"github_issue_url": "", "updated_by": "system"}
+        )
         assert result == [
             {"id": 1, "github_issue_url": "https://github.com/owner/repo/issues/123"}
         ]
@@ -190,6 +198,7 @@ def test_update_issue_url_with_long_file_path(self, mock_supabase_success):
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
@@ -212,6 +221,7 @@ def test_update_issue_url_with_special_characters_in_path(
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
@@ -232,6 +242,7 @@ def test_update_issue_url_with_large_repo_id(self, mock_supabase_success):
             repo_id=repo_id,
             file_path=file_path,
             github_issue_url=github_issue_url,
+            updated_by="system",
         )
 
         # Assert
@@ -252,6 +263,7 @@ def test_update_issue_url_exception_handling(self):
                 repo_id=123456,
                 file_path="src/main.py",
                 github_issue_url="https://github.com/owner/repo/issues/123",
+                updated_by="system",
             )
 
             # Assert - The handle_exceptions decorator should return None on error
@@ -268,6 +280,7 @@ def test_update_issue_url_method_chaining(self, mock_supabase_success):
             repo_id=123456,
             file_path="src/main.py",
             github_issue_url="https://github.com/owner/repo/issues/123",
+            updated_by="system",
         )
 
         # Assert - Verify the method chaining sequence

services/supabase/coverages/update_issue_url.py

@@ -4,11 +4,15 @@
 
 @handle_exceptions(default_return_value=None, raise_on_error=False)
 def update_issue_url(
-    owner_id: int, repo_id: int, file_path: str, github_issue_url: str
+    owner_id: int,
+    repo_id: int,
+    file_path: str,
+    github_issue_url: str,
+    updated_by: str,
 ):
     result = (
         supabase.table("coverages")
-        .update({"github_issue_url": github_issue_url})
+        .update({"github_issue_url": github_issue_url, "updated_by": updated_by})
         .eq("owner_id", owner_id)
         .eq("repo_id", repo_id)
         .eq("full_path", file_path)

services/supabase/create_user_request.py

@@ -33,6 +33,7 @@ def create_user_request(
         repo_name=repo_name,
         pr_number=pr_number,
         user_id=user_id,
+        user_name=user_name,
         installation_id=installation_id,
         source=source,
         trigger=trigger,

services/supabase/installations/insert_installation.py

@@ -8,12 +8,15 @@ def insert_installation(
     owner_id: int,
     owner_type: str,
     owner_name: str,
+    user_id: int,
+    user_name: str,
 ):
     supabase.table(table_name="installations").insert(
         json={
             "installation_id": installation_id,
             "owner_id": owner_id,
             "owner_type": owner_type,
             "owner_name": owner_name,
+            "created_by": f"{user_id}:{user_name}",
         }
     ).execute()

services/supabase/installations/test_insert_installation.py

@@ -36,6 +36,8 @@ def valid_installation_data():
         "owner_id": TEST_OWNER_ID,
         "owner_type": TEST_OWNER_TYPE,
         "owner_name": TEST_OWNER_NAME,
+        "user_id": 11111,
+        "user_name": "test-sender",
     }
 
 
@@ -70,6 +72,8 @@ def test_insert_installation_with_minimal_data(mock_supabase_client):
         "owner_id": 67890,
         "owner_type": "User",
         "owner_name": "test-user",
+        "user_id": 11111,
+        "user_name": "test-sender",
     }
 
     result = insert_installation(**minimal_data)
@@ -94,6 +98,8 @@ def test_insert_installation_with_organization_owner(mock_supabase_client):
         "owner_id": 11111,
         "owner_type": "Organization",
         "owner_name": "test-org",
+        "user_id": 22222,
+        "user_name": "test-sender",
     }
 
     result = insert_installation(**org_data)
@@ -125,6 +131,8 @@ def test_insert_installation_with_various_data_types(
         owner_id=owner_id,
         owner_type=owner_type,
         owner_name=owner_name,
+        user_id=11111,
+        user_name="test-sender",
     )
 
     assert result is None
@@ -145,6 +153,8 @@ def test_insert_installation_supabase_chain_calls(mock_supabase_client):
         owner_id=TEST_OWNER_ID,
         owner_type=TEST_OWNER_TYPE,
         owner_name=TEST_OWNER_NAME,
+        user_id=11111,
+        user_name="test-sender",
     )
 
     # Verify the method chain: supabase.table().insert().execute()
@@ -168,8 +178,15 @@ def test_insert_installation_function_signature():
     sig = inspect.signature(insert_installation)
 
     # Assert parameter count and names
-    assert len(sig.parameters) == 4
-    expected_params = ["installation_id", "owner_id", "owner_type", "owner_name"]
+    assert len(sig.parameters) == 6
+    expected_params = [
+        "installation_id",
+        "owner_id",
+        "owner_type",
+        "owner_name",
+        "user_id",
+        "user_name",
+    ]
     for param in expected_params:
         assert param in sig.parameters
 
@@ -178,6 +195,8 @@ def test_insert_installation_function_signature():
     assert sig.parameters["owner_id"].annotation is int
     assert sig.parameters["owner_type"].annotation is str
     assert sig.parameters["owner_name"].annotation is str
+    assert sig.parameters["user_id"].annotation is int
+    assert sig.parameters["user_name"].annotation is str
 
 
 def test_insert_installation_with_supabase_exception():
@@ -197,6 +216,8 @@ def test_insert_installation_with_supabase_exception():
                 owner_id=TEST_OWNER_ID,
                 owner_type=TEST_OWNER_TYPE,
                 owner_name=TEST_OWNER_NAME,
+                user_id=11111,
+                user_name="test-sender",
             )
 
 
@@ -225,6 +246,8 @@ def test_insert_installation_with_http_error():
                 owner_id=TEST_OWNER_ID,
                 owner_type=TEST_OWNER_TYPE,
                 owner_name=TEST_OWNER_NAME,
+                user_id=11111,
+                user_name="test-sender",
             )
 
 
@@ -246,6 +269,8 @@ def test_insert_installation_with_special_characters_in_owner_name(
             owner_id=TEST_OWNER_ID,
             owner_type=TEST_OWNER_TYPE,
             owner_name=owner_name,
+            user_id=11111,
+            user_name="test-sender",
         )
 
         # Verify the special characters are preserved
@@ -267,6 +292,8 @@ def test_insert_installation_with_large_ids(mock_supabase_client):
         owner_id=large_owner_id,
         owner_type=TEST_OWNER_TYPE,
         owner_name=TEST_OWNER_NAME,
+        user_id=11111,
+        user_name="test-sender",
     )
 
     insert_call_args = mock_supabase_client.table.return_value.insert.call_args
@@ -288,6 +315,8 @@ def test_insert_installation_with_empty_owner_name(mock_supabase_client):
         owner_id=TEST_OWNER_ID,
         owner_type=TEST_OWNER_TYPE,
         owner_name="",
+        user_id=11111,
+        user_name="test-sender",
     )
 
     insert_call_args = mock_supabase_client.table.return_value.insert.call_args
@@ -306,6 +335,8 @@ def test_insert_installation_with_different_owner_types(mock_supabase_client):
             owner_id=TEST_OWNER_ID,
             owner_type=owner_type,
             owner_name=TEST_OWNER_NAME,
+            user_id=11111,
+            user_name="test-sender",
         )
 
         insert_call_args = mock_supabase_client.table.return_value.insert.call_args

services/supabase/llm_requests/clear_old_content.py

@@ -27,7 +27,7 @@ def clear_old_content(retention_days: int = 14):
             ids = [row["id"] for row in batch.data]
 
             supabase.table("llm_requests").update(
-                {"input_content": "", "output_content": ""}
+                {"input_content": "", "output_content": "", "updated_by": "system"}
             ).in_("id", ids).execute()
 
             total_cleared += len(ids)

services/supabase/llm_requests/insert_llm_request.py

@@ -16,9 +16,9 @@ def insert_llm_request(
     input_tokens: int,
     output_message: MessageParam,
     output_tokens: int,
+    created_by: str,
     response_time_ms: int | None = None,
     error_message: str | None = None,
-    created_by: str | None = None,
 ):
     # Convert messages to JSON strings
     input_content = json.dumps(input_messages, ensure_ascii=False)

services/supabase/llm_requests/test_clear_old_content.py

@@ -46,7 +46,9 @@ def test_clear_old_content_single_batch(mock_datetime, mock_supabase):
     mock_select.lt.assert_called_with("created_at", expected_cutoff)
     mock_lt_select.neq.assert_called_with("input_content", "")
     mock_neq.limit.assert_called_with(SUPABASE_BATCH_SIZE)
-    mock_table.update.assert_called_with({"input_content": "", "output_content": ""})
+    mock_table.update.assert_called_with(
+        {"input_content": "", "output_content": "", "updated_by": "system"}
+    )
     mock_update.in_.assert_called_with("id", [1, 2, 3])
 
 

services/supabase/llm_requests/test_insert_llm_request.py

@@ -71,6 +71,7 @@ def test_insert_llm_request_database_error(mock_supabase):
         input_tokens=10,
         output_message={"role": "assistant", "content": "response"},
         output_tokens=5,
+        created_by="4:test-user",
     )
 
     assert result is None