Class: Insika::Commands::SetSkillAgents

Inherits:
Object
  • Object
show all
Defined in:
lib/insika/commands/set_skill_agents.rb

Overview

Control command: enables/disables a skill on N agents at once, adjusting each one's profile.skills allowlist. Takes effect on the next dispatch (hot via ProfileSource). -> { name, enabled_for }.

Allowlist semantics (AgentProfile): nil = ALL, [] = none, [names] = subset. Important and deliberate consequence:

  • enabling on an agent with skills=nil: no-op (already has all).
  • DISABLING on an agent with skills=nil: NOT done here — removing one from "all" would require enumerating the catalog and materializing an explicit allowlist (destructive/surprising). These agents are left intact and go into skipped_all. To restrict, use an explicit :set_agent_tools/allowlist first.

Instance Method Summary collapse

Constructor Details

#initialize(profile_source:, event_stream:) ⇒ SetSkillAgents

Returns a new instance of SetSkillAgents.



20
21
22
23
 
# File 'lib/insika/commands/set_skill_agents.rb', line 20

def initialize(profile_source:, event_stream:)
  @profile_source = profile_source
  @event_stream = event_stream
end

Instance Method Details

#call(command) ⇒ Object

Raises:



25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
# File 'lib/insika/commands/set_skill_agents.rb', line 25

def call(command)
  p = AgentPayload.symbolize(command.payload)
  name = AgentPayload.presence(p[:name])
  raise Insika::ValidationError, "name is required" if name.nil?
  raise Insika::ValidationError, "agent_ids must be a list" unless p[:agent_ids].nil? || p[:agent_ids].is_a?(Array)

  wanted = Array(p[:agent_ids]).map(&:to_s)
  enabled_for = []
  skipped_all = []

  @profile_source.all.each do |profile|
    want = wanted.include?(profile.id)
    new_skills = next_skills(profile.skills, name, want)

    if new_skills == :skip
      skipped_all << profile.id
      next
    end
    next if new_skills == profile.skills # no change

    @profile_source.put(Insika::AgentProfile.build(**profile.to_h.merge(skills: new_skills)))
    enabled_for << profile.id if want
  end

  @event_stream.emit(Insika::Event.new(
                       type: :skill_agents_set,
                       data: { name: name, agent_ids: wanted, skipped_all: skipped_all },
                       meta: { at: Time.now.utc.iso8601 }
                     ))
  { name: name, enabled_for: enabled_for, skipped_all: skipped_all }
end