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