rubbs/lib/bbs/flow_runner.rb

# frozen_string_literal: true

module BBS
  class FlowRunner
    STYLES = {
      success: "\e[1;32m",
      muted:   "\e[0;37m",
      error:   "\e[1;31m",
      info:    "\e[0;33m",
      prompt:  "\e[1;37m",
      confirm: "\e[1;36m",
      cyan:    "\e[0;36m",
      magenta: "\e[0;35m",
      blue:    "\e[0;34m",
      yellow:  "\e[0;33m",
      white:   "\e[1;37m",
      green:   "\e[1;32m",
      red:     "\e[1;31m",
    }.freeze

    attr_reader :session_id

    def initialize(session, session_id, flow)
      @session    = session
      @session_id = session_id
      @flow       = flow
      @ctx        = { session_id: session_id }
    end

    def run
      execute(@flow.steps)
    end

    def write(data) = @session.write(data)
    def readline    = @session.readline

    private

    def execute(steps)
      steps.each do |step|
        result = dispatch(step)
        return result if result == :halt || result == :exit_menu
      end
      nil
    end

    def dispatch(step)
      case step[:type]
      when :screen        then run_screen(step)
      when :banner        then run_banner(step)
      when :big_banner    then run_big_banner(step)
      when :say           then run_say(step)
      when :set           then run_set(step)
      when :ask           then run_ask(step)
      when :persist       then run_persist(step)
      when :pause         then run_pause(step)
      when :gate          then run_gate(step)
      when :confirm_halt  then run_confirm_halt(step)
      when :confirm_block then run_confirm_block(step)
      when :menu          then run_menu(step)
      when :exit_menu     then :exit_menu
      when :call          then run_call(step)
      when :line          then run_line(step)
      when :section       then run_section(step)
      when :text          then run_text(step)
      when :rows          then run_rows(step)
      when :table         then run_table(step)
      when :wait_enter    then run_wait_enter(step)
      when :fetch         then run_fetch(step)
      when :pick          then run_pick(step)
      when :body          then run_body(step)
      when :output        then run_output(step)
      end
    end

    # ── step handlers ──────────────────────────────────────────────────────────

    def run_screen(step)
      vars = step[:vars].transform_values { |v| v.is_a?(Symbol) ? @ctx[v] : v }
      write Renderer.render(step[:name].to_s, @ctx.merge(vars))
    end

    def run_banner(step)
      color = STYLES.fetch(step[:style], STYLES[:success])
      write Banner.render(step[:text], color: color)
    end

    def run_big_banner(step)
      color = STYLES.fetch(step[:style], STYLES[:success])
      write Banner.render_big(step[:text], color: color, font: step[:font])
    end

    def run_say(step)
      color = STYLES.fetch(step[:style], STYLES[:muted])
      write "\r\n  #{color}#{step[:text]}\e[0m\r\n\r\n"
    end

    def run_set(step)
      @ctx[step[:name]] = step[:value]
      nil
    end

    def run_ask(step)
      write "  #{STYLES[:prompt]}#{step[:prompt]}\e[0m: "
      value = readline&.strip
      return :halt if value.nil?

      value = apply_transform(value, step[:transform])

      if step[:validate] && !valid?(value, step[:validate])
        write "\r\n  #{STYLES[:error]}#{validation_message(step[:validate])}\e[0m\r\n\r\n"
        return :halt
      end

      @ctx[step[:name]] = value
      nil
    end

    def run_persist(step)
      fields = step[:fields].filter_map { |f| [f, @ctx[f]] if @ctx.key?(f) }.to_h
      step[:store].upsert(session_id: @session_id, **fields) unless fields.empty?
      nil
    end

    def run_pause(step)
      write "\r\n  #{STYLES[:info]}#{step[:message]}\e[0m\r\n"
      sleep step[:seconds]
      nil
    end

    def run_gate(step)
      return nil if step[:check].call(@ctx)
      write "  #{STYLES[:error]}#{step[:denied]}\e[0m\r\n\r\n"
      :halt
    end

    def run_confirm_halt(step)
      write "\r\n  #{STYLES[:confirm]}#{step[:message]}\e[0m [yes/no]: "
      answer = readline&.strip&.downcase
      return :halt if answer.nil?
      return nil   if %w[yes y].include?(answer)
      write "\r\n  #{STYLES[:muted]}#{step[:denied]}\e[0m\r\n\r\n" if step[:denied]
      :halt
    end

    def run_confirm_block(step)
      write "\r\n  #{STYLES[:prompt]}#{step[:message]}\e[0m [yes/no]: "
      answer = readline&.strip&.downcase
      return :halt if answer.nil?

      if %w[yes y].include?(answer)
        execute(step[:sub_steps])
      else
        write "\r\n  #{STYLES[:muted]}#{step[:denied]}\e[0m\r\n\r\n" if step[:denied]
        nil
      end
    end

    def run_menu(step)
      loop do
        write "\r\n"
        step[:options].each_with_index do |opt, i|
          write "  #{STYLES[:muted]}#{i + 1}.  #{opt[:label]}\e[0m\r\n"
        end
        write "\r\n  #{STYLES[:prompt]}#{step[:prompt]}\e[0m "

        input = readline&.strip
        return :halt if input.nil?

        index = input.to_i - 1
        unless (0...step[:options].length).include?(index)
          write "\r\n  #{STYLES[:error]}Enter a number between 1 and #{step[:options].length}.\e[0m\r\n"
          next
        end

        result = execute(step[:options][index][:steps])
        return :halt if result == :halt
        return nil   if result == :exit_menu

        break unless step[:loop]
      end
      nil
    end

    def run_call(step)
      result = step[:block].call(@ctx, self)
      result == :halt ? :halt : nil
    rescue IOError, Errno::EPIPE, Errno::ECONNRESET
      :halt
    rescue => e
      warn "BBS call error: #{e.class}: #{e.message}\n#{e.backtrace.first(5).join("\n")}"
      write "\r\n  \e[1;31mError: #{e.message}\e[0m\r\n\r\n"
      nil
    end

    def run_line(step)
      color = style_color(step[:color])
      write "  #{color}#{'─' * 66}\e[0m\r\n"
    end

    def run_section(step)
      color = style_color(step[:color])
      title = step[:title]
      pad   = [70 - title.length - 6, 2].max
      write "\r\n  #{color}┌─ \e[1;37m#{title} #{color}#{'─' * pad}┐\e[0m\r\n\r\n"
    end

    def run_text(step)
      color   = style_color(step[:style])
      content = step[:block] ? step[:block].call(@ctx) : step[:text]
      write "  #{color}#{content}\e[0m\r\n" if content
    end

    def run_rows(step)
      items = step[:block].call(@ctx)
      items = Array(items)
      if items.empty?
        write "  #{STYLES[:muted]}#{step[:empty]}\e[0m\r\n"
      else
        items.each { |row| write "  #{row}\r\n" }
      end
      nil
    rescue IOError, Errno::EPIPE, Errno::ECONNRESET
      :halt
    rescue => e
      warn "BBS rows error: #{e.class}: #{e.message}"
      write "\r\n  #{STYLES[:error]}Error loading content.\e[0m\r\n"
      nil
    end

    def run_table(step)
      pairs = step[:block].call(@ctx)
      pairs.each do |label, value|
        write "  #{STYLES[:muted]}#{label.to_s.ljust(16)}#{STYLES[:prompt]}#{value}\e[0m\r\n"
      end
      nil
    rescue IOError, Errno::EPIPE, Errno::ECONNRESET
      :halt
    rescue => e
      warn "BBS table error: #{e.class}: #{e.message}"
      write "\r\n  #{STYLES[:error]}Error loading content.\e[0m\r\n"
      nil
    end

    def run_wait_enter(step)
      write "\r\n  #{STYLES[:muted]}#{step[:prompt]}\e[0m"
      return :halt if readline.nil?
      nil
    end

    def run_fetch(step)
      write "\r\n  #{STYLES[:muted]}#{step[:loading]}\e[0m\r\n"
      result = step[:block].call(@ctx)
      write "\e[1A\e[2K"
      @ctx[step[:name]] = result
      nil
    rescue IOError, Errno::EPIPE, Errno::ECONNRESET
      :halt
    rescue => e
      warn "BBS fetch error: #{e.class}: #{e.message}"
      write "\r\n  #{STYLES[:error]}Error loading content.\e[0m\r\n"
      nil
    end

    def run_pick(step)
      items = Array(@ctx[step[:from]]).first(25)

      if items.empty?
        write "\r\n  #{STYLES[:error]}#{step[:empty]}\e[0m\r\n"
        write "\r\n  #{STYLES[:muted]}Press ENTER to continue...\e[0m"
        return :halt if readline.nil?
        return nil
      end

      write "\r\n"
      items.each_with_index do |item, i|
        write "  #{step[:item].call(item, i + 1)}\r\n"
        if step[:hint]
          hint = step[:hint].call(item, i + 1).to_s.strip
          write "     #{STYLES[:muted]}#{hint}\e[0m\r\n" unless hint.empty?
        end
      end

      write "\r\n  #{STYLES[:muted]}#{step[:prompt]}\e[0m "
      input = readline&.strip
      return :halt if input.nil?
      return nil   if input.empty?

      idx = input.to_i - 1
      picked = items[idx]
      unless picked
        write "\r\n  #{STYLES[:error]}Invalid selection.\e[0m\r\n"
        return nil
      end

      @ctx[:picked] = picked
      write "\r\n"
      execute(step[:sub_steps])
    rescue IOError, Errno::EPIPE, Errno::ECONNRESET
      :halt
    end

    def run_body(step)
      text   = strip_md(step[:block].call(@ctx).to_s)
      width  = step[:width]
      prefix = ' ' * step[:indent]
      words  = text.split
      lines  = []
      line   = +''
      words.each do |word|
        if line.empty?
          line << word
        elsif line.length + 1 + word.length <= width
          line << ' ' << word
        else
          lines << line.dup
          line = +word
        end
      end
      lines << line unless line.empty?
      write "\r\n"
      lines.each { |l| write "#{prefix}#{l}\r\n" }
      write "\r\n"
      nil
    rescue IOError, Errno::EPIPE, Errno::ECONNRESET
      :halt
    rescue => e
      warn "BBS body error: #{e.class}: #{e.message}"
      nil
    end

    def run_output(step)
      content = step[:block].call(@ctx).to_s
      write content unless content.empty?
      nil
    rescue IOError, Errno::EPIPE, Errno::ECONNRESET
      :halt
    rescue => e
      warn "BBS output error: #{e.class}: #{e.message}"
      write "\r\n  #{STYLES[:error]}Error rendering content.\e[0m\r\n"
      nil
    end

    # ── helpers ────────────────────────────────────────────────────────────────

    def strip_md(text)
      text.gsub(/\[([^\]]+)\]\([^)]+\)/, '\1')
          .gsub(/[#*_`~>|\\]/, '')
          .gsub(/\r?\n+/, ' ')
          .strip
    end

    def style_color(value)
      value.is_a?(Symbol) ? STYLES.fetch(value, STYLES[:muted]) : value.to_s
    end

    def apply_transform(value, transform)
      case transform
      when :upcase   then value.upcase
      when :downcase then value.downcase
      when Proc      then transform.call(value)
      else value
      end
    end

    def valid?(value, validator)
      case validator
      when :email     then value.match?(/\A[^@\s]+@[^@\s]+\.[^@\s]+\z/)
      when :non_empty then !value.empty?
      else true
      end
    end

    def validation_message(validator)
      case validator
      when :email then "That doesn't look like a valid email address. Farewell."
      else "Invalid input. Farewell."
      end
    end
  end
end