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
|
#ifndef CLSSHCHANNEL_H
#define CLSSHCHANNEL_H
#if USE_SFTP
#include "cl_ssh.h"
#include "codelite_exports.h"
#include <wx/msgqueue.h>
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_READ_ERROR, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_WRITE_ERROR, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_READ_OUTPUT, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_READ_STDERR, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_CLOSED, clCommandEvent);
wxDECLARE_EXPORTED_EVENT(WXDLLIMPEXP_CL, wxEVT_SSH_CHANNEL_PTY, clCommandEvent);
class clJoinableThread;
class WXDLLIMPEXP_CL clSSHChannel : public wxEvtHandler
{
public:
typedef wxSharedPtr<clSSHChannel> Ptr_t;
enum eChannelType {
kInterativeMode,
kRemoteCommand,
};
public:
struct Message {
wxString buffer;
bool raw = false;
};
protected:
clSSH::Ptr_t m_ssh;
SSHChannel_t m_channel = nullptr;
clJoinableThread* m_thread = nullptr;
wxMessageQueue<Message> m_Queue;
wxEvtHandler* m_owner = nullptr;
eChannelType m_type = kRemoteCommand;
bool m_wantStderr = false;
protected:
wxString BuildError(const wxString& prefix) const;
void DoWrite(const wxString& buffer, bool raw);
void OnReadError(clCommandEvent& event);
void OnWriteError(clCommandEvent& event);
void OnReadOutput(clCommandEvent& event);
void OnReadStderr(clCommandEvent& event);
void OnChannelClosed(clCommandEvent& event);
void OnChannelPty(clCommandEvent& event);
public:
clSSHChannel(clSSH::Ptr_t ssh, clSSHChannel::eChannelType type, wxEvtHandler* owner, bool wantStderrEvents = false);
virtual ~clSSHChannel();
/**
* @brief is the channel opened?
*/
bool IsOpen() const { return m_channel != nullptr; }
/**
* @brief Open the channel
* @throw clException
*/
void Open();
/**
* @brief close the channel
*/
void Close();
/**
* @brief execute remote command
* The reply will be returned to 'sink' object in form of events
*/
void Execute(const wxString& command);
/**
* @brief write message to the channel
*/
void Write(const wxString& message);
/**
* @brief write the buffer as is
*/
void WriteRaw(const wxString& message);
bool IsInteractive() const { return m_type == kInterativeMode; }
/**
* @brief Send a signal to remote process
*/
void SendSignal(wxSignal sig);
/**
* @brief detach from the remote process (this does not kill it)
*/
void Detach();
};
#endif
#endif // CLSSHCHANNEL_H
|