- <.link href={~p"/sources/new"} class="btn btn-primary btn-sm" id="new-source-button">
+ <.link href={~p"/query"} class="btn btn-primary btn-sm">
+ Run a query
+
+ <.link href={~p"/sources/new"} class="btn btn-primary btn-sm">
New source
diff --git a/mix.exs b/mix.exs
index 91c15b993..44a31629e 100644
--- a/mix.exs
+++ b/mix.exs
@@ -225,7 +225,8 @@ defmodule Logflare.Mixfile do
{:opentelemetry_api, "~> 1.2"},
{:opentelemetry_exporter, "~> 1.6"},
{:opentelemetry_phoenix, "~> 1.1"},
- {:opentelemetry_cowboy, "~> 0.2"}
+ {:opentelemetry_cowboy, "~> 0.2"},
+ {:live_monaco_editor, "~> 0.1"}
]
end
diff --git a/mix.lock b/mix.lock
index fc379db6f..24bae1459 100644
--- a/mix.lock
+++ b/mix.lock
@@ -74,6 +74,7 @@
"jumper": {:hex, :jumper, "1.0.2", "68cdcd84472a00ac596b4e6459a41b3062d4427cbd4f1e8c8793c5b54f1406a7", [:mix], [], "hexpm", "9b7782409021e01ab3c08270e26f36eb62976a38c1aa64b2eaf6348422f165e1"},
"key_tools": {:hex, :key_tools, "0.4.1", "4bdf5a39190dc465e58f0c44784b7bb5300bafbbfff2b4ada4d7ec3bfde8d470", [:mix], [], "hexpm", "1a5afce636176481acec2db91066e68af5bf3c512327292a14078ca1aad1a57e"},
"libcluster": {:hex, :libcluster, "3.3.3", "a4f17721a19004cfc4467268e17cff8b1f951befe428975dd4f6f7b84d927fe0", [:mix], [{:jason, "~> 1.1", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "7c0a2275a0bb83c07acd17dab3c3bfb4897b145106750eeccc62d302e3bdfee5"},
+ "live_monaco_editor": {:hex, :live_monaco_editor, "0.1.8", "149c02cab1c595fe2d2049cffb0a424db2a329a5fa848ee8b778d5acd8694733", [:mix], [{:jason, "~> 1.4", [hex: :jason, repo: "hexpm", optional: false]}, {:phoenix, "~> 1.7", [hex: :phoenix, repo: "hexpm", optional: false]}, {:phoenix_live_view, "~> 0.18", [hex: :phoenix_live_view, repo: "hexpm", optional: false]}], "hexpm", "9a56e88a61cdf6d58081627e4842f4e3a8e3a75dd8749f271a464164ad4530f1"},
"local_cluster": {:hex, :local_cluster, "1.2.1", "8eab3b8a387680f0872eacfb1a8bd5a91cb1d4d61256eec6a655b07ac7030c73", [:mix], [{:global_flags, "~> 1.0", [hex: :global_flags, repo: "hexpm", optional: false]}], "hexpm", "aae80c9bc92c911cb0be085fdeea2a9f5b88f81b6bec2ff1fec244bb0acc232c"},
"logflare_api_client": {:hex, :logflare_api_client, "0.3.5", "c427ebf65a8402d68b056d4a5ef3e1eb3b90c0ad1d0de97d1fe23807e0c1b113", [:mix], [{:bertex, "~> 1.3", [hex: :bertex, repo: "hexpm", optional: false]}, {:finch, "~> 0.10", [hex: :finch, repo: "hexpm", optional: false]}, {:jason, ">= 1.0.0", [hex: :jason, repo: "hexpm", optional: false]}, {:tesla, "~> 1.0", [hex: :tesla, repo: "hexpm", optional: false]}], "hexpm", "16d29abcb80c4f72745cdf943379da02a201504813c3aa12b4d4acb0302b7723"},
"logflare_etso": {:hex, :logflare_etso, "1.1.2", "040bd3e482aaf0ed20080743b7562242ec5079fd88a6f9c8ce5d8298818292e9", [:mix], [{:ecto, "~> 3.8", [hex: :ecto, repo: "hexpm", optional: false]}], "hexpm", "ab96be42900730a49b132891f43a9be1d52e4ad3ee9ed9cb92565c5f87345117"},
diff --git a/test/logflare_web/live_views/query_live_test.exs b/test/logflare_web/live_views/query_live_test.exs
new file mode 100644
index 000000000..54a62dba6
--- /dev/null
+++ b/test/logflare_web/live_views/query_live_test.exs
@@ -0,0 +1,43 @@
+defmodule LogflareWeb.QueryLiveTest do
+ @moduledoc false
+ use LogflareWeb.ConnCase
+
+ setup %{conn: conn} do
+ insert(:plan)
+ user = insert(:user)
+ conn = login_user(conn, user)
+ {:ok, user: user, conn: conn}
+ end
+
+ describe "query page" do
+ test "run a valid query", %{conn: conn} do
+ GoogleApi.BigQuery.V2.Api.Jobs
+ |> expect(:bigquery_jobs_query, 1, fn _conn, _proj_id, _opts ->
+ {:ok, TestUtils.gen_bq_response([%{"ts" => "some-data"}])}
+ end)
+
+ {:ok, view, _html} = live(conn, "/query")
+
+ # link to show
+ view
+ |> element("form")
+ |> render_submit(%{
+ live_monaco_editor: %{
+ query: "select current_timestamp() as ts"
+ }
+ }) =~ "Ran query successfully"
+
+ assert_patch(view) =~ ~r/current_timestamp/
+ assert render(view) =~ "some-data"
+ end
+
+ test "parser error", %{conn: conn} do
+ {:ok, view, _html} = live(conn, "/query")
+
+ assert view
+ |> render_hook("parse-query", %{
+ value: "select current_datetime() order-by invalid"
+ }) =~ "parser error"
+ end
+ end
+end