1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
#ifndef CLCODELITEREMOTEPROCESS_HPP
#define CLCODELITEREMOTEPROCESS_HPP
#include "asyncprocess.h"
#include "cl_command_event.h"
#include "codelite_exports.h"
#include "ssh_account_info.h"
#include <deque>
#include <functional>
#include <queue>
#include <vector>
#include <wx/arrstr.h>
#include <wx/event.h>
#include <wx/string.h>
class WXDLLIMPEXP_SDK clCodeLiteRemoteProcess : public wxEvtHandler
{
protected:
typedef void (clCodeLiteRemoteProcess::*CallbackFunc)(const wxString&, bool);
struct callback_pair {
CallbackFunc func = nullptr;
IProcess* handler = nullptr;
callback_pair(CallbackFunc func, IProcess* handler)
{
this->func = func;
this->handler = handler;
}
};
protected:
IProcess* m_process = nullptr;
std::deque<callback_pair> m_completionCallbacks;
wxString m_outputRead;
size_t m_fif_matches_count = 0;
size_t m_fif_files_scanned = 0;
bool m_going_down = false;
wxString m_context;
SSHAccountInfo m_account;
wxString m_scriptPath;
protected:
void OnProcessOutput(clProcessEvent& e);
void OnProcessTerminated(clProcessEvent& e);
void Cleanup();
void ProcessOutput();
bool GetNextBuffer(wxString& raw_input_buffer, wxString& output, bool& is_completed);
void ResetStates();
// prepare an event from list command output
void OnListFilesOutput(const wxString& output, bool is_completed);
void OnListLSPsOutput(const wxString& output, bool is_completed);
void OnFindOutput(const wxString& buffer, bool is_completed);
void OnLocateOutput(const wxString& buffer, bool is_completed);
void OnFindPathOutput(const wxString& buffer, bool is_completed);
void OnExecOutput(const wxString& buffer, bool is_completed);
bool DoExec(const wxString& cmd, const wxString& working_directory, const clEnvList_t& env,
IProcess* handler = nullptr);
template <typename Container> wxString GetCmdString(const Container& args) const
{
if(args.empty()) {
return wxEmptyString;
}
wxString cmdstr;
for(auto arg : args) {
if(arg.Contains(" ")) {
// escape any " before we start escaping
arg.Replace("\"", "\\\"");
// now wrap with double quotes
arg.Prepend("\"").Append("\"");
}
cmdstr << arg << " ";
}
cmdstr.RemoveLast();
return cmdstr;
}
public:
clCodeLiteRemoteProcess();
~clCodeLiteRemoteProcess();
/**
* @brief start the process using the same arguments used in the last call to StartInteractive. If the process is
* running, do nothing
*/
void StartIfNotRunning();
const wxString& GetContext() const { return m_context; }
/**
* @brief start remote process in an interactive mode
*/
void StartInteractive(const SSHAccountInfo& account, const wxString& scriptPath, const wxString& contextString);
/**
* @brief save as above, but with the account name
*/
void StartInteractive(const wxString& account, const wxString& scriptPath, const wxString& contextString);
void Stop();
bool IsRunning() const { return m_process != nullptr; }
// API
/**
* @brief find all files on a remote machine from a given directory that matches the extensions list
*/
void ListFiles(const wxString& root_dir, const wxString& extensions);
/**
* @brief list all configured LSPs on the remote machine
* the configuration is read from `codelite-remote.json` config file
*/
void ListLSPs();
/**
* @brief find in files on a remote machine
*/
void Search(const wxString& root_dir, const wxString& extensions, const wxString& find_what, bool whole_word,
bool icase);
/**
* @brief execute a command on the remote machine
*/
void Exec(const wxArrayString& args, const wxString& working_directory, const clEnvList_t& env);
/**
* @brief attempt to locate a file on the remote machine with possible version number
*/
void Locate(const wxString& path, const wxString& name, const wxString& ext, const std::vector<wxString>& = {});
/**
* @brief execute a command on the remote machine
*/
void Exec(const wxString& cmd, const wxString& working_directory, const clEnvList_t& env);
/**
* @brief find a path from. if path does not exist, check the parent folder
* going up until we hit the root path
*/
void FindPath(const wxString& path);
/**
* @brief call 'exec' and return an instance of IProcess. This method is for compatability with the
* CreateAsyncProcess family of functions
* @note it is up to the caller to delete the return process object
*/
IProcess* CreateAsyncProcess(wxEvtHandler* handler, const wxString& cmd, const wxString& working_directory,
const clEnvList_t& env);
/**
* @brief call 'exec' with callback
*/
void CreateAsyncProcessCB(const wxString& cmd, std::function<void(const wxString&)> callback,
const wxString& working_directory, const clEnvList_t& env);
/**
* @brief call 'exec' and return an instance of IProcess. This method is for compatability with the
* CreateAsyncProcess family of functions
* @note it is up to the caller to delete the return process object
*/
template <typename Container>
IProcess* CreateAsyncProcess(wxEvtHandler* handler, const Container& cmd, const wxString& working_directory,
const clEnvList_t& env)
{
wxString cmdstr = GetCmdString(cmd);
return CreateAsyncProcess(handler, cmdstr, working_directory, env);
}
/**
* @brief execute remote process `cmd` and wait for its output
*/
bool SyncExec(const wxString& cmd, const wxString& working_directory, const clEnvList_t& env, wxString* output);
/**
* @brief write string to the running process's stdin
*/
void Write(const wxString& str);
};
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_RESTARTED, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_LIST_FILES, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_LIST_FILES_DONE, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_FIND_RESULTS, clFindInFilesEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_FIND_RESULTS_DONE, clFindInFilesEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_EXEC_OUTPUT, clProcessEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_EXEC_DONE, clProcessEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_LOCATE, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_LOCATE_DONE, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_FINDPATH, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_FINDPATH_DONE, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_LIST_LSPS, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_SDK, wxEVT_CODELITE_REMOTE_LIST_LSPS_DONE, clCommandEvent);
#endif // CLCODELITEREMOTEPROCESS_HPP
|
