feat: init commit

Author: rcarriga

.gitignore

@@ -0,0 +1,3 @@
+neovim/
+plenary.nvim/
+Session.vim

lua/neotest/adapters/init.lua

@@ -0,0 +1,64 @@
+local async = require("plenary.async")
+local logger = require("neotest.logging")
+local lib = require("neotest.lib")
+
+local M = {}
+
+---@type table<string, NeotestAdapter>
+local adapters = {}
+
+function M.set_adapters(a)
+  adapters = a
+end
+
+local function get_current_adapter_from_cwd()
+  for _, adapter in pairs(adapters) do
+    logger.info("Checking current directory for test files with", adapter.name, "adapter")
+    local tree = adapter.discover_positions(async.fn.getcwd())
+    if tree and #tree:children() > 0 then
+      return adapter
+    end
+  end
+end
+
+local function get_adapter_from_open_bufs()
+  local buffers = async.api.nvim_list_bufs()
+  for _, adapter in pairs(adapters) do
+    for _, bufnr in pairs(buffers) do
+      if adapter.is_test_file(async.fn.fnamemodify(async.fn.bufname(bufnr), ":p")) then
+        return adapter
+      end
+    end
+  end
+end
+
+local function get_adapter_from_file_path(file_path)
+  for _, adapter in pairs(adapters) do
+    if adapter.is_test_file(file_path) then
+      return adapter
+    end
+  end
+end
+
+local adapter = nil
+
+function M.get_adapter(opts)
+  local file_path = opts.file_path
+  if not adapter and file_path then
+    adapter = get_adapter_from_file_path(file_path)
+  end
+  if not adapter then
+    adapter = get_adapter_from_open_bufs()
+  end
+  if opts.from_dir and not adapter then
+    adapter = get_current_adapter_from_cwd()
+  end
+  if adapter then
+    logger.debug("Using adapter " .. adapter.name)
+  else
+    logger.info("No adapter found")
+  end
+  return adapter
+end
+
+return M

lua/neotest/adapters/interface.lua

@@ -0,0 +1,24 @@
+---@class NeotestAdapter
+---@field name string
+local NeotestAdapter = {}
+
+
+---@async
+---@param file_path string
+---@return boolean
+function NeotestAdapter.is_test_file(file_path) end
+
+---@async
+---@param path string
+---@return Tree | nil
+function NeotestAdapter.discover_positions(path) end
+
+---@param args NeotestRunArgs
+---@return NeotestRunSpec
+function NeotestAdapter.build_spec(args) end
+
+---@async
+---@param spec NeotestRunSpec
+---@param result NeotestStrategyResult
+---@return table<string, NeotestResult>
+function NeotestAdapter.results(spec, result) end

lua/neotest/client/events/init.lua

@@ -0,0 +1,58 @@
+local logger = require("neotest.logging")
+
+local M = {}
+
+---@alias NeotestEvent "discover_positions" | "run" | "results"
+---@class NeotestEvents
+---@field DISCOVER_POSITIONS "discover_positions"
+---@field RUN "run"
+---@field RESULTS "results"
+local NeotestEvents = {
+  DISCOVER_POSITIONS = "discover_positions",
+  RUN = "run",
+  RESULTS = "results",
+}
+
+M.events = NeotestEvents
+
+---@class NeotestEventListeners
+---@field discover_files table<string, fun(files: string[])>
+---@field discover_positions table<string, fun(file_path: string, tree: Tree)>
+---@field run table<string, fun(position_ids: string[])>
+---@field results table<string, fun(results: table<string, NeotestResult>)>
+
+---@class NeotestEventProcessor
+---@field listeners NeotestEventListeners
+local NeotestEventProcessor = {}
+
+function NeotestEventProcessor:new()
+  local events = {}
+  local listeners = {}
+  for _, event in pairs(NeotestEvents) do
+    listeners[event] = {}
+  end
+  events.listeners = listeners
+  setmetatable(events, self)
+  self.__index = self
+  return events
+end
+
+---@param event NeotestEvent
+---@vararg any Arguments for the event
+function NeotestEventProcessor:emit(event, ...)
+  logger.info("Emitting", event, "event")
+  for name, listener in pairs(self.listeners[event] or {}) do
+    logger.debug("Calling listener", name, "for event", event)
+    local success, err = pcall(listener, ...)
+    if not success then
+      logger.error("Error during listener", name, "for event:", err)
+    end
+  end
+end
+
+---@return NeotestEventProcessor
+function M.processor()
+  return NeotestEventProcessor:new()
+end
+
+return M