class Riffer::Rig::Terminal::Ticker

# File lib/riffer/rig/terminal/ticker.rb, line 25
def initialize(footer:, theme:, buffer:, rates:)
  @footer = footer
  @theme = theme
  @buffer = buffer
  @rates = rates
  @mutex = Mutex.new
  @halt = Queue.new
  @tick = 0
  @unmetered = 0
end

# File lib/riffer/rig/terminal/ticker.rb, line 44
def absorb(event)
  # The ticker thread reads the buffer, so the buffer takes each event under
  # the lock a frame is drawn under: no frame shows half of one.
  @mutex.synchronize do
    @buffer.absorb(event)
    case event
    when Riffer::StreamEvents::ReasoningDelta, Riffer::StreamEvents::TextDelta
      @unmetered += event.content.length
    when Riffer::StreamEvents::ToolCallDelta
      @unmetered += event.arguments_delta.length
    when Riffer::StreamEvents::TokenUsageDone
      @unmetered = 0
    end
  end
end

# File lib/riffer/rig/terminal/ticker.rb, line 37
def start
  tick
  @thread = Thread.new { tick until @halt.pop(timeout: TICK_SECONDS) }
end

# File lib/riffer/rig/terminal/ticker.rb, line 72
def stop
  @halt << true
  @thread&.join
  @footer.status('')
end

# File lib/riffer/rig/terminal/ticker.rb, line 61
def tick
  room = @footer.status_room
  jobs = @footer.job_count
  reasoning = @footer.reasoning
  status = @mutex.synchronize do
    line(room, jobs, reasoning).tap { @tick += 1 }
  end
  @footer.status(status)
end