28#include <wx/clipbrd.h>
29#include <wx/dcclient.h>
31#include <wx/textctrl.h>
34#include "observable.h"
39#include <wx/msw/winundef.h>
47const wxString kUtfCheckMark = wxString::FromUTF8(u8
"\u2713");
48const wxString kUtfCircledDivisionSlash = wxString::FromUTF8(u8
"\u2298");
49const wxString kUtfFallingDiagonal = wxString::FromUTF8(u8
"\u269F");
50const wxString kUtfIdenticalTo = wxString::FromUTF8(u8
"\u2261");
51const wxString kUtfLeftArrow = wxString::FromUTF8(u8
"\u2190");
52const wxString kUtfLeftRightArrow = wxString::FromUTF8(u8
"\u2194");
53const wxString kUtfLeftwardsArrowToBar = wxString::FromUTF8(u8
"\u21E4");
54const wxString kUtfMultiplicationX = wxString::FromUTF8(u8
"\u2716");
55const wxString kUtfRightArrow = wxString::FromUTF8(u8
"\u2192");
58static bool IsFilterMatch(
const struct Logline& ll,
const std::string& s) {
59 if (ll.navmsg->source->iface.find(s) != std::string::npos)
return true;
60 return ll.message.find(s) != std::string::npos;
63static std::string Timestamp(
const NavmsgTimePoint& when) {
65 using namespace std::chrono;
67 auto now = when.time_since_epoch();
68 auto _hours = duration_cast<hours>(now);
70 auto _minutes = duration_cast<minutes>(now);
72 auto _seconds = duration_cast<seconds>(now);
74 auto ms = duration_cast<milliseconds>(now);
75#ifdef CSTDIO_TTYSCROLL_TIMESTAMP
78 snprintf(buf,
sizeof(buf),
"%02ld:%02ld:%02ld.%03ld", _hours.count() % 24,
79 _minutes.count(), _seconds.count(), ms.count());
83 ss << setw(2) << setfill(
'0') << _hours.count() % 24 <<
":" << setw(2)
84 << _minutes.count() <<
":" << setw(2) << _seconds.count() <<
"." << setw(3)
92 static const wxColor kDarkGreen(30, 72, 56);
93 if (ns.status != NavmsgStatus::State::kOk)
94 color = wxColour(
"RED");
95 else if (ns.accepted == NavmsgStatus::Accepted::kFilteredNoOutput)
96 color = wxColour(
"CORAL");
97 else if (ns.accepted == NavmsgStatus::Accepted::kFilteredDropped)
98 color = wxColour(
"MAROON");
99 else if (ns.direction == NavmsgStatus::Direction::kOutput)
100 color = wxColour(
"BLUE");
101 else if (ns.direction == NavmsgStatus::Direction::kInput)
102 color = wxColour(
"ORANGE");
111 if (!ll.message.empty()) ws << Timestamp(ll.navmsg->created_at) <<
" ";
112 if (ll.state.direction == NavmsgStatus::Direction::kOutput)
113 ws <<
" " << kUtfRightArrow <<
" ";
114 else if (ll.state.direction == NavmsgStatus::Direction::kInput)
115 ws <<
" " << kUtfLeftwardsArrowToBar <<
" ";
116 else if (ll.state.direction == NavmsgStatus::Direction::kInternal)
117 ws <<
" " << kUtfLeftRightArrow <<
" ";
119 ws <<
" " << kUtfLeftArrow <<
" ";
121 if (ll.state.status != NavmsgStatus::State::kOk)
122 ws << kUtfMultiplicationX;
123 else if (ll.state.accepted == NavmsgStatus::Accepted::kFilteredNoOutput)
124 ws << kUtfFallingDiagonal;
125 else if (ll.state.accepted == NavmsgStatus::Accepted::kFilteredDropped)
126 ws << kUtfCircledDivisionSlash;
130 std::stringstream error_msg;
131 if (ll.state.status != NavmsgStatus::State::kOk) {
133 << (ll.error_msg.empty() ?
"Unknown errror" : ll.error_msg);
135 std::string iface(ll.navmsg ? ll.navmsg->source->iface :
"");
136 if (iface.size() > 30)
137 iface = std::string(
"...") + iface.substr(iface.size() - 27);
140 dc.DrawText(ws, 0, y);
142 ws << ll.message << error_msg.str();
143 dc.DrawText(ws, data_pos, y);
145 std::max(m_text_width, GetTextExtent(ws).GetWidth() + data_pos);
149 : wxScrolledWindow(parent), m_n_lines(n_lines), m_is_paused(false) {
150 SetName(
"TtyScroll");
152 dc.GetTextExtent(
"Line Height", NULL, &m_line_height);
153 SetScrollRate(m_line_height, m_line_height);
154 for (
unsigned i = 0; i < m_n_lines; i++) m_lines.push_back(
Logline());
155 SetColors(std::make_unique<StdColorsByState>());
156 Bind(wxEVT_SIZE, [&](wxSizeEvent& ev) { OnSize(ev); });
159void TtyScroll::OnSize(wxSizeEvent& ev) {
160 m_n_lines = ev.GetSize().y / GetCharHeight();
161 while (m_lines.size() < m_n_lines) m_lines.push_back(
Logline());
166 if (m_is_paused || !m_filter.
Pass(ll.state, ll.navmsg))
return;
167 if (!m_quick_filter.empty() && !IsFilterMatch(ll, m_quick_filter))
return;
168 while (m_lines.size() > m_n_lines - 1) m_lines.pop_front();
169 m_lines.push_back(ll);
174 m_color_by_state = std::move(color_by_state);
177void TtyScroll::OnDraw(wxDC& dc) {
179 wxRect rect_update = GetUpdateRegion().GetBox();
180 CalcUnscrolledPosition(rect_update.x, rect_update.y, &rect_update.x,
182 size_t line_from = rect_update.y / m_line_height;
183 size_t line_to = rect_update.GetBottom() / m_line_height;
184 if (line_to > m_n_lines - 1) line_to = m_n_lines - 1;
186 wxCoord y = line_from * m_line_height;
188 for (
size_t line = line_from; line <= line_to; line++) {
190 dc.SetTextForeground((*m_color_by_state)(m_lines[line].state));
191 DrawLine(dc, m_lines[line], 40 * GetCharWidth(), y);
194 SetVirtualSize(m_text_width, (m_n_lines + 1) * m_line_height);
198 std::stringstream ss;
199 for (
auto& line : m_lines) ss << line.message <<
"\n";
200 if (wxTheClipboard->Open()) {
201 wxTheClipboard->SetData(
new wxTextDataObject(ss.str()));
202 wxTheClipboard->Close();
bool Pass(NavmsgStatus status, const std::shared_ptr< const NavMsg > &msg)
Return true if message is not matched by filter.
Representation of message status as determined by the multiplexer.