]>
Commit | Line | Data |
---|---|---|
1 | /* Cycript - The Truly Universal Scripting Language | |
2 | * Copyright (C) 2009-2016 Jay Freeman (saurik) | |
3 | */ | |
4 | ||
5 | /* GNU Affero General Public License, Version 3 {{{ */ | |
6 | /* | |
7 | * This program is free software: you can redistribute it and/or modify | |
8 | * it under the terms of the GNU Affero General Public License as published by | |
9 | * the Free Software Foundation, either version 3 of the License, or | |
10 | * (at your option) any later version. | |
11 | ||
12 | * This program is distributed in the hope that it will be useful, | |
13 | * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
14 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
15 | * GNU Affero General Public License for more details. | |
16 | ||
17 | * You should have received a copy of the GNU Affero General Public License | |
18 | * along with this program. If not, see <http://www.gnu.org/licenses/>. | |
19 | **/ | |
20 | /* }}} */ | |
21 | ||
22 | #include "cycript.hpp" | |
23 | ||
24 | #ifdef CY_EXECUTE | |
25 | #include "JavaScript.hpp" | |
26 | #endif | |
27 | ||
28 | #include <cstdio> | |
29 | #include <complex> | |
30 | #include <fstream> | |
31 | #include <sstream> | |
32 | ||
33 | #ifdef HAVE_READLINE_H | |
34 | #include <readline.h> | |
35 | #else | |
36 | #include <readline/readline.h> | |
37 | #endif | |
38 | ||
39 | #ifdef HAVE_HISTORY_H | |
40 | #include <history.h> | |
41 | #else | |
42 | #include <readline/history.h> | |
43 | #endif | |
44 | ||
45 | #include <errno.h> | |
46 | #include <getopt.h> | |
47 | #include <setjmp.h> | |
48 | #include <signal.h> | |
49 | #include <unistd.h> | |
50 | ||
51 | #include <sys/socket.h> | |
52 | #include <sys/types.h> | |
53 | #include <sys/stat.h> | |
54 | #include <fcntl.h> | |
55 | #include <netdb.h> | |
56 | ||
57 | #include <sys/ioctl.h> | |
58 | #include <sys/types.h> | |
59 | #include <sys/socket.h> | |
60 | #include <netinet/in.h> | |
61 | #include <sys/un.h> | |
62 | ||
63 | #include <dlfcn.h> | |
64 | #include <pwd.h> | |
65 | #include <term.h> | |
66 | ||
67 | #ifdef __APPLE__ | |
68 | #include <mach/mach_time.h> | |
69 | #endif | |
70 | ||
71 | #include "Code.hpp" | |
72 | #include "Driver.hpp" | |
73 | #include "Error.hpp" | |
74 | #include "Highlight.hpp" | |
75 | #include "Syntax.hpp" | |
76 | ||
77 | extern "C" int rl_display_fixed; | |
78 | extern "C" int _rl_vis_botlin; | |
79 | extern "C" int _rl_last_c_pos; | |
80 | extern "C" int _rl_last_v_pos; | |
81 | ||
82 | typedef std::complex<int> CYCursor; | |
83 | ||
84 | static CYCursor current_; | |
85 | static int width_; | |
86 | static size_t point_; | |
87 | ||
88 | unsigned CYDisplayWidth() { | |
89 | struct winsize info; | |
90 | if (ioctl(1, TIOCGWINSZ, &info) != -1) | |
91 | return info.ws_col; | |
92 | return tgetnum(const_cast<char *>("co")); | |
93 | } | |
94 | ||
95 | void CYDisplayOutput_(bool display, const char *&data) { | |
96 | for (;; ++data) { | |
97 | char next(*data); | |
98 | if (next == '\0' || next == CYIgnoreEnd) | |
99 | return; | |
100 | if (display) | |
101 | putchar(next); | |
102 | } | |
103 | } | |
104 | ||
105 | CYCursor CYDisplayOutput(bool display, int width, const char *data, ssize_t offset = 0) { | |
106 | CYCursor point(current_); | |
107 | ||
108 | for (;;) { | |
109 | if (offset-- == 0) | |
110 | point = current_; | |
111 | switch (char next = *data++) { | |
112 | case '\0': | |
113 | return point; | |
114 | break; | |
115 | ||
116 | case CYIgnoreStart: | |
117 | CYDisplayOutput_(display, data); | |
118 | case CYIgnoreEnd: | |
119 | ++offset; | |
120 | break; | |
121 | ||
122 | default: | |
123 | if (display) | |
124 | putchar(next); | |
125 | current_ += CYCursor(0, 1); | |
126 | if (current_.imag() != width) | |
127 | break; | |
128 | current_ = CYCursor(current_.real() + 1, 0); | |
129 | if (display) | |
130 | putp(clr_eos); | |
131 | break; | |
132 | ||
133 | case '\n': | |
134 | current_ = CYCursor(current_.real() + 1, 4); | |
135 | if (display) { | |
136 | putp(clr_eol); | |
137 | putchar('\n'); | |
138 | putchar(' '); | |
139 | putchar(' '); | |
140 | putchar(' '); | |
141 | putchar(' '); | |
142 | } | |
143 | break; | |
144 | ||
145 | } | |
146 | } | |
147 | } | |
148 | ||
149 | void CYDisplayMove_(char *negative, char *positive, int offset) { | |
150 | if (offset < 0) | |
151 | putp(tparm(negative, -offset)); | |
152 | else if (offset > 0) | |
153 | putp(tparm(positive, offset)); | |
154 | } | |
155 | ||
156 | void CYDisplayMove(CYCursor target) { | |
157 | CYCursor offset(target - current_); | |
158 | ||
159 | CYDisplayMove_(parm_up_cursor, parm_down_cursor, offset.real()); | |
160 | ||
161 | if (char *parm = tparm(column_address, target.imag())) | |
162 | putp(parm); | |
163 | else | |
164 | CYDisplayMove_(parm_left_cursor, parm_right_cursor, offset.imag()); | |
165 | ||
166 | current_ = target; | |
167 | } | |
168 | ||
169 | void CYDisplayUpdate() { | |
170 | current_ = CYCursor(_rl_last_v_pos, _rl_last_c_pos); | |
171 | ||
172 | const char *prompt(rl_display_prompt); | |
173 | ||
174 | std::ostringstream stream; | |
175 | CYLexerHighlight(rl_line_buffer, rl_end, stream, true); | |
176 | std::string string(stream.str()); | |
177 | const char *buffer(string.c_str()); | |
178 | ||
179 | int width(CYDisplayWidth()); | |
180 | if (width_ != width) { | |
181 | current_ = CYCursor(); | |
182 | CYDisplayOutput(false, width, prompt); | |
183 | current_ = CYDisplayOutput(false, width, buffer, point_); | |
184 | } | |
185 | ||
186 | CYDisplayMove(CYCursor()); | |
187 | CYDisplayOutput(true, width, prompt); | |
188 | CYCursor target(CYDisplayOutput(true, width, stream.str().c_str(), rl_point)); | |
189 | ||
190 | _rl_vis_botlin = current_.real(); | |
191 | ||
192 | if (current_.imag() == 0) | |
193 | CYDisplayOutput(true, width, " "); | |
194 | putp(clr_eos); | |
195 | ||
196 | CYDisplayMove(target); | |
197 | fflush(stdout); | |
198 | ||
199 | _rl_last_v_pos = current_.real(); | |
200 | _rl_last_c_pos = current_.imag(); | |
201 | ||
202 | width_ = width; | |
203 | point_ = rl_point; | |
204 | } | |
205 | ||
206 | static volatile enum { | |
207 | Working, | |
208 | Parsing, | |
209 | Running, | |
210 | Sending, | |
211 | Waiting, | |
212 | } mode_; | |
213 | ||
214 | static jmp_buf ctrlc_; | |
215 | ||
216 | static void sigint(int) { | |
217 | switch (mode_) { | |
218 | case Working: | |
219 | return; | |
220 | case Parsing: | |
221 | longjmp(ctrlc_, 1); | |
222 | case Running: | |
223 | #ifndef __ANDROID__ | |
224 | CYCancel(); | |
225 | #endif | |
226 | return; | |
227 | case Sending: | |
228 | return; | |
229 | case Waiting: | |
230 | return; | |
231 | } | |
232 | } | |
233 | ||
234 | static bool bison_; | |
235 | static bool timing_; | |
236 | static bool strict_; | |
237 | static bool pretty_; | |
238 | ||
239 | void Setup(CYDriver &driver) { | |
240 | if (bison_) | |
241 | driver.debug_ = 1; | |
242 | if (strict_) | |
243 | driver.strict_ = true; | |
244 | } | |
245 | ||
246 | void Setup(CYOutput &out, CYDriver &driver, CYOptions &options, bool lower) { | |
247 | out.pretty_ = pretty_; | |
248 | if (lower) | |
249 | driver.Replace(options); | |
250 | } | |
251 | ||
252 | class CYRemote { | |
253 | public: | |
254 | virtual CYUTF8String Run(CYPool &pool, CYUTF8String code) = 0; | |
255 | ||
256 | inline CYUTF8String Run(CYPool &pool, const std::string &code) { | |
257 | return Run(pool, CYUTF8String(code.c_str(), code.size())); | |
258 | } | |
259 | }; | |
260 | ||
261 | class CYLocalRemote : | |
262 | public CYRemote | |
263 | { | |
264 | public: | |
265 | virtual CYUTF8String Run(CYPool &pool, CYUTF8String code) { | |
266 | const char *json; | |
267 | uint32_t size; | |
268 | ||
269 | mode_ = Running; | |
270 | #ifdef CY_EXECUTE | |
271 | json = CYExecute(CYGetJSContext(), pool, code); | |
272 | #else | |
273 | json = NULL; | |
274 | #endif | |
275 | mode_ = Working; | |
276 | if (json == NULL) | |
277 | size = 0; | |
278 | else | |
279 | size = strlen(json); | |
280 | ||
281 | return CYUTF8String(json, size); | |
282 | } | |
283 | }; | |
284 | ||
285 | class CYSocketRemote : | |
286 | public CYRemote | |
287 | { | |
288 | private: | |
289 | int socket_; | |
290 | ||
291 | public: | |
292 | CYSocketRemote(const char *host, const char *port) { | |
293 | struct addrinfo hints; | |
294 | memset(&hints, 0, sizeof(hints)); | |
295 | hints.ai_family = AF_UNSPEC; | |
296 | hints.ai_socktype = SOCK_STREAM; | |
297 | hints.ai_protocol = 0; | |
298 | hints.ai_flags = 0; | |
299 | ||
300 | struct addrinfo *infos; | |
301 | _syscall(getaddrinfo(host, port, &hints, &infos)); | |
302 | ||
303 | _assert(infos != NULL); try { | |
304 | for (struct addrinfo *info(infos); info != NULL; info = info->ai_next) { | |
305 | socket_ = _syscall(socket(info->ai_family, info->ai_socktype, info->ai_protocol)); try { | |
306 | _syscall(connect(socket_, info->ai_addr, info->ai_addrlen)); | |
307 | break; | |
308 | } catch (...) { | |
309 | _syscall(close(socket_)); | |
310 | throw; | |
311 | } | |
312 | } | |
313 | } catch (...) { | |
314 | freeaddrinfo(infos); | |
315 | throw; | |
316 | } | |
317 | } | |
318 | ||
319 | virtual CYUTF8String Run(CYPool &pool, CYUTF8String code) { | |
320 | const char *json; | |
321 | uint32_t size; | |
322 | ||
323 | mode_ = Sending; | |
324 | size = code.size; | |
325 | _assert(CYSendAll(socket_, &size, sizeof(size))); | |
326 | _assert(CYSendAll(socket_, code.data, code.size)); | |
327 | mode_ = Waiting; | |
328 | _assert(CYRecvAll(socket_, &size, sizeof(size))); | |
329 | if (size == _not(uint32_t)) { | |
330 | size = 0; | |
331 | json = NULL; | |
332 | } else { | |
333 | char *temp(new(pool) char[size + 1]); | |
334 | _assert(CYRecvAll(socket_, temp, size)); | |
335 | temp[size] = '\0'; | |
336 | json = temp; | |
337 | } | |
338 | mode_ = Working; | |
339 | ||
340 | return CYUTF8String(json, size); | |
341 | } | |
342 | }; | |
343 | ||
344 | void InjectLibrary(pid_t, std::ostream &stream, int, const char *const []); | |
345 | ||
346 | class CYInjectRemote : | |
347 | public CYRemote | |
348 | { | |
349 | private: | |
350 | int pid_; | |
351 | ||
352 | public: | |
353 | CYInjectRemote(int pid) : | |
354 | pid_(pid) | |
355 | { | |
356 | // XXX: wait | |
357 | } | |
358 | ||
359 | virtual CYUTF8String Run(CYPool &pool, CYUTF8String code) { | |
360 | std::ostringstream stream; | |
361 | const char *args[2] = {"-e", code.data}; | |
362 | InjectLibrary(pid_, stream, 2, args); | |
363 | std::string json(stream.str()); | |
364 | if (!json.empty() && json[json.size() - 1] == '\n') | |
365 | json.resize(json.size() - 1); | |
366 | return CYUTF8String(strdup(json.c_str()), json.size()); | |
367 | } | |
368 | }; | |
369 | ||
370 | static std::ostream *out_; | |
371 | ||
372 | static void Output(CYUTF8String json, std::ostream *out, bool reparse = false) { | |
373 | CYPool pool; | |
374 | ||
375 | if (reparse) do { | |
376 | CYStream stream(json.data, json.data + json.size); | |
377 | CYDriver driver(pool, stream); | |
378 | if (driver.Parse(CYMarkExpression)) | |
379 | break; | |
380 | std::stringbuf str; | |
381 | CYOptions options; | |
382 | CYOutput out(str, options); | |
383 | out.pretty_ = true; | |
384 | out << *driver.context_; | |
385 | std::string data(str.str()); | |
386 | json = CYPoolUTF8String(pool, data); | |
387 | if (json.size == 0) | |
388 | json.data = NULL; | |
389 | } while (false); | |
390 | ||
391 | const char *data(json.data); | |
392 | size_t size(json.size); | |
393 | ||
394 | if (size == 0 || out == NULL) | |
395 | return; | |
396 | ||
397 | CYLexerHighlight(data, size, *out); | |
398 | *out << std::endl; | |
399 | } | |
400 | ||
401 | int (*append_history$)(int, const char *); | |
402 | ||
403 | static std::string command_; | |
404 | ||
405 | static CYRemote *remote_; | |
406 | ||
407 | static CYUTF8String Run(CYPool &pool, const std::string &code) { | |
408 | return remote_->Run(pool, code); | |
409 | } | |
410 | ||
411 | static char **Complete(const char *word, int start, int end) { | |
412 | rl_attempted_completion_over = ~0; | |
413 | std::string line(rl_line_buffer, start); | |
414 | char **values(CYComplete(word, command_ + line, &Run)); | |
415 | mode_ = Parsing; | |
416 | return values; | |
417 | } | |
418 | ||
419 | // need char *, not const char * | |
420 | static char name_[] = "cycript"; | |
421 | static char break_[] = " \t\n\"\\'`@><=;|&{(" ")}" ".:[]"; | |
422 | ||
423 | class History { | |
424 | private: | |
425 | std::string histfile_; | |
426 | size_t histlines_; | |
427 | ||
428 | public: | |
429 | History(std::string histfile) : | |
430 | histfile_(histfile), | |
431 | histlines_(0) | |
432 | { | |
433 | read_history(histfile_.c_str()); | |
434 | ||
435 | for (HIST_ENTRY *history((history_set_pos(0), current_history())); history; history = next_history()) | |
436 | for (char *character(history->line); *character; ++character) | |
437 | if (*character == '\x01') *character = '\n'; | |
438 | } | |
439 | ||
440 | ~History() { try { | |
441 | for (HIST_ENTRY *history((history_set_pos(0), current_history())); history; history = next_history()) | |
442 | for (char *character(history->line); *character; ++character) | |
443 | if (*character == '\n') *character = '\x01'; | |
444 | ||
445 | if (append_history$ != NULL) { | |
446 | int fd(_syscall(open(histfile_.c_str(), O_CREAT | O_WRONLY, 0600))); | |
447 | _syscall(close(fd)); | |
448 | _assert((*append_history$)(histlines_, histfile_.c_str()) == 0); | |
449 | } else { | |
450 | _assert(write_history(histfile_.c_str()) == 0); | |
451 | } | |
452 | } catch (const CYException &error) { | |
453 | CYPool pool; | |
454 | std::cout << error.PoolCString(pool) << std::endl; | |
455 | } } | |
456 | ||
457 | void operator +=(std::string command) { | |
458 | if (HIST_ENTRY *entry = history_get(where_history())) | |
459 | if (command == entry->line) | |
460 | return; | |
461 | add_history(command.c_str()); | |
462 | ++histlines_; | |
463 | } | |
464 | }; | |
465 | ||
466 | template <typename Type_> | |
467 | static Type_ *CYmemrchr(Type_ *data, Type_ value, size_t size) { | |
468 | while (size != 0) | |
469 | if (data[--size] == value) | |
470 | return data + size; | |
471 | return NULL; | |
472 | } | |
473 | ||
474 | static void _lblcall(int (*command)(int, int), int count, int key) { | |
475 | int last(_rl_last_c_pos); | |
476 | // rl_rubout crashes in _rl_erase_at_end_of_line if _rl_last_c_pos != 0 | |
477 | if (command == &rl_rubout) | |
478 | _rl_last_c_pos = 0; | |
479 | for (int i(0); i != count; ++i) | |
480 | if (command(1, key) != 0) | |
481 | _assert(false); | |
482 | _rl_last_c_pos = last; | |
483 | } | |
484 | ||
485 | static int CYConsoleKeyReturn(int count, int key) { | |
486 | if (rl_point != rl_end) { | |
487 | if (memchr(rl_line_buffer, '\n', rl_end) == NULL) { | |
488 | _lblcall(&rl_newline, count, key); | |
489 | return 0; | |
490 | } | |
491 | ||
492 | insert: | |
493 | char *before(CYmemrchr(rl_line_buffer, '\n', rl_point)); | |
494 | if (before == NULL) | |
495 | before = rl_line_buffer; | |
496 | ||
497 | int space(before + 1 - rl_line_buffer); | |
498 | while (space != rl_point && rl_line_buffer[space] == ' ') | |
499 | ++space; | |
500 | ||
501 | int adjust(rl_line_buffer + space - 1 - before); | |
502 | if (space == rl_point && adjust != 0) | |
503 | _lblcall(&rl_rubout, adjust, '\b'); | |
504 | ||
505 | _lblcall(&rl_insert, count, '\n'); | |
506 | if (adjust != 0) | |
507 | _lblcall(&rl_insert, adjust, ' '); | |
508 | ||
509 | return 0; | |
510 | } | |
511 | ||
512 | bool done(false); | |
513 | if (rl_line_buffer[0] == '?') | |
514 | done = true; | |
515 | else { | |
516 | std::string command(rl_line_buffer, rl_end); | |
517 | command += '\n'; | |
518 | std::stringbuf stream(command); | |
519 | ||
520 | size_t last(std::string::npos); | |
521 | for (size_t i(0); i != std::string::npos; i = command.find('\n', i + 1)) | |
522 | ++last; | |
523 | ||
524 | CYPool pool; | |
525 | CYDriver driver(pool, stream); | |
526 | if (driver.Parse() || !driver.errors_.empty()) | |
527 | for (CYDriver::Errors::const_iterator error(driver.errors_.begin()); error != driver.errors_.end(); ++error) { | |
528 | if (error->location_.begin.line != last + 1) | |
529 | done = true; | |
530 | break; | |
531 | } | |
532 | else | |
533 | done = true; | |
534 | } | |
535 | ||
536 | if (done) { | |
537 | _lblcall(&rl_newline, count, key); | |
538 | return 0; | |
539 | } | |
540 | ||
541 | // XXX: this was the most obvious fix, but is seriously dumb | |
542 | goto insert; | |
543 | } | |
544 | ||
545 | static int CYConsoleKeyUp(int count, int key) { | |
546 | for (; count != 0; --count) { | |
547 | char *after(CYmemrchr(rl_line_buffer, '\n', rl_point)); | |
548 | if (after == NULL) { | |
549 | if (int value = rl_get_previous_history(1, key)) | |
550 | return value; | |
551 | continue; | |
552 | } | |
553 | ||
554 | char *before(CYmemrchr(rl_line_buffer, '\n', after - rl_line_buffer)); | |
555 | if (before == NULL) | |
556 | before = rl_line_buffer - 1; | |
557 | ||
558 | ptrdiff_t offset(rl_line_buffer + rl_point - after); | |
559 | if (offset > after - before) | |
560 | rl_point = after - rl_line_buffer; | |
561 | else | |
562 | rl_point = before + offset - rl_line_buffer; | |
563 | } | |
564 | ||
565 | return 0; | |
566 | } | |
567 | ||
568 | static int CYConsoleKeyDown(int count, int key) { | |
569 | for (; count != 0; --count) { | |
570 | char *after(static_cast<char *>(memchr(rl_line_buffer + rl_point, '\n', rl_end - rl_point))); | |
571 | if (after == NULL) { | |
572 | int where(where_history()); | |
573 | if (int value = rl_get_next_history(1, key)) | |
574 | return value; | |
575 | if (where != where_history()) { | |
576 | char *first(static_cast<char *>(memchr(rl_line_buffer, '\n', rl_end))); | |
577 | if (first != NULL) | |
578 | rl_point = first - 1 - rl_line_buffer; | |
579 | } | |
580 | continue; | |
581 | } | |
582 | ||
583 | char *before(CYmemrchr(rl_line_buffer, '\n', rl_point)); | |
584 | if (before == NULL) | |
585 | before = rl_line_buffer - 1; | |
586 | ||
587 | char *next(static_cast<char *>(memchr(after + 1, '\n', rl_line_buffer + rl_end - after - 1))); | |
588 | if (next == NULL) | |
589 | next = rl_line_buffer + rl_end; | |
590 | ||
591 | ptrdiff_t offset(rl_line_buffer + rl_point - before); | |
592 | if (offset > next - after) | |
593 | rl_point = next - rl_line_buffer; | |
594 | else | |
595 | rl_point = after + offset - rl_line_buffer; | |
596 | } | |
597 | ||
598 | return 0; | |
599 | } | |
600 | ||
601 | static int CYConsoleLineBegin(int count, int key) { | |
602 | while (rl_point != 0 && rl_line_buffer[rl_point - 1] != '\n') | |
603 | --rl_point; | |
604 | return 0; | |
605 | } | |
606 | ||
607 | static int CYConsoleLineEnd(int count, int key) { | |
608 | while (rl_point != rl_end && rl_line_buffer[rl_point] != '\n') | |
609 | ++rl_point; | |
610 | if (rl_point != rl_end && rl_editing_mode == 0) | |
611 | --rl_point; | |
612 | return 0; | |
613 | } | |
614 | ||
615 | static int CYConsoleKeyBack(int count, int key) { | |
616 | for (; count != 0; --count) { | |
617 | if (rl_point == 0) | |
618 | return 1; | |
619 | ||
620 | char *before(CYmemrchr(rl_line_buffer, '\n', rl_point)); | |
621 | if (before == NULL) { | |
622 | int adjust(std::min(count, rl_point)); | |
623 | _lblcall(&rl_rubout, adjust, key); | |
624 | count -= adjust - 1; | |
625 | continue; | |
626 | } | |
627 | ||
628 | int start(before + 1 - rl_line_buffer); | |
629 | if (start == rl_point) rubout: { | |
630 | _lblcall(&rl_rubout, 1, key); | |
631 | continue; | |
632 | } | |
633 | ||
634 | for (int i(start); i != rl_point; ++i) | |
635 | if (rl_line_buffer[i] != ' ') | |
636 | goto rubout; | |
637 | _lblcall(&rl_rubout, (rl_point - start) % 4 ?: 4, key); | |
638 | } | |
639 | ||
640 | return 0; | |
641 | } | |
642 | ||
643 | static int CYConsoleKeyTab(int count, int key) { | |
644 | char *before(CYmemrchr(rl_line_buffer, '\n', rl_point)); | |
645 | if (before == NULL) complete: | |
646 | return rl_complete_internal(rl_completion_mode(&CYConsoleKeyTab)); | |
647 | int start(before + 1 - rl_line_buffer); | |
648 | for (int i(start); i != rl_point; ++i) | |
649 | if (rl_line_buffer[i] != ' ') | |
650 | goto complete; | |
651 | _lblcall(&rl_insert, 4 - (rl_point - start) % 4, ' '); | |
652 | return 0; | |
653 | } | |
654 | ||
655 | static void CYConsoleRemapBind(Keymap map, rl_command_func_t *from, rl_command_func_t *to) { | |
656 | char **keyseqs(rl_invoking_keyseqs_in_map(from, map)); | |
657 | if (keyseqs == NULL) | |
658 | return; | |
659 | for (char **keyseq(keyseqs); *keyseq != NULL; ++keyseq) { | |
660 | rl_bind_keyseq_in_map(*keyseq, to, map); | |
661 | free(*keyseq); | |
662 | } | |
663 | free(keyseqs); | |
664 | } | |
665 | ||
666 | static void CYConsoleRemapKeys(Keymap map) { | |
667 | CYConsoleRemapBind(map, &rl_beg_of_line, &CYConsoleLineBegin); | |
668 | CYConsoleRemapBind(map, &rl_end_of_line, &CYConsoleLineEnd); | |
669 | ||
670 | CYConsoleRemapBind(map, &rl_get_previous_history, &CYConsoleKeyUp); | |
671 | CYConsoleRemapBind(map, &rl_get_next_history, &CYConsoleKeyDown); | |
672 | ||
673 | CYConsoleRemapBind(map, &rl_rubout, &CYConsoleKeyBack); | |
674 | CYConsoleRemapBind(map, &rl_complete, &CYConsoleKeyTab); | |
675 | } | |
676 | ||
677 | static void CYConsolePrepTerm(int meta) { | |
678 | rl_prep_terminal(meta); | |
679 | ||
680 | CYConsoleRemapKeys(emacs_standard_keymap); | |
681 | CYConsoleRemapKeys(emacs_meta_keymap); | |
682 | CYConsoleRemapKeys(emacs_ctlx_keymap); | |
683 | CYConsoleRemapKeys(vi_insertion_keymap); | |
684 | CYConsoleRemapKeys(vi_movement_keymap); | |
685 | } | |
686 | ||
687 | static void CYOutputRun(const std::string &code, bool reparse = false) { | |
688 | CYPool pool; | |
689 | Output(Run(pool, code), &std::cout, reparse); | |
690 | } | |
691 | ||
692 | static void Console(CYOptions &options) { | |
693 | std::string basedir; | |
694 | #ifdef __ANDROID__ | |
695 | basedir = "/data/local/tmp"; | |
696 | #else | |
697 | if (const char *home = getenv("HOME")) | |
698 | basedir = home; | |
699 | else { | |
700 | passwd *passwd; | |
701 | if (const char *username = getenv("LOGNAME")) | |
702 | passwd = getpwnam(username); | |
703 | else | |
704 | passwd = getpwuid(getuid()); | |
705 | basedir = passwd->pw_dir; | |
706 | } | |
707 | #endif | |
708 | ||
709 | basedir += "/.cycript"; | |
710 | mkdir(basedir.c_str(), 0700); | |
711 | ||
712 | rl_initialize(); | |
713 | rl_readline_name = name_; | |
714 | ||
715 | History history(basedir + "/history"); | |
716 | ||
717 | bool bypass(false); | |
718 | bool debug(false); | |
719 | bool lower(true); | |
720 | bool reparse(false); | |
721 | ||
722 | out_ = &std::cout; | |
723 | ||
724 | rl_completer_word_break_characters = break_; | |
725 | rl_attempted_completion_function = &Complete; | |
726 | ||
727 | if (cur_term != NULL) { | |
728 | rl_redisplay_function = CYDisplayUpdate; | |
729 | rl_prep_term_function = CYConsolePrepTerm; | |
730 | } | |
731 | ||
732 | CYOutputRun(""); | |
733 | ||
734 | for (;;) { | |
735 | struct sigaction action; | |
736 | sigemptyset(&action.sa_mask); | |
737 | action.sa_handler = &sigint; | |
738 | action.sa_flags = 0; | |
739 | sigaction(SIGINT, &action, NULL); | |
740 | ||
741 | if (setjmp(ctrlc_) != 0) { | |
742 | mode_ = Working; | |
743 | *out_ << std::endl; | |
744 | continue; | |
745 | } | |
746 | ||
747 | if (bypass) { | |
748 | rl_bind_key('\r', &rl_newline); | |
749 | rl_bind_key('\n', &rl_newline); | |
750 | } else { | |
751 | rl_bind_key('\r', &CYConsoleKeyReturn); | |
752 | rl_bind_key('\n', &CYConsoleKeyReturn); | |
753 | } | |
754 | ||
755 | mode_ = Parsing; | |
756 | char *line(readline("cy# ")); | |
757 | mode_ = Working; | |
758 | ||
759 | if (line == NULL) { | |
760 | *out_ << std::endl; | |
761 | break; | |
762 | } | |
763 | ||
764 | std::string command(line); | |
765 | free(line); | |
766 | if (command.empty()) | |
767 | continue; | |
768 | history += command; | |
769 | ||
770 | if (command[0] == '?') { | |
771 | std::string data(command.substr(1)); | |
772 | if (data == "bypass") { | |
773 | bypass = !bypass; | |
774 | *out_ << "bypass == " << (bypass ? "true" : "false") << std::endl; | |
775 | } else if (data == "debug") { | |
776 | debug = !debug; | |
777 | *out_ << "debug == " << (debug ? "true" : "false") << std::endl; | |
778 | } else if (data == "destroy") { | |
779 | CYDestroyContext(); | |
780 | } else if (data == "gc") { | |
781 | *out_ << "collecting... " << std::flush; | |
782 | CYGarbageCollect(CYGetJSContext()); | |
783 | *out_ << "done." << std::endl; | |
784 | } else if (data == "exit") { | |
785 | return; | |
786 | } else if (data == "lower") { | |
787 | lower = !lower; | |
788 | *out_ << "lower == " << (lower ? "true" : "false") << std::endl; | |
789 | } else if (data == "reparse") { | |
790 | reparse = !reparse; | |
791 | *out_ << "reparse == " << (reparse ? "true" : "false") << std::endl; | |
792 | } | |
793 | ||
794 | continue; | |
795 | } | |
796 | ||
797 | std::string code; | |
798 | if (bypass) | |
799 | code = command; | |
800 | else try { | |
801 | std::stringbuf stream(command); | |
802 | ||
803 | CYPool pool; | |
804 | CYDriver driver(pool, stream); | |
805 | Setup(driver); | |
806 | ||
807 | if (driver.Parse() || !driver.errors_.empty()) { | |
808 | for (CYDriver::Errors::const_iterator error(driver.errors_.begin()); error != driver.errors_.end(); ++error) { | |
809 | CYPosition begin(error->location_.begin); | |
810 | CYPosition end(error->location_.end); | |
811 | ||
812 | /*if (begin.line != lines2.size()) { | |
813 | std::cerr << " | "; | |
814 | std::cerr << lines2[begin.line - 1] << std::endl; | |
815 | }*/ | |
816 | ||
817 | std::cerr << "...."; | |
818 | for (size_t i(0); i != begin.column; ++i) | |
819 | std::cerr << '.'; | |
820 | if (begin.line != end.line || begin.column == end.column) | |
821 | std::cerr << '^'; | |
822 | else for (size_t i(0), e(end.column - begin.column); i != e; ++i) | |
823 | std::cerr << '^'; | |
824 | std::cerr << std::endl; | |
825 | ||
826 | std::cerr << " | "; | |
827 | std::cerr << error->message_ << std::endl; | |
828 | ||
829 | break; | |
830 | } | |
831 | ||
832 | continue; | |
833 | } | |
834 | ||
835 | if (driver.script_ == NULL) | |
836 | continue; | |
837 | ||
838 | std::stringbuf str; | |
839 | CYOutput out(str, options); | |
840 | Setup(out, driver, options, lower); | |
841 | out << *driver.script_; | |
842 | code = str.str(); | |
843 | } catch (const CYException &error) { | |
844 | CYPool pool; | |
845 | std::cout << error.PoolCString(pool) << std::endl; | |
846 | continue; | |
847 | } | |
848 | ||
849 | if (debug) { | |
850 | std::cout << "cy= "; | |
851 | CYLexerHighlight(code.c_str(), code.size(), std::cout); | |
852 | std::cout << std::endl; | |
853 | } | |
854 | ||
855 | CYOutputRun(code, reparse); | |
856 | } | |
857 | } | |
858 | ||
859 | static uint64_t CYGetTime() { | |
860 | #ifdef __APPLE__ | |
861 | return mach_absolute_time(); | |
862 | #else | |
863 | struct timespec spec; | |
864 | clock_gettime(CLOCK_MONOTONIC, &spec); | |
865 | return spec.tv_sec * UINT64_C(1000000000) + spec.tv_nsec; | |
866 | #endif | |
867 | } | |
868 | ||
869 | int Main(int argc, char * const argv[], char const * const envp[]) { | |
870 | bool tty(isatty(STDIN_FILENO)); | |
871 | bool compile(false); | |
872 | bool target(false); | |
873 | CYOptions options; | |
874 | ||
875 | append_history$ = (int (*)(int, const char *)) (dlsym(RTLD_DEFAULT, "append_history")); | |
876 | ||
877 | pid_t pid(_not(pid_t)); | |
878 | ||
879 | const char *host(NULL); | |
880 | const char *port(NULL); | |
881 | ||
882 | const char *argv0(argv[0]); | |
883 | ||
884 | optind = 1; | |
885 | ||
886 | for (;;) { | |
887 | int option(getopt_long(argc, argv, | |
888 | "c" | |
889 | "g:" | |
890 | "n:" | |
891 | "p:" | |
892 | "r:" | |
893 | "s" | |
894 | , (const struct option[]) { | |
895 | {NULL, no_argument, NULL, 'c'}, | |
896 | {NULL, required_argument, NULL, 'g'}, | |
897 | {NULL, required_argument, NULL, 'n'}, | |
898 | {NULL, required_argument, NULL, 'p'}, | |
899 | {NULL, required_argument, NULL, 'r'}, | |
900 | {NULL, no_argument, NULL, 's'}, | |
901 | {0, 0, 0, 0}}, NULL)); | |
902 | ||
903 | switch (option) { | |
904 | case -1: | |
905 | goto getopt; | |
906 | ||
907 | case ':': | |
908 | case '?': | |
909 | fprintf(stderr, | |
910 | "usage: cycript [-c]" | |
911 | " [-p <pid|name>]" | |
912 | " [-r <host:port>]" | |
913 | " [<script> [<arg>...]]\n" | |
914 | ); | |
915 | return 1; | |
916 | ||
917 | target: | |
918 | if (!target) | |
919 | target = true; | |
920 | else { | |
921 | fprintf(stderr, "only one of -[cpr] may be used at a time\n"); | |
922 | return 1; | |
923 | } | |
924 | break; | |
925 | ||
926 | case 'c': | |
927 | compile = true; | |
928 | goto target; | |
929 | ||
930 | case 'g': | |
931 | if (false); | |
932 | else if (strcmp(optarg, "rename") == 0) | |
933 | options.verbose_ = true; | |
934 | else if (strcmp(optarg, "bison") == 0) | |
935 | bison_ = true; | |
936 | else if (strcmp(optarg, "timing") == 0) | |
937 | timing_ = true; | |
938 | else { | |
939 | fprintf(stderr, "invalid name for -g\n"); | |
940 | return 1; | |
941 | } | |
942 | break; | |
943 | ||
944 | case 'n': | |
945 | if (false); | |
946 | else if (strcmp(optarg, "minify") == 0) | |
947 | pretty_ = true; | |
948 | else { | |
949 | fprintf(stderr, "invalid name for -n\n"); | |
950 | return 1; | |
951 | } | |
952 | break; | |
953 | ||
954 | case 'p': { | |
955 | size_t size(strlen(optarg)); | |
956 | char *end; | |
957 | ||
958 | pid = strtoul(optarg, &end, 0); | |
959 | if (optarg + size != end) { | |
960 | // XXX: arg needs to be escaped in some horrendous way of doom | |
961 | // XXX: this is a memory leak now because I just don't care enough | |
962 | char *command; | |
963 | int writ(asprintf(&command, "ps axc|sed -e '/^ *[0-9]/{s/^ *\\([0-9]*\\)\\( *[^ ]*\\)\\{3\\} *-*\\([^ ]*\\)/\\3 \\1/;/^%s /{s/^[^ ]* //;q;};};d'", optarg)); | |
964 | _assert(writ != -1); | |
965 | ||
966 | if (FILE *pids = popen(command, "r")) { | |
967 | char value[32]; | |
968 | size = 0; | |
969 | ||
970 | for (;;) { | |
971 | size_t read(fread(value + size, 1, sizeof(value) - size, pids)); | |
972 | if (read == 0) | |
973 | break; | |
974 | else { | |
975 | size += read; | |
976 | if (size == sizeof(value)) | |
977 | goto fail; | |
978 | } | |
979 | } | |
980 | ||
981 | size: | |
982 | if (size == 0) | |
983 | goto fail; | |
984 | if (value[size - 1] == '\n') { | |
985 | --size; | |
986 | goto size; | |
987 | } | |
988 | ||
989 | value[size] = '\0'; | |
990 | size = strlen(value); | |
991 | pid = strtoul(value, &end, 0); | |
992 | if (value + size != end) fail: | |
993 | pid = _not(pid_t); | |
994 | _syscall(pclose(pids)); | |
995 | } | |
996 | ||
997 | if (pid == _not(pid_t)) { | |
998 | fprintf(stderr, "unable to find process `%s' using ps\n", optarg); | |
999 | return 1; | |
1000 | } | |
1001 | } | |
1002 | } goto target; | |
1003 | ||
1004 | case 'r': { | |
1005 | //size_t size(strlen(optarg)); | |
1006 | ||
1007 | char *colon(strrchr(optarg, ':')); | |
1008 | if (colon == NULL) { | |
1009 | fprintf(stderr, "missing colon in hostspec\n"); | |
1010 | return 1; | |
1011 | } | |
1012 | ||
1013 | /*char *end; | |
1014 | port = strtoul(colon + 1, &end, 10); | |
1015 | if (end != optarg + size) { | |
1016 | fprintf(stderr, "invalid port in hostspec\n"); | |
1017 | return 1; | |
1018 | }*/ | |
1019 | ||
1020 | host = optarg; | |
1021 | *colon = '\0'; | |
1022 | port = colon + 1; | |
1023 | } goto target; | |
1024 | ||
1025 | case 's': | |
1026 | strict_ = true; | |
1027 | break; | |
1028 | ||
1029 | default: | |
1030 | _assert(false); | |
1031 | } | |
1032 | } | |
1033 | ||
1034 | getopt: | |
1035 | argc -= optind; | |
1036 | argv += optind; | |
1037 | ||
1038 | const char *script; | |
1039 | ||
1040 | if (pid != _not(pid_t) && argc > 1) { | |
1041 | fprintf(stderr, "-p cannot set argv\n"); | |
1042 | return 1; | |
1043 | } | |
1044 | ||
1045 | if (argc == 0) | |
1046 | script = NULL; | |
1047 | else { | |
1048 | script = argv[0]; | |
1049 | if (strcmp(script, "-") == 0) | |
1050 | script = NULL; | |
1051 | --argc; | |
1052 | ++argv; | |
1053 | } | |
1054 | ||
1055 | #ifdef CY_EXECUTE | |
1056 | // XXX: const_cast?! wtf gcc :( | |
1057 | CYSetArgs(argv0, script, argc, const_cast<const char **>(argv)); | |
1058 | #endif | |
1059 | ||
1060 | if (remote_ == NULL && pid != _not(pid_t)) | |
1061 | remote_ = new CYInjectRemote(pid); | |
1062 | ||
1063 | if (remote_ == NULL && host != NULL && port != NULL) | |
1064 | remote_ = new CYSocketRemote(host, port); | |
1065 | ||
1066 | if (remote_ == NULL) | |
1067 | remote_ = new CYLocalRemote(); | |
1068 | ||
1069 | if (script == NULL && tty) | |
1070 | Console(options); | |
1071 | else { | |
1072 | std::istream *stream; | |
1073 | if (script == NULL) { | |
1074 | stream = &std::cin; | |
1075 | script = "<stdin>"; | |
1076 | } else { | |
1077 | stream = new std::fstream(script, std::ios::in | std::ios::binary); | |
1078 | _assert(!stream->fail()); | |
1079 | } | |
1080 | ||
1081 | if (timing_) { | |
1082 | std::stringbuf buffer; | |
1083 | stream->get(buffer, '\0'); | |
1084 | _assert(!stream->fail()); | |
1085 | ||
1086 | double average(0); | |
1087 | int samples(-50); | |
1088 | uint64_t start(CYGetTime()); | |
1089 | ||
1090 | for (;;) { | |
1091 | stream = new std::istringstream(buffer.str()); | |
1092 | ||
1093 | CYPool pool; | |
1094 | CYDriver driver(pool, *stream->rdbuf(), script); | |
1095 | Setup(driver); | |
1096 | ||
1097 | uint64_t begin(CYGetTime()); | |
1098 | driver.Parse(); | |
1099 | uint64_t end(CYGetTime()); | |
1100 | ||
1101 | delete stream; | |
1102 | ||
1103 | average += (end - begin - average) / ++samples; | |
1104 | ||
1105 | uint64_t now(CYGetTime()); | |
1106 | if (samples == 0) | |
1107 | average = 0; | |
1108 | else if ((now - start) / 1000000000 >= 1) | |
1109 | std::cout << std::fixed << average << '\t' << (end - begin) << '\t' << samples << std::endl; | |
1110 | else continue; | |
1111 | ||
1112 | start = now; | |
1113 | } | |
1114 | ||
1115 | stream = new std::istringstream(buffer.str()); | |
1116 | std::cin.get(); | |
1117 | } | |
1118 | ||
1119 | CYPool pool; | |
1120 | CYDriver driver(pool, *stream->rdbuf(), script); | |
1121 | Setup(driver); | |
1122 | ||
1123 | bool failed(driver.Parse()); | |
1124 | ||
1125 | if (failed || !driver.errors_.empty()) { | |
1126 | for (CYDriver::Errors::const_iterator i(driver.errors_.begin()); i != driver.errors_.end(); ++i) | |
1127 | std::cerr << i->location_.begin << ": " << i->message_ << std::endl; | |
1128 | return 1; | |
1129 | } else if (driver.script_ != NULL) { | |
1130 | std::stringbuf str; | |
1131 | CYOutput out(str, options); | |
1132 | Setup(out, driver, options, true); | |
1133 | out << *driver.script_; | |
1134 | std::string code(str.str()); | |
1135 | if (compile) | |
1136 | std::cout << code; | |
1137 | else { | |
1138 | CYUTF8String json(Run(pool, code)); | |
1139 | if (CYStartsWith(json, "throw ")) { | |
1140 | CYLexerHighlight(json.data, json.size, std::cerr); | |
1141 | std::cerr << std::endl; | |
1142 | return 1; | |
1143 | } | |
1144 | } | |
1145 | } | |
1146 | } | |
1147 | ||
1148 | return 0; | |
1149 | } | |
1150 | ||
1151 | _visible int main(int argc, char * const argv[], char const * const envp[]) { | |
1152 | try { | |
1153 | return Main(argc, argv, envp); | |
1154 | } catch (const CYException &error) { | |
1155 | CYPool pool; | |
1156 | fprintf(stderr, "%s\n", error.PoolCString(pool)); | |
1157 | return 1; | |
1158 | } | |
1159 | } |