Projects : yrc : yrc_input_history
| 1 | Record types |
| 2 | ============ |
| 3 | |
| 4 | conn |
| 5 | - network: file-safe str |
| 6 | - sock: socket |
| 7 | - rdbuf: str |
| 8 | - wrbuf: str |
| 9 | - addrs: non-empty list of (host: str, port: int) (first entry is current) |
| 10 | - nick: str |
| 11 | - password: str | None |
| 12 | - registered: bool |
| 13 | - channels: dict of (channel: casemapped str) => (set of nick: casemapped str) |
| 14 | - casemapper: function of (str -> casemapped str) |
| 15 | - reconn_delay: int |
| 16 | - count: int (number of times connected) |
| 17 | - ping_ts: float (monotonic time of last sent ping) |
| 18 | - pong_ts: float (monotonic time of last received pong) |
| 19 | |
| 20 | buf |
| 21 | - name: str |
| 22 | - parent: buf |
| 23 | - title: str |
| 24 | - vscroll: (origin: int, offset: int) |
| 25 | - lines: list of str |
| 26 | - num_read: int |
| 27 | - at_end: bool |
| 28 | |
| 29 | buflist (singleton) |
| 30 | - vscroll: int |
| 31 | - width: int |
| 32 | - selection: buf |
| 33 | - cursor: buf |
| 34 | - last: buf |
| 35 | |
| 36 | prompt (singleton) |
| 37 | - chars: list of str |
| 38 | - cursor: int |
| 39 | - hscroll: int |
| 40 | |
| 41 | flags (singleton) |
| 42 | - refresh |
| 43 | - redraw |
| 44 | - buflist_draw |
| 45 | - buf_draw |
| 46 | - prompt_draw |
| 47 | - status_draw |
| 48 | - quit |
| 49 | - buflist |
| 50 | - prompt |
| 51 | - ping_draw |
| 52 | |
| 53 | ring |
| 54 | - start: int |
| 55 | - list: list |
| 56 | |
| 57 | Enumerations |
| 58 | ============ |
| 59 | |
| 60 | kbd_state: ks_start ks_cx ks_esc ks_cseq ks_cs_intermed |
| 61 | |
| 62 | Variant types |
| 63 | ============= |
| 64 | |
| 65 | message: (args all str unless noted) |
| 66 | - m_privmsg(sender, msg) |
| 67 | - m_notice(sender, msg) |
| 68 | - m_join(sender, chan) |
| 69 | - m_part(sender, chan, msg) |
| 70 | - m_quit(sender, msg) |
| 71 | - m_nick(sender, nick) |
| 72 | - m_kick(sender, chan, name, msg) |
| 73 | - m_kicked(sender, chan, msg) |
| 74 | - m_topic(sender, topic: str | None) |
| 75 | - m_chantopic(sender, chan, topic: str | None) |
| 76 | - m_mode(sender, modes) |
| 77 | - m_chanmode(sender, chan, modes) |
| 78 | - m_names(sender, chan, names) |
| 79 | - m_endnames(sender, chan) |
| 80 | - m_error(sender, msg) |
| 81 | - m_client(msg) |
| 82 | - m_server(sender, msg) |
| 83 | |
| 84 | Quasiconstants |
| 85 | ============== |
| 86 | |
| 87 | self_pipe_rd: int |
| 88 | self_pipe_wr: int |
| 89 | commands: (name: str) => function |
| 90 | |
| 91 | Global state |
| 92 | ============ |
| 93 | |
| 94 | cur_buf: buf |
| 95 | scr_height: int |
| 96 | scr_width: int |
| 97 | mono_last: float |
| 98 | mono_offset: float |
| 99 | out_buf: bytearray |
| 100 | kbd_accum: bytearray |
| 101 | kbd_state: function |
| 102 | history_pos: int | None |
| 103 | history_stash: str | None |
| 104 | |
| 105 | Collections |
| 106 | =========== |
| 107 | |
| 108 | buffers: non-empty list of buf |
| 109 | buffer_index: (name: str, parent_name: str) => buf |
| 110 | opening_conns: (fileno: int) => conn |
| 111 | open_conns: (fileno: int) => conn |
| 112 | network_conns: (network: str) => conn : all enabled networks, whether TCP alive or not |
| 113 | schedule: min-heap of (time: float) => thunk |
| 114 | history_ring: ring of str |
| 115 | |
| 116 | Functions |
| 117 | ========= |
| 118 | |
| 119 | Excluding record constructors, accessors and basic mutators. |
| 120 | |
| 121 | Startup only: |
| 122 | command(name: str, min_args=0: int, max_args=None: int | None, extended_arg=False: bool)(function) -> function |
| 123 | check_command_dicts(keymap) |
| 124 | make_casemapper(int) -> function of (str -> casemapped str) |
| 125 | |
| 126 | Boring: |
| 127 | set_nonblock |
| 128 | |
| 129 | Pure functions: |
| 130 | format_time(time_tuple) -> str |
| 131 | is_ctrl(chr) -> bool |
| 132 | ctrl(chr) -> chr |
| 133 | is_meta(chr) -> bool |
| 134 | meta(chr) -> chr |
| 135 | variant_name(val) -> str |
| 136 | variant_args(val) -> list |
| 137 | matcher(vtype, cases: iterable of (constructor, receiver: function of (*args -> x))) -> function of (val: vtype -> x) |
| 138 | sequence(*thunks) -> thunk |
| 139 | char_range(pair) -> str |
| 140 | partition(list, pred) -> (left: list, right: list) |
| 141 | split_pair(str, sep=' ': str) -> [str, str] |
| 142 | make_encoder(function of chr -> str) -> function of (str -> str) |
| 143 | asciify(str) -> str |
| 144 | fs_encode(str) -> str |
| 145 | casemap_ascii(str) -> str |
| 146 | clip(min: comparable, max: comparable, comparable) -> comparable |
| 147 | clip_to(list, int) -> int |
| 148 | get_clipped(list, int) -> element of list |
| 149 | clip_str(str, width: int) -> str |
| 150 | pad_or_clip_str(str, width: int, pad=' ': chr) -> str |
| 151 | wrap(line, width, indent=0) -> list of str |
| 152 | is_digit(chr) -> bool |
| 153 | parse_address(addr) -> (host: str, port: int) / ValueError |
| 154 | format_address((host: str, port: int)) -> str |
| 155 | int_of_bytes(str) -> int |
| 156 | bit_length(int) -> int |
| 157 | heap_peek(heap: list) -> (key, value) / IndexError |
| 158 | safe_filename(name) -> bool |
| 159 | config_lines(text) -> non-empty list of non-empty str | None |
| 160 | format_buf_msg(val: message) -> str |
| 161 | buf_width() -> int |
| 162 | buf_height() -> int |
| 163 | render_line(str) -> list of str |
| 164 | buf_max_vscroll(buf) -> (int, int) |
| 165 | add_scroll_coords(lines: list of str, coords: (int, int), delta: int) -> (int, int) |
| 166 | sub_scroll_coords(lines: list of str, coords: (int, int), delta: int) -> (int, int) |
| 167 | render_lines(lines: list of str, vscroll: (int, int), row_limit: int) -> (list, int) |
| 168 | build_msg(prefix, cmd, params) -> str |
| 169 | max_param_len(cmd, prefix=None) -> int |
| 170 | parse_msg(msg) -> (prefix: str | None, cmd: str, params: list of str) / ProtocolError |
| 171 | is_chan(str) -> bool |
| 172 | valid_chan(str) -> bool |
| 173 | valid_nick(str) -> bool |
| 174 | valid_password(str) -> bool |
| 175 | conn_nick_lc(conn) -> casemapped str |
| 176 | sender_nick(str) -> str |
| 177 | arg2 |
| 178 | arg3 |
| 179 | empty2 |
| 180 | lterr / TypeError |
| 181 | format_log_msg(val: message except (m_chantopic | m_mode | m_client)) -> str |
| 182 | ring_index(ring, int) -> int |
| 183 | ring_get(ring of t, int) -> t | None |
| 184 | |
| 185 | Pure I/O: |
| 186 | write_all(blocking fd, str|bytearray) / EnvironmentError |
| 187 | read_all(nonblocking fd) -> str / EOFError, EnvironmentError : may return empty |
| 188 | |
| 189 | Pure drawing: |
| 190 | buf_draw(buf) |
| 191 | prompt_draw |
| 192 | draw_status(y: int) |
| 193 | buflist_draw |
| 194 | buflist_vline_draw |
| 195 | place_cursor |
| 196 | refresh_if_needed |
| 197 | |
| 198 | "Queries": |
| 199 | find_buf(buf) -> int : find buf's index in buffers list |
| 200 | #buf_network(buf) -> str |
| 201 | buf_conn(buf) -> conn / CommandError |
| 202 | buf_registered_conn(buf) -> conn / CommandError |
| 203 | get_config(key, paths=(()), default=None) -> str | default |
| 204 | |
| 205 | Side effects on data: |
| 206 | write_out(str) : stores for write to terminal |
| 207 | flush_out : sends full terminal output buffer |
| 208 | variant(vtype, name: str, nargs: int) -> constructor: function of (*args -> (tag, args)) |
| 209 | rand_int(int) -> int |
| 210 | heap_insert(heap: list, key: comparable, value) |
| 211 | heap_extract(heap: list) -> (key, value) / IndexError |
| 212 | run_command(line: str) -> * / CommandError |
| 213 | buf_log_msg(buf, m: message) |
| 214 | buf_privmsg(buf, msg: str) : buf_parent ; buf_registered_conn ; conn_privmsg / CommandError |
| 215 | check_buf_at_end : buf_set_at_end(cur_buf) | buf_clr_at_end(cur_buf) |
| 216 | is_child_of(buf) -> function of (buf -> bool) |
| 217 | sort_buffers : sorts buffers & generates buffer_index |
| 218 | get_buf(name, parent_name) -> buf : buffer_index lookup but creates if not found |
| 219 | close_buf(buf) |
| 220 | prompt_insert(chr) |
| 221 | prompt_submit |
| 222 | prompt_end |
| 223 | history_prev |
| 224 | history_next |
| 225 | prompt_backspace |
| 226 | prompt_delete |
| 227 | info(msg: str, buf=None) : buf_log_msg to buf or buffers[0] |
| 228 | error(msg_or_exc: str | Exception, buf=None) : buf_log_msg to buf or buffers[0] |
| 229 | kaccum(str) |
| 230 | kaccept(str) |
| 231 | ktrans(kbd_state) |
| 232 | ks_start(chr) |
| 233 | ks_cx(chr) |
| 234 | ks_esc(chr) |
| 235 | ks_cseq(chr) |
| 236 | ks_cs_intermed(chr) |
| 237 | conn_run_in(conn, seconds: float, method: function of (conn), run_if_down=False) : run_in |
| 238 | conn_log_msg(conn, venue: casemapped str | None, m: message) : get_buf ; buf_log_msg ; file_log_msg |
| 239 | conn_info(conn, str) : uses conn_log_msg |
| 240 | conn_error(conn, str) : uses conn_log_msg |
| 241 | conn_start(conn) : starts connecting; bumps count; rotates addrs; adds to opening_conns and network_conns |
| 242 | conn_write(conn, str) : stores for nonblocking write by main loop |
| 243 | conn_send(conn, cmd: str, params: list of str, prefix=None: str) : build_msg ;conn_write (TODO check msg well-formedness) |
| 244 | conn_handle_connected(conn) : if successful, moves c from opening_conns to open_conns & sends login |
| 245 | conn_close(conn) : shuts down and removes from open_conns |
| 246 | conn_handle_data(conn, data: str) : does input buffering; extracts messages and calls... |
| 247 | conn_handle_msg(conn, msg: str) : mega-function for handling IRC commands |
| 248 | conn_join(conn, chan: str, key=None) : conn_info ; conn_send |
| 249 | conn_privmsg(conn, target: str, msg: str) : conn_log_msg ; conn_send |
| 250 | conn_ping(conn) |
| 251 | conn_timeout(conn) |
| 252 | conn_reg_timeout(conn) |
| 253 | file_log_msg(network: file-safe str, venue: casemapped str | None, m: message) |
| 254 | handle_resize |
| 255 | mono_time -> float |
| 256 | run_in(seconds, thunk) |
| 257 | ring_set(ring of t, int, t) |
| 258 | ring_rotate(ring, int) |
| 259 | ring_append(ring of t, t) |
| 260 | |
| 261 | Slash commands: |
| 262 | quit_cmd |
| 263 | connect_cmd |
| 264 | disconnect_cmd |
| 265 | join_cmd |
| 266 | kick_cmd |
| 267 | mode_cmd |
| 268 | nick_cmd |
| 269 | part_cmd |
| 270 | send_cmd |
| 271 | |
| 272 | Lifecycle: |
| 273 | main |
| 274 | crash_handler |
| 275 | |
| 276 | MVP: |
| 277 | finish commands |
| 278 | close/close-net debug |
| 279 | prefix case sensitivity in conn_handle_msg? |
| 280 | |
| 281 | TODO: |
| 282 | nick fallback |
| 283 | buflist vscroll |
| 284 | modes |
| 285 | date changes |
| 286 | prompt history, kill ring |
| 287 | tab completion (but how to focus buf/prompt?) |
| 288 | username, realname |
| 289 | logging |
| 290 | bold nicks (generally: formatted wrap) |
| 291 | search in scrollback |
| 292 | channel key (config, persist across reconnect) |
| 293 | buffer cleanup by category |
| 294 | help |
| 295 | scripting |
| 296 | self-ping to find user@host to calc max privmsg length |
| 297 | Proliferation of casemapping is bound to be buggy. |
| 298 | Recognize WHOIS/WHOWAS/LIST responses |
| 299 | bracketed paste |
| 300 | |
| 301 | Possible cleanups: |
| 302 | more use of lambda/sequence for trivial functions |
| 303 | rename buf* to wind* to match manual's terminology (nobody but emacs uses "buffer" to mean "window"...) |
| 304 | move cur_buf global to a buflist attribute |
| 305 | use the new scheduler for schedule_*; use delayed redraw to perform well under message floods |