aboutsummaryrefslogtreecommitdiff
path: root/ttwhy/scanner.cppm
blob: 86a8493cfcda82e3794afce2628b4f56ad1381fd (plain)
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
module;

#include <algorithm>
#include <boost/sml.hpp>

#include <cctype>
#include <span>
#include <vector>

export module ttwhy:scanner;

import :event;

namespace ttwhy::detail
{

  /// Events

  struct byte_received
  {
    char value;
  };

  /// States

  auto const idle = boost::sml::state<class idle>;
  auto const escape_sequence = boost::sml::state<class escape_sequence>;
  auto const csi_sequence = boost::sml::state<class csi_sequence>;

  /// Actions

  auto push_character = [](byte_received const & event, std::vector<input_event> & queue) {
    queue.push_back(character_event{event.value});
  };

  auto push_backspace = [](std::vector<input_event> & queue) {
    queue.push_back(control_event{control_key::backspace});
  };

  auto push_delete = [](std::vector<input_event> & queue) {
    queue.push_back(navigation_event{navigation_key::delete_key});
  };

  auto fallback_escape = [](byte_received const & event, std::vector<input_event> & queue) {
    queue.push_back(control_event{control_key::escape});
    if (event.value >= 0x20 && event.value <= 0x7e)
    {
      queue.push_back(character_event{event.value});
    }
  };

  /// Guards

  auto is_backspace = [](byte_received e) {
    return e.value == '\x08' || e.value == '\x7f';
  };

  auto is_escape = [](byte_received e) {
    return e.value == '\x1b';
  };

  auto is_printable = [](byte_received e) {
    return e.value >= 0x20 && e.value <= 0x7e;
  };

  auto is_csi_introducer = [](byte_received e) {
    return e.value == '[';
  };

  auto is_csi_param = [](byte_received e) {
    return e.value >= 0x20 && e.value <= 0x3f;
  };

  auto is_csi_terminator = [](byte_received e) {
    return e.value >= 0x40 && e.value <= 0x7e;
  };

  auto is_tilde = [](byte_received e) {
    return e.value == '~';
  };

  /// Transitions

  struct transition_table
  {
    auto operator()() const noexcept
    {
      using namespace boost::sml;

      // clang-format off
      return make_transition_table(
          *idle +            event<byte_received>[is_escape]                            = escape_sequence,
           idle +            event<byte_received>[is_backspace]       / push_backspace  = idle,
           idle +            event<byte_received>[is_printable]       / push_character  = idle,

           escape_sequence + event<byte_received>[is_csi_introducer]                    = csi_sequence,
           escape_sequence + event<byte_received>[!is_csi_introducer] / fallback_escape = idle,

           csi_sequence +    event<byte_received>[is_csi_param]                         = csi_sequence,
           csi_sequence +    event<byte_received>[is_tilde]           / push_delete     = idle,
           csi_sequence +    event<byte_received>[is_csi_terminator]                    = idle
      );
      // clang-format on
    }
  };

}  // namespace ttwhy::detail

export namespace ttwhy
{

  struct ansi_scanner
  {
    explicit ansi_scanner(std::vector<input_event> & queue)
        : m_state_machine{queue}
    {}

    auto process(std::span<char const> buffer) -> void
    {
      std::ranges::for_each(buffer, [&](auto byte) { m_state_machine.process_event(detail::byte_received{byte}); });
    }

  private:
    boost::sml::sm<detail::transition_table> m_state_machine;
  };

}  // namespace ttwhy