]> git.saurik.com Git - cycript.git/blobdiff - Console.cpp
Remove now-obsolete prefix size clip.
[cycript.git] / Console.cpp
index 8e1c0dae2ce32515504c747453fc9eabbf583809..3fe2310617fe7ff404a151708c6039add3f7911a 100644 (file)
@@ -81,6 +81,8 @@
 
 #include <dlfcn.h>
 
 
 #include <dlfcn.h>
 
+#include "Replace.hpp"
+
 static volatile enum {
     Working,
     Parsing,
 static volatile enum {
     Working,
     Parsing,
@@ -127,14 +129,14 @@ void Setup(CYOutput &out, CYDriver &driver, CYOptions &options) {
     driver.program_->Replace(context);
 }
 
     driver.program_->Replace(context);
 }
 
-void Run(int client, const char *data, size_t size, FILE *fout = NULL, bool expand = false) {
-    CYPool pool;
-
+static CYUTF8String Run(CYPool &pool, int client, CYUTF8String code) {
     const char *json;
     const char *json;
+    size_t size;
+
     if (client == -1) {
         mode_ = Running;
 #ifdef CY_EXECUTE
     if (client == -1) {
         mode_ = Running;
 #ifdef CY_EXECUTE
-        json = CYExecute(pool, data);
+        json = CYExecute(pool, code);
 #else
         json = NULL;
 #endif
 #else
         json = NULL;
 #endif
@@ -143,8 +145,9 @@ void Run(int client, const char *data, size_t size, FILE *fout = NULL, bool expa
             size = strlen(json);
     } else {
         mode_ = Sending;
             size = strlen(json);
     } else {
         mode_ = Sending;
+        size = code.size;
         CYSendAll(client, &size, sizeof(size));
         CYSendAll(client, &size, sizeof(size));
-        CYSendAll(client, data, size);
+        CYSendAll(client, code.data, code.size);
         mode_ = Waiting;
         CYRecvAll(client, &size, sizeof(size));
         if (size == _not(size_t))
         mode_ = Waiting;
         CYRecvAll(client, &size, sizeof(size));
         if (size == _not(size_t))
@@ -158,39 +161,225 @@ void Run(int client, const char *data, size_t size, FILE *fout = NULL, bool expa
         mode_ = Working;
     }
 
         mode_ = Working;
     }
 
-    if (json != NULL && fout != NULL) {
-        if (!expand || json[0] != '"' && json[0] != '\'')
-            fputs(json, fout);
-        else for (size_t i(0); i != size; ++i)
-            if (json[i] != '\\')
-                fputc(json[i], fout);
-            else switch(json[++i]) {
-                case '\0': goto done;
-                case '\\': fputc('\\', fout); break;
-                case '\'': fputc('\'', fout); break;
-                case '"': fputc('"', fout); break;
-                case 'b': fputc('\b', fout); break;
-                case 'f': fputc('\f', fout); break;
-                case 'n': fputc('\n', fout); break;
-                case 'r': fputc('\r', fout); break;
-                case 't': fputc('\t', fout); break;
-                case 'v': fputc('\v', fout); break;
-                default: fputc('\\', fout); --i; break;
-            }
+    return CYUTF8String(json, size);
+}
 
 
-      done:
-        fputs("\n", fout);
-        fflush(fout);
-    }
+static CYUTF8String Run(CYPool &pool, int client, const std::string &code) {
+    return Run(pool, client, CYUTF8String(code.c_str(), code.size()));
 }
 
 }
 
-void Run(int client, std::string &code, FILE *fout = NULL, bool expand = false) {
+FILE *fout_;
+
+static void Output(CYUTF8String json, FILE *fout, bool expand = false) {
+    const char *data(json.data);
+    size_t size(json.size);
+
+    if (data == NULL || fout == NULL)
+        return;
+
+    if (!expand || data[0] != '"' && data[0] != '\'')
+        fputs(data, fout);
+    else for (size_t i(0); i != size; ++i)
+        if (data[i] != '\\')
+            fputc(data[i], fout);
+        else switch(data[++i]) {
+            case '\0': goto done;
+            case '\\': fputc('\\', fout); break;
+            case '\'': fputc('\'', fout); break;
+            case '"': fputc('"', fout); break;
+            case 'b': fputc('\b', fout); break;
+            case 'f': fputc('\f', fout); break;
+            case 'n': fputc('\n', fout); break;
+            case 'r': fputc('\r', fout); break;
+            case 't': fputc('\t', fout); break;
+            case 'v': fputc('\v', fout); break;
+            default: fputc('\\', fout); --i; break;
+        }
+
+  done:
+    fputs("\n", fout);
+    fflush(fout);
+}
+
+static void Run(int client, const char *data, size_t size, FILE *fout = NULL, bool expand = false) {
+    CYPool pool;
+    Output(Run(pool, client, CYUTF8String(data, size)), fout, expand);
+}
+
+static void Run(int client, std::string &code, FILE *fout = NULL, bool expand = false) {
     Run(client, code.c_str(), code.size(), fout, expand);
 }
 
 int (*append_history$)(int, const char *);
 
     Run(client, code.c_str(), code.size(), fout, expand);
 }
 
 int (*append_history$)(int, const char *);
 
-static void Console(apr_pool_t *pool, int client, CYOptions &options) {
+static std::string command_;
+
+static CYExpression *ParseExpression(CYPool &pool, CYUTF8String code) {
+    std::ostringstream str;
+    str << '(' << code << ')';
+    std::string string(str.str());
+
+    CYDriver driver(pool);
+    driver.data_ = string.c_str();
+    driver.size_ = string.size();
+
+    cy::parser parser(driver);
+    Setup(driver, parser);
+
+    if (parser.parse() != 0 || !driver.errors_.empty())
+        _assert(false);
+
+    CYExpress *express(dynamic_cast<CYExpress *>(driver.program_->statements_));
+    _assert(express != NULL);
+    return express->expression_;
+}
+
+static int client_;
+
+static char **Complete(const char *word, int start, int end) {
+    rl_attempted_completion_over = TRUE;
+
+    CYPool pool;
+
+    CYDriver driver(pool);
+    cy::parser parser(driver);
+    Setup(driver, parser);
+
+    std::string line(rl_line_buffer, start);
+    std::string command(command_ + line);
+
+    driver.data_ = command.c_str();
+    driver.size_ = command.size();
+
+    driver.auto_ = true;
+
+    if (parser.parse() != 0 || !driver.errors_.empty())
+        return NULL;
+
+    if (driver.mode_ == CYDriver::AutoNone)
+        return NULL;
+
+    CYExpression *expression;
+
+    CYOptions options;
+    CYContext context(driver.pool_, options);
+
+    std::ostringstream prefix;
+
+    switch (driver.mode_) {
+        case CYDriver::AutoPrimary:
+            expression = $ CYThis();
+        break;
+
+        case CYDriver::AutoDirect:
+            expression = driver.context_;
+        break;
+
+        case CYDriver::AutoIndirect:
+            expression = $ CYIndirect(driver.context_);
+        break;
+
+        case CYDriver::AutoMessage: {
+            CYDriver::Context &thing(driver.contexts_.back());
+            expression = $M($M($ CYIndirect(thing.context_), $S("isa")), $S("messages"));
+            for (CYDriver::Context::Words::const_iterator part(thing.words_.begin()); part != thing.words_.end(); ++part)
+                prefix << (*part)->word_ << ':';
+        } break;
+
+        default:
+            _assert(false);
+    }
+
+    std::string begin(prefix.str());
+
+    driver.program_ = $ CYProgram($ CYExpress($C3(ParseExpression(pool,
+    "   function(object, prefix, word) {\n"
+    "       var names = [];\n"
+    "       var pattern = '^' + prefix + word;\n"
+    "       var length = prefix.length;\n"
+    "       for (name in object)\n"
+    "           if (name.match(pattern) != null)\n"
+    "               names.push(name.substr(length));\n"
+    "       return names;\n"
+    "   }\n"
+    ), expression, $S(begin.c_str()), $S(word))));
+
+    driver.program_->Replace(context);
+
+    std::ostringstream str;
+    CYOutput out(str, options);
+    out << *driver.program_;
+
+    std::string code(str.str());
+    CYUTF8String json(Run(pool, client_, code));
+
+    CYExpression *result(ParseExpression(pool, json));
+    CYArray *array(dynamic_cast<CYArray *>(result));
+
+    if (array == NULL) {
+        fprintf(fout_, "\n");
+        Output(json, fout_);
+        rl_forced_update_display();
+        return NULL;
+    }
+
+    // XXX: use an std::set?
+    typedef std::vector<std::string> Completions;
+    Completions completions;
+
+    std::string common;
+    bool rest(false);
+
+    for (CYElement *element(array->elements_); element != NULL; element = element->next_) {
+        CYString *string(dynamic_cast<CYString *>(element->value_));
+        _assert(string != NULL);
+
+        std::string completion(string->value_, string->size_);
+        completions.push_back(completion);
+
+        if (!rest) {
+            common = completion;
+            rest = true;
+        } else {
+            size_t limit(completion.size()), size(common.size());
+            if (size > limit)
+                common = common.substr(0, limit);
+            else
+                limit = size;
+            for (limit = 0; limit != size; ++limit)
+                if (common[limit] != completion[limit])
+                    break;
+            if (limit != size)
+                common = common.substr(0, limit);
+        }
+    }
+
+    size_t count(completions.size());
+    if (count == 0)
+        return NULL;
+
+    size_t colon(common.find(':'));
+    if (colon != std::string::npos)
+        common = common.substr(0, colon + 1);
+    if (completions.size() == 1)
+        common += ' ';
+
+    char **results(reinterpret_cast<char **>(malloc(sizeof(char *) * (count + 2))));
+
+    results[0] = strdup(common.c_str());
+    size_t index(0);
+    for (Completions::const_iterator i(completions.begin()); i != completions.end(); ++i)
+        results[++index] = strdup(i->c_str());
+    results[count + 1] = NULL;
+
+    return results;
+}
+
+// need char *, not const char *
+static char name_[] = "cycript";
+static char break_[] = " \t\n\"\\'`@$><=;|&{(" ")}" ".:[]";
+
+static void Console(apr_pool_t *pool, CYOptions &options) {
     passwd *passwd;
     if (const char *username = getenv("LOGNAME"))
         passwd = getpwnam(username);
     passwd *passwd;
     if (const char *username = getenv("LOGNAME"))
         passwd = getpwnam(username);
@@ -201,6 +390,9 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
     const char *histfile(apr_psprintf(pool, "%s/history", basedir));
     size_t histlines(0);
 
     const char *histfile(apr_psprintf(pool, "%s/history", basedir));
     size_t histlines(0);
 
+    rl_initialize();
+    rl_readline_name = name_;
+
     mkdir(basedir, 0700);
     read_history(histfile);
 
     mkdir(basedir, 0700);
     read_history(histfile);
 
@@ -208,9 +400,14 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
     bool debug(false);
     bool expand(false);
 
     bool debug(false);
     bool expand(false);
 
-    FILE *fout(stdout);
+    fout_ = stdout;
 
 
-    rl_bind_key('\t', rl_insert);
+    // rl_completer_word_break_characters is broken in libedit
+    rl_basic_word_break_characters = break_;
+
+    rl_completer_word_break_characters = break_;
+    rl_attempted_completion_function = &Complete;
+    rl_bind_key('\t', rl_complete);
 
     struct sigaction action;
     sigemptyset(&action.sa_mask);
 
     struct sigaction action;
     sigemptyset(&action.sa_mask);
@@ -219,7 +416,7 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
     sigaction(SIGINT, &action, NULL);
 
     restart: for (;;) {
     sigaction(SIGINT, &action, NULL);
 
     restart: for (;;) {
-        std::string command;
+        command_.clear();
         std::vector<std::string> lines;
 
         bool extra(false);
         std::vector<std::string> lines;
 
         bool extra(false);
@@ -227,8 +424,8 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
 
         if (setjmp(ctrlc_) != 0) {
             mode_ = Working;
 
         if (setjmp(ctrlc_) != 0) {
             mode_ = Working;
-            fputs("\n", fout);
-            fflush(fout);
+            fputs("\n", fout_);
+            fflush(fout_);
             goto restart;
         }
 
             goto restart;
         }
 
@@ -247,16 +444,16 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
                 std::string data(line + 1);
                 if (data == "bypass") {
                     bypass = !bypass;
                 std::string data(line + 1);
                 if (data == "bypass") {
                     bypass = !bypass;
-                    fprintf(fout, "bypass == %s\n", bypass ? "true" : "false");
-                    fflush(fout);
+                    fprintf(fout_, "bypass == %s\n", bypass ? "true" : "false");
+                    fflush(fout_);
                 } else if (data == "debug") {
                     debug = !debug;
                 } else if (data == "debug") {
                     debug = !debug;
-                    fprintf(fout, "debug == %s\n", debug ? "true" : "false");
-                    fflush(fout);
+                    fprintf(fout_, "debug == %s\n", debug ? "true" : "false");
+                    fflush(fout_);
                 } else if (data == "expand") {
                     expand = !expand;
                 } else if (data == "expand") {
                     expand = !expand;
-                    fprintf(fout, "expand == %s\n", expand ? "true" : "false");
-                    fflush(fout);
+                    fprintf(fout_, "expand == %s\n", expand ? "true" : "false");
+                    fflush(fout_);
                 }
                 add_history(line);
                 ++histlines;
                 }
                 add_history(line);
                 ++histlines;
@@ -264,7 +461,7 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
             }
         }
 
             }
         }
 
-        command += line;
+        command_ += line;
 
         char *begin(line), *end(line + strlen(line));
         while (char *nl = reinterpret_cast<char *>(memchr(begin, '\n', end - begin))) {
 
         char *begin(line), *end(line + strlen(line));
         while (char *nl = reinterpret_cast<char *>(memchr(begin, '\n', end - begin))) {
@@ -280,14 +477,14 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
         std::string code;
 
         if (bypass)
         std::string code;
 
         if (bypass)
-            code = command;
+            code = command_;
         else {
         else {
-            CYDriver driver("");
+            CYDriver driver;
             cy::parser parser(driver);
             Setup(driver, parser);
 
             cy::parser parser(driver);
             Setup(driver, parser);
 
-            driver.data_ = command.c_str();
-            driver.size_ = command.size();
+            driver.data_ = command_.c_str();
+            driver.size_ = command_.size();
 
             if (parser.parse() != 0 || !driver.errors_.empty()) {
                 for (CYDriver::Errors::const_iterator error(driver.errors_.begin()); error != driver.errors_.end(); ++error) {
 
             if (parser.parse() != 0 || !driver.errors_.empty()) {
                 for (CYDriver::Errors::const_iterator error(driver.errors_.begin()); error != driver.errors_.end(); ++error) {
@@ -312,7 +509,7 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
                         std::cerr << "  | ";
                         std::cerr << error->message_ << std::endl;
 
                         std::cerr << "  | ";
                         std::cerr << error->message_ << std::endl;
 
-                        add_history(command.c_str());
+                        add_history(command_.c_str());
                         ++histlines;
                         goto restart;
                     }
                         ++histlines;
                         goto restart;
                     }
@@ -320,7 +517,7 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
 
                 driver.errors_.clear();
 
 
                 driver.errors_.clear();
 
-                command += '\n';
+                command_ += '\n';
                 prompt = "cy> ";
                 goto read;
             }
                 prompt = "cy> ";
                 goto read;
             }
@@ -328,8 +525,8 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
             if (driver.program_ == NULL)
                 goto restart;
 
             if (driver.program_ == NULL)
                 goto restart;
 
-            if (client != -1)
-                code = command;
+            if (client_ != -1)
+                code = command_;
             else {
                 std::ostringstream str;
                 CYOutput out(str, options);
             else {
                 std::ostringstream str;
                 CYOutput out(str, options);
@@ -339,13 +536,13 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
             }
         }
 
             }
         }
 
-        add_history(command.c_str());
+        add_history(command_.c_str());
         ++histlines;
 
         if (debug)
             std::cout << code << std::endl;
 
         ++histlines;
 
         if (debug)
             std::cout << code << std::endl;
 
-        Run(client, code, fout, expand);
+        Run(client_, code, fout_, expand);
     }
 
     if (append_history$ != NULL) {
     }
 
     if (append_history$ != NULL) {
@@ -355,8 +552,8 @@ static void Console(apr_pool_t *pool, int client, CYOptions &options) {
         write_history(histfile);
     }
 
         write_history(histfile);
     }
 
-    fputs("\n", fout);
-    fflush(fout);
+    fputs("\n", fout_);
+    fflush(fout_);
 }
 
 static void *Map(const char *path, size_t *psize) {
 }
 
 static void *Map(const char *path, size_t *psize) {
@@ -542,11 +739,9 @@ int Main(int argc, char const * const argv[], char const * const envp[]) {
     }
 #endif
 
     }
 #endif
 
-    int client;
-
 #ifdef CY_ATTACH
     if (pid == _not(pid_t))
 #ifdef CY_ATTACH
     if (pid == _not(pid_t))
-        client = -1;
+        client_ = -1;
     else {
         int server(_syscall(socket(PF_UNIX, SOCK_STREAM, 0))); try {
             struct sockaddr_un address;
     else {
         int server(_syscall(socket(PF_UNIX, SOCK_STREAM, 0))); try {
             struct sockaddr_un address;
@@ -561,7 +756,7 @@ int Main(int argc, char const * const argv[], char const * const envp[]) {
             try {
                 _syscall(listen(server, 1));
                 InjectLibrary(pid);
             try {
                 _syscall(listen(server, 1));
                 InjectLibrary(pid);
-                client = _syscall(accept(server, NULL, NULL));
+                client_ = _syscall(accept(server, NULL, NULL));
             } catch (...) {
                 // XXX: exception?
                 unlink(address.sun_path);
             } catch (...) {
                 // XXX: exception?
                 unlink(address.sun_path);
@@ -573,13 +768,13 @@ int Main(int argc, char const * const argv[], char const * const envp[]) {
         }
     }
 #else
         }
     }
 #else
-    client = -1;
+    client_ = -1;
 #endif
 
     if (script == NULL && tty)
 #endif
 
     if (script == NULL && tty)
-        Console(pool, client, options);
+        Console(pool, options);
     else {
     else {
-        CYDriver driver(script ?: "<stdin>");
+        CYDriver driver(pool, script ?: "<stdin>");
         cy::parser parser(driver);
         Setup(driver, parser);
 
         cy::parser parser(driver);
         Setup(driver, parser);
 
@@ -612,9 +807,9 @@ int Main(int argc, char const * const argv[], char const * const envp[]) {
             for (CYDriver::Errors::const_iterator i(driver.errors_.begin()); i != driver.errors_.end(); ++i)
                 std::cerr << i->location_.begin << ": " << i->message_ << std::endl;
         } else if (driver.program_ != NULL)
             for (CYDriver::Errors::const_iterator i(driver.errors_.begin()); i != driver.errors_.end(); ++i)
                 std::cerr << i->location_.begin << ": " << i->message_ << std::endl;
         } else if (driver.program_ != NULL)
-            if (client != -1) {
+            if (client_ != -1) {
                 std::string code(start, end-start);
                 std::string code(start, end-start);
-                Run(client, code, stdout);
+                Run(client_, code, stdout);
             } else {
                 std::ostringstream str;
                 CYOutput out(str, options);
             } else {
                 std::ostringstream str;
                 CYOutput out(str, options);
@@ -624,7 +819,7 @@ int Main(int argc, char const * const argv[], char const * const envp[]) {
                 if (compile)
                     std::cout << code;
                 else
                 if (compile)
                     std::cout << code;
                 else
-                    Run(client, code, stdout);
+                    Run(client_, code, stdout);
             }
     }
 
             }
     }