Complete agent attribution coverage (#181)

Amp-Thread-ID: https://ampcode.com/threads/T-01a01147-8d44-7468-ac98-bf40b04e3cee

Co-authored-by: Amp <amp@ampcode.com>

Author: HamptonMakes

db/migrate/20260815174516_add_agent_provenance_to_library_events.co_plan.rb

@@ -0,0 +1,8 @@
+class AddAgentProvenanceToLibraryEvents < ActiveRecord::Migration[8.1]
+  def change
+    add_column :coplan_library_events, :agent_name, :string
+    add_column :coplan_library_events, :api_token_id, :string, limit: 36
+    add_index :coplan_library_events, :api_token_id
+    add_foreign_key :coplan_library_events, :coplan_api_tokens, column: :api_token_id
+  end
+end

db/schema.rb

@@ -104,7 +104,14 @@ def destroy
             return
           end
 
-          Comments::SoftDelete.call(comment: comment, actor: current_user)
+          Comments::SoftDelete.call(
+            comment: comment,
+            actor: current_user,
+            actor_type: api_author_type,
+            actor_id: api_user_id,
+            agent_name: api_agent_name,
+            api_token_id: api_token_id
+          )
 
           thread = comment.comment_thread
           if thread.reload.empty?

engine/app/controllers/coplan/api/v1/comments_controller.rb

@@ -48,7 +48,7 @@ def create
             created_by_user: current_user
           )
           Libraries::LogEvent.call(
-            library: library, actor: current_user, actor_type: api_author_type,
+            library: library, actor: current_user, **library_event_identity,
             event_type: "folder_created", folder: folder, after: folder.path
           )
           render json: folder_json(folder), status: :created
@@ -93,7 +93,7 @@ def destroy
           path = @folder.path
           if @folder.destroy
             Libraries::LogEvent.call(
-              library: @folder.library, actor: current_user, actor_type: api_author_type,
+              library: @folder.library, actor: current_user, **library_event_identity,
               event_type: "folder_deleted", before: path,
               metadata: { folder_name: @folder.name }
             )
@@ -117,26 +117,34 @@ def log_folder_update(old_path, old_description)
           new_path = @folder.path
           if @folder.saved_change_to_name?
             Libraries::LogEvent.call(
-              library: @folder.library, actor: current_user, actor_type: api_author_type,
+              library: @folder.library, actor: current_user, **library_event_identity,
               event_type: "folder_renamed", folder: @folder, before: old_path, after: new_path
             )
           end
           if @folder.saved_change_to_parent_id?
             Libraries::LogEvent.call(
-              library: @folder.library, actor: current_user, actor_type: api_author_type,
+              library: @folder.library, actor: current_user, **library_event_identity,
               event_type: "folder_moved", folder: @folder, before: old_path, after: new_path
             )
           end
           if @folder.saved_change_to_description?
             Libraries::LogEvent.call(
-              library: @folder.library, actor: current_user, actor_type: api_author_type,
+              library: @folder.library, actor: current_user, **library_event_identity,
               event_type: "folder_described", folder: @folder,
               before: old_description, after: @folder.description,
               metadata: { path: new_path }
             )
           end
         end
 
+        def library_event_identity
+          {
+            actor_type: api_author_type,
+            agent_name: api_agent_name,
+            api_token_id: api_token_id
+          }
+        end
+
         # `paths` and `counts` let index serialize the whole tree without
         # per-folder queries. `plans_count` is the folder's own visible
         # placements (not including subfolders).

engine/app/controllers/coplan/api/v1/folders_controller.rb

@@ -243,6 +243,8 @@ def event_json(event)
             actor_type: event.actor_type,
             agent: event.actor_type != "human",
             actor: event.actor_user && { id: event.actor_user.id, name: event.actor_user.name },
+            agent_name: event.agent_name,
+            api_token_id: event.api_token_id,
             actor_label: event.metadata["actor_label"],
             run_id: event.run_id,
             plan_id: event.plan_id,

engine/app/controllers/coplan/api/v1/libraries_controller.rb

@@ -327,6 +327,7 @@ def resolve_folder_params
             created.each do |f|
               Libraries::LogEvent.call(
                 library: current_user.library, actor: current_user, actor_type: api_author_type,
+                agent_name: api_agent_name, api_token_id: api_token_id,
                 event_type: "folder_created", folder: f, after: f.path
               )
             end

engine/app/controllers/coplan/api/v1/plans_controller.rb

@@ -3,6 +3,7 @@ class Comment < ApplicationRecord
     AUTHOR_TYPES = %w[human local_agent cloud_persona system].freeze
 
     belongs_to :comment_thread
+    belongs_to :api_token, class_name: "CoPlan::ApiToken", optional: true
 
     validates :body_markdown, presence: true
     validates :author_type, presence: true, inclusion: { in: AUTHOR_TYPES }

engine/app/models/coplan/comment.rb

@@ -28,20 +28,22 @@ class LibraryEvent < ApplicationRecord
 
     belongs_to :library, class_name: "CoPlan::Library", inverse_of: :library_events
     belongs_to :actor_user, class_name: "CoPlan::User", foreign_key: "actor_id", optional: true
+    belongs_to :api_token, class_name: "CoPlan::ApiToken", optional: true
 
     after_initialize { self.metadata ||= {} }
 
     validates :actor_type, presence: true, inclusion: { in: ACTOR_TYPES }
     validates :event_type, presence: true, inclusion: { in: EVENT_TYPES }
+    validates :agent_name, length: { maximum: ApiToken::AGENT_NAME_LIMIT }, allow_nil: true
 
     scope :recent_first, -> { order(created_at: :desc, id: :desc) }
 
     def self.ransackable_attributes(_auth_object = nil)
-      %w[id library_id actor_id actor_type event_type plan_id folder_id run_id before_value after_value created_at]
+      %w[id library_id actor_id actor_type agent_name api_token_id event_type plan_id folder_id run_id before_value after_value created_at]
     end
 
     def self.ransackable_associations(_auth_object = nil)
-      %w[library actor_user]
+      %w[library actor_user api_token]
     end
   end
 end

engine/app/models/coplan/library_event.rb

@@ -37,6 +37,7 @@ class PlanEvent < ApplicationRecord
 
     belongs_to :plan
     belongs_to :actor_user, class_name: "CoPlan::User", foreign_key: "actor_id", optional: true
+    belongs_to :api_token, class_name: "CoPlan::ApiToken", optional: true
 
     after_initialize { self.metadata ||= {} }
 
@@ -49,11 +50,11 @@ class PlanEvent < ApplicationRecord
     scope :for_history, -> { order(created_at: :desc) }
 
     def self.ransackable_attributes(_auth_object = nil)
-      %w[id plan_id actor_id actor_type event_type field before_value after_value created_at]
+      %w[id plan_id actor_id actor_type agent_name api_token_id event_type field before_value after_value created_at]
     end
 
     def self.ransackable_associations(_auth_object = nil)
-      %w[plan actor_user]
+      %w[plan actor_user api_token]
     end
 
     # Marker so history rendering can branch on the kind of item without

engine/app/models/coplan/plan_event.rb

@@ -4,6 +4,7 @@ class PlanVersion < ApplicationRecord
 
     belongs_to :plan
     belongs_to :actor_user, class_name: "CoPlan::User", foreign_key: "actor_id", optional: true
+    belongs_to :api_token, class_name: "CoPlan::ApiToken", optional: true
     has_many :comment_threads, dependent: :nullify
 
     # has_attribute? guard: list pages load lean stubs (id + sha only) via