15#include <unordered_map>
17#include <nlohmann/json.hpp>
20#include <frozen/string.h>
21#include <frozen/unordered_map.h>
26#include "static/Message.h"
27#include "generated/ErrorCodes.h"
29#include "generated/CompletionList.h"
30#include "generated/CompletionParams.h"
32#include "../bpp_include/bpp_codegen.h"
36using json = nlohmann::json;
43template<
typename... Ts>
44void printValue(std::ostream& os,
const std::variant<Ts...>& v) {
45 std::visit([&os](
auto&& arg) { os << arg; }, v);
86 static const frozen::unordered_map<frozen::string, RequestHandler, 8>
request_handlers;
112 GenericResponseMessage
shutdown(
const GenericRequestMessage& request);
118 GenericResponseMessage
handleInitialize(
const GenericRequestMessage& request);
119 GenericResponseMessage
handleDefinition(
const GenericRequestMessage& request);
120 GenericResponseMessage
handleHover(
const GenericRequestMessage& request);
122 GenericResponseMessage
handleRename(
const GenericRequestMessage& request);
123 GenericResponseMessage
handleReferences(
const GenericRequestMessage& request);
124 GenericResponseMessage
handleCompletion(
const GenericRequestMessage& request);
130 void handleDidOpen(
const GenericNotificationMessage& request);
135 void sendResponse(
const GenericResponseMessage& response);
143 template <
typename... Args>
144 void log(Args&&... args) {
148 std::lock_guard<std::mutex> lock(
log_mutex);
Manages a pool of bpp_program objects for efficient reuse and access.
Definition ProgramPool.h:36
A thread pool implementation that manages a pool of worker threads to execute tasks concurrently.
Definition ThreadPool.h:23
The main server class for handling LSP requests and notifications.
Definition BashppServer.h:57
void publishDiagnostics(std::shared_ptr< bpp::bpp_program > program)
Definition BashppServer.cpp:327
GenericResponseMessage handleHover(const GenericRequestMessage &request)
Definition handleHover.cpp:10
static const frozen::unordered_map< frozen::string, NotificationHandler, 4 > notification_handlers
Maps notification types to the functions that handle them.
Definition BashppServer.h:26
void(BashppServer::*)(const GenericNotificationMessage &) NotificationHandler
Definition BashppServer.h:81
void processNotification(const GenericNotificationMessage ¬ification)
Definition BashppServer.cpp:273
void mainLoop()
Definition BashppServer.cpp:173
static std::mutex log_mutex
Definition BashppServer.h:78
GenericResponseMessage handleRename(const GenericRequestMessage &request)
Definition handleRename.cpp:10
pid_t pid
Definition BashppServer.h:59
void sendNotification(const GenericNotificationMessage ¬ification)
Definition BashppServer.cpp:243
void setSocketPath(const std::string &path)
Definition BashppServer.cpp:147
void processRequest(const GenericRequestMessage &request)
Definition BashppServer.cpp:249
GenericResponseMessage handleDocumentSymbol(const GenericRequestMessage &request)
Definition handleDocumentSymbol.cpp:9
ProgramPool program_pool
Definition BashppServer.h:65
std::unordered_map< std::string, std::string > unsaved_changes
Definition BashppServer.h:67
void handleDidClose(const GenericNotificationMessage &request)
Definition handledDidClose.cpp:9
GenericResponseMessage(BashppServer::*)(const GenericRequestMessage &) RequestHandler
Definition BashppServer.h:80
std::optional< std::string > socket_path
Definition BashppServer.h:63
void sendResponse(const GenericResponseMessage &response)
Definition BashppServer.cpp:237
ThreadPool thread_pool
Definition BashppServer.h:64
std::mutex debounce_mutex
Definition BashppServer.h:73
void setOutputStream(std::shared_ptr< std::ostream > stream)
Definition BashppServer.cpp:143
GenericResponseMessage shutdown(const GenericRequestMessage &request)
Definition BashppServer.cpp:319
GenericResponseMessage handleReferences(const GenericRequestMessage &request)
Definition handleReference.cpp:11
std::shared_ptr< std::istream > input_stream
Definition BashppServer.h:61
std::mutex unsaved_changes_mutex
Definition BashppServer.h:68
static void invalidNotificationHandler(const GenericNotificationMessage &request)
Definition BashppServer.cpp:227
std::shared_ptr< std::ostream > output_stream
Definition BashppServer.h:62
void handleDidChange(const GenericNotificationMessage &request)
Definition handleDidChange.cpp:9
void processMessage(const std::string &message)
Definition BashppServer.cpp:289
std::atomic< bool > stored_changes_content_updating
Definition BashppServer.h:69
void handleDidOpen(const GenericNotificationMessage &request)
Definition handleDidOpen.cpp:9
void log(Args &&... args)
Definition BashppServer.h:144
BashppServer()
Definition BashppServer.cpp:33
GenericResponseMessage handleInitialize(const GenericRequestMessage &request)
Definition handleInitialize.cpp:11
void setInputStream(std::shared_ptr< std::istream > stream)
Definition BashppServer.cpp:139
std::ofstream log_file
Definition BashppServer.h:66
GenericResponseMessage handleDefinition(const GenericRequestMessage &request)
Definition handleDefinition.cpp:10
CompletionList handleDOTCompletion(const CompletionParams ¶ms)
Definition handleCompletion.cpp:115
void setLogFile(const std::string &path)
Definition BashppServer.cpp:151
CompletionList handleATCompletion(const CompletionParams ¶ms)
Definition handleCompletion.cpp:66
void handleDidChangeWatchedFiles(const GenericNotificationMessage &request)
Definition handleDidChangeWatchedFiles.cpp:9
std::unordered_map< std::string, std::shared_ptr< std::atomic< uint64_t > > > debounce_timestamps
Definition BashppServer.h:72
void add_include_path(const std::string &path)
Definition BashppServer.cpp:373
static const GenericResponseMessage invalidRequestHandler(const GenericRequestMessage &request)
Definition BashppServer.cpp:223
void cleanup()
Definition BashppServer.cpp:158
CompletionList default_completion_list
Definition BashppServer.h:100
static std::mutex output_mutex
Definition BashppServer.h:77
void _sendMessage(const std::string &message)
Definition BashppServer.cpp:231
~BashppServer()
Definition BashppServer.cpp:137
GenericResponseMessage handleCompletion(const GenericRequestMessage &request)
Definition handleCompletion.cpp:10
static const frozen::unordered_map< frozen::string, RequestHandler, 8 > request_handlers
Maps request types to the functions that handle them.
Definition BashppServer.h:15
void set_suppress_warnings(bool suppress)
Definition BashppServer.cpp:377
Definition bash_case.cpp:8
void printValue(std::ostream &os, const T &value)
Definition BashppServer.h:39
nlohmann::json json
Definition BashppServer.h:36