Add sessions

Author: hkupty

API.md

@@ -22,6 +22,15 @@ Dissociates the connection for the given path
 pwd **(string)**: path (usually project root).
 
 
+## `acid.connections.peek([pwd])`
+Return active connection for the given path
+
+*pwd* **(string)**: path (usually project root).
+
+
+**({string,string})** Connection tuple with ip and port or nil.
+
+
 ## `acid.connections.get(pwd)`
 Return active connection for the given path
 

lua/acid/connections.lua

@@ -63,6 +63,14 @@ connections.unselect = function(pwd)
   connections.current[pwd] = nil
 end
 
+--- Return active connection for the given path
+-- @tparam[opt] string pwd path (usually project root).
+-- @treturn {string,string} Connection tuple with ip and port or nil.
+connections.peek = function(pwd)
+  pwd = pwd_to_key(pwd or vim.api.nvim_call_function("getcwd", {}))
+  return connections.current[pwd]
+end
+
 --- Return active connection for the given path
 -- @tparam string pwd path (usually project root).
 -- @treturn {string,string} Connection tuple with ip and port or nil.

lua/acid/init.lua

@@ -6,6 +6,7 @@
 local core = require("acid.core")
 local connections = require("acid.connections")
 local utils = require("acid.utils")
+local sessions = require("acid.sessions")
 
 local acid = {}
 
@@ -27,7 +28,8 @@ end
 -- @param cmd A command (op + payload + handler) to be executed.
 -- @param conn A connection where this command will be run.
 acid.run = function(cmd, conn)
-  return core.send(conn, cmd:build())
+  local filtered = cmd:update_payload(sessions.filter)
+  return core.send(conn, filtered:build())
 end
 
 

plugin/acid.vim

@@ -90,6 +90,7 @@ augroup acid
   autocmd!
   autocmd BufWritePost *.clj call s:require()
 
+  autocmd User AcidConnected lua require("acid.sessions").new_session()
   autocmd User AcidConnected lua require("acid.features").preload()
   autocmd User AcidConnected lua require("acid.features").load_all_nss()