# frozen_string_literal: true

require_relative '../embedding'
require_relative '../../logic/cartridge/safety'

require 'concurrent'

module NanoBot
  module Components
    module Providers
      module Tools
        def self.confirming(tool, feedback)
          feedback.call(
            { should_be_stored: false,
              interaction: { who: 'AI', message: nil, meta: {
                tool: { action: 'confirming', id: tool[:id], name: tool[:label], parameters: tool[:parameters] }
              } } }
          )
        end

        def self.apply(cartridge, function_cartridge, tools, feedback, tools_logic)
          prepared_tools = tools_logic.prepare(function_cartridge, tools)

          if Logic::Cartridge::Safety.confirmable?(cartridge)
            prepared_tools.each { |tool| tool[:allowed] = confirming(tool, feedback) }
          else
            prepared_tools.each { |tool| tool[:allowed] = true }
          end

          futures = prepared_tools.map do |tool|
            Concurrent::Promises.future do
              if tool[:allowed]
                process!(tool, feedback, function_cartridge, cartridge)
              else
                tool[:output] =
                  "We asked the user you're chatting with for permission, but the user did not allow you to run this tool or function."
                tool
              end
            end
          end

          results = Concurrent::Promises.zip(*futures).value!

          results.map do |applied_tool|
            {
              who: 'tool',
              message: applied_tool[:output],
              meta: { id: applied_tool[:id], name: applied_tool[:name] }
            }
          end
        end

        def self.process!(tool, feedback, _function_cartridge, cartridge)
          feedback.call(
            { should_be_stored: false,
              interaction: { who: 'AI', message: nil, meta: {
                tool: { action: 'executing', id: tool[:id], name: tool[:label], parameters: tool[:parameters] }
              } } }
          )

          call = {
            parameters: %w[parameters],
            values: [tool[:parameters]],
            safety: { sandboxed: Logic::Cartridge::Safety.sandboxed?(cartridge) }
          }

          if %i[fennel lua clojure].count { |key| !tool[:source][key].nil? } > 1
            raise StandardError, 'conflicting tools'
          end

          if !tool[:source][:fennel].nil?
            call[:source] = tool[:source][:fennel]
            tool[:output] = Components::Embedding.fennel(**call)
          elsif !tool[:source][:clojure].nil?
            call[:source] = tool[:source][:clojure]
            tool[:output] = Components::Embedding.clojure(**call)
          elsif !tool[:source][:lua].nil?
            call[:source] = tool[:source][:lua]
            tool[:output] = Components::Embedding.lua(**call)
          else
            raise 'missing source code'
          end

          feedback.call(
            { should_be_stored: false,
              interaction: { who: 'AI', message: nil, meta: {
                tool: {
                  action: 'responding', id: tool[:id], name: tool[:label],
                  parameters: tool[:parameters], output: tool[:output]
                }
              } } }
          )

          tool
        end
      end
    end
  end
end