core.lua

-- luacheck: globals unpack vim

--- low-level connection handler.
-- @module acid.core
-- @todo merge with acid and acid.connections
local output = require("acid.output")
local connections = require("acid.connections")
local utils = require("acid.utils")
local log = require("acid.log")

local core = {
  indirection = setmetatable({}, utils.LRU(5))
}

--- Forward messages to the nrepl and registers the handler.
-- @tparam[opt] {string,string} connection Ip and Port tuple. Will try to get one if nil.
-- @tparam table obj Payload to be sent to the nrepl.
-- @tparam function handler Handler function to deal with the response.
core.send = function(connection, obj, handler)
  local conn, conn_id
  if handler == nil then
    vim.api.nvim_err_writeln("Please provide a handler for that operation.")
    return
  end

  local pwd = vim.api.nvim_call_function("getcwd", {})

  local ctp = type(connection)
  if ctp == "string" then
    conn_id = connection
    conn = connections.store[connection]
  elseif ctp == "table" then
    conn = connection
    conn_id = connections.reverse_lookup(connection)
  elseif connection == nil then
    conn_id = connections.peek()
    conn = connections.store[conn_id]
  end

  if conn == nil then
    log.msg("No active connection to a nrepl session. Aborting")
    return
  end

  if obj.code ~= nil then
    output.draw(conn_id, (obj.ns or "") .. "=> " .. obj.code)
  end

  if obj.id == nil then
    obj.id = utils.ulid()
  end

  core.register_callback(conn, handler, obj.id)

  vim.api.nvim_call_function("AcidSendNrepl", {obj, conn})

end

core.register_callback = function(conn, handler, session)
  core.indirection[session] = {
    fn = handler,
    conn = conn
  }
  return session
end

return core