[prql] fix multi-line completion and add completion for "let"

Compile PRQL before trying to tack on `take 5`
to make sure it's valid in the first place.

Related to #1677

Author: tstack

src/bottom_status_source.hh

@@ -65,6 +65,11 @@ public:
         this->bss_error.set_value(msg);
     }
 
+    void set_error(const attr_line_t& msg)
+    {
+        this->bss_error.set_value(msg);
+    }
+
     size_t statusview_fields() override;
 
     status_field& statusview_value_for_field(int field) override;

src/command_executor.cc

@@ -54,18 +54,13 @@
 #include "lnav_util.hh"
 #include "log_format_loader.hh"
 #include "log_vtab_impl.hh"
-#include "prql-modules.h"
 #include "readline_highlighters.hh"
 #include "service_tags.hh"
 #include "shlex.hh"
 #include "sql_help.hh"
 #include "sql_util.hh"
 #include "vtab_module.hh"
 
-#ifdef HAVE_RUST_DEPS
-#    include "lnav_rs_ext.cxx.hh"
-#endif
-
 using namespace std::literals::chrono_literals;
 using namespace lnav::roles::literals;
 
@@ -330,53 +325,11 @@ execute_sql(exec_context& ec, const std::string& sql, std::string& alt_msg)
     if (lnav::sql::is_prql(stmt_str)) {
         log_info("compiling PRQL: %s", stmt_str.c_str());
 
-#if HAVE_RUST_DEPS
-        extern rust::Vec<lnav_rs_ext::SourceTreeElement> sqlite_extension_prql;
-        auto opts = lnav_rs_ext::Options{true, "sql.sqlite", true};
-
-        auto tree = sqlite_extension_prql;
-        for (const auto& mod : lnav_prql_modules) {
-            auto name = mod.get_name().to_string();
-            log_debug("lnav_rs_ext adding mod %s", name.c_str());
-            tree.emplace_back(lnav_rs_ext::SourceTreeElement{
-                name.c_str(),
-                mod.to_string_fragment_producer()->to_string(),
-            });
-        }
-        tree.emplace_back(lnav_rs_ext::SourceTreeElement{"", stmt_str});
-        log_debug("BEGIN compiling tree");
-        auto cr = lnav_rs_ext::compile_tree(tree, opts);
-        log_debug("END compiling tree");
-
-        for (const auto& msg : cr.messages) {
-            if (msg.kind != lnav_rs_ext::MessageKind::Error) {
-                continue;
-            }
-
-            auto stmt_al = attr_line_t(stmt_str);
-            readline_sql_highlighter(stmt_al, lnav::sql::dialect::prql, 0);
-            auto um
-                = lnav::console::user_message::error(
-                      attr_line_t("unable to compile PRQL: ").append(stmt_al))
-                      .with_reason(
-                          attr_line_t::from_ansi_str((std::string) msg.reason));
-            if (!msg.display.empty()) {
-                um.with_note(
-                    attr_line_t::from_ansi_str((std::string) msg.display));
-            }
-            for (const auto& hint : msg.hints) {
-                um.with_help(attr_line_t::from_ansi_str((std::string) hint));
-                break;
-            }
-            return Err(um);
+        auto compile_res = lnav::prql::compile(stmt_str);
+        if (compile_res.isErr()) {
+            return Err(compile_res.unwrapErr());
         }
-        log_debug("done!");
-        stmt_str = (std::string) cr.output;
-#else
-        auto um = lnav::console::user_message::error(
-            attr_line_t("PRQL is not supported in this build"));
-        return Err(um);
-#endif
+        stmt_str = compile_res.unwrap();
     }
 
     log_info("Executing SQL: %s", stmt_str.c_str());

src/field_overlay_source.cc

@@ -324,6 +324,19 @@ field_overlay_source::build_field_lines(const listview_curses& lv,
         this->fos_lines.emplace_back(permalink);
     }
 
+    {
+        const auto& filename
+            = this->fos_log_helper.ldh_file->get_filename_as_string();
+        auto file_al = attr_line_t(" ")
+                           .append("File:"_h2)
+                           .pad_to(15)
+                           .append(lnav::roles::file(filename));
+
+        this->fos_row_to_field_meta.emplace(this->fos_lines.size(),
+                                            row_info{std::nullopt, filename});
+        this->fos_lines.emplace_back(file_al);
+    }
+
     this->fos_known_key_size = LOG_BODY.length();
     if (!this->fos_contexts.empty()) {
         this->fos_known_key_size += this->fos_contexts.top().c_prefix.length();
@@ -385,6 +398,8 @@ field_overlay_source::build_field_lines(const listview_curses& lv,
             pattern_al.length(),
             line_range{skip, (int) pattern_al.length()});
         for (const auto& pattern_line_al : pattern_al.split_lines()) {
+            this->fos_row_to_field_meta.emplace(
+                this->fos_lines.size(), row_info{std::nullopt, pattern_str});
             this->fos_lines.emplace_back(pattern_line_al);
         }
     }

src/internals/sql-ref.rst

@@ -4894,7 +4894,7 @@ aggregate *expr*
       [1,2]
 
   **See Also**
-    :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -4910,7 +4910,7 @@ append *table*
     * **table\*** --- The table to use as a source
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -4936,7 +4936,7 @@ derive *column*
                2          4 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -4960,7 +4960,7 @@ filter *expr*
       2
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -4996,7 +4996,7 @@ from *table*
                2 def  
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5025,7 +5025,7 @@ group *key_columns* *pipeline*
       error              1 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5043,7 +5043,33 @@ join *\[side:inner\]* *table* *condition*
     * **condition\*** --- The condition used to join rows
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+
+----
+
+
+.. _prql_let:
+
+let *name*
+^^^^^^^^^^
+
+  Define a variable
+
+  **Parameters**
+    * **name\*** --- The name for the variable
+
+  **Examples**
+    To set 'x' to 5:
+
+    .. code-block::  custsqlite
+
+      ;let x = 5
+        error: unable to compile PRQL: let x = 5
+       reason: PRQL queries must begin with 'from'
+       = help: A query must start with a 'from' statement to define the main pipeline
+
+  **See Also**
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5078,7 +5104,7 @@ select *expr*
                4 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5104,7 +5130,7 @@ sort *expr*
                1 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5128,7 +5154,7 @@ stats.average_of *col*
       1.3333333333333333
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5155,7 +5181,7 @@ stats.by *col* *values*
                2               1 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5181,7 +5207,7 @@ stats.count_by *column*
                2          1 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5218,7 +5244,7 @@ stats.hist *col* *\[slice:'1h'\]* *\[top:10\]*
       2017-02⋯.000000 {"gw":1}        
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5242,7 +5268,7 @@ stats.sum_of *col*
       4
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`utils_distinct`
 
 ----
 
@@ -5275,7 +5301,7 @@ take *n_or_range*
                3 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`, :ref:`utils_distinct`
 
 ----
 
@@ -5301,7 +5327,7 @@ utils.distinct *col*
                2 
 
   **See Also**
-    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`
+    :ref:`prql_aggregate`, :ref:`prql_append`, :ref:`prql_derive`, :ref:`prql_filter`, :ref:`prql_from`, :ref:`prql_group`, :ref:`prql_join`, :ref:`prql_let`, :ref:`prql_select`, :ref:`prql_sort`, :ref:`prql_take`, :ref:`stats_average_of`, :ref:`stats_by`, :ref:`stats_count_by`, :ref:`stats_hist`, :ref:`stats_sum_of`
 
 ----
 

src/readline_callbacks.cc

@@ -35,14 +35,14 @@
 #include "base/humanize.network.hh"
 #include "base/injector.hh"
 #include "base/itertools.hh"
+#include "base/itertools.similar.hh"
 #include "base/paths.hh"
 #include "bound_tags.hh"
 #include "cmd.parser.hh"
 #include "command_executor.hh"
 #include "config.h"
 #include "field_overlay_source.hh"
 #include "help_text_formatter.hh"
-#include "base/itertools.similar.hh"
 #include "lnav.hh"
 #include "lnav.prompt.hh"
 #include "lnav_config.hh"
@@ -599,11 +599,11 @@ rl_sql_change(textinput_curses& rc, bool is_req)
         rc.open_popup_for_completion(0, poss);
         rc.tc_popup.set_title("DB Command");
     } else if (is_prql) {
-        auto anno_line = attr_line_t(line);
+        auto anno_line = rc.tc_lines[rc.tc_cursor.y];
         lnav::sql::annotate_prql_statement(anno_line);
-        auto cursor_offset = prompt.p_editor.get_cursor_offset();
+        auto cursor_offset = anno_line.column_to_byte_index(rc.tc_cursor.x);
 
-        log_debug("curs %d", cursor_offset);
+        log_debug("curs %zu", cursor_offset);
         for (const auto& attr : anno_line.al_attrs) {
             log_debug("attr [%d:%d) %s",
                       attr.sa_range.lr_start,
@@ -615,10 +615,6 @@ rl_sql_change(textinput_curses& rc, bool is_req)
             anno_line.al_attrs, cursor_offset, [](const auto& x) {
                 return x.sa_type != &lnav::sql::PRQL_STAGE_ATTR;
             });
-        auto stage_iter = rfind_string_attr_if(
-            anno_line.al_attrs, cursor_offset, [](const auto& x) {
-                return x.sa_type == &lnav::sql::PRQL_STAGE_ATTR;
-            });
         if (attr_iter != anno_line.al_attrs.end()) {
             auto to_complete_sf = anno_line.to_string_fragment(attr_iter);
             auto to_complete = to_complete_sf.to_string();
@@ -1148,6 +1144,20 @@ rl_search_internal(textinput_curses& rc, ln_mode_t mode, bool complete = false)
                 lnav_data.ld_db_preview_source[0].clear();
                 lnav_data.ld_db_preview_source[1].clear();
 
+                {
+                    auto compile_res = lnav::prql::compile(term_val);
+                    if (compile_res.isErr()) {
+                        auto um = compile_res.unwrapErr();
+                        auto err_as_line = attr_line_t()
+                                               .append(um.um_message)
+                                               .append("  \u2014  ")
+                                               .append(um.um_reason);
+                        lnav_data.ld_bottom_source.set_error(err_as_line);
+                        lnav_data.ld_status[LNS_BOTTOM].set_needs_update();
+                        return;
+                    }
+                }
+
                 auto orig_prql_stmt = attr_line_t(term_val);
                 orig_prql_stmt.rtrim("| \r\n\t");
                 lnav::sql::annotate_prql_statement(orig_prql_stmt);