Class: Silas::Inbox::SessionsController

Inherits:
BaseController
  • Object
show all
Defined in:
app/controllers/silas/inbox/sessions_controller.rb

Constant Summary collapse

PER_PAGE = 
50

Instance Method Summary collapse

Instance Method Details

#create ⇒ Object

Start a session from the browser. channel stays nil ("direct") — web chat is read live on the session page, not delivered outbound.



43
44
45
46
47
48
49
50
51
52
 
# File 'app/controllers/silas/inbox/sessions_controller.rb', line 43

def create
  input = params[:input].to_s.strip
  return redirect_to inbox_sessions_path, alert: "Type a message first." if input.empty?

  handle = params[:agent].present? ? Silas.agent(params[:agent]) : Silas.agent
  started = handle.start(input: input)
  redirect_to inbox_session_path(started)
rescue Silas::Error => e
  redirect_to inbox_sessions_path, alert: e.message
end

#index ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'app/controllers/silas/inbox/sessions_controller.rb', line 8

def index
  # Keyset pagination on id (?before=<id> pages older), newest first.
  scope = Silas::Session.order(id: :desc)
  scope = scope.where(agent_name: params[:agent]) if params[:agent].present?
  if params[:pending].present? # the "N awaiting approval" badge drills into this
    # Subquery, not joins+distinct: DISTINCT over silas_sessions.* trips
    # on the json metadata column (PG json has no equality operator).
    scope = scope.where(
      id: Silas::Turn.joins(:tool_invocations)
                     .where(silas_tool_invocations: { approval_state: "required" })
                     .select(:session_id)
    )
  end
  scope = scope.where(id: ...params[:before].to_i) if params[:before].present?

  # One query for the rows + turns, one for the pending counts — the
  # per-row active_turn/turns.last/counts pattern was ~4 queries a card.
  @sessions = scope.limit(PER_PAGE).includes(:turns).to_a
  @next_before = @sessions.last&.id if @sessions.size == PER_PAGE
  @pending_counts = Silas::ToolInvocation.joins(:turn)
                                         .where(approval_state: "required",
                                                silas_turns: { session_id: @sessions.map(&:id) })
                                         .group("silas_turns.session_id").count
  @agent_names = Silas::Session.distinct.pluck(:agent_name).sort
  @pending_total = Silas::ToolInvocation.where(approval_state: "required").count
end

#show ⇒ Object 



35
36
37
38
39
 
# File 'app/controllers/silas/inbox/sessions_controller.rb', line 35

def show
  @session = Silas::Session.find(params[:id])
  @turns = @session.turns.includes(steps: :tool_invocations)
  @cost = Silas::Inbox::Cost.for_session(@session)
end